linux/net/bridge/br_device.c
<<
>>
Prefs
   1/*
   2 *      Device handling code
   3 *      Linux ethernet bridge
   4 *
   5 *      Authors:
   6 *      Lennert Buytenhek               <buytenh@gnu.org>
   7 *
   8 *      This program is free software; you can redistribute it and/or
   9 *      modify it under the terms of the GNU General Public License
  10 *      as published by the Free Software Foundation; either version
  11 *      2 of the License, or (at your option) any later version.
  12 */
  13
  14#include <linux/kernel.h>
  15#include <linux/netdevice.h>
  16#include <linux/netpoll.h>
  17#include <linux/etherdevice.h>
  18#include <linux/ethtool.h>
  19#include <linux/list.h>
  20#include <linux/netfilter_bridge.h>
  21
  22#include <linux/uaccess.h>
  23#include "br_private.h"
  24
  25#define COMMON_FEATURES (NETIF_F_SG | NETIF_F_FRAGLIST | NETIF_F_HIGHDMA | \
  26                         NETIF_F_GSO_MASK | NETIF_F_HW_CSUM)
  27
  28const struct nf_br_ops __rcu *nf_br_ops __read_mostly;
  29EXPORT_SYMBOL_GPL(nf_br_ops);
  30
  31static struct lock_class_key bridge_netdev_addr_lock_key;
  32
  33/* net device transmit always called with BH disabled */
  34netdev_tx_t br_dev_xmit(struct sk_buff *skb, struct net_device *dev)
  35{
  36        struct net_bridge *br = netdev_priv(dev);
  37        struct net_bridge_fdb_entry *dst;
  38        struct net_bridge_mdb_entry *mdst;
  39        struct pcpu_sw_netstats *brstats = this_cpu_ptr(br->stats);
  40        const struct nf_br_ops *nf_ops;
  41        const unsigned char *dest;
  42        struct ethhdr *eth;
  43        u16 vid = 0;
  44
  45        rcu_read_lock();
  46        nf_ops = rcu_dereference(nf_br_ops);
  47        if (nf_ops && nf_ops->br_dev_xmit_hook(skb)) {
  48                rcu_read_unlock();
  49                return NETDEV_TX_OK;
  50        }
  51
  52        u64_stats_update_begin(&brstats->syncp);
  53        brstats->tx_packets++;
  54        brstats->tx_bytes += skb->len;
  55        u64_stats_update_end(&brstats->syncp);
  56
  57        br_switchdev_frame_unmark(skb);
  58        BR_INPUT_SKB_CB(skb)->brdev = dev;
  59
  60        skb_reset_mac_header(skb);
  61        eth = eth_hdr(skb);
  62        skb_pull(skb, ETH_HLEN);
  63
  64        if (!br_allowed_ingress(br, br_vlan_group_rcu(br), skb, &vid))
  65                goto out;
  66
  67        if (IS_ENABLED(CONFIG_INET) &&
  68            (eth->h_proto == htons(ETH_P_ARP) ||
  69             eth->h_proto == htons(ETH_P_RARP)) &&
  70            br_opt_get(br, BROPT_NEIGH_SUPPRESS_ENABLED)) {
  71                br_do_proxy_suppress_arp(skb, br, vid, NULL);
  72        } else if (IS_ENABLED(CONFIG_IPV6) &&
  73                   skb->protocol == htons(ETH_P_IPV6) &&
  74                   br_opt_get(br, BROPT_NEIGH_SUPPRESS_ENABLED) &&
  75                   pskb_may_pull(skb, sizeof(struct ipv6hdr) +
  76                                 sizeof(struct nd_msg)) &&
  77                   ipv6_hdr(skb)->nexthdr == IPPROTO_ICMPV6) {
  78                        struct nd_msg *msg, _msg;
  79
  80                        msg = br_is_nd_neigh_msg(skb, &_msg);
  81                        if (msg)
  82                                br_do_suppress_nd(skb, br, vid, NULL, msg);
  83        }
  84
  85        dest = eth_hdr(skb)->h_dest;
  86        if (is_broadcast_ether_addr(dest)) {
  87                br_flood(br, skb, BR_PKT_BROADCAST, false, true);
  88        } else if (is_multicast_ether_addr(dest)) {
  89                if (unlikely(netpoll_tx_running(dev))) {
  90                        br_flood(br, skb, BR_PKT_MULTICAST, false, true);
  91                        goto out;
  92                }
  93                if (br_multicast_rcv(br, NULL, skb, vid)) {
  94                        kfree_skb(skb);
  95                        goto out;
  96                }
  97
  98                mdst = br_mdb_get(br, skb, vid);
  99                if ((mdst || BR_INPUT_SKB_CB_MROUTERS_ONLY(skb)) &&
 100                    br_multicast_querier_exists(br, eth_hdr(skb)))
 101                        br_multicast_flood(mdst, skb, false, true);
 102                else
 103                        br_flood(br, skb, BR_PKT_MULTICAST, false, true);
 104        } else if ((dst = br_fdb_find_rcu(br, dest, vid)) != NULL) {
 105                br_forward(dst->dst, skb, false, true);
 106        } else {
 107                br_flood(br, skb, BR_PKT_UNICAST, false, true);
 108        }
 109out:
 110        rcu_read_unlock();
 111        return NETDEV_TX_OK;
 112}
 113
 114static void br_set_lockdep_class(struct net_device *dev)
 115{
 116        lockdep_set_class(&dev->addr_list_lock, &bridge_netdev_addr_lock_key);
 117}
 118
 119static int br_dev_init(struct net_device *dev)
 120{
 121        struct net_bridge *br = netdev_priv(dev);
 122        int err;
 123
 124        br->stats = netdev_alloc_pcpu_stats(struct pcpu_sw_netstats);
 125        if (!br->stats)
 126                return -ENOMEM;
 127
 128        err = br_fdb_hash_init(br);
 129        if (err) {
 130                free_percpu(br->stats);
 131                return err;
 132        }
 133
 134        err = br_vlan_init(br);
 135        if (err) {
 136                free_percpu(br->stats);
 137                br_fdb_hash_fini(br);
 138                return err;
 139        }
 140
 141        err = br_multicast_init_stats(br);
 142        if (err) {
 143                free_percpu(br->stats);
 144                br_vlan_flush(br);
 145                br_fdb_hash_fini(br);
 146        }
 147        br_set_lockdep_class(dev);
 148
 149        return err;
 150}
 151
 152static void br_dev_uninit(struct net_device *dev)
 153{
 154        struct net_bridge *br = netdev_priv(dev);
 155
 156        br_multicast_dev_del(br);
 157        br_multicast_uninit_stats(br);
 158        br_vlan_flush(br);
 159        br_fdb_hash_fini(br);
 160        free_percpu(br->stats);
 161}
 162
 163static int br_dev_open(struct net_device *dev)
 164{
 165        struct net_bridge *br = netdev_priv(dev);
 166
 167        netdev_update_features(dev);
 168        netif_start_queue(dev);
 169        br_stp_enable_bridge(br);
 170        br_multicast_open(br);
 171
 172        return 0;
 173}
 174
 175static void br_dev_set_multicast_list(struct net_device *dev)
 176{
 177}
 178
 179static void br_dev_change_rx_flags(struct net_device *dev, int change)
 180{
 181        if (change & IFF_PROMISC)
 182                br_manage_promisc(netdev_priv(dev));
 183}
 184
 185static int br_dev_stop(struct net_device *dev)
 186{
 187        struct net_bridge *br = netdev_priv(dev);
 188
 189        br_stp_disable_bridge(br);
 190        br_multicast_stop(br);
 191
 192        netif_stop_queue(dev);
 193
 194        return 0;
 195}
 196
 197static void br_get_stats64(struct net_device *dev,
 198                           struct rtnl_link_stats64 *stats)
 199{
 200        struct net_bridge *br = netdev_priv(dev);
 201        struct pcpu_sw_netstats tmp, sum = { 0 };
 202        unsigned int cpu;
 203
 204        for_each_possible_cpu(cpu) {
 205                unsigned int start;
 206                const struct pcpu_sw_netstats *bstats
 207                        = per_cpu_ptr(br->stats, cpu);
 208                do {
 209                        start = u64_stats_fetch_begin_irq(&bstats->syncp);
 210                        memcpy(&tmp, bstats, sizeof(tmp));
 211                } while (u64_stats_fetch_retry_irq(&bstats->syncp, start));
 212                sum.tx_bytes   += tmp.tx_bytes;
 213                sum.tx_packets += tmp.tx_packets;
 214                sum.rx_bytes   += tmp.rx_bytes;
 215                sum.rx_packets += tmp.rx_packets;
 216        }
 217
 218        stats->tx_bytes   = sum.tx_bytes;
 219        stats->tx_packets = sum.tx_packets;
 220        stats->rx_bytes   = sum.rx_bytes;
 221        stats->rx_packets = sum.rx_packets;
 222}
 223
 224static int br_change_mtu(struct net_device *dev, int new_mtu)
 225{
 226        struct net_bridge *br = netdev_priv(dev);
 227
 228        dev->mtu = new_mtu;
 229
 230        /* this flag will be cleared if the MTU was automatically adjusted */
 231        br_opt_toggle(br, BROPT_MTU_SET_BY_USER, true);
 232#if IS_ENABLED(CONFIG_BRIDGE_NETFILTER)
 233        /* remember the MTU in the rtable for PMTU */
 234        dst_metric_set(&br->fake_rtable.dst, RTAX_MTU, new_mtu);
 235#endif
 236
 237        return 0;
 238}
 239
 240/* Allow setting mac address to any valid ethernet address. */
 241static int br_set_mac_address(struct net_device *dev, void *p)
 242{
 243        struct net_bridge *br = netdev_priv(dev);
 244        struct sockaddr *addr = p;
 245
 246        if (!is_valid_ether_addr(addr->sa_data))
 247                return -EADDRNOTAVAIL;
 248
 249        spin_lock_bh(&br->lock);
 250        if (!ether_addr_equal(dev->dev_addr, addr->sa_data)) {
 251                /* Mac address will be changed in br_stp_change_bridge_id(). */
 252                br_stp_change_bridge_id(br, addr->sa_data);
 253        }
 254        spin_unlock_bh(&br->lock);
 255
 256        return 0;
 257}
 258
 259static void br_getinfo(struct net_device *dev, struct ethtool_drvinfo *info)
 260{
 261        strlcpy(info->driver, "bridge", sizeof(info->driver));
 262        strlcpy(info->version, BR_VERSION, sizeof(info->version));
 263        strlcpy(info->fw_version, "N/A", sizeof(info->fw_version));
 264        strlcpy(info->bus_info, "N/A", sizeof(info->bus_info));
 265}
 266
 267static netdev_features_t br_fix_features(struct net_device *dev,
 268        netdev_features_t features)
 269{
 270        struct net_bridge *br = netdev_priv(dev);
 271
 272        return br_features_recompute(br, features);
 273}
 274
 275#ifdef CONFIG_NET_POLL_CONTROLLER
 276static void br_poll_controller(struct net_device *br_dev)
 277{
 278}
 279
 280static void br_netpoll_cleanup(struct net_device *dev)
 281{
 282        struct net_bridge *br = netdev_priv(dev);
 283        struct net_bridge_port *p;
 284
 285        list_for_each_entry(p, &br->port_list, list)
 286                br_netpoll_disable(p);
 287}
 288
 289static int __br_netpoll_enable(struct net_bridge_port *p)
 290{
 291        struct netpoll *np;
 292        int err;
 293
 294        np = kzalloc(sizeof(*p->np), GFP_KERNEL);
 295        if (!np)
 296                return -ENOMEM;
 297
 298        err = __netpoll_setup(np, p->dev);
 299        if (err) {
 300                kfree(np);
 301                return err;
 302        }
 303
 304        p->np = np;
 305        return err;
 306}
 307
 308int br_netpoll_enable(struct net_bridge_port *p)
 309{
 310        if (!p->br->dev->npinfo)
 311                return 0;
 312
 313        return __br_netpoll_enable(p);
 314}
 315
 316static int br_netpoll_setup(struct net_device *dev, struct netpoll_info *ni)
 317{
 318        struct net_bridge *br = netdev_priv(dev);
 319        struct net_bridge_port *p;
 320        int err = 0;
 321
 322        list_for_each_entry(p, &br->port_list, list) {
 323                if (!p->dev)
 324                        continue;
 325                err = __br_netpoll_enable(p);
 326                if (err)
 327                        goto fail;
 328        }
 329
 330out:
 331        return err;
 332
 333fail:
 334        br_netpoll_cleanup(dev);
 335        goto out;
 336}
 337
 338void br_netpoll_disable(struct net_bridge_port *p)
 339{
 340        struct netpoll *np = p->np;
 341
 342        if (!np)
 343                return;
 344
 345        p->np = NULL;
 346
 347        __netpoll_free_async(np);
 348}
 349
 350#endif
 351
 352static int br_add_slave(struct net_device *dev, struct net_device *slave_dev,
 353                        struct netlink_ext_ack *extack)
 354
 355{
 356        struct net_bridge *br = netdev_priv(dev);
 357
 358        return br_add_if(br, slave_dev, extack);
 359}
 360
 361static int br_del_slave(struct net_device *dev, struct net_device *slave_dev)
 362{
 363        struct net_bridge *br = netdev_priv(dev);
 364
 365        return br_del_if(br, slave_dev);
 366}
 367
 368static const struct ethtool_ops br_ethtool_ops = {
 369        .get_drvinfo    = br_getinfo,
 370        .get_link       = ethtool_op_get_link,
 371};
 372
 373static const struct net_device_ops br_netdev_ops = {
 374        .ndo_open                = br_dev_open,
 375        .ndo_stop                = br_dev_stop,
 376        .ndo_init                = br_dev_init,
 377        .ndo_uninit              = br_dev_uninit,
 378        .ndo_start_xmit          = br_dev_xmit,
 379        .ndo_get_stats64         = br_get_stats64,
 380        .ndo_set_mac_address     = br_set_mac_address,
 381        .ndo_set_rx_mode         = br_dev_set_multicast_list,
 382        .ndo_change_rx_flags     = br_dev_change_rx_flags,
 383        .ndo_change_mtu          = br_change_mtu,
 384        .ndo_do_ioctl            = br_dev_ioctl,
 385#ifdef CONFIG_NET_POLL_CONTROLLER
 386        .ndo_netpoll_setup       = br_netpoll_setup,
 387        .ndo_netpoll_cleanup     = br_netpoll_cleanup,
 388        .ndo_poll_controller     = br_poll_controller,
 389#endif
 390        .ndo_add_slave           = br_add_slave,
 391        .ndo_del_slave           = br_del_slave,
 392        .ndo_fix_features        = br_fix_features,
 393        .ndo_fdb_add             = br_fdb_add,
 394        .ndo_fdb_del             = br_fdb_delete,
 395        .ndo_fdb_dump            = br_fdb_dump,
 396        .ndo_bridge_getlink      = br_getlink,
 397        .ndo_bridge_setlink      = br_setlink,
 398        .ndo_bridge_dellink      = br_dellink,
 399        .ndo_features_check      = passthru_features_check,
 400};
 401
 402static struct device_type br_type = {
 403        .name   = "bridge",
 404};
 405
 406void br_dev_setup(struct net_device *dev)
 407{
 408        struct net_bridge *br = netdev_priv(dev);
 409
 410        eth_hw_addr_random(dev);
 411        ether_setup(dev);
 412
 413        dev->netdev_ops = &br_netdev_ops;
 414        dev->needs_free_netdev = true;
 415        dev->ethtool_ops = &br_ethtool_ops;
 416        SET_NETDEV_DEVTYPE(dev, &br_type);
 417        dev->priv_flags = IFF_EBRIDGE | IFF_NO_QUEUE;
 418
 419        dev->features = COMMON_FEATURES | NETIF_F_LLTX | NETIF_F_NETNS_LOCAL |
 420                        NETIF_F_HW_VLAN_CTAG_TX | NETIF_F_HW_VLAN_STAG_TX;
 421        dev->hw_features = COMMON_FEATURES | NETIF_F_HW_VLAN_CTAG_TX |
 422                           NETIF_F_HW_VLAN_STAG_TX;
 423        dev->vlan_features = COMMON_FEATURES;
 424
 425        br->dev = dev;
 426        spin_lock_init(&br->lock);
 427        INIT_LIST_HEAD(&br->port_list);
 428        INIT_HLIST_HEAD(&br->fdb_list);
 429        spin_lock_init(&br->hash_lock);
 430
 431        br->bridge_id.prio[0] = 0x80;
 432        br->bridge_id.prio[1] = 0x00;
 433
 434        ether_addr_copy(br->group_addr, eth_stp_addr);
 435
 436        br->stp_enabled = BR_NO_STP;
 437        br->group_fwd_mask = BR_GROUPFWD_DEFAULT;
 438        br->group_fwd_mask_required = BR_GROUPFWD_DEFAULT;
 439
 440        br->designated_root = br->bridge_id;
 441        br->bridge_max_age = br->max_age = 20 * HZ;
 442        br->bridge_hello_time = br->hello_time = 2 * HZ;
 443        br->bridge_forward_delay = br->forward_delay = 15 * HZ;
 444        br->bridge_ageing_time = br->ageing_time = BR_DEFAULT_AGEING_TIME;
 445        dev->max_mtu = ETH_MAX_MTU;
 446
 447        br_netfilter_rtable_init(br);
 448        br_stp_timer_init(br);
 449        br_multicast_init(br);
 450        INIT_DELAYED_WORK(&br->gc_work, br_fdb_cleanup);
 451}
 452