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     /* 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 */