1 /* 2 * replay-net.c 3 * 4 * Copyright (c) 2010-2016 Institute for System Programming 5 * of the Russian Academy of Sciences. 6 * 7 * This work is licensed under the terms of the GNU GPL, version 2 or later. 8 * See the COPYING file in the top-level directory. 9 * 10 */ 11 12 #include "qemu/osdep.h" 13 #include "qemu/error-report.h" 14 #include "sysemu/replay.h" 15 #include "replay-internal.h" 16 #include "net/net.h" 17 #include "net/filter.h" 18 #include "qemu/iov.h" 19 20 struct ReplayNetState { 21 NetFilterState *nfs; 22 int id; 23 }; 24 25 typedef struct NetEvent { 26 uint8_t id; 27 uint32_t flags; 28 uint8_t *data; 29 size_t size; 30 } NetEvent; 31 32 static NetFilterState **network_filters; 33 static int network_filters_count; 34 35 ReplayNetState *replay_register_net(NetFilterState *nfs) 36 { 37 ReplayNetState *rns = g_new0(ReplayNetState, 1); 38 rns->nfs = nfs; 39 rns->id = network_filters_count++; 40 network_filters = g_realloc(network_filters, 41 network_filters_count 42 * sizeof(*network_filters)); 43 network_filters[network_filters_count - 1] = nfs; 44 return rns; 45 } 46 47 void replay_unregister_net(ReplayNetState *rns) 48 { 49 network_filters[rns->id] = NULL; 50 g_free(rns); 51 } 52 53 void replay_net_packet_event(ReplayNetState *rns, unsigned flags, 54 const struct iovec *iov, int iovcnt) 55 { 56 NetEvent *event = g_new(NetEvent, 1); 57 event->flags = flags; 58 event->data = g_malloc(iov_size(iov, iovcnt)); 59 event->size = iov_size(iov, iovcnt); 60 event->id = rns->id; 61 iov_to_buf(iov, iovcnt, 0, event->data, event->size); 62 63 replay_add_event(REPLAY_ASYNC_EVENT_NET, event, NULL, 0); 64 } 65 66 void replay_event_net_run(void *opaque) 67 { 68 NetEvent *event = opaque; 69 struct iovec iov = { 70 .iov_base = (void *)event->data, 71 .iov_len = event->size 72 }; 73 74 assert(event->id < network_filters_count); 75 76 qemu_netfilter_pass_to_next(network_filters[event->id]->netdev, 77 event->flags, &iov, 1, network_filters[event->id]); 78 79 g_free(event->data); 80 g_free(event); 81 } 82 83 void replay_event_net_save(void *opaque) 84 { 85 NetEvent *event = opaque; 86 87 replay_put_byte(event->id); 88 replay_put_dword(event->flags); 89 replay_put_array(event->data, event->size); 90 } 91 92 void *replay_event_net_load(void) 93 { 94 NetEvent *event = g_new(NetEvent, 1); 95 96 event->id = replay_get_byte(); 97 event->flags = replay_get_dword(); 98 replay_get_array_alloc(&event->data, &event->size); 99 100 return event; 101 } 102