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