icount: fixed saving/restoring of icount warp timers
[qemu/ar7.git] / net / colo.h
blob0658e869b4fa4cdbf7bb14f39a0e864c874f46d7
1 /*
2 * COarse-grain LOck-stepping Virtual Machines for Non-stop Service (COLO)
3 * (a.k.a. Fault Tolerance or Continuous Replication)
5 * Copyright (c) 2016 HUAWEI TECHNOLOGIES CO., LTD.
6 * Copyright (c) 2016 FUJITSU LIMITED
7 * Copyright (c) 2016 Intel Corporation
9 * Author: Zhang Chen <zhangchen.fnst@cn.fujitsu.com>
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.
15 #ifndef QEMU_COLO_PROXY_H
16 #define QEMU_COLO_PROXY_H
18 #include "slirp/slirp.h"
19 #include "qemu/jhash.h"
20 #include "qemu/timer.h"
22 #define HASHTABLE_MAX_SIZE 16384
24 #ifndef IPPROTO_DCCP
25 #define IPPROTO_DCCP 33
26 #endif
28 #ifndef IPPROTO_SCTP
29 #define IPPROTO_SCTP 132
30 #endif
32 #ifndef IPPROTO_UDPLITE
33 #define IPPROTO_UDPLITE 136
34 #endif
36 typedef struct Packet {
37 void *data;
38 union {
39 uint8_t *network_header;
40 struct ip *ip;
42 uint8_t *transport_header;
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 } Packet;
50 typedef struct ConnectionKey {
51 /* (src, dst) must be grouped, in the same way than in IP header */
52 struct in_addr src;
53 struct in_addr dst;
54 uint16_t src_port;
55 uint16_t dst_port;
56 uint8_t ip_proto;
57 } QEMU_PACKED ConnectionKey;
59 typedef struct Connection {
60 /* connection primary send queue: element type: Packet */
61 GQueue primary_list;
62 /* connection secondary send queue: element type: Packet */
63 GQueue secondary_list;
64 /* flag to enqueue unprocessed_connections */
65 bool processing;
66 uint8_t ip_proto;
67 /* offset = secondary_seq - primary_seq */
68 tcp_seq offset;
70 * we use this flag update offset func
71 * run once in independent tcp connection
73 int syn_flag;
74 } Connection;
76 uint32_t connection_key_hash(const void *opaque);
77 int connection_key_equal(const void *opaque1, const void *opaque2);
78 int parse_packet_early(Packet *pkt);
79 void extract_ip_and_port(uint32_t tmp_ports, ConnectionKey *key, Packet *pkt);
80 void fill_connection_key(Packet *pkt, ConnectionKey *key);
81 void reverse_connection_key(ConnectionKey *key);
82 Connection *connection_new(ConnectionKey *key);
83 void connection_destroy(void *opaque);
84 Connection *connection_get(GHashTable *connection_track_table,
85 ConnectionKey *key,
86 GQueue *conn_list);
87 void connection_hashtable_reset(GHashTable *connection_track_table);
88 Packet *packet_new(const void *data, int size, int vnet_hdr_len);
89 void packet_destroy(void *opaque, void *user_data);
91 #endif /* QEMU_COLO_PROXY_H */