1 | /* |
2 | * COarse-grain LOck-stepping Virtual Machines for Non-stop Service (COLO) |
3 | * (a.k.a. Fault Tolerance or Continuous Replication) |
4 | * |
5 | * Copyright (c) 2016 HUAWEI TECHNOLOGIES CO., LTD. |
6 | * Copyright (c) 2016 FUJITSU LIMITED |
7 | * Copyright (c) 2016 Intel Corporation |
8 | * |
9 | * Author: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
10 | * |
11 | * This work is licensed under the terms of the GNU GPL, version 2 or |
12 | * later. See the COPYING file in the top-level directory. |
13 | */ |
14 | |
15 | #ifndef NET_COLO_H |
16 | #define NET_COLO_H |
17 | |
18 | #include "qemu/jhash.h" |
19 | #include "qemu/timer.h" |
20 | #include "net/eth.h" |
21 | |
22 | #define HASHTABLE_MAX_SIZE 16384 |
23 | |
24 | #ifndef IPPROTO_DCCP |
25 | #define IPPROTO_DCCP 33 |
26 | #endif |
27 | |
28 | #ifndef IPPROTO_SCTP |
29 | #define IPPROTO_SCTP 132 |
30 | #endif |
31 | |
32 | #ifndef IPPROTO_UDPLITE |
33 | #define IPPROTO_UDPLITE 136 |
34 | #endif |
35 | |
36 | typedef struct Packet { |
37 | void *data; |
38 | union { |
39 | uint8_t *; |
40 | struct ip *ip; |
41 | }; |
42 | uint8_t *; |
43 | int size; |
44 | /* Time of packet creation, in wall clock ms */ |
45 | int64_t creation_ms; |
46 | /* Get vnet_hdr_len from filter */ |
47 | uint32_t vnet_hdr_len; |
48 | uint32_t tcp_seq; /* sequence number */ |
49 | uint32_t tcp_ack; /* acknowledgement number */ |
50 | /* the sequence number of the last byte of the packet */ |
51 | uint32_t seq_end; |
52 | uint8_t ; /* the header length */ |
53 | uint16_t payload_size; /* the payload length */ |
54 | /* record the payload offset(the length that has been compared) */ |
55 | uint16_t offset; |
56 | uint8_t flags; /* Flags(aka Control bits) */ |
57 | } Packet; |
58 | |
59 | typedef struct ConnectionKey { |
60 | /* (src, dst) must be grouped, in the same way than in IP header */ |
61 | struct in_addr src; |
62 | struct in_addr dst; |
63 | uint16_t src_port; |
64 | uint16_t dst_port; |
65 | uint8_t ip_proto; |
66 | } QEMU_PACKED ConnectionKey; |
67 | |
68 | typedef struct Connection { |
69 | /* connection primary send queue: element type: Packet */ |
70 | GQueue primary_list; |
71 | /* connection secondary send queue: element type: Packet */ |
72 | GQueue secondary_list; |
73 | /* flag to enqueue unprocessed_connections */ |
74 | bool processing; |
75 | uint8_t ip_proto; |
76 | /* record the sequence number that has been compared */ |
77 | uint32_t compare_seq; |
78 | /* the maximum of acknowledgement number in primary_list queue */ |
79 | uint32_t pack; |
80 | /* the maximum of acknowledgement number in secondary_list queue */ |
81 | uint32_t sack; |
82 | /* offset = secondary_seq - primary_seq */ |
83 | uint32_t offset; |
84 | |
85 | int tcp_state; /* TCP FSM state */ |
86 | uint32_t fin_ack_seq; /* the seq of 'fin=1,ack=1' */ |
87 | } Connection; |
88 | |
89 | uint32_t connection_key_hash(const void *opaque); |
90 | int connection_key_equal(const void *opaque1, const void *opaque2); |
91 | int parse_packet_early(Packet *pkt); |
92 | void extract_ip_and_port(uint32_t tmp_ports, ConnectionKey *key, Packet *pkt); |
93 | void fill_connection_key(Packet *pkt, ConnectionKey *key); |
94 | void reverse_connection_key(ConnectionKey *key); |
95 | Connection *connection_new(ConnectionKey *key); |
96 | void connection_destroy(void *opaque); |
97 | Connection *connection_get(GHashTable *connection_track_table, |
98 | ConnectionKey *key, |
99 | GQueue *conn_list); |
100 | bool connection_has_tracked(GHashTable *connection_track_table, |
101 | ConnectionKey *key); |
102 | void connection_hashtable_reset(GHashTable *connection_track_table); |
103 | Packet *packet_new(const void *data, int size, int vnet_hdr_len); |
104 | void packet_destroy(void *opaque, void *user_data); |
105 | |
106 | #endif /* NET_COLO_H */ |
107 | |