X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=lib%2Fnetdev-linux.c;h=ac511f0b5574a914baaae998b9e56f97eacd5911;hb=7b6b0ef47e398a2fbda48fd385f9781b2df8bebb;hp=eda12760376cd6714b9dde41838641bfd57be54e;hpb=ac4d3bcb46fa0acd0b63f79449432df28569f74f;p=openvswitch diff --git a/lib/netdev-linux.c b/lib/netdev-linux.c index eda12760..ac511f0b 100644 --- a/lib/netdev-linux.c +++ b/lib/netdev-linux.c @@ -383,15 +383,6 @@ static int af_inet_sock = -1; /* AF_INET, SOCK_DGRAM. */ /* A Netlink routing socket that is not subscribed to any multicast groups. */ static struct nl_sock *rtnl_sock; -struct netdev_linux_notifier { - struct netdev_notifier notifier; - struct list node; -}; - -static struct shash netdev_linux_notifiers = - SHASH_INITIALIZER(&netdev_linux_notifiers); -static struct rtnetlink_notifier netdev_linux_poll_notifier; - /* This is set pretty low because we probably won't learn anything from the * additional log messages. */ static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 20); @@ -417,7 +408,6 @@ static int set_etheraddr(const char *netdev_name, int hwaddr_family, static int get_stats_via_netlink(int ifindex, struct netdev_stats *stats); static int get_stats_via_proc(const char *netdev_name, struct netdev_stats *stats); static int af_packet_sock(void); -static void poll_notify(struct list *); static void netdev_linux_miimon_run(void); static void netdev_linux_miimon_wait(void); @@ -649,8 +639,7 @@ netdev_linux_destroy(struct netdev_dev *netdev_dev_) } static int -netdev_linux_open(struct netdev_dev *netdev_dev_, int ethertype, - struct netdev **netdevp) +netdev_linux_open(struct netdev_dev *netdev_dev_, struct netdev **netdevp) { struct netdev_dev_linux *netdev_dev = netdev_dev_linux_cast(netdev_dev_); struct netdev_linux *netdev; @@ -686,54 +675,6 @@ netdev_linux_open(struct netdev_dev *netdev_dev_, int ethertype, * directions appearing to be reversed. */ netdev->fd = netdev_dev->state.tap.fd; netdev_dev->state.tap.opened = true; - } else if (ethertype != NETDEV_ETH_TYPE_NONE) { - struct sockaddr_ll sll; - int protocol; - int ifindex; - - /* Create file descriptor. */ - protocol = (ethertype == NETDEV_ETH_TYPE_ANY ? ETH_P_ALL - : ethertype == NETDEV_ETH_TYPE_802_2 ? ETH_P_802_2 - : ethertype); - netdev->fd = socket(PF_PACKET, SOCK_RAW, - (OVS_FORCE int) htons(protocol)); - if (netdev->fd < 0) { - error = errno; - goto error; - } - - /* Set non-blocking mode. */ - error = set_nonblocking(netdev->fd); - if (error) { - goto error; - } - - /* Get ethernet device index. */ - error = get_ifindex(&netdev->netdev, &ifindex); - if (error) { - goto error; - } - - /* Bind to specific ethernet device. */ - memset(&sll, 0, sizeof sll); - sll.sll_family = AF_PACKET; - sll.sll_ifindex = ifindex; - if (bind(netdev->fd, - (struct sockaddr *) &sll, sizeof sll) < 0) { - error = errno; - VLOG_ERR("bind to %s failed: %s", netdev_dev_get_name(netdev_dev_), - strerror(error)); - goto error; - } - - /* Between the socket() and bind() calls above, the socket receives all - * packets of the requested type on all system interfaces. We do not - * want to receive that data, but there is no way to avoid it. So we - * must now drain out the receive queue. */ - error = drain_rcvbuf(netdev->fd); - if (error) { - goto error; - } } *netdevp = &netdev->netdev; @@ -778,13 +719,68 @@ netdev_linux_enumerate(struct sset *sset) } } +static int +netdev_linux_listen(struct netdev *netdev_) +{ + struct netdev_linux *netdev = netdev_linux_cast(netdev_); + struct sockaddr_ll sll; + int ifindex; + int error; + int fd; + + if (netdev->fd >= 0) { + return 0; + } + + /* Create file descriptor. */ + fd = socket(PF_PACKET, SOCK_RAW, 0); + if (fd < 0) { + error = errno; + VLOG_ERR("failed to create raw socket (%s)", strerror(error)); + goto error; + } + + /* Set non-blocking mode. */ + error = set_nonblocking(fd); + if (error) { + goto error; + } + + /* Get ethernet device index. */ + error = get_ifindex(&netdev->netdev, &ifindex); + if (error) { + goto error; + } + + /* Bind to specific ethernet device. */ + memset(&sll, 0, sizeof sll); + sll.sll_family = AF_PACKET; + sll.sll_ifindex = ifindex; + sll.sll_protocol = (OVS_FORCE unsigned short int) htons(ETH_P_ALL); + if (bind(fd, (struct sockaddr *) &sll, sizeof sll) < 0) { + error = errno; + VLOG_ERR("%s: failed to bind raw socket (%s)", + netdev_get_name(netdev_), strerror(error)); + goto error; + } + + netdev->fd = fd; + return 0; + +error: + if (fd >= 0) { + close(fd); + } + return error; +} + static int netdev_linux_recv(struct netdev *netdev_, void *data, size_t size) { struct netdev_linux *netdev = netdev_linux_cast(netdev_); if (netdev->fd < 0) { - /* Device was opened with NETDEV_ETH_TYPE_NONE. */ + /* Device is not listening. */ return -EAGAIN; } @@ -1173,14 +1169,7 @@ netdev_linux_miimon_run(void) netdev_linux_get_miimon(dev->netdev_dev.name, &miimon); if (miimon != dev->miimon) { - struct list *list; - dev->miimon = miimon; - list = shash_find_data(&netdev_linux_notifiers, - dev->netdev_dev.name); - if (list) { - poll_notify(list); - } netdev_dev_linux_changed(dev); } @@ -2247,90 +2236,6 @@ netdev_linux_update_flags(struct netdev *netdev, enum netdev_flags off, return error; } -static void -poll_notify(struct list *list) -{ - struct netdev_linux_notifier *notifier; - LIST_FOR_EACH (notifier, node, list) { - struct netdev_notifier *n = ¬ifier->notifier; - n->cb(n); - } -} - -static void -netdev_linux_poll_cb(const struct rtnetlink_link_change *change, - void *aux OVS_UNUSED) -{ - if (change) { - struct list *list = shash_find_data(&netdev_linux_notifiers, - change->ifname); - if (list) { - poll_notify(list); - } - } else { - struct shash_node *node; - SHASH_FOR_EACH (node, &netdev_linux_notifiers) { - poll_notify(node->data); - } - } -} - -static int -netdev_linux_poll_add(struct netdev *netdev, - void (*cb)(struct netdev_notifier *), void *aux, - struct netdev_notifier **notifierp) -{ - const char *netdev_name = netdev_get_name(netdev); - struct netdev_linux_notifier *notifier; - struct list *list; - - if (shash_is_empty(&netdev_linux_notifiers)) { - int error; - error = rtnetlink_link_notifier_register(&netdev_linux_poll_notifier, - netdev_linux_poll_cb, NULL); - if (error) { - return error; - } - } - - list = shash_find_data(&netdev_linux_notifiers, netdev_name); - if (!list) { - list = xmalloc(sizeof *list); - list_init(list); - shash_add(&netdev_linux_notifiers, netdev_name, list); - } - - notifier = xmalloc(sizeof *notifier); - netdev_notifier_init(¬ifier->notifier, netdev, cb, aux); - list_push_back(list, ¬ifier->node); - *notifierp = ¬ifier->notifier; - return 0; -} - -static void -netdev_linux_poll_remove(struct netdev_notifier *notifier_) -{ - struct netdev_linux_notifier *notifier = - CONTAINER_OF(notifier_, struct netdev_linux_notifier, notifier); - struct list *list; - - /* Remove 'notifier' from its list. */ - list = list_remove(¬ifier->node); - if (list_is_empty(list)) { - /* The list is now empty. Remove it from the hash and free it. */ - const char *netdev_name = netdev_get_name(notifier->notifier.netdev); - shash_delete(&netdev_linux_notifiers, - shash_find(&netdev_linux_notifiers, netdev_name)); - free(list); - } - free(notifier); - - /* If that was the last notifier, unregister. */ - if (shash_is_empty(&netdev_linux_notifiers)) { - rtnetlink_link_notifier_unregister(&netdev_linux_poll_notifier); - } -} - static unsigned int netdev_linux_change_seq(const struct netdev *netdev) { @@ -2348,12 +2253,14 @@ netdev_linux_change_seq(const struct netdev *netdev) CREATE, \ netdev_linux_destroy, \ NULL, /* set_config */ \ + NULL, /* config_equal */ \ \ netdev_linux_open, \ netdev_linux_close, \ \ ENUMERATE, \ \ + netdev_linux_listen, \ netdev_linux_recv, \ netdev_linux_recv_wait, \ netdev_linux_drain, \ @@ -2396,8 +2303,6 @@ netdev_linux_change_seq(const struct netdev *netdev) \ netdev_linux_update_flags, \ \ - netdev_linux_poll_add, \ - netdev_linux_poll_remove, \ netdev_linux_change_seq \ } @@ -4254,8 +4159,12 @@ get_etheraddr(const char *netdev_name, uint8_t ea[ETH_ADDR_LEN]) ovs_strzcpy(ifr.ifr_name, netdev_name, sizeof ifr.ifr_name); COVERAGE_INC(netdev_get_hwaddr); if (ioctl(af_inet_sock, SIOCGIFHWADDR, &ifr) < 0) { - VLOG_ERR("ioctl(SIOCGIFHWADDR) on %s device failed: %s", - netdev_name, strerror(errno)); + /* ENODEV probably means that a vif disappeared asynchronously and + * hasn't been removed from the database yet, so reduce the log level + * to INFO for that case. */ + VLOG(errno == ENODEV ? VLL_INFO : VLL_ERR, + "ioctl(SIOCGIFHWADDR) on %s device failed: %s", + netdev_name, strerror(errno)); return errno; } hwaddr_family = ifr.ifr_hwaddr.sa_family;