2 * Copyright (c) 2015 FUJITSU LIMITED
3 * Author: Yang Hongyang <yanghy@cn.fujitsu.com>
5 * This work is licensed under the terms of the GNU GPL, version 2 or
6 * later. See the COPYING file in the top-level directory.
9 #include "qemu-common.h"
10 #include "qapi/qmp/qerror.h"
11 #include "qemu/error-report.h"
13 #include "net/filter.h"
15 #include "net/vhost_net.h"
16 #include "qom/object_interfaces.h"
18 ssize_t
qemu_netfilter_receive(NetFilterState
*nf
,
19 NetFilterDirection direction
,
20 NetClientState
*sender
,
22 const struct iovec
*iov
,
24 NetPacketSent
*sent_cb
)
26 if (nf
->direction
== direction
||
27 nf
->direction
== NET_FILTER_DIRECTION_ALL
) {
28 return NETFILTER_GET_CLASS(OBJECT(nf
))->receive_iov(
29 nf
, sender
, flags
, iov
, iovcnt
, sent_cb
);
35 static char *netfilter_get_netdev_id(Object
*obj
, Error
**errp
)
37 NetFilterState
*nf
= NETFILTER(obj
);
39 return g_strdup(nf
->netdev_id
);
42 static void netfilter_set_netdev_id(Object
*obj
, const char *str
, Error
**errp
)
44 NetFilterState
*nf
= NETFILTER(obj
);
46 nf
->netdev_id
= g_strdup(str
);
49 static int netfilter_get_direction(Object
*obj
, Error
**errp G_GNUC_UNUSED
)
51 NetFilterState
*nf
= NETFILTER(obj
);
55 static void netfilter_set_direction(Object
*obj
, int direction
, Error
**errp
)
57 NetFilterState
*nf
= NETFILTER(obj
);
58 nf
->direction
= direction
;
61 static void netfilter_init(Object
*obj
)
63 object_property_add_str(obj
, "netdev",
64 netfilter_get_netdev_id
, netfilter_set_netdev_id
,
66 object_property_add_enum(obj
, "queue", "NetFilterDirection",
67 NetFilterDirection_lookup
,
68 netfilter_get_direction
, netfilter_set_direction
,
72 static void netfilter_complete(UserCreatable
*uc
, Error
**errp
)
74 NetFilterState
*nf
= NETFILTER(uc
);
75 NetClientState
*ncs
[MAX_QUEUE_NUM
];
76 NetFilterClass
*nfc
= NETFILTER_GET_CLASS(uc
);
78 Error
*local_err
= NULL
;
81 error_setg(errp
, "Parameter 'netdev' is required");
85 queues
= qemu_find_net_clients_except(nf
->netdev_id
, ncs
,
86 NET_CLIENT_OPTIONS_KIND_NIC
,
89 error_setg(errp
, QERR_INVALID_PARAMETER_VALUE
, "netdev",
90 "a network backend id");
92 } else if (queues
> 1) {
93 error_setg(errp
, "multiqueue is not supported");
97 if (get_vhost_net(ncs
[0])) {
98 error_setg(errp
, "Vhost is not supported");
105 nfc
->setup(nf
, &local_err
);
107 error_propagate(errp
, local_err
);
111 QTAILQ_INSERT_TAIL(&nf
->netdev
->filters
, nf
, next
);
114 static void netfilter_finalize(Object
*obj
)
116 NetFilterState
*nf
= NETFILTER(obj
);
117 NetFilterClass
*nfc
= NETFILTER_GET_CLASS(obj
);
123 if (nf
->netdev
&& !QTAILQ_EMPTY(&nf
->netdev
->filters
)) {
124 QTAILQ_REMOVE(&nf
->netdev
->filters
, nf
, next
);
128 static void netfilter_class_init(ObjectClass
*oc
, void *data
)
130 UserCreatableClass
*ucc
= USER_CREATABLE_CLASS(oc
);
132 ucc
->complete
= netfilter_complete
;
135 static const TypeInfo netfilter_info
= {
136 .name
= TYPE_NETFILTER
,
137 .parent
= TYPE_OBJECT
,
139 .class_size
= sizeof(NetFilterClass
),
140 .class_init
= netfilter_class_init
,
141 .instance_size
= sizeof(NetFilterState
),
142 .instance_init
= netfilter_init
,
143 .instance_finalize
= netfilter_finalize
,
144 .interfaces
= (InterfaceInfo
[]) {
145 { TYPE_USER_CREATABLE
},
150 static void register_types(void)
152 type_register_static(&netfilter_info
);
155 type_init(register_types
);