@@ -40,6 +40,11 @@ typedef struct NICConf {
/* Net clients */
+typedef struct Filter Filter;
+struct Filter {
+ NetFilterState *nf;
+ QTAILQ_ENTRY(Filter) next;
+};
typedef void (NetPoll)(NetClientState *, bool enable);
typedef int (NetCanReceive)(NetClientState *);
@@ -92,6 +97,7 @@ struct NetClientState {
NetClientDestructor *destructor;
unsigned int queue_index;
unsigned rxfilter_notify_enabled:1;
+ QTAILQ_HEAD(, Filter) filters;
};
typedef struct NICState {
@@ -109,6 +115,8 @@ NetClientState *qemu_new_net_client(NetClientInfo *info,
NetClientState *peer,
const char *model,
const char *name);
+int qemu_netdev_add_filter(NetClientState *nc, NetFilterState *nf);
+void qemu_netdev_remove_filter(NetClientState *nc, NetFilterState *nf);
NICState *qemu_new_nic(NetClientInfo *info,
NICConf *conf,
const char *model,
@@ -37,14 +37,14 @@ NetFilterState *qemu_new_net_filter(NetFilterInfo *info,
nf->netdev = netdev;
nf->chain = chain;
QTAILQ_INSERT_TAIL(&net_filters, nf, next);
- /* TODO: attach netfilter to netdev */
+ qemu_netdev_add_filter(netdev, nf);
return nf;
}
static void qemu_cleanup_net_filter(NetFilterState *nf)
{
- /* TODO: remove netfilter from netdev */
+ qemu_netdev_remove_filter(nf->netdev, nf);
QTAILQ_REMOVE(&net_filters, nf, next);
@@ -287,6 +287,7 @@ static void qemu_net_client_setup(NetClientState *nc,
nc->incoming_queue = qemu_new_net_queue(nc);
nc->destructor = destructor;
+ QTAILQ_INIT(&nc->filters);
}
NetClientState *qemu_new_net_client(NetClientInfo *info,
@@ -305,6 +306,38 @@ NetClientState *qemu_new_net_client(NetClientInfo *info,
return nc;
}
+int qemu_netdev_add_filter(NetClientState *nc, NetFilterState *nf)
+{
+ Filter *filter = g_malloc0(sizeof(*filter));
+
+ filter->nf = nf;
+ QTAILQ_INSERT_TAIL(&nc->filters, filter, next);
+ return 0;
+}
+
+static void remove_filter(NetClientState *nc, Filter *filter)
+{
+ if (!filter) {
+ return;
+ }
+
+ QTAILQ_REMOVE(&nc->filters, filter, next);
+ g_free(filter);
+}
+
+void qemu_netdev_remove_filter(NetClientState *nc, NetFilterState *nf)
+{
+ Filter *filter = NULL;
+
+ QTAILQ_FOREACH(filter, &nc->filters, next) {
+ if (filter->nf == nf) {
+ break;
+ }
+ }
+
+ remove_filter(nc, filter);
+}
+
NICState *qemu_new_nic(NetClientInfo *info,
NICConf *conf,
const char *model,
@@ -367,6 +400,8 @@ static void qemu_cleanup_net_client(NetClientState *nc)
static void qemu_free_net_client(NetClientState *nc)
{
+ Filter *filter, *next;
+
if (nc->incoming_queue) {
qemu_del_net_queue(nc->incoming_queue);
}
@@ -375,6 +410,9 @@ static void qemu_free_net_client(NetClientState *nc)
}
g_free(nc->name);
g_free(nc->model);
+ QTAILQ_FOREACH_SAFE(filter, &nc->filters, next, next) {
+ remove_filter(nc, filter);
+ }
if (nc->destructor) {
nc->destructor(nc);
}
add/remove filters from network backend Signed-off-by: Yang Hongyang <yanghy@cn.fujitsu.com> --- include/net/net.h | 8 ++++++++ net/filter.c | 4 ++-- net/net.c | 38 ++++++++++++++++++++++++++++++++++++++ 3 files changed, 48 insertions(+), 2 deletions(-)