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 /* 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 tcp_seq offset; 84 /* 85 * we use this flag update offset func 86 * run once in independent tcp connection 87 */ 88 int syn_flag; 89 } Connection; 90 91 uint32_t connection_key_hash(const void *opaque); 92 int connection_key_equal(const void *opaque1, const void *opaque2); 93 int parse_packet_early(Packet *pkt); 94 void extract_ip_and_port(uint32_t tmp_ports, ConnectionKey *key, Packet *pkt); 95 void fill_connection_key(Packet *pkt, ConnectionKey *key); 96 void reverse_connection_key(ConnectionKey *key); 97 Connection *connection_new(ConnectionKey *key); 98 void connection_destroy(void *opaque); 99 Connection *connection_get(GHashTable *connection_track_table, 100 ConnectionKey *key, 101 GQueue *conn_list); 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 /* QEMU_COLO_PROXY_H */ 107