tests: virtio-9p: rename PCI configuration test
[qemu.git] / net / colo.h
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 QEMU_COLO_PROXY_H
16 #define QEMU_COLO_PROXY_H
17
18 #include "slirp/slirp.h"
19 #include "qemu/jhash.h"
20 #include "qemu/timer.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 *network_header;
40 struct ip *ip;
41 };
42 uint8_t *transport_header;
43 int size;
44 /* Time of packet creation, in wall clock ms */
45 int64_t creation_ms;
46 } Packet;
47
48 typedef struct ConnectionKey {
49 /* (src, dst) must be grouped, in the same way than in IP header */
50 struct in_addr src;
51 struct in_addr dst;
52 uint16_t src_port;
53 uint16_t dst_port;
54 uint8_t ip_proto;
55 } QEMU_PACKED ConnectionKey;
56
57 typedef struct Connection {
58 /* connection primary send queue: element type: Packet */
59 GQueue primary_list;
60 /* connection secondary send queue: element type: Packet */
61 GQueue secondary_list;
62 /* flag to enqueue unprocessed_connections */
63 bool processing;
64 uint8_t ip_proto;
65 /* offset = secondary_seq - primary_seq */
66 tcp_seq offset;
67 /*
68 * we use this flag update offset func
69 * run once in independent tcp connection
70 */
71 int syn_flag;
72 } Connection;
73
74 uint32_t connection_key_hash(const void *opaque);
75 int connection_key_equal(const void *opaque1, const void *opaque2);
76 int parse_packet_early(Packet *pkt);
77 void fill_connection_key(Packet *pkt, ConnectionKey *key);
78 void reverse_connection_key(ConnectionKey *key);
79 Connection *connection_new(ConnectionKey *key);
80 void connection_destroy(void *opaque);
81 Connection *connection_get(GHashTable *connection_track_table,
82 ConnectionKey *key,
83 GQueue *conn_list);
84 void connection_hashtable_reset(GHashTable *connection_track_table);
85 Packet *packet_new(const void *data, int size);
86 void packet_destroy(void *opaque, void *user_data);
87
88 #endif /* QEMU_COLO_PROXY_H */