LXR qemu/net/hub.c

   1/*
   2 * Hub net client
   3 *
   4 * Copyright IBM, Corp. 2012
   5 *
   6 * Authors:
   7 *  Stefan Hajnoczi   <stefanha@linux.vnet.ibm.com>
   8 *  Zhi Yong Wu       <wuzhy@linux.vnet.ibm.com>
   9 *
  10 * This work is licensed under the terms of the GNU LGPL, version 2 or later.
  11 * See the COPYING.LIB file in the top-level directory.
  12 *
  13 */
  14
  15#include "monitor/monitor.h"
  16#include "net/net.h"
  17#include "clients.h"
  18#include "hub.h"
  19#include "qemu/iov.h"
  20
  21/*
  22 * A hub broadcasts incoming packets to all its ports except the source port.
  23 * Hubs can be used to provide independent network segments, also confusingly
  24 * named the QEMU 'vlan' feature.
  25 */
  26
  27typedef struct NetHub NetHub;
  28
  29typedef struct NetHubPort {
  30    NetClientState nc;
  31    QLIST_ENTRY(NetHubPort) next;
  32    NetHub *hub;
  33    int id;
  34} NetHubPort;
  35
  36struct NetHub {
  37    int id;
  38    QLIST_ENTRY(NetHub) next;
  39    int num_ports;
  40    QLIST_HEAD(, NetHubPort) ports;
  41};
  42
  43static QLIST_HEAD(, NetHub) hubs = QLIST_HEAD_INITIALIZER(&hubs);
  44
  45static ssize_t net_hub_receive(NetHub *hub, NetHubPort *source_port,
  46                               const uint8_t *buf, size_t len)
  47{
  48    NetHubPort *port;
  49
  50    QLIST_FOREACH(port, &hub->ports, next) {
  51        if (port == source_port) {
  52            continue;
  53        }
  54
  55        qemu_send_packet(&port->nc, buf, len);
  56    }
  57    return len;
  58}
  59
  60static ssize_t net_hub_receive_iov(NetHub *hub, NetHubPort *source_port,
  61                                   const struct iovec *iov, int iovcnt)
  62{
  63    NetHubPort *port;
  64    ssize_t len = iov_size(iov, iovcnt);
  65
  66    QLIST_FOREACH(port, &hub->ports, next) {
  67        if (port == source_port) {
  68            continue;
  69        }
  70
  71        qemu_sendv_packet(&port->nc, iov, iovcnt);
  72    }
  73    return len;
  74}
  75
  76static NetHub *net_hub_new(int id)
  77{
  78    NetHub *hub;
  79
  80    hub = g_malloc(sizeof(*hub));
  81    hub->id = id;
  82    hub->num_ports = 0;
  83    QLIST_INIT(&hub->ports);
  84
  85    QLIST_INSERT_HEAD(&hubs, hub, next);
  86
  87    return hub;
  88}
  89
  90static int net_hub_port_can_receive(NetClientState *nc)
  91{
  92    NetHubPort *port;
  93    NetHubPort *src_port = DO_UPCAST(NetHubPort, nc, nc);
  94    NetHub *hub = src_port->hub;
  95
  96    QLIST_FOREACH(port, &hub->ports, next) {
  97        if (port == src_port) {
  98            continue;
  99        }
 100
 101        if (qemu_can_send_packet(&port->nc)) {
 102            return 1;
 103        }
 104    }
 105
 106    return 0;
 107}
 108
 109static ssize_t net_hub_port_receive(NetClientState *nc,
 110                                    const uint8_t *buf, size_t len)
 111{
 112    NetHubPort *port = DO_UPCAST(NetHubPort, nc, nc);
 113
 114    return net_hub_receive(port->hub, port, buf, len);
 115}
 116
 117static ssize_t net_hub_port_receive_iov(NetClientState *nc,
 118                                        const struct iovec *iov, int iovcnt)
 119{
 120    NetHubPort *port = DO_UPCAST(NetHubPort, nc, nc);
 121
 122    return net_hub_receive_iov(port->hub, port, iov, iovcnt);
 123}
 124
 125static void net_hub_port_cleanup(NetClientState *nc)
 126{
 127    NetHubPort *port = DO_UPCAST(NetHubPort, nc, nc);
 128
 129    QLIST_REMOVE(port, next);
 130}
 131
 132static NetClientInfo net_hub_port_info = {
 133    .type = NET_CLIENT_OPTIONS_KIND_HUBPORT,
 134    .size = sizeof(NetHubPort),
 135    .can_receive = net_hub_port_can_receive,
 136    .receive = net_hub_port_receive,
 137    .receive_iov = net_hub_port_receive_iov,
 138    .cleanup = net_hub_port_cleanup,
 139};
 140
 141static NetHubPort *net_hub_port_new(NetHub *hub, const char *name)
 142{
 143    NetClientState *nc;
 144    NetHubPort *port;
 145    int id = hub->num_ports++;
 146    char default_name[128];
 147
 148    if (!name) {
 149        snprintf(default_name, sizeof(default_name),
 150                 "hub%dport%d", hub->id, id);
 151        name = default_name;
 152    }
 153
 154    nc = qemu_new_net_client(&net_hub_port_info, NULL, "hub", name);
 155    port = DO_UPCAST(NetHubPort, nc, nc);
 156    port->id = id;
 157    port->hub = hub;
 158
 159    QLIST_INSERT_HEAD(&hub->ports, port, next);
 160
 161    return port;
 162}
 163
 164/**
 165 * Create a port on a given hub
 166 * @name: Net client name or NULL for default name.
 167 *
 168 * If there is no existing hub with the given id then a new hub is created.
 169 */
 170NetClientState *net_hub_add_port(int hub_id, const char *name)
 171{
 172    NetHub *hub;
 173    NetHubPort *port;
 174
 175    QLIST_FOREACH(hub, &hubs, next) {
 176        if (hub->id == hub_id) {
 177            break;
 178        }
 179    }
 180
 181    if (!hub) {
 182        hub = net_hub_new(hub_id);
 183    }
 184
 185    port = net_hub_port_new(hub, name);
 186    return &port->nc;
 187}
 188
 189/**
 190 * Find a specific client on a hub
 191 */
 192NetClientState *net_hub_find_client_by_name(int hub_id, const char *name)
 193{
 194    NetHub *hub;
 195    NetHubPort *port;
 196    NetClientState *peer;
 197
 198    QLIST_FOREACH(hub, &hubs, next) {
 199        if (hub->id == hub_id) {
 200            QLIST_FOREACH(port, &hub->ports, next) {
 201                peer = port->nc.peer;
 202
 203                if (peer && strcmp(peer->name, name) == 0) {
 204                    return peer;
 205                }
 206            }
 207        }
 208    }
 209    return NULL;
 210}
 211
 212/**
 213 * Find a available port on a hub; otherwise create one new port
 214 */
 215NetClientState *net_hub_port_find(int hub_id)
 216{
 217    NetHub *hub;
 218    NetHubPort *port;
 219    NetClientState *nc;
 220
 221    QLIST_FOREACH(hub, &hubs, next) {
 222        if (hub->id == hub_id) {
 223            QLIST_FOREACH(port, &hub->ports, next) {
 224                nc = port->nc.peer;
 225                if (!nc) {
 226                    return &(port->nc);
 227                }
 228            }
 229            break;
 230        }
 231    }
 232
 233    nc = net_hub_add_port(hub_id, NULL);
 234    return nc;
 235}
 236
 237/**
 238 * Print hub configuration
 239 */
 240void net_hub_info(Monitor *mon)
 241{
 242    NetHub *hub;
 243    NetHubPort *port;
 244
 245    QLIST_FOREACH(hub, &hubs, next) {
 246        monitor_printf(mon, "hub %d\n", hub->id);
 247        QLIST_FOREACH(port, &hub->ports, next) {
 248            monitor_printf(mon, " \\ %s", port->nc.name);
 249            if (port->nc.peer) {
 250                monitor_printf(mon, ": ");
 251                print_net_client(mon, port->nc.peer);
 252            } else {
 253                monitor_printf(mon, "\n");
 254            }
 255        }
 256    }
 257}
 258
 259/**
 260 * Get the hub id that a client is connected to
 261 *
 262 * @id: Pointer for hub id output, may be NULL
 263 */
 264int net_hub_id_for_client(NetClientState *nc, int *id)
 265{
 266    NetHubPort *port;
 267
 268    if (nc->info->type == NET_CLIENT_OPTIONS_KIND_HUBPORT) {
 269        port = DO_UPCAST(NetHubPort, nc, nc);
 270    } else if (nc->peer != NULL && nc->peer->info->type ==
 271            NET_CLIENT_OPTIONS_KIND_HUBPORT) {
 272        port = DO_UPCAST(NetHubPort, nc, nc->peer);
 273    } else {
 274        return -ENOENT;
 275    }
 276
 277    if (id) {
 278        *id = port->hub->id;
 279    }
 280    return 0;
 281}
 282
 283int net_init_hubport(const NetClientOptions *opts, const char *name,
 284                     NetClientState *peer)
 285{
 286    const NetdevHubPortOptions *hubport;
 287
 288    assert(opts->kind == NET_CLIENT_OPTIONS_KIND_HUBPORT);
 289    hubport = opts->hubport;
 290
 291    if (peer) {
 292        return -EINVAL;
 293    }
 294
 295    net_hub_add_port(hubport->hubid, name);
 296    return 0;
 297}
 298
 299/**
 300 * Warn if hub configurations are likely wrong
 301 */
 302void net_hub_check_clients(void)
 303{
 304    NetHub *hub;
 305    NetHubPort *port;
 306    NetClientState *peer;
 307
 308    QLIST_FOREACH(hub, &hubs, next) {
 309        int has_nic = 0, has_host_dev = 0;
 310
 311        QLIST_FOREACH(port, &hub->ports, next) {
 312            peer = port->nc.peer;
 313            if (!peer) {
 314                fprintf(stderr, "Warning: hub port %s has no peer\n",
 315                        port->nc.name);
 316                continue;
 317            }
 318
 319            switch (peer->info->type) {
 320            case NET_CLIENT_OPTIONS_KIND_NIC:
 321                has_nic = 1;
 322                break;
 323            case NET_CLIENT_OPTIONS_KIND_USER:
 324            case NET_CLIENT_OPTIONS_KIND_TAP:
 325            case NET_CLIENT_OPTIONS_KIND_SOCKET:
 326            case NET_CLIENT_OPTIONS_KIND_VDE:
 327            case NET_CLIENT_OPTIONS_KIND_VHOST_USER:
 328                has_host_dev = 1;
 329                break;
 330            default:
 331                break;
 332            }
 333        }
 334        if (has_host_dev && !has_nic) {
 335            fprintf(stderr, "Warning: vlan %d with no nics\n", hub->id);
 336        }
 337        if (has_nic && !has_host_dev) {
 338            fprintf(stderr,
 339                    "Warning: vlan %d is not connected to host network\n",
 340                    hub->id);
 341        }
 342    }
 343}
 344
 345bool net_hub_flush(NetClientState *nc)
 346{
 347    NetHubPort *port;
 348    NetHubPort *source_port = DO_UPCAST(NetHubPort, nc, nc);
 349    int ret = 0;
 350
 351    QLIST_FOREACH(port, &source_port->hub->ports, next) {
 352        if (port != source_port) {
 353            ret += qemu_net_queue_flush(port->nc.incoming_queue);
 354        }
 355    }
 356    return ret ? true : false;
 357}
 358