X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=lib%2Fnetdev.c;h=804050fcdc978c87ab96f1e0918d4bd9cb8297d3;hb=49c36903d6d65bed96cba31f05534510a21a68d7;hp=d14b9099db7e89c933e93934be9867e03890b68d;hpb=56fd8edf80b6098289f9ddd94a6a4be3be648472;p=sliver-openvswitch.git diff --git a/lib/netdev.c b/lib/netdev.c index d14b9099d..804050fcd 100644 --- a/lib/netdev.c +++ b/lib/netdev.c @@ -186,7 +186,7 @@ netdev_destroy(const char *name) } shash_delete(&netdev_obj_shash, node); - netdev_obj->class->destroy(netdev_obj); + netdev_obj->netdev_class->destroy(netdev_obj); return 0; } @@ -208,8 +208,8 @@ netdev_reconfigure(const char *name, const struct shash *args) return ENODEV; } - if (netdev_obj->class->reconfigure) { - return netdev_obj->class->reconfigure(netdev_obj, args); + if (netdev_obj->netdev_class->reconfigure) { + return netdev_obj->netdev_class->reconfigure(netdev_obj, args); } return 0; @@ -235,7 +235,7 @@ netdev_open(const char *name, int ethertype, struct netdev **netdevp) netdev_obj = shash_find_data(&netdev_obj_shash, name); if (netdev_obj) { - error = netdev_obj->class->open(name, ethertype, &netdev); + error = netdev_obj->netdev_class->open(name, ethertype, &netdev); } else { /* Default to "system". */ error = EAFNOSUPPORT; @@ -298,7 +298,7 @@ netdev_close(struct netdev *netdev) } /* Free. */ - netdev->class->close(netdev); + netdev->netdev_class->close(netdev); free(name); } } @@ -372,8 +372,8 @@ netdev_recv(struct netdev *netdev, struct ofpbuf *buffer) assert(buffer->size == 0); assert(ofpbuf_tailroom(buffer) >= ETH_TOTAL_MIN); - retval = netdev->class->recv(netdev, - buffer->data, ofpbuf_tailroom(buffer)); + retval = netdev->netdev_class->recv(netdev, + buffer->data, ofpbuf_tailroom(buffer)); if (retval >= 0) { COVERAGE_INC(netdev_received); buffer->size += retval; @@ -391,14 +391,14 @@ netdev_recv(struct netdev *netdev, struct ofpbuf *buffer) void netdev_recv_wait(struct netdev *netdev) { - netdev->class->recv_wait(netdev); + netdev->netdev_class->recv_wait(netdev); } /* Discards all packets waiting to be received from 'netdev'. */ int netdev_drain(struct netdev *netdev) { - return netdev->class->drain(netdev); + return netdev->netdev_class->drain(netdev); } /* Sends 'buffer' on 'netdev'. Returns 0 if successful, otherwise a positive @@ -413,7 +413,7 @@ netdev_drain(struct netdev *netdev) int netdev_send(struct netdev *netdev, const struct ofpbuf *buffer) { - int error = netdev->class->send(netdev, buffer->data, buffer->size); + int error = netdev->netdev_class->send(netdev, buffer->data, buffer->size); if (!error) { COVERAGE_INC(netdev_sent); } @@ -430,7 +430,7 @@ netdev_send(struct netdev *netdev, const struct ofpbuf *buffer) void netdev_send_wait(struct netdev *netdev) { - return netdev->class->send_wait(netdev); + return netdev->netdev_class->send_wait(netdev); } /* Attempts to set 'netdev''s MAC address to 'mac'. Returns 0 if successful, @@ -438,7 +438,7 @@ netdev_send_wait(struct netdev *netdev) int netdev_set_etheraddr(struct netdev *netdev, const uint8_t mac[ETH_ADDR_LEN]) { - return netdev->class->set_etheraddr(netdev, mac); + return netdev->netdev_class->set_etheraddr(netdev, mac); } /* Retrieves 'netdev''s MAC address. If successful, returns 0 and copies the @@ -447,7 +447,7 @@ netdev_set_etheraddr(struct netdev *netdev, const uint8_t mac[ETH_ADDR_LEN]) int netdev_get_etheraddr(const struct netdev *netdev, uint8_t mac[ETH_ADDR_LEN]) { - return netdev->class->get_etheraddr(netdev, mac); + return netdev->netdev_class->get_etheraddr(netdev, mac); } /* Returns the name of the network device that 'netdev' represents, @@ -468,7 +468,7 @@ netdev_get_name(const struct netdev *netdev) int netdev_get_mtu(const struct netdev *netdev, int *mtup) { - int error = netdev->class->get_mtu(netdev, mtup); + int error = netdev->netdev_class->get_mtu(netdev, mtup); if (error) { VLOG_WARN_RL(&rl, "failed to retrieve MTU for network device %s: %s", netdev_get_name(netdev), strerror(error)); @@ -489,7 +489,7 @@ netdev_get_mtu(const struct netdev *netdev, int *mtup) int netdev_get_ifindex(const struct netdev *netdev) { - return netdev->class->get_ifindex(netdev); + return netdev->netdev_class->get_ifindex(netdev); } /* Stores the features supported by 'netdev' into each of '*current', @@ -518,8 +518,8 @@ netdev_get_features(struct netdev *netdev, peer = &dummy[3]; } - error = netdev->class->get_features(netdev, current, advertised, supported, - peer); + error = netdev->netdev_class->get_features(netdev, current, advertised, + supported, peer); if (error) { *current = *advertised = *supported = *peer = 0; } @@ -560,8 +560,8 @@ netdev_features_is_full_duplex(uint32_t features) int netdev_set_advertisements(struct netdev *netdev, uint32_t advertise) { - return (netdev->class->set_advertisements - ? netdev->class->set_advertisements(netdev, advertise) + return (netdev->netdev_class->set_advertisements + ? netdev->netdev_class->set_advertisements(netdev, advertise) : EOPNOTSUPP); } @@ -585,8 +585,8 @@ netdev_get_in4(const struct netdev *netdev, struct in_addr netmask; int error; - error = (netdev->class->get_in4 - ? netdev->class->get_in4(netdev, &address, &netmask) + error = (netdev->netdev_class->get_in4 + ? netdev->netdev_class->get_in4(netdev, &address, &netmask) : EOPNOTSUPP); if (address_) { address_->s_addr = error ? 0 : address.s_addr; @@ -603,8 +603,8 @@ netdev_get_in4(const struct netdev *netdev, int netdev_set_in4(struct netdev *netdev, struct in_addr addr, struct in_addr mask) { - return (netdev->class->set_in4 - ? netdev->class->set_in4(netdev, addr, mask) + return (netdev->netdev_class->set_in4 + ? netdev->netdev_class->set_in4(netdev, addr, mask) : EOPNOTSUPP); } @@ -614,8 +614,8 @@ int netdev_add_router(struct netdev *netdev, struct in_addr router) { COVERAGE_INC(netdev_add_router); - return (netdev->class->add_router - ? netdev->class->add_router(netdev, router) + return (netdev->netdev_class->add_router + ? netdev->netdev_class->add_router(netdev, router) : EOPNOTSUPP); } @@ -631,8 +631,9 @@ netdev_get_next_hop(const struct netdev *netdev, const struct in_addr *host, struct in_addr *next_hop, char **netdev_name) { - int error = (netdev->class->get_next_hop - ? netdev->class->get_next_hop(host, next_hop, netdev_name) + int error = (netdev->netdev_class->get_next_hop + ? netdev->netdev_class->get_next_hop(host, next_hop, + netdev_name) : EOPNOTSUPP); if (error) { next_hop->s_addr = 0; @@ -658,8 +659,8 @@ netdev_get_in6(const struct netdev *netdev, struct in6_addr *in6) struct in6_addr dummy; int error; - error = (netdev->class->get_in6 - ? netdev->class->get_in6(netdev, in6 ? in6 : &dummy) + error = (netdev->netdev_class->get_in6 + ? netdev->netdev_class->get_in6(netdev, in6 ? in6 : &dummy) : EOPNOTSUPP); if (error && in6) { memset(in6, 0, sizeof *in6); @@ -679,7 +680,8 @@ do_update_flags(struct netdev *netdev, enum netdev_flags off, enum netdev_flags old_flags; int error; - error = netdev->class->update_flags(netdev, off & ~on, on, &old_flags); + error = netdev->netdev_class->update_flags(netdev, off & ~on, + on, &old_flags); if (error) { VLOG_WARN_RL(&rl, "failed to %s flags for network device %s: %s", off || on ? "set" : "get", netdev_get_name(netdev), @@ -752,8 +754,8 @@ int netdev_arp_lookup(const struct netdev *netdev, uint32_t ip, uint8_t mac[ETH_ADDR_LEN]) { - int error = (netdev->class->arp_lookup - ? netdev->class->arp_lookup(netdev, ip, mac) + int error = (netdev->netdev_class->arp_lookup + ? netdev->netdev_class->arp_lookup(netdev, ip, mac) : EOPNOTSUPP); if (error) { memset(mac, 0, ETH_ADDR_LEN); @@ -766,8 +768,8 @@ netdev_arp_lookup(const struct netdev *netdev, int netdev_get_carrier(const struct netdev *netdev, bool *carrier) { - int error = (netdev->class->get_carrier - ? netdev->class->get_carrier(netdev, carrier) + int error = (netdev->netdev_class->get_carrier + ? netdev->netdev_class->get_carrier(netdev, carrier) : EOPNOTSUPP); if (error) { *carrier = false; @@ -782,8 +784,8 @@ netdev_get_stats(const struct netdev *netdev, struct netdev_stats *stats) int error; COVERAGE_INC(netdev_get_stats); - error = (netdev->class->get_stats - ? netdev->class->get_stats(netdev, stats) + error = (netdev->netdev_class->get_stats + ? netdev->netdev_class->get_stats(netdev, stats) : EOPNOTSUPP); if (error) { memset(stats, 0xff, sizeof *stats); @@ -798,8 +800,9 @@ int netdev_set_policing(struct netdev *netdev, uint32_t kbits_rate, uint32_t kbits_burst) { - return (netdev->class->set_policing - ? netdev->class->set_policing(netdev, kbits_rate, kbits_burst) + return (netdev->netdev_class->set_policing + ? netdev->netdev_class->set_policing(netdev, + kbits_rate, kbits_burst) : EOPNOTSUPP); } @@ -811,8 +814,8 @@ netdev_set_policing(struct netdev *netdev, uint32_t kbits_rate, int netdev_get_vlan_vid(const struct netdev *netdev, int *vlan_vid) { - int error = (netdev->class->get_vlan_vid - ? netdev->class->get_vlan_vid(netdev, vlan_vid) + int error = (netdev->netdev_class->get_vlan_vid + ? netdev->netdev_class->get_vlan_vid(netdev, vlan_vid) : ENOENT); if (error) { *vlan_vid = 0; @@ -849,32 +852,33 @@ exit: } /* Initializes 'netdev_obj' as a netdev object named 'name' of the - * specified 'class'. + * specified 'netdev_class'. * * This function adds 'netdev_obj' to a netdev-owned shash, so it is * very important that 'netdev_obj' only be freed after calling * netdev_destroy(). */ void netdev_obj_init(struct netdev_obj *netdev_obj, const char *name, - const struct netdev_class *class, bool created) + const struct netdev_class *netdev_class, bool created) { assert(!shash_find(&netdev_obj_shash, name)); - netdev_obj->class = class; + netdev_obj->netdev_class = netdev_class; netdev_obj->ref_cnt = 0; netdev_obj->created = created; shash_add(&netdev_obj_shash, name, netdev_obj); } -/* Initializes 'netdev' as a netdev named 'name' of the specified 'class'. +/* Initializes 'netdev' as a netdev named 'name' of the specified + * 'netdev_class'. * * This function adds 'netdev' to a netdev-owned linked list, so it is very * important that 'netdev' only be freed after calling netdev_close(). */ void netdev_init(struct netdev *netdev, const char *name, - const struct netdev_class *class) + const struct netdev_class *netdev_class) { - netdev->class = class; + netdev->netdev_class = netdev_class; netdev->name = xstrdup(name); netdev->save_flags = 0; netdev->changed_flags = 0; @@ -886,7 +890,7 @@ netdev_init(struct netdev *netdev, const char *name, * The caller must not free the returned value. */ const char *netdev_get_type(const struct netdev *netdev) { - return netdev->class->type; + return netdev->netdev_class->type; } /* Initializes 'notifier' as a netdev notifier for 'netdev', for which @@ -926,7 +930,7 @@ netdev_monitor_destroy(struct netdev_monitor *monitor) SHASH_FOR_EACH (node, &monitor->polled_netdevs) { struct netdev_notifier *notifier = node->data; - notifier->netdev->class->poll_remove(notifier); + notifier->netdev->netdev_class->poll_remove(notifier); } shash_destroy(&monitor->polled_netdevs); @@ -956,11 +960,11 @@ netdev_monitor_add(struct netdev_monitor *monitor, struct netdev *netdev) const char *netdev_name = netdev_get_name(netdev); int error = 0; if (!shash_find(&monitor->polled_netdevs, netdev_name) - && netdev->class->poll_add) + && netdev->netdev_class->poll_add) { struct netdev_notifier *notifier; - error = netdev->class->poll_add(netdev, netdev_monitor_cb, monitor, - ¬ifier); + error = netdev->netdev_class->poll_add(netdev, netdev_monitor_cb, + monitor, ¬ifier); if (!error) { assert(notifier->netdev == netdev); shash_add(&monitor->polled_netdevs, netdev_name, notifier); @@ -982,7 +986,7 @@ netdev_monitor_remove(struct netdev_monitor *monitor, struct netdev *netdev) if (node) { /* Cancel future notifications. */ struct netdev_notifier *notifier = node->data; - netdev->class->poll_remove(notifier); + netdev->netdev_class->poll_remove(notifier); shash_delete(&monitor->polled_netdevs, node); /* Drop any pending notification. */ @@ -1040,9 +1044,10 @@ restore_flags(struct netdev *netdev) if (netdev->changed_flags) { enum netdev_flags restore = netdev->save_flags & netdev->changed_flags; enum netdev_flags old_flags; - return netdev->class->update_flags(netdev, - netdev->changed_flags & ~restore, - restore, &old_flags); + return netdev->netdev_class->update_flags(netdev, + netdev->changed_flags + & ~restore, + restore, &old_flags); } return 0; }