xref: /openbmc/qemu/net/colo.h (revision f13f22ba)
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 *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     /* 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 header_size;  /* 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,
93                          Packet *pkt, bool reverse);
94 void fill_connection_key(Packet *pkt, ConnectionKey *key, bool reverse);
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 Packet *packet_new_nocopy(void *data, int size, int vnet_hdr_len);
105 void packet_destroy(void *opaque, void *user_data);
106 void packet_destroy_partial(void *opaque, void *user_data);
107 
108 #endif /* NET_COLO_H */
109