]>
Commit | Line | Data |
---|---|---|
59509ec1 ZC |
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 | ||
58ea30f5 MA |
15 | #ifndef NET_COLO_H |
16 | #define NET_COLO_H | |
59509ec1 | 17 | |
ccf0426c | 18 | #include "qemu/jhash.h" |
0682e15b | 19 | #include "qemu/timer.h" |
e05ae1d9 | 20 | #include "net/eth.h" |
3772cf0d | 21 | #include "standard-headers/linux/virtio_net.h" |
59509ec1 ZC |
22 | |
23 | #define HASHTABLE_MAX_SIZE 16384 | |
24 | ||
b6540d40 ZC |
25 | #ifndef IPPROTO_DCCP |
26 | #define IPPROTO_DCCP 33 | |
27 | #endif | |
28 | ||
29 | #ifndef IPPROTO_SCTP | |
30 | #define IPPROTO_SCTP 132 | |
31 | #endif | |
32 | ||
33 | #ifndef IPPROTO_UDPLITE | |
34 | #define IPPROTO_UDPLITE 136 | |
35 | #endif | |
36 | ||
59509ec1 ZC |
37 | typedef struct Packet { |
38 | void *data; | |
39 | union { | |
40 | uint8_t *network_header; | |
41 | struct ip *ip; | |
42 | }; | |
43 | uint8_t *transport_header; | |
44 | int size; | |
0682e15b ZC |
45 | /* Time of packet creation, in wall clock ms */ |
46 | int64_t creation_ms; | |
ada1a33f ZC |
47 | /* Get vnet_hdr_len from filter */ |
48 | uint32_t vnet_hdr_len; | |
f449c9e5 MZ |
49 | uint32_t tcp_seq; /* sequence number */ |
50 | uint32_t tcp_ack; /* acknowledgement number */ | |
51 | /* the sequence number of the last byte of the packet */ | |
52 | uint32_t seq_end; | |
53 | uint8_t header_size; /* the header length */ | |
54 | uint16_t payload_size; /* the payload length */ | |
55 | /* record the payload offset(the length that has been compared) */ | |
56 | uint16_t offset; | |
57 | uint8_t flags; /* Flags(aka Control bits) */ | |
59509ec1 ZC |
58 | } Packet; |
59 | ||
b6540d40 ZC |
60 | typedef struct ConnectionKey { |
61 | /* (src, dst) must be grouped, in the same way than in IP header */ | |
62 | struct in_addr src; | |
63 | struct in_addr dst; | |
64 | uint16_t src_port; | |
65 | uint16_t dst_port; | |
66 | uint8_t ip_proto; | |
67 | } QEMU_PACKED ConnectionKey; | |
68 | ||
69 | typedef struct Connection { | |
70 | /* connection primary send queue: element type: Packet */ | |
71 | GQueue primary_list; | |
72 | /* connection secondary send queue: element type: Packet */ | |
73 | GQueue secondary_list; | |
74 | /* flag to enqueue unprocessed_connections */ | |
75 | bool processing; | |
76 | uint8_t ip_proto; | |
f449c9e5 MZ |
77 | /* record the sequence number that has been compared */ |
78 | uint32_t compare_seq; | |
79 | /* the maximum of acknowledgement number in primary_list queue */ | |
80 | uint32_t pack; | |
81 | /* the maximum of acknowledgement number in secondary_list queue */ | |
82 | uint32_t sack; | |
30656b09 | 83 | /* offset = secondary_seq - primary_seq */ |
e05ae1d9 | 84 | uint32_t offset; |
6214231a ZC |
85 | |
86 | int tcp_state; /* TCP FSM state */ | |
e05ae1d9 | 87 | uint32_t fin_ack_seq; /* the seq of 'fin=1,ack=1' */ |
b6540d40 ZC |
88 | } Connection; |
89 | ||
90 | uint32_t connection_key_hash(const void *opaque); | |
91 | int connection_key_equal(const void *opaque1, const void *opaque2); | |
59509ec1 | 92 | int parse_packet_early(Packet *pkt); |
64153ca6 RL |
93 | void extract_ip_and_port(uint32_t tmp_ports, ConnectionKey *key, |
94 | Packet *pkt, bool reverse); | |
95 | void fill_connection_key(Packet *pkt, ConnectionKey *key, bool reverse); | |
b6540d40 ZC |
96 | Connection *connection_new(ConnectionKey *key); |
97 | void connection_destroy(void *opaque); | |
98 | Connection *connection_get(GHashTable *connection_track_table, | |
99 | ConnectionKey *key, | |
100 | GQueue *conn_list); | |
24525e93 ZC |
101 | bool connection_has_tracked(GHashTable *connection_track_table, |
102 | ConnectionKey *key); | |
59509ec1 | 103 | void connection_hashtable_reset(GHashTable *connection_track_table); |
ada1a33f | 104 | Packet *packet_new(const void *data, int size, int vnet_hdr_len); |
9b492719 | 105 | Packet *packet_new_nocopy(void *data, int size, int vnet_hdr_len); |
59509ec1 | 106 | void packet_destroy(void *opaque, void *user_data); |
9c55fe94 | 107 | void packet_destroy_partial(void *opaque, void *user_data); |
59509ec1 | 108 | |
58ea30f5 | 109 | #endif /* NET_COLO_H */ |