1f6c874e3SStefan Hajnoczi /*
2f6c874e3SStefan Hajnoczi * Hub net client
3f6c874e3SStefan Hajnoczi *
4f6c874e3SStefan Hajnoczi * Copyright IBM, Corp. 2012
5f6c874e3SStefan Hajnoczi *
6f6c874e3SStefan Hajnoczi * Authors:
7f6c874e3SStefan Hajnoczi * Stefan Hajnoczi <stefanha@linux.vnet.ibm.com>
8f6c874e3SStefan Hajnoczi * Zhi Yong Wu <wuzhy@linux.vnet.ibm.com>
9f6c874e3SStefan Hajnoczi *
10f6c874e3SStefan Hajnoczi * This work is licensed under the terms of the GNU LGPL, version 2 or later.
11f6c874e3SStefan Hajnoczi * See the COPYING.LIB file in the top-level directory.
12f6c874e3SStefan Hajnoczi *
13f6c874e3SStefan Hajnoczi */
14f6c874e3SStefan Hajnoczi
152744d920SPeter Maydell #include "qemu/osdep.h"
1618d65d22SThomas Huth #include "qapi/error.h"
1783c9089eSPaolo Bonzini #include "monitor/monitor.h"
181422e32dSPaolo Bonzini #include "net/net.h"
19a245fc18SPaolo Bonzini #include "clients.h"
20f6c874e3SStefan Hajnoczi #include "hub.h"
211de7afc9SPaolo Bonzini #include "qemu/iov.h"
222ab4b135SAlistair Francis #include "qemu/error-report.h"
2356512e1dSJason Wang #include "sysemu/qtest.h"
24f6c874e3SStefan Hajnoczi
25f6c874e3SStefan Hajnoczi /*
26f6c874e3SStefan Hajnoczi * A hub broadcasts incoming packets to all its ports except the source port.
27442da403SThomas Huth * Hubs can be used to provide independent emulated network segments.
28f6c874e3SStefan Hajnoczi */
29f6c874e3SStefan Hajnoczi
30f6c874e3SStefan Hajnoczi typedef struct NetHub NetHub;
31f6c874e3SStefan Hajnoczi
32f6c874e3SStefan Hajnoczi typedef struct NetHubPort {
334e68f7a0SStefan Hajnoczi NetClientState nc;
34f6c874e3SStefan Hajnoczi QLIST_ENTRY(NetHubPort) next;
35f6c874e3SStefan Hajnoczi NetHub *hub;
36f6c874e3SStefan Hajnoczi int id;
37f6c874e3SStefan Hajnoczi } NetHubPort;
38f6c874e3SStefan Hajnoczi
39f6c874e3SStefan Hajnoczi struct NetHub {
40f6c874e3SStefan Hajnoczi int id;
41f6c874e3SStefan Hajnoczi QLIST_ENTRY(NetHub) next;
42f6c874e3SStefan Hajnoczi int num_ports;
43f6c874e3SStefan Hajnoczi QLIST_HEAD(, NetHubPort) ports;
44f6c874e3SStefan Hajnoczi };
45f6c874e3SStefan Hajnoczi
46f6c874e3SStefan Hajnoczi static QLIST_HEAD(, NetHub) hubs = QLIST_HEAD_INITIALIZER(&hubs);
47f6c874e3SStefan Hajnoczi
net_hub_receive(NetHub * hub,NetHubPort * source_port,const uint8_t * buf,size_t len)48f6c874e3SStefan Hajnoczi static ssize_t net_hub_receive(NetHub *hub, NetHubPort *source_port,
49f6c874e3SStefan Hajnoczi const uint8_t *buf, size_t len)
50f6c874e3SStefan Hajnoczi {
51f6c874e3SStefan Hajnoczi NetHubPort *port;
52f6c874e3SStefan Hajnoczi
53f6c874e3SStefan Hajnoczi QLIST_FOREACH(port, &hub->ports, next) {
54f6c874e3SStefan Hajnoczi if (port == source_port) {
55f6c874e3SStefan Hajnoczi continue;
56f6c874e3SStefan Hajnoczi }
57f6c874e3SStefan Hajnoczi
58f6c874e3SStefan Hajnoczi qemu_send_packet(&port->nc, buf, len);
59f6c874e3SStefan Hajnoczi }
60f6c874e3SStefan Hajnoczi return len;
61f6c874e3SStefan Hajnoczi }
62f6c874e3SStefan Hajnoczi
net_hub_receive_iov(NetHub * hub,NetHubPort * source_port,const struct iovec * iov,int iovcnt)63f6c874e3SStefan Hajnoczi static ssize_t net_hub_receive_iov(NetHub *hub, NetHubPort *source_port,
64f6c874e3SStefan Hajnoczi const struct iovec *iov, int iovcnt)
65f6c874e3SStefan Hajnoczi {
66f6c874e3SStefan Hajnoczi NetHubPort *port;
6752a3cb86SZhi Yong Wu ssize_t len = iov_size(iov, iovcnt);
68f6c874e3SStefan Hajnoczi
69f6c874e3SStefan Hajnoczi QLIST_FOREACH(port, &hub->ports, next) {
70f6c874e3SStefan Hajnoczi if (port == source_port) {
71f6c874e3SStefan Hajnoczi continue;
72f6c874e3SStefan Hajnoczi }
73f6c874e3SStefan Hajnoczi
7452a3cb86SZhi Yong Wu qemu_sendv_packet(&port->nc, iov, iovcnt);
75f6c874e3SStefan Hajnoczi }
7652a3cb86SZhi Yong Wu return len;
77f6c874e3SStefan Hajnoczi }
78f6c874e3SStefan Hajnoczi
net_hub_new(int id)79f6c874e3SStefan Hajnoczi static NetHub *net_hub_new(int id)
80f6c874e3SStefan Hajnoczi {
81f6c874e3SStefan Hajnoczi NetHub *hub;
82f6c874e3SStefan Hajnoczi
83f6c874e3SStefan Hajnoczi hub = g_malloc(sizeof(*hub));
84f6c874e3SStefan Hajnoczi hub->id = id;
85f6c874e3SStefan Hajnoczi hub->num_ports = 0;
86f6c874e3SStefan Hajnoczi QLIST_INIT(&hub->ports);
87f6c874e3SStefan Hajnoczi
88f6c874e3SStefan Hajnoczi QLIST_INSERT_HEAD(&hubs, hub, next);
89f6c874e3SStefan Hajnoczi
90f6c874e3SStefan Hajnoczi return hub;
91f6c874e3SStefan Hajnoczi }
92f6c874e3SStefan Hajnoczi
net_hub_port_can_receive(NetClientState * nc)93b8c4b67eSPhilippe Mathieu-Daudé static bool net_hub_port_can_receive(NetClientState *nc)
9452a3cb86SZhi Yong Wu {
9552a3cb86SZhi Yong Wu NetHubPort *port;
9652a3cb86SZhi Yong Wu NetHubPort *src_port = DO_UPCAST(NetHubPort, nc, nc);
9752a3cb86SZhi Yong Wu NetHub *hub = src_port->hub;
9852a3cb86SZhi Yong Wu
9952a3cb86SZhi Yong Wu QLIST_FOREACH(port, &hub->ports, next) {
10052a3cb86SZhi Yong Wu if (port == src_port) {
10152a3cb86SZhi Yong Wu continue;
10252a3cb86SZhi Yong Wu }
10352a3cb86SZhi Yong Wu
10461518a74SStefan Hajnoczi if (qemu_can_send_packet(&port->nc)) {
105b8c4b67eSPhilippe Mathieu-Daudé return true;
10652a3cb86SZhi Yong Wu }
10752a3cb86SZhi Yong Wu }
10852a3cb86SZhi Yong Wu
109b8c4b67eSPhilippe Mathieu-Daudé return false;
11052a3cb86SZhi Yong Wu }
11152a3cb86SZhi Yong Wu
net_hub_port_receive(NetClientState * nc,const uint8_t * buf,size_t len)1124e68f7a0SStefan Hajnoczi static ssize_t net_hub_port_receive(NetClientState *nc,
113f6c874e3SStefan Hajnoczi const uint8_t *buf, size_t len)
114f6c874e3SStefan Hajnoczi {
115f6c874e3SStefan Hajnoczi NetHubPort *port = DO_UPCAST(NetHubPort, nc, nc);
116f6c874e3SStefan Hajnoczi
117f6c874e3SStefan Hajnoczi return net_hub_receive(port->hub, port, buf, len);
118f6c874e3SStefan Hajnoczi }
119f6c874e3SStefan Hajnoczi
net_hub_port_receive_iov(NetClientState * nc,const struct iovec * iov,int iovcnt)1204e68f7a0SStefan Hajnoczi static ssize_t net_hub_port_receive_iov(NetClientState *nc,
121f6c874e3SStefan Hajnoczi const struct iovec *iov, int iovcnt)
122f6c874e3SStefan Hajnoczi {
123f6c874e3SStefan Hajnoczi NetHubPort *port = DO_UPCAST(NetHubPort, nc, nc);
124f6c874e3SStefan Hajnoczi
125f6c874e3SStefan Hajnoczi return net_hub_receive_iov(port->hub, port, iov, iovcnt);
126f6c874e3SStefan Hajnoczi }
127f6c874e3SStefan Hajnoczi
net_hub_port_cleanup(NetClientState * nc)1284e68f7a0SStefan Hajnoczi static void net_hub_port_cleanup(NetClientState *nc)
129f6c874e3SStefan Hajnoczi {
130f6c874e3SStefan Hajnoczi NetHubPort *port = DO_UPCAST(NetHubPort, nc, nc);
131f6c874e3SStefan Hajnoczi
132f6c874e3SStefan Hajnoczi QLIST_REMOVE(port, next);
133f6c874e3SStefan Hajnoczi }
134f6c874e3SStefan Hajnoczi
135f6c874e3SStefan Hajnoczi static NetClientInfo net_hub_port_info = {
136f394b2e2SEric Blake .type = NET_CLIENT_DRIVER_HUBPORT,
137f6c874e3SStefan Hajnoczi .size = sizeof(NetHubPort),
13852a3cb86SZhi Yong Wu .can_receive = net_hub_port_can_receive,
139f6c874e3SStefan Hajnoczi .receive = net_hub_port_receive,
140f6c874e3SStefan Hajnoczi .receive_iov = net_hub_port_receive_iov,
141f6c874e3SStefan Hajnoczi .cleanup = net_hub_port_cleanup,
142f6c874e3SStefan Hajnoczi };
143f6c874e3SStefan Hajnoczi
net_hub_port_new(NetHub * hub,const char * name,NetClientState * hubpeer)14418d65d22SThomas Huth static NetHubPort *net_hub_port_new(NetHub *hub, const char *name,
14518d65d22SThomas Huth NetClientState *hubpeer)
146f6c874e3SStefan Hajnoczi {
1474e68f7a0SStefan Hajnoczi NetClientState *nc;
148f6c874e3SStefan Hajnoczi NetHubPort *port;
149f6c874e3SStefan Hajnoczi int id = hub->num_ports++;
150f6c874e3SStefan Hajnoczi char default_name[128];
151f6c874e3SStefan Hajnoczi
152f6c874e3SStefan Hajnoczi if (!name) {
153f6c874e3SStefan Hajnoczi snprintf(default_name, sizeof(default_name),
154f6c874e3SStefan Hajnoczi "hub%dport%d", hub->id, id);
155f6c874e3SStefan Hajnoczi name = default_name;
156f6c874e3SStefan Hajnoczi }
157f6c874e3SStefan Hajnoczi
15818d65d22SThomas Huth nc = qemu_new_net_client(&net_hub_port_info, hubpeer, "hub", name);
159f6c874e3SStefan Hajnoczi port = DO_UPCAST(NetHubPort, nc, nc);
160f6c874e3SStefan Hajnoczi port->id = id;
161f6c874e3SStefan Hajnoczi port->hub = hub;
162f6c874e3SStefan Hajnoczi
163f6c874e3SStefan Hajnoczi QLIST_INSERT_HEAD(&hub->ports, port, next);
164f6c874e3SStefan Hajnoczi
165f6c874e3SStefan Hajnoczi return port;
166f6c874e3SStefan Hajnoczi }
167f6c874e3SStefan Hajnoczi
168f6c874e3SStefan Hajnoczi /**
169f6c874e3SStefan Hajnoczi * Create a port on a given hub
17018d65d22SThomas Huth * @hub_id: Number of the hub
171f6c874e3SStefan Hajnoczi * @name: Net client name or NULL for default name.
17218d65d22SThomas Huth * @hubpeer: Peer to use (if "netdev=id" has been specified)
173f6c874e3SStefan Hajnoczi *
174f6c874e3SStefan Hajnoczi * If there is no existing hub with the given id then a new hub is created.
175f6c874e3SStefan Hajnoczi */
net_hub_add_port(int hub_id,const char * name,NetClientState * hubpeer)17618d65d22SThomas Huth NetClientState *net_hub_add_port(int hub_id, const char *name,
17718d65d22SThomas Huth NetClientState *hubpeer)
178f6c874e3SStefan Hajnoczi {
179f6c874e3SStefan Hajnoczi NetHub *hub;
180f6c874e3SStefan Hajnoczi NetHubPort *port;
181f6c874e3SStefan Hajnoczi
182f6c874e3SStefan Hajnoczi QLIST_FOREACH(hub, &hubs, next) {
183f6c874e3SStefan Hajnoczi if (hub->id == hub_id) {
184f6c874e3SStefan Hajnoczi break;
185f6c874e3SStefan Hajnoczi }
186f6c874e3SStefan Hajnoczi }
187f6c874e3SStefan Hajnoczi
188f6c874e3SStefan Hajnoczi if (!hub) {
189f6c874e3SStefan Hajnoczi hub = net_hub_new(hub_id);
190f6c874e3SStefan Hajnoczi }
191f6c874e3SStefan Hajnoczi
19218d65d22SThomas Huth port = net_hub_port_new(hub, name, hubpeer);
193f6c874e3SStefan Hajnoczi return &port->nc;
194f6c874e3SStefan Hajnoczi }
195f6c874e3SStefan Hajnoczi
196f6c874e3SStefan Hajnoczi /**
197606c10e2SZhi Yong Wu * Find a available port on a hub; otherwise create one new port
198606c10e2SZhi Yong Wu */
net_hub_port_find(int hub_id)1994e68f7a0SStefan Hajnoczi NetClientState *net_hub_port_find(int hub_id)
200606c10e2SZhi Yong Wu {
201606c10e2SZhi Yong Wu NetHub *hub;
202606c10e2SZhi Yong Wu NetHubPort *port;
2034e68f7a0SStefan Hajnoczi NetClientState *nc;
204606c10e2SZhi Yong Wu
205606c10e2SZhi Yong Wu QLIST_FOREACH(hub, &hubs, next) {
206606c10e2SZhi Yong Wu if (hub->id == hub_id) {
207606c10e2SZhi Yong Wu QLIST_FOREACH(port, &hub->ports, next) {
208606c10e2SZhi Yong Wu nc = port->nc.peer;
209606c10e2SZhi Yong Wu if (!nc) {
210606c10e2SZhi Yong Wu return &(port->nc);
211606c10e2SZhi Yong Wu }
212606c10e2SZhi Yong Wu }
213606c10e2SZhi Yong Wu break;
214606c10e2SZhi Yong Wu }
215606c10e2SZhi Yong Wu }
216606c10e2SZhi Yong Wu
21718d65d22SThomas Huth nc = net_hub_add_port(hub_id, NULL, NULL);
218606c10e2SZhi Yong Wu return nc;
219606c10e2SZhi Yong Wu }
220606c10e2SZhi Yong Wu
221606c10e2SZhi Yong Wu /**
222f6c874e3SStefan Hajnoczi * Print hub configuration
223f6c874e3SStefan Hajnoczi */
net_hub_info(Monitor * mon)224f6c874e3SStefan Hajnoczi void net_hub_info(Monitor *mon)
225f6c874e3SStefan Hajnoczi {
226f6c874e3SStefan Hajnoczi NetHub *hub;
227f6c874e3SStefan Hajnoczi NetHubPort *port;
228f6c874e3SStefan Hajnoczi
229f6c874e3SStefan Hajnoczi QLIST_FOREACH(hub, &hubs, next) {
230f6c874e3SStefan Hajnoczi monitor_printf(mon, "hub %d\n", hub->id);
231f6c874e3SStefan Hajnoczi QLIST_FOREACH(port, &hub->ports, next) {
232a6efd6aeSJason Wang monitor_printf(mon, " \\ %s", port->nc.name);
2331a859593SZhi Yong Wu if (port->nc.peer) {
234a6efd6aeSJason Wang monitor_printf(mon, ": ");
2351a859593SZhi Yong Wu print_net_client(mon, port->nc.peer);
236a6efd6aeSJason Wang } else {
237a6efd6aeSJason Wang monitor_printf(mon, "\n");
2381a859593SZhi Yong Wu }
239f6c874e3SStefan Hajnoczi }
240f6c874e3SStefan Hajnoczi }
241f6c874e3SStefan Hajnoczi }
242f6c874e3SStefan Hajnoczi
243f6c874e3SStefan Hajnoczi /**
244f6c874e3SStefan Hajnoczi * Get the hub id that a client is connected to
245f6c874e3SStefan Hajnoczi *
246e103129bSZhi Yong Wu * @id: Pointer for hub id output, may be NULL
247f6c874e3SStefan Hajnoczi */
net_hub_id_for_client(NetClientState * nc,int * id)2484e68f7a0SStefan Hajnoczi int net_hub_id_for_client(NetClientState *nc, int *id)
249f6c874e3SStefan Hajnoczi {
250f6c874e3SStefan Hajnoczi NetHubPort *port;
251f6c874e3SStefan Hajnoczi
252f394b2e2SEric Blake if (nc->info->type == NET_CLIENT_DRIVER_HUBPORT) {
253f6c874e3SStefan Hajnoczi port = DO_UPCAST(NetHubPort, nc, nc);
254f6c874e3SStefan Hajnoczi } else if (nc->peer != NULL && nc->peer->info->type ==
255f394b2e2SEric Blake NET_CLIENT_DRIVER_HUBPORT) {
256f6c874e3SStefan Hajnoczi port = DO_UPCAST(NetHubPort, nc, nc->peer);
257f6c874e3SStefan Hajnoczi } else {
258f6c874e3SStefan Hajnoczi return -ENOENT;
259f6c874e3SStefan Hajnoczi }
260f6c874e3SStefan Hajnoczi
261f6c874e3SStefan Hajnoczi if (id) {
262f6c874e3SStefan Hajnoczi *id = port->hub->id;
263f6c874e3SStefan Hajnoczi }
264f6c874e3SStefan Hajnoczi return 0;
265f6c874e3SStefan Hajnoczi }
266f6c874e3SStefan Hajnoczi
net_init_hubport(const Netdev * netdev,const char * name,NetClientState * peer,Error ** errp)267cebea510SKővágó, Zoltán int net_init_hubport(const Netdev *netdev, const char *name,
268a30ecde6SMarkus Armbruster NetClientState *peer, Error **errp)
269f6c874e3SStefan Hajnoczi {
270f6c874e3SStefan Hajnoczi const NetdevHubPortOptions *hubport;
27118d65d22SThomas Huth NetClientState *hubpeer = NULL;
272f6c874e3SStefan Hajnoczi
273f394b2e2SEric Blake assert(netdev->type == NET_CLIENT_DRIVER_HUBPORT);
274ca7eb184SMarkus Armbruster assert(!peer);
275f394b2e2SEric Blake hubport = &netdev->u.hubport;
276f6c874e3SStefan Hajnoczi
277*7480874aSMarkus Armbruster if (hubport->netdev) {
27818d65d22SThomas Huth hubpeer = qemu_find_netdev(hubport->netdev);
27918d65d22SThomas Huth if (!hubpeer) {
28018d65d22SThomas Huth error_setg(errp, "netdev '%s' not found", hubport->netdev);
28118d65d22SThomas Huth return -1;
28218d65d22SThomas Huth }
28318d65d22SThomas Huth }
28418d65d22SThomas Huth
28518d65d22SThomas Huth net_hub_add_port(hubport->hubid, name, hubpeer);
28618d65d22SThomas Huth
287f6c874e3SStefan Hajnoczi return 0;
288f6c874e3SStefan Hajnoczi }
28981017645SStefan Hajnoczi
29081017645SStefan Hajnoczi /**
29181017645SStefan Hajnoczi * Warn if hub configurations are likely wrong
29281017645SStefan Hajnoczi */
net_hub_check_clients(void)29381017645SStefan Hajnoczi void net_hub_check_clients(void)
29481017645SStefan Hajnoczi {
29581017645SStefan Hajnoczi NetHub *hub;
29681017645SStefan Hajnoczi NetHubPort *port;
2974e68f7a0SStefan Hajnoczi NetClientState *peer;
29881017645SStefan Hajnoczi
29981017645SStefan Hajnoczi QLIST_FOREACH(hub, &hubs, next) {
30081017645SStefan Hajnoczi int has_nic = 0, has_host_dev = 0;
30181017645SStefan Hajnoczi
30281017645SStefan Hajnoczi QLIST_FOREACH(port, &hub->ports, next) {
30381017645SStefan Hajnoczi peer = port->nc.peer;
30481017645SStefan Hajnoczi if (!peer) {
305b62e39b4SAlistair Francis warn_report("hub port %s has no peer", port->nc.name);
30681017645SStefan Hajnoczi continue;
30781017645SStefan Hajnoczi }
30881017645SStefan Hajnoczi
30981017645SStefan Hajnoczi switch (peer->info->type) {
310f394b2e2SEric Blake case NET_CLIENT_DRIVER_NIC:
31181017645SStefan Hajnoczi has_nic = 1;
31281017645SStefan Hajnoczi break;
313f394b2e2SEric Blake case NET_CLIENT_DRIVER_USER:
314f394b2e2SEric Blake case NET_CLIENT_DRIVER_TAP:
315f394b2e2SEric Blake case NET_CLIENT_DRIVER_SOCKET:
3165166fe0aSLaurent Vivier case NET_CLIENT_DRIVER_STREAM:
3175166fe0aSLaurent Vivier case NET_CLIENT_DRIVER_DGRAM:
318f394b2e2SEric Blake case NET_CLIENT_DRIVER_VDE:
319f394b2e2SEric Blake case NET_CLIENT_DRIVER_VHOST_USER:
32081017645SStefan Hajnoczi has_host_dev = 1;
32181017645SStefan Hajnoczi break;
32281017645SStefan Hajnoczi default:
32381017645SStefan Hajnoczi break;
32481017645SStefan Hajnoczi }
32581017645SStefan Hajnoczi }
32681017645SStefan Hajnoczi if (has_host_dev && !has_nic) {
327442da403SThomas Huth warn_report("hub %d with no nics", hub->id);
32881017645SStefan Hajnoczi }
32956512e1dSJason Wang if (has_nic && !has_host_dev && !qtest_enabled()) {
330442da403SThomas Huth warn_report("hub %d is not connected to host network", hub->id);
33181017645SStefan Hajnoczi }
33281017645SStefan Hajnoczi }
33381017645SStefan Hajnoczi }
334199ee608SLuigi Rizzo
net_hub_flush(NetClientState * nc)335199ee608SLuigi Rizzo bool net_hub_flush(NetClientState *nc)
336199ee608SLuigi Rizzo {
337199ee608SLuigi Rizzo NetHubPort *port;
338199ee608SLuigi Rizzo NetHubPort *source_port = DO_UPCAST(NetHubPort, nc, nc);
339199ee608SLuigi Rizzo int ret = 0;
340199ee608SLuigi Rizzo
341199ee608SLuigi Rizzo QLIST_FOREACH(port, &source_port->hub->ports, next) {
342199ee608SLuigi Rizzo if (port != source_port) {
343067404beSJan Kiszka ret += qemu_net_queue_flush(port->nc.incoming_queue);
344199ee608SLuigi Rizzo }
345199ee608SLuigi Rizzo }
346199ee608SLuigi Rizzo return ret ? true : false;
347199ee608SLuigi Rizzo }
348