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 <[email protected]>
  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 */