2  * COarse-grain LOck-stepping Virtual Machines for Non-stop Service (COLO)
3  * (a.k.a. Fault Tolerance or Continuous Replication)
12  * later.  See the COPYING file in the top-level directory.
27     a += key->src.s_addr;  in connection_key_hash()
28     b += key->dst.s_addr;  in connection_key_hash()
29     c += (key->src_port | key->dst_port << 16);  in connection_key_hash()
32     a += key->ip_proto;  in connection_key_hash()
47     uint8_t *data = pkt->data;  in parse_packet_early()
54     if ((pkt->vnet_hdr_len > sizeof(struct virtio_net_hdr_v1_hash)) ||  in parse_packet_early()
55         (pkt->size < sizeof(struct eth_header) + sizeof(struct vlan_header) +  in parse_packet_early()
56         pkt->vnet_hdr_len)) {  in parse_packet_early()
59          * Please enable/disable filter module's the vnet_hdr flag at  in parse_packet_early()
63                                         pkt->vnet_hdr_len, pkt->size);  in parse_packet_early()
66     data += pkt->vnet_hdr_len;  in parse_packet_early()
74         trace_colo_proxy_main("COLO-proxy don't support vlan");  in parse_packet_early()
78     pkt->network_header = data + l2hdr_len;  in parse_packet_early()
90     network_length = pkt->ip->ip_hl * 4;  in parse_packet_early()
91     if (pkt->size < l2hdr_len + network_length + pkt->vnet_hdr_len) {  in parse_packet_early()
92         trace_colo_proxy_main("pkt->size < network_header + network_length");  in parse_packet_early()
95     pkt->transport_header = pkt->network_header + network_length;  in parse_packet_early()
104         key->src = pkt->ip->ip_dst;  in extract_ip_and_port()
105         key->dst = pkt->ip->ip_src;  in extract_ip_and_port()
106         key->src_port = ntohs(tmp_ports & 0xffff);  in extract_ip_and_port()
107         key->dst_port = ntohs(tmp_ports >> 16);  in extract_ip_and_port()
109         key->src = pkt->ip->ip_src;  in extract_ip_and_port()
110         key->dst = pkt->ip->ip_dst;  in extract_ip_and_port()
111         key->src_port = ntohs(tmp_ports >> 16);  in extract_ip_and_port()
112         key->dst_port = ntohs(tmp_ports & 0xffff);  in extract_ip_and_port()
120     key->ip_proto = pkt->ip->ip_p;  in fill_connection_key()
122     switch (key->ip_proto) {  in fill_connection_key()
129         tmp_ports = *(uint32_t *)(pkt->transport_header);  in fill_connection_key()
132         tmp_ports = *(uint32_t *)(pkt->transport_header + 4);  in fill_connection_key()
145     conn->ip_proto = key->ip_proto;  in connection_new()
146     conn->processing = false;  in connection_new()
147     conn->tcp_state = TCPS_CLOSED;  in connection_new()
148     g_queue_init(&conn->primary_list);  in connection_new()
149     g_queue_init(&conn->secondary_list);  in connection_new()
158     g_queue_foreach(&conn->primary_list, packet_destroy, NULL);  in connection_destroy()
159     g_queue_clear(&conn->primary_list);  in connection_destroy()
160     g_queue_foreach(&conn->secondary_list, packet_destroy, NULL);  in connection_destroy()
161     g_queue_clear(&conn->secondary_list);  in connection_destroy()
169     pkt->data = g_memdup(data, size);  in packet_new()
170     pkt->size = size;  in packet_new()
171     pkt->creation_ms = qemu_clock_get_ms(QEMU_CLOCK_HOST);  in packet_new()
172     pkt->vnet_hdr_len = vnet_hdr_len;  in packet_new()
185     pkt->data = data;  in packet_new_nocopy()
186     pkt->size = size;  in packet_new_nocopy()
187     pkt->creation_ms = qemu_clock_get_ms(QEMU_CLOCK_HOST);  in packet_new_nocopy()
188     pkt->vnet_hdr_len = vnet_hdr_len;  in packet_new_nocopy()
197     g_free(pkt->data);  in packet_destroy()