X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fnetdev-dummy.c;h=ac2656490851aa3429a476873df3a9fa783e702c;hb=015ac88281952a1b43ad46e9e6300db1c6e3647b;hp=dc3ddf80e14ed6410b7829283afd01f6015faa60;hpb=86f1d0326bd07ebf0f3dcb197007d7b67c205cbe;p=sliver-openvswitch.git diff --git a/lib/netdev-dummy.c b/lib/netdev-dummy.c index dc3ddf80e..ac2656490 100644 --- a/lib/netdev-dummy.c +++ b/lib/netdev-dummy.c @@ -44,23 +44,35 @@ struct dummy_stream { struct list txq; }; +/* Protects 'dummy_list'. */ +static struct ovs_mutex dummy_list_mutex = OVS_MUTEX_INITIALIZER; + +/* Contains all 'struct dummy_dev's. */ +static struct list dummy_list OVS_GUARDED_BY(dummy_list_mutex) + = LIST_INITIALIZER(&dummy_list); + struct netdev_dummy { struct netdev up; - uint8_t hwaddr[ETH_ADDR_LEN]; - int mtu; - struct netdev_stats stats; - enum netdev_flags flags; - unsigned int change_seq; - int ifindex; - struct pstream *pstream; - struct dummy_stream *streams; - size_t n_streams; + /* In dummy_list. */ + struct list list_node OVS_GUARDED_BY(dummy_list_mutex); - struct list rxes; /* List of child "netdev_rx_dummy"s. */ -}; + /* Protects all members below. */ + struct ovs_mutex mutex OVS_ACQ_AFTER(dummy_list_mutex); + + uint8_t hwaddr[ETH_ADDR_LEN] OVS_GUARDED; + int mtu OVS_GUARDED; + struct netdev_stats stats OVS_GUARDED; + enum netdev_flags flags OVS_GUARDED; + unsigned int change_seq OVS_GUARDED; + int ifindex OVS_GUARDED; -static const struct netdev_class dummy_class; + struct pstream *pstream OVS_GUARDED; + struct dummy_stream *streams OVS_GUARDED; + size_t n_streams OVS_GUARDED; + + struct list rxes OVS_GUARDED; /* List of child "netdev_rx_dummy"s. */ +}; /* Max 'recv_queue_len' in struct netdev_dummy. */ #define NETDEV_DUMMY_MAX_QUEUE 100 @@ -73,12 +85,10 @@ struct netdev_rx_dummy { bool listening; }; -static const struct netdev_rx_class netdev_rx_dummy_class; - static unixctl_cb_func netdev_dummy_set_admin_state; -static int netdev_dummy_create(const struct netdev_class *, const char *, - struct netdev **); -static void netdev_dummy_poll_notify(struct netdev_dummy *); +static int netdev_dummy_construct(struct netdev *); +static void netdev_dummy_poll_notify(struct netdev_dummy *netdev) + OVS_REQUIRES(netdev->mutex); static void netdev_dummy_queue_packet(struct netdev_dummy *, struct ofpbuf *); static void dummy_stream_close(struct dummy_stream *); @@ -86,7 +96,7 @@ static void dummy_stream_close(struct dummy_stream *); static bool is_dummy_class(const struct netdev_class *class) { - return class->create == netdev_dummy_create; + return class->construct == netdev_dummy_construct; } static struct netdev_dummy * @@ -99,22 +109,21 @@ netdev_dummy_cast(const struct netdev *netdev) static struct netdev_rx_dummy * netdev_rx_dummy_cast(const struct netdev_rx *rx) { - netdev_rx_assert_class(rx, &netdev_rx_dummy_class); + ovs_assert(is_dummy_class(netdev_get_class(rx->netdev))); return CONTAINER_OF(rx, struct netdev_rx_dummy, up); } static void netdev_dummy_run(void) { - struct shash dummy_netdevs; - struct shash_node *node; + struct netdev_dummy *dev; - shash_init(&dummy_netdevs); - netdev_get_devices(&dummy_class, &dummy_netdevs); - SHASH_FOR_EACH (node, &dummy_netdevs) { - struct netdev_dummy *dev = node->data; + ovs_mutex_lock(&dummy_list_mutex); + LIST_FOR_EACH (dev, list_node, &dummy_list) { size_t i; + ovs_mutex_lock(&dev->mutex); + if (dev->pstream) { struct stream *new_stream; int error; @@ -206,9 +215,9 @@ netdev_dummy_run(void) } } - netdev_close(&dev->up); + ovs_mutex_unlock(&dev->mutex); } - shash_destroy(&dummy_netdevs); + ovs_mutex_unlock(&dummy_list_mutex); } static void @@ -222,15 +231,13 @@ dummy_stream_close(struct dummy_stream *s) static void netdev_dummy_wait(void) { - struct shash dummy_netdevs; - struct shash_node *node; + struct netdev_dummy *dev; - shash_init(&dummy_netdevs); - netdev_get_devices(&dummy_class, &dummy_netdevs); - SHASH_FOR_EACH (node, &dummy_netdevs) { - struct netdev_dummy *dev = node->data; + ovs_mutex_lock(&dummy_list_mutex); + LIST_FOR_EACH (dev, list_node, &dummy_list) { size_t i; + ovs_mutex_lock(&dev->mutex); if (dev->pstream) { pstream_wait(dev->pstream); } @@ -243,22 +250,29 @@ netdev_dummy_wait(void) } stream_recv_wait(s->stream); } - netdev_close(&dev->up); + ovs_mutex_unlock(&dev->mutex); } - shash_destroy(&dummy_netdevs); + ovs_mutex_unlock(&dummy_list_mutex); +} + +static struct netdev * +netdev_dummy_alloc(void) +{ + struct netdev_dummy *netdev = xzalloc(sizeof *netdev); + return &netdev->up; } static int -netdev_dummy_create(const struct netdev_class *class, const char *name, - struct netdev **netdevp) +netdev_dummy_construct(struct netdev *netdev_) { static atomic_uint next_n = ATOMIC_VAR_INIT(0xaa550000); - struct netdev_dummy *netdev; + struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); unsigned int n; atomic_add(&next_n, 1, &n); - netdev = xzalloc(sizeof *netdev); - netdev_init(&netdev->up, name, class); + + ovs_mutex_init(&netdev->mutex); + ovs_mutex_lock(&netdev->mutex); netdev->hwaddr[0] = 0xaa; netdev->hwaddr[1] = 0x55; netdev->hwaddr[2] = n >> 24; @@ -275,23 +289,40 @@ netdev_dummy_create(const struct netdev_class *class, const char *name, netdev->n_streams = 0; list_init(&netdev->rxes); + ovs_mutex_unlock(&netdev->mutex); - *netdevp = &netdev->up; + ovs_mutex_lock(&dummy_list_mutex); + list_push_back(&dummy_list, &netdev->list_node); + ovs_mutex_unlock(&dummy_list_mutex); return 0; } static void -netdev_dummy_destroy(struct netdev *netdev_) +netdev_dummy_destruct(struct netdev *netdev_) { struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); size_t i; + ovs_mutex_lock(&dummy_list_mutex); + list_remove(&netdev->list_node); + ovs_mutex_unlock(&dummy_list_mutex); + + ovs_mutex_lock(&netdev->mutex); pstream_close(netdev->pstream); for (i = 0; i < netdev->n_streams; i++) { dummy_stream_close(&netdev->streams[i]); } free(netdev->streams); + ovs_mutex_unlock(&netdev->mutex); + ovs_mutex_destroy(&netdev->mutex); +} + +static void +netdev_dummy_dealloc(struct netdev *netdev_) +{ + struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); + free(netdev); } @@ -300,12 +331,15 @@ netdev_dummy_get_config(const struct netdev *netdev_, struct smap *args) { struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); + ovs_mutex_lock(&netdev->mutex); if (netdev->ifindex >= 0) { smap_add_format(args, "ifindex", "%d", netdev->ifindex); } if (netdev->pstream) { smap_add(args, "pstream", pstream_get_name(netdev->pstream)); } + ovs_mutex_unlock(&netdev->mutex); + return 0; } @@ -315,6 +349,7 @@ netdev_dummy_set_config(struct netdev *netdev_, const struct smap *args) struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); const char *pstream; + ovs_mutex_lock(&netdev->mutex); netdev->ifindex = smap_get_int(args, "ifindex", -EOPNOTSUPP); pstream = smap_get(args, "pstream"); @@ -334,38 +369,74 @@ netdev_dummy_set_config(struct netdev *netdev_, const struct smap *args) } } } + ovs_mutex_unlock(&netdev->mutex); + return 0; } +static struct netdev_rx * +netdev_dummy_rx_alloc(void) +{ + struct netdev_rx_dummy *rx = xzalloc(sizeof *rx); + return &rx->up; +} + static int -netdev_dummy_rx_open(struct netdev *netdev_, struct netdev_rx **rxp) +netdev_dummy_rx_construct(struct netdev_rx *rx_) { - struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); - struct netdev_rx_dummy *rx; + struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); + struct netdev_dummy *netdev = netdev_dummy_cast(rx->up.netdev); - rx = xmalloc(sizeof *rx); - netdev_rx_init(&rx->up, &netdev->up, &netdev_rx_dummy_class); + ovs_mutex_lock(&netdev->mutex); list_push_back(&netdev->rxes, &rx->node); list_init(&rx->recv_queue); rx->recv_queue_len = 0; + ovs_mutex_unlock(&netdev->mutex); - *rxp = &rx->up; return 0; } +static void +netdev_dummy_rx_destruct(struct netdev_rx *rx_) +{ + struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); + struct netdev_dummy *netdev = netdev_dummy_cast(rx->up.netdev); + + ovs_mutex_lock(&netdev->mutex); + list_remove(&rx->node); + ofpbuf_list_delete(&rx->recv_queue); + ovs_mutex_unlock(&netdev->mutex); +} + +static void +netdev_dummy_rx_dealloc(struct netdev_rx *rx_) +{ + struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); + + free(rx); +} + static int -netdev_rx_dummy_recv(struct netdev_rx *rx_, void *buffer, size_t size) +netdev_dummy_rx_recv(struct netdev_rx *rx_, void *buffer, size_t size) { struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); + struct netdev_dummy *netdev = netdev_dummy_cast(rx->up.netdev); struct ofpbuf *packet; int retval; - if (list_is_empty(&rx->recv_queue)) { + ovs_mutex_lock(&netdev->mutex); + if (!list_is_empty(&rx->recv_queue)) { + packet = ofpbuf_from_list(list_pop_front(&rx->recv_queue)); + rx->recv_queue_len--; + } else { + packet = NULL; + } + ovs_mutex_unlock(&netdev->mutex); + + if (!packet) { return -EAGAIN; } - packet = ofpbuf_from_list(list_pop_front(&rx->recv_queue)); - rx->recv_queue_len--; if (packet->size <= size) { memcpy(buffer, packet->data, packet->size); retval = packet->size; @@ -378,29 +449,29 @@ netdev_rx_dummy_recv(struct netdev_rx *rx_, void *buffer, size_t size) } static void -netdev_rx_dummy_destroy(struct netdev_rx *rx_) +netdev_dummy_rx_wait(struct netdev_rx *rx_) { struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); - list_remove(&rx->node); - ofpbuf_list_delete(&rx->recv_queue); - free(rx); -} + struct netdev_dummy *netdev = netdev_dummy_cast(rx->up.netdev); -static void -netdev_rx_dummy_wait(struct netdev_rx *rx_) -{ - struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); + ovs_mutex_lock(&netdev->mutex); if (!list_is_empty(&rx->recv_queue)) { poll_immediate_wake(); } + ovs_mutex_unlock(&netdev->mutex); } static int -netdev_rx_dummy_drain(struct netdev_rx *rx_) +netdev_dummy_rx_drain(struct netdev_rx *rx_) { struct netdev_rx_dummy *rx = netdev_rx_dummy_cast(rx_); + struct netdev_dummy *netdev = netdev_dummy_cast(rx->up.netdev); + + ovs_mutex_lock(&netdev->mutex); ofpbuf_list_delete(&rx->recv_queue); rx->recv_queue_len = 0; + ovs_mutex_unlock(&netdev->mutex); + return 0; } @@ -416,7 +487,10 @@ netdev_dummy_send(struct netdev *netdev, const void *buffer, size_t size) const struct eth_header *eth = buffer; int max_size; + ovs_mutex_lock(&dev->mutex); max_size = dev->mtu + ETH_HEADER_LEN; + ovs_mutex_unlock(&dev->mutex); + if (eth->eth_type == htons(ETH_TYPE_VLAN)) { max_size += VLAN_HEADER_LEN; } @@ -425,6 +499,7 @@ netdev_dummy_send(struct netdev *netdev, const void *buffer, size_t size) } } + ovs_mutex_lock(&dev->mutex); dev->stats.tx_packets++; dev->stats.tx_bytes += size; @@ -439,6 +514,7 @@ netdev_dummy_send(struct netdev *netdev, const void *buffer, size_t size) list_push_back(&s->txq, &b->list_node); } } + ovs_mutex_unlock(&dev->mutex); return 0; } @@ -449,10 +525,12 @@ netdev_dummy_set_etheraddr(struct netdev *netdev, { struct netdev_dummy *dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dev->mutex); if (!eth_addr_equals(dev->hwaddr, mac)) { memcpy(dev->hwaddr, mac, ETH_ADDR_LEN); netdev_dummy_poll_notify(dev); } + ovs_mutex_unlock(&dev->mutex); return 0; } @@ -461,18 +539,24 @@ static int netdev_dummy_get_etheraddr(const struct netdev *netdev, uint8_t mac[ETH_ADDR_LEN]) { - const struct netdev_dummy *dev = netdev_dummy_cast(netdev); + struct netdev_dummy *dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dev->mutex); memcpy(mac, dev->hwaddr, ETH_ADDR_LEN); + ovs_mutex_unlock(&dev->mutex); + return 0; } static int netdev_dummy_get_mtu(const struct netdev *netdev, int *mtup) { - const struct netdev_dummy *dev = netdev_dummy_cast(netdev); + struct netdev_dummy *dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dev->mutex); *mtup = dev->mtu; + ovs_mutex_unlock(&dev->mutex); + return 0; } @@ -481,16 +565,22 @@ netdev_dummy_set_mtu(const struct netdev *netdev, int mtu) { struct netdev_dummy *dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dev->mutex); dev->mtu = mtu; + ovs_mutex_unlock(&dev->mutex); + return 0; } static int netdev_dummy_get_stats(const struct netdev *netdev, struct netdev_stats *stats) { - const struct netdev_dummy *dev = netdev_dummy_cast(netdev); + struct netdev_dummy *dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dev->mutex); *stats = dev->stats; + ovs_mutex_unlock(&dev->mutex); + return 0; } @@ -499,7 +589,10 @@ netdev_dummy_set_stats(struct netdev *netdev, const struct netdev_stats *stats) { struct netdev_dummy *dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dev->mutex); dev->stats = *stats; + ovs_mutex_unlock(&dev->mutex); + return 0; } @@ -507,17 +600,21 @@ static int netdev_dummy_get_ifindex(const struct netdev *netdev) { struct netdev_dummy *dev = netdev_dummy_cast(netdev); + int ifindex; + + ovs_mutex_lock(&dev->mutex); + ifindex = dev->ifindex; + ovs_mutex_unlock(&dev->mutex); - return dev->ifindex; + return ifindex; } static int -netdev_dummy_update_flags(struct netdev *netdev_, - enum netdev_flags off, enum netdev_flags on, - enum netdev_flags *old_flagsp) +netdev_dummy_update_flags__(struct netdev_dummy *netdev, + enum netdev_flags off, enum netdev_flags on, + enum netdev_flags *old_flagsp) + OVS_REQUIRES(netdev->mutex) { - struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); - if ((off | on) & ~(NETDEV_UP | NETDEV_PROMISC)) { return EINVAL; } @@ -528,13 +625,36 @@ netdev_dummy_update_flags(struct netdev *netdev_, if (*old_flagsp != netdev->flags) { netdev_dummy_poll_notify(netdev); } + return 0; } +static int +netdev_dummy_update_flags(struct netdev *netdev_, + enum netdev_flags off, enum netdev_flags on, + enum netdev_flags *old_flagsp) +{ + struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); + int error; + + ovs_mutex_lock(&netdev->mutex); + error = netdev_dummy_update_flags__(netdev, off, on, old_flagsp); + ovs_mutex_unlock(&netdev->mutex); + + return error; +} + static unsigned int -netdev_dummy_change_seq(const struct netdev *netdev) +netdev_dummy_change_seq(const struct netdev *netdev_) { - return netdev_dummy_cast(netdev)->change_seq; + struct netdev_dummy *netdev = netdev_dummy_cast(netdev_); + unsigned int change_seq; + + ovs_mutex_lock(&netdev->mutex); + change_seq = netdev->change_seq; + ovs_mutex_unlock(&netdev->mutex); + + return change_seq; } /* Helper functions. */ @@ -554,14 +674,14 @@ static const struct netdev_class dummy_class = { netdev_dummy_run, netdev_dummy_wait, - netdev_dummy_create, - netdev_dummy_destroy, + netdev_dummy_alloc, + netdev_dummy_construct, + netdev_dummy_destruct, + netdev_dummy_dealloc, netdev_dummy_get_config, netdev_dummy_set_config, NULL, /* get_tunnel_config */ - netdev_dummy_rx_open, - netdev_dummy_send, /* send */ NULL, /* send_wait */ @@ -601,14 +721,15 @@ static const struct netdev_class dummy_class = { netdev_dummy_update_flags, - netdev_dummy_change_seq -}; + netdev_dummy_change_seq, -static const struct netdev_rx_class netdev_rx_dummy_class = { - netdev_rx_dummy_destroy, - netdev_rx_dummy_recv, - netdev_rx_dummy_wait, - netdev_rx_dummy_drain, + netdev_dummy_rx_alloc, + netdev_dummy_rx_construct, + netdev_dummy_rx_destruct, + netdev_dummy_rx_dealloc, + netdev_dummy_rx_recv, + netdev_dummy_rx_wait, + netdev_dummy_rx_drain, }; static struct ofpbuf * @@ -703,10 +824,11 @@ netdev_dummy_receive(struct unixctl_conn *conn, goto exit; } + ovs_mutex_lock(&dummy_dev->mutex); dummy_dev->stats.rx_packets++; dummy_dev->stats.rx_bytes += packet->size; - netdev_dummy_queue_packet(dummy_dev, packet); + ovs_mutex_unlock(&dummy_dev->mutex); } unixctl_command_reply(conn, NULL); @@ -717,13 +839,14 @@ exit: static void netdev_dummy_set_admin_state__(struct netdev_dummy *dev, bool admin_state) + OVS_REQUIRES(dev->mutex) { enum netdev_flags old_flags; if (admin_state) { - netdev_dummy_update_flags(&dev->up, 0, NETDEV_UP, &old_flags); + netdev_dummy_update_flags__(dev, 0, NETDEV_UP, &old_flags); } else { - netdev_dummy_update_flags(&dev->up, NETDEV_UP, 0, &old_flags); + netdev_dummy_update_flags__(dev, NETDEV_UP, 0, &old_flags); } } @@ -747,7 +870,10 @@ netdev_dummy_set_admin_state(struct unixctl_conn *conn, int argc, if (netdev && is_dummy_class(netdev->netdev_class)) { struct netdev_dummy *dummy_dev = netdev_dummy_cast(netdev); + ovs_mutex_lock(&dummy_dev->mutex); netdev_dummy_set_admin_state__(dummy_dev, up); + ovs_mutex_unlock(&dummy_dev->mutex); + netdev_close(netdev); } else { unixctl_command_reply_error(conn, "Unknown Dummy Interface"); @@ -755,17 +881,15 @@ netdev_dummy_set_admin_state(struct unixctl_conn *conn, int argc, return; } } else { - struct shash dummy_netdevs; - struct shash_node *node; - - shash_init(&dummy_netdevs); - netdev_get_devices(&dummy_class, &dummy_netdevs); - SHASH_FOR_EACH (node, &dummy_netdevs) { - struct netdev *netdev = node->data; - netdev_dummy_set_admin_state__(netdev_dummy_cast(netdev), up); - netdev_close(netdev); + struct netdev_dummy *netdev; + + ovs_mutex_lock(&dummy_list_mutex); + LIST_FOR_EACH (netdev, list_node, &dummy_list) { + ovs_mutex_lock(&netdev->mutex); + netdev_dummy_set_admin_state__(netdev, up); + ovs_mutex_unlock(&netdev->mutex); } - shash_destroy(&dummy_netdevs); + ovs_mutex_unlock(&dummy_list_mutex); } unixctl_command_reply(conn, "OK"); } @@ -788,11 +912,17 @@ netdev_dummy_register(bool override) SSET_FOR_EACH (type, &types) { if (!netdev_unregister_provider(type)) { struct netdev_class *class; + int error; - class = xmalloc(sizeof *class); - *class = dummy_class; + class = xmemdup(&dummy_class, sizeof dummy_class); class->type = xstrdup(type); - netdev_register_provider(class); + error = netdev_register_provider(class); + if (error) { + VLOG_ERR("%s: failed to register netdev provider (%s)", + type, ovs_strerror(error)); + free(CONST_CAST(char *, class->type)); + free(class); + } } } sset_destroy(&types);