colo.c (0682e15b19b2f41c0568142b42518b9471168597) colo.c (afe461240940077e7ea8313e9c547a4898263cd2)
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 *

--- 100 unchanged lines hidden (view full) ---

109 key->src_port = ntohs(tmp_ports & 0xffff);
110 key->dst_port = ntohs(tmp_ports >> 16);
111 break;
112 default:
113 break;
114 }
115}
116
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 *

--- 100 unchanged lines hidden (view full) ---

109 key->src_port = ntohs(tmp_ports & 0xffff);
110 key->dst_port = ntohs(tmp_ports >> 16);
111 break;
112 default:
113 break;
114 }
115}
116
117void reverse_connection_key(ConnectionKey *key)
118{
119 struct in_addr tmp_ip;
120 uint16_t tmp_port;
121
122 tmp_ip = key->src;
123 key->src = key->dst;
124 key->dst = tmp_ip;
125
126 tmp_port = key->src_port;
127 key->src_port = key->dst_port;
128 key->dst_port = tmp_port;
129}
130
117Connection *connection_new(ConnectionKey *key)
118{
119 Connection *conn = g_slice_new(Connection);
120
121 conn->ip_proto = key->ip_proto;
122 conn->processing = false;
123 g_queue_init(&conn->primary_list);
124 g_queue_init(&conn->secondary_list);

--- 71 unchanged lines hidden --- 		131Connection *connection_new(ConnectionKey *key)
132{
133 Connection *conn = g_slice_new(Connection);
134
135 conn->ip_proto = key->ip_proto;
136 conn->processing = false;
137 g_queue_init(&conn->primary_list);
138 g_queue_init(&conn->secondary_list);

--- 71 unchanged lines hidden ---