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 } Packet; 49 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; 58 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; 69 /* 70 * we use this flag update offset func 71 * run once in independent tcp connection 72 */ 73 int syn_flag; 74 } Connection; 75 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); 90 91 #endif /* QEMU_COLO_PROXY_H */ 92