| Author | Tokens | Token Proportion | Commits | Commit Proportion |
|---|---|---|---|---|
| Vladimir Oltean | 2366 | 35.11% | 80 | 35.40% |
| Vivien Didelot | 1946 | 28.88% | 64 | 28.32% |
| Andrew Lunn | 823 | 12.21% | 11 | 4.87% |
| Florian Fainelli | 544 | 8.07% | 28 | 12.39% |
| Tobias Waldekranz | 434 | 6.44% | 3 | 1.33% |
| Lennert Buytenhek | 204 | 3.03% | 3 | 1.33% |
| Jiri Pirko | 99 | 1.47% | 4 | 1.77% |
| Ioana Ciornei | 55 | 0.82% | 1 | 0.44% |
| Arkadi Sharshevsky | 52 | 0.77% | 2 | 0.88% |
| Ben Hutchings | 36 | 0.53% | 3 | 1.33% |
| Wen Yang | 28 | 0.42% | 1 | 0.44% |
| Christophe Jaillet | 19 | 0.28% | 1 | 0.44% |
| Kurt Kanzenbach | 17 | 0.25% | 1 | 0.44% |
| Colin Ian King | 16 | 0.24% | 1 | 0.44% |
| Yue haibing | 13 | 0.19% | 1 | 0.44% |
| Leon Romanovsky | 13 | 0.19% | 2 | 0.88% |
| Brandon Streiff | 12 | 0.18% | 2 | 0.88% |
| Rafał Miłecki | 10 | 0.15% | 1 | 0.44% |
| Maxim Kochetkov | 8 | 0.12% | 1 | 0.44% |
| Stephen Hemminger | 7 | 0.10% | 1 | 0.44% |
| George McCollister | 6 | 0.09% | 1 | 0.44% |
| Miaoqian Lin | 5 | 0.07% | 1 | 0.44% |
| Guenter Roeck | 5 | 0.07% | 1 | 0.44% |
| Jonathan McDowell | 4 | 0.06% | 1 | 0.44% |
| Paul Gortmaker | 3 | 0.04% | 1 | 0.44% |
| David S. Miller | 2 | 0.03% | 1 | 0.44% |
| Thierry Reding | 2 | 0.03% | 1 | 0.44% |
| Felix Fietkau | 2 | 0.03% | 1 | 0.44% |
| Linus Torvalds (pre-git) | 1 | 0.01% | 1 | 0.44% |
| Thomas Gleixner | 1 | 0.01% | 1 | 0.44% |
| Ben Dooks | 1 | 0.01% | 1 | 0.44% |
| Alvin Šipraga | 1 | 0.01% | 1 | 0.44% |
| Rusty Russell | 1 | 0.01% | 1 | 0.44% |
| Arınç ÜNAL | 1 | 0.01% | 1 | 0.44% |
| Wei Yongjun | 1 | 0.01% | 1 | 0.44% |
| Total | 6738 | 226 |
// SPDX-License-Identifier: GPL-2.0-or-later /* * DSA topology and switch handling * * Copyright (c) 2008-2009 Marvell Semiconductor * Copyright (c) 2013 Florian Fainelli <florian@openwrt.org> * Copyright (c) 2016 Andrew Lunn <andrew@lunn.ch> */ #include <linux/device.h> #include <linux/err.h> #include <linux/list.h> #include <linux/module.h> #include <linux/netdevice.h> #include <linux/slab.h> #include <linux/rtnetlink.h> #include <linux/of.h> #include <linux/of_net.h> #include <net/dsa_stubs.h> #include <net/sch_generic.h> #include "conduit.h" #include "devlink.h" #include "dsa.h" #include "netlink.h" #include "port.h" #include "switch.h" #include "tag.h" #include "user.h" #define DSA_MAX_NUM_OFFLOADING_BRIDGES BITS_PER_LONG static DEFINE_MUTEX(dsa2_mutex); LIST_HEAD(dsa_tree_list); static struct workqueue_struct *dsa_owq; /* Track the bridges with forwarding offload enabled */ static unsigned long dsa_fwd_offloading_bridges; bool dsa_schedule_work(struct work_struct *work) { return queue_work(dsa_owq, work); } void dsa_flush_workqueue(void) { flush_workqueue(dsa_owq); } EXPORT_SYMBOL_GPL(dsa_flush_workqueue); /** * dsa_lag_map() - Map LAG structure to a linear LAG array * @dst: Tree in which to record the mapping. * @lag: LAG structure that is to be mapped to the tree's array. * * dsa_lag_id/dsa_lag_by_id can then be used to translate between the * two spaces. The size of the mapping space is determined by the * driver by setting ds->num_lag_ids. It is perfectly legal to leave * it unset if it is not needed, in which case these functions become * no-ops. */ void dsa_lag_map(struct dsa_switch_tree *dst, struct dsa_lag *lag) { unsigned int id; for (id = 1; id <= dst->lags_len; id++) { if (!dsa_lag_by_id(dst, id)) { dst->lags[id - 1] = lag; lag->id = id; return; } } /* No IDs left, which is OK. Some drivers do not need it. The * ones that do, e.g. mv88e6xxx, will discover that dsa_lag_id * returns an error for this device when joining the LAG. The * driver can then return -EOPNOTSUPP back to DSA, which will * fall back to a software LAG. */ } /** * dsa_lag_unmap() - Remove a LAG ID mapping * @dst: Tree in which the mapping is recorded. * @lag: LAG structure that was mapped. * * As there may be multiple users of the mapping, it is only removed * if there are no other references to it. */ void dsa_lag_unmap(struct dsa_switch_tree *dst, struct dsa_lag *lag) { unsigned int id; dsa_lags_foreach_id(id, dst) { if (dsa_lag_by_id(dst, id) == lag) { dst->lags[id - 1] = NULL; lag->id = 0; break; } } } struct dsa_lag *dsa_tree_lag_find(struct dsa_switch_tree *dst, const struct net_device *lag_dev) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) if (dsa_port_lag_dev_get(dp) == lag_dev) return dp->lag; return NULL; } struct dsa_bridge *dsa_tree_bridge_find(struct dsa_switch_tree *dst, const struct net_device *br) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) if (dsa_port_bridge_dev_get(dp) == br) return dp->bridge; return NULL; } static int dsa_bridge_num_find(const struct net_device *bridge_dev) { struct dsa_switch_tree *dst; list_for_each_entry(dst, &dsa_tree_list, list) { struct dsa_bridge *bridge; bridge = dsa_tree_bridge_find(dst, bridge_dev); if (bridge) return bridge->num; } return 0; } unsigned int dsa_bridge_num_get(const struct net_device *bridge_dev, int max) { unsigned int bridge_num = dsa_bridge_num_find(bridge_dev); /* Switches without FDB isolation support don't get unique * bridge numbering */ if (!max) return 0; if (!bridge_num) { /* First port that requests FDB isolation or TX forwarding * offload for this bridge */ bridge_num = find_next_zero_bit(&dsa_fwd_offloading_bridges, DSA_MAX_NUM_OFFLOADING_BRIDGES, 1); if (bridge_num >= max) return 0; set_bit(bridge_num, &dsa_fwd_offloading_bridges); } return bridge_num; } void dsa_bridge_num_put(const struct net_device *bridge_dev, unsigned int bridge_num) { /* Since we refcount bridges, we know that when we call this function * it is no longer in use, so we can just go ahead and remove it from * the bit mask. */ clear_bit(bridge_num, &dsa_fwd_offloading_bridges); } struct dsa_switch *dsa_switch_find(int tree_index, int sw_index) { struct dsa_switch_tree *dst; struct dsa_port *dp; list_for_each_entry(dst, &dsa_tree_list, list) { if (dst->index != tree_index) continue; list_for_each_entry(dp, &dst->ports, list) { if (dp->ds->index != sw_index) continue; return dp->ds; } } return NULL; } EXPORT_SYMBOL_GPL(dsa_switch_find); static struct dsa_switch_tree *dsa_tree_find(int index) { struct dsa_switch_tree *dst; list_for_each_entry(dst, &dsa_tree_list, list) if (dst->index == index) return dst; return NULL; } static struct dsa_switch_tree *dsa_tree_alloc(int index) { struct dsa_switch_tree *dst; dst = kzalloc(sizeof(*dst), GFP_KERNEL); if (!dst) return NULL; dst->index = index; INIT_LIST_HEAD(&dst->rtable); INIT_LIST_HEAD(&dst->ports); INIT_LIST_HEAD(&dst->list); list_add_tail(&dst->list, &dsa_tree_list); kref_init(&dst->refcount); return dst; } static void dsa_tree_free(struct dsa_switch_tree *dst) { if (dst->tag_ops) dsa_tag_driver_put(dst->tag_ops); list_del(&dst->list); kfree(dst); } static struct dsa_switch_tree *dsa_tree_get(struct dsa_switch_tree *dst) { if (dst) kref_get(&dst->refcount); return dst; } static struct dsa_switch_tree *dsa_tree_touch(int index) { struct dsa_switch_tree *dst; dst = dsa_tree_find(index); if (dst) return dsa_tree_get(dst); else return dsa_tree_alloc(index); } static void dsa_tree_release(struct kref *ref) { struct dsa_switch_tree *dst; dst = container_of(ref, struct dsa_switch_tree, refcount); dsa_tree_free(dst); } static void dsa_tree_put(struct dsa_switch_tree *dst) { if (dst) kref_put(&dst->refcount, dsa_tree_release); } static struct dsa_port *dsa_tree_find_port_by_node(struct dsa_switch_tree *dst, struct device_node *dn) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) if (dp->dn == dn) return dp; return NULL; } static struct dsa_link *dsa_link_touch(struct dsa_port *dp, struct dsa_port *link_dp) { struct dsa_switch *ds = dp->ds; struct dsa_switch_tree *dst; struct dsa_link *dl; dst = ds->dst; list_for_each_entry(dl, &dst->rtable, list) if (dl->dp == dp && dl->link_dp == link_dp) return dl; dl = kzalloc(sizeof(*dl), GFP_KERNEL); if (!dl) return NULL; dl->dp = dp; dl->link_dp = link_dp; INIT_LIST_HEAD(&dl->list); list_add_tail(&dl->list, &dst->rtable); return dl; } static bool dsa_port_setup_routing_table(struct dsa_port *dp) { struct dsa_switch *ds = dp->ds; struct dsa_switch_tree *dst = ds->dst; struct device_node *dn = dp->dn; struct of_phandle_iterator it; struct dsa_port *link_dp; struct dsa_link *dl; int err; of_for_each_phandle(&it, err, dn, "link", NULL, 0) { link_dp = dsa_tree_find_port_by_node(dst, it.node); if (!link_dp) { of_node_put(it.node); return false; } dl = dsa_link_touch(dp, link_dp); if (!dl) { of_node_put(it.node); return false; } } return true; } static bool dsa_tree_setup_routing_table(struct dsa_switch_tree *dst) { bool complete = true; struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) { if (dsa_port_is_dsa(dp)) { complete = dsa_port_setup_routing_table(dp); if (!complete) break; } } return complete; } static struct dsa_port *dsa_tree_find_first_cpu(struct dsa_switch_tree *dst) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) if (dsa_port_is_cpu(dp)) return dp; return NULL; } struct net_device *dsa_tree_find_first_conduit(struct dsa_switch_tree *dst) { struct device_node *ethernet; struct net_device *conduit; struct dsa_port *cpu_dp; cpu_dp = dsa_tree_find_first_cpu(dst); ethernet = of_parse_phandle(cpu_dp->dn, "ethernet", 0); conduit = of_find_net_device_by_node(ethernet); of_node_put(ethernet); return conduit; } /* Assign the default CPU port (the first one in the tree) to all ports of the * fabric which don't already have one as part of their own switch. */ static int dsa_tree_setup_default_cpu(struct dsa_switch_tree *dst) { struct dsa_port *cpu_dp, *dp; cpu_dp = dsa_tree_find_first_cpu(dst); if (!cpu_dp) { pr_err("DSA: tree %d has no CPU port\n", dst->index); return -EINVAL; } list_for_each_entry(dp, &dst->ports, list) { if (dp->cpu_dp) continue; if (dsa_port_is_user(dp) || dsa_port_is_dsa(dp)) dp->cpu_dp = cpu_dp; } return 0; } static struct dsa_port * dsa_switch_preferred_default_local_cpu_port(struct dsa_switch *ds) { struct dsa_port *cpu_dp; if (!ds->ops->preferred_default_local_cpu_port) return NULL; cpu_dp = ds->ops->preferred_default_local_cpu_port(ds); if (!cpu_dp) return NULL; if (WARN_ON(!dsa_port_is_cpu(cpu_dp) || cpu_dp->ds != ds)) return NULL; return cpu_dp; } /* Perform initial assignment of CPU ports to user ports and DSA links in the * fabric, giving preference to CPU ports local to each switch. Default to * using the first CPU port in the switch tree if the port does not have a CPU * port local to this switch. */ static int dsa_tree_setup_cpu_ports(struct dsa_switch_tree *dst) { struct dsa_port *preferred_cpu_dp, *cpu_dp, *dp; list_for_each_entry(cpu_dp, &dst->ports, list) { if (!dsa_port_is_cpu(cpu_dp)) continue; preferred_cpu_dp = dsa_switch_preferred_default_local_cpu_port(cpu_dp->ds); if (preferred_cpu_dp && preferred_cpu_dp != cpu_dp) continue; /* Prefer a local CPU port */ dsa_switch_for_each_port(dp, cpu_dp->ds) { /* Prefer the first local CPU port found */ if (dp->cpu_dp) continue; if (dsa_port_is_user(dp) || dsa_port_is_dsa(dp)) dp->cpu_dp = cpu_dp; } } return dsa_tree_setup_default_cpu(dst); } static void dsa_tree_teardown_cpu_ports(struct dsa_switch_tree *dst) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) if (dsa_port_is_user(dp) || dsa_port_is_dsa(dp)) dp->cpu_dp = NULL; } static int dsa_port_setup(struct dsa_port *dp) { bool dsa_port_link_registered = false; struct dsa_switch *ds = dp->ds; bool dsa_port_enabled = false; int err = 0; if (dp->setup) return 0; err = dsa_port_devlink_setup(dp); if (err) return err; switch (dp->type) { case DSA_PORT_TYPE_UNUSED: dsa_port_disable(dp); break; case DSA_PORT_TYPE_CPU: if (dp->dn) { err = dsa_shared_port_link_register_of(dp); if (err) break; dsa_port_link_registered = true; } else { dev_warn(ds->dev, "skipping link registration for CPU port %d\n", dp->index); } err = dsa_port_enable(dp, NULL); if (err) break; dsa_port_enabled = true; break; case DSA_PORT_TYPE_DSA: if (dp->dn) { err = dsa_shared_port_link_register_of(dp); if (err) break; dsa_port_link_registered = true; } else { dev_warn(ds->dev, "skipping link registration for DSA port %d\n", dp->index); } err = dsa_port_enable(dp, NULL); if (err) break; dsa_port_enabled = true; break; case DSA_PORT_TYPE_USER: of_get_mac_address(dp->dn, dp->mac); err = dsa_user_create(dp); break; } if (err && dsa_port_enabled) dsa_port_disable(dp); if (err && dsa_port_link_registered) dsa_shared_port_link_unregister_of(dp); if (err) { dsa_port_devlink_teardown(dp); return err; } dp->setup = true; return 0; } static void dsa_port_teardown(struct dsa_port *dp) { if (!dp->setup) return; switch (dp->type) { case DSA_PORT_TYPE_UNUSED: break; case DSA_PORT_TYPE_CPU: dsa_port_disable(dp); if (dp->dn) dsa_shared_port_link_unregister_of(dp); break; case DSA_PORT_TYPE_DSA: dsa_port_disable(dp); if (dp->dn) dsa_shared_port_link_unregister_of(dp); break; case DSA_PORT_TYPE_USER: if (dp->user) { dsa_user_destroy(dp->user); dp->user = NULL; } break; } dsa_port_devlink_teardown(dp); dp->setup = false; } static int dsa_port_setup_as_unused(struct dsa_port *dp) { dp->type = DSA_PORT_TYPE_UNUSED; return dsa_port_setup(dp); } static int dsa_switch_setup_tag_protocol(struct dsa_switch *ds) { const struct dsa_device_ops *tag_ops = ds->dst->tag_ops; struct dsa_switch_tree *dst = ds->dst; int err; if (tag_ops->proto == dst->default_proto) goto connect; rtnl_lock(); err = ds->ops->change_tag_protocol(ds, tag_ops->proto); rtnl_unlock(); if (err) { dev_err(ds->dev, "Unable to use tag protocol \"%s\": %pe\n", tag_ops->name, ERR_PTR(err)); return err; } connect: if (tag_ops->connect) { err = tag_ops->connect(ds); if (err) return err; } if (ds->ops->connect_tag_protocol) { err = ds->ops->connect_tag_protocol(ds, tag_ops->proto); if (err) { dev_err(ds->dev, "Unable to connect to tag protocol \"%s\": %pe\n", tag_ops->name, ERR_PTR(err)); goto disconnect; } } return 0; disconnect: if (tag_ops->disconnect) tag_ops->disconnect(ds); return err; } static void dsa_switch_teardown_tag_protocol(struct dsa_switch *ds) { const struct dsa_device_ops *tag_ops = ds->dst->tag_ops; if (tag_ops->disconnect) tag_ops->disconnect(ds); } static int dsa_switch_setup(struct dsa_switch *ds) { int err; if (ds->setup) return 0; /* Initialize ds->phys_mii_mask before registering the user MDIO bus * driver and before ops->setup() has run, since the switch drivers and * the user MDIO bus driver rely on these values for probing PHY * devices or not */ ds->phys_mii_mask |= dsa_user_ports(ds); err = dsa_switch_devlink_alloc(ds); if (err) return err; err = dsa_switch_register_notifier(ds); if (err) goto devlink_free; ds->configure_vlan_while_not_filtering = true; err = ds->ops->setup(ds); if (err < 0) goto unregister_notifier; err = dsa_switch_setup_tag_protocol(ds); if (err) goto teardown; if (!ds->user_mii_bus && ds->ops->phy_read) { ds->user_mii_bus = mdiobus_alloc(); if (!ds->user_mii_bus) { err = -ENOMEM; goto teardown; } dsa_user_mii_bus_init(ds); err = mdiobus_register(ds->user_mii_bus); if (err < 0) goto free_user_mii_bus; } dsa_switch_devlink_register(ds); ds->setup = true; return 0; free_user_mii_bus: if (ds->user_mii_bus && ds->ops->phy_read) mdiobus_free(ds->user_mii_bus); teardown: if (ds->ops->teardown) ds->ops->teardown(ds); unregister_notifier: dsa_switch_unregister_notifier(ds); devlink_free: dsa_switch_devlink_free(ds); return err; } static void dsa_switch_teardown(struct dsa_switch *ds) { if (!ds->setup) return; dsa_switch_devlink_unregister(ds); if (ds->user_mii_bus && ds->ops->phy_read) { mdiobus_unregister(ds->user_mii_bus); mdiobus_free(ds->user_mii_bus); ds->user_mii_bus = NULL; } dsa_switch_teardown_tag_protocol(ds); if (ds->ops->teardown) ds->ops->teardown(ds); dsa_switch_unregister_notifier(ds); dsa_switch_devlink_free(ds); ds->setup = false; } /* First tear down the non-shared, then the shared ports. This ensures that * all work items scheduled by our switchdev handlers for user ports have * completed before we destroy the refcounting kept on the shared ports. */ static void dsa_tree_teardown_ports(struct dsa_switch_tree *dst) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) if (dsa_port_is_user(dp) || dsa_port_is_unused(dp)) dsa_port_teardown(dp); dsa_flush_workqueue(); list_for_each_entry(dp, &dst->ports, list) if (dsa_port_is_dsa(dp) || dsa_port_is_cpu(dp)) dsa_port_teardown(dp); } static void dsa_tree_teardown_switches(struct dsa_switch_tree *dst) { struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) dsa_switch_teardown(dp->ds); } /* Bring shared ports up first, then non-shared ports */ static int dsa_tree_setup_ports(struct dsa_switch_tree *dst) { struct dsa_port *dp; int err = 0; list_for_each_entry(dp, &dst->ports, list) { if (dsa_port_is_dsa(dp) || dsa_port_is_cpu(dp)) { err = dsa_port_setup(dp); if (err) goto teardown; } } list_for_each_entry(dp, &dst->ports, list) { if (dsa_port_is_user(dp) || dsa_port_is_unused(dp)) { err = dsa_port_setup(dp); if (err) { err = dsa_port_setup_as_unused(dp); if (err) goto teardown; } } } return 0; teardown: dsa_tree_teardown_ports(dst); return err; } static int dsa_tree_setup_switches(struct dsa_switch_tree *dst) { struct dsa_port *dp; int err = 0; list_for_each_entry(dp, &dst->ports, list) { err = dsa_switch_setup(dp->ds); if (err) { dsa_tree_teardown_switches(dst); break; } } return err; } static int dsa_tree_setup_conduit(struct dsa_switch_tree *dst) { struct dsa_port *cpu_dp; int err = 0; rtnl_lock(); dsa_tree_for_each_cpu_port(cpu_dp, dst) { struct net_device *conduit = cpu_dp->conduit; bool admin_up = (conduit->flags & IFF_UP) && !qdisc_tx_is_noop(conduit); err = dsa_conduit_setup(conduit, cpu_dp); if (err) break; /* Replay conduit state event */ dsa_tree_conduit_admin_state_change(dst, conduit, admin_up); dsa_tree_conduit_oper_state_change(dst, conduit, netif_oper_up(conduit)); } rtnl_unlock(); return err; } static void dsa_tree_teardown_conduit(struct dsa_switch_tree *dst) { struct dsa_port *cpu_dp; rtnl_lock(); dsa_tree_for_each_cpu_port(cpu_dp, dst) { struct net_device *conduit = cpu_dp->conduit; /* Synthesizing an "admin down" state is sufficient for * the switches to get a notification if the conduit is * currently up and running. */ dsa_tree_conduit_admin_state_change(dst, conduit, false); dsa_conduit_teardown(conduit); } rtnl_unlock(); } static int dsa_tree_setup_lags(struct dsa_switch_tree *dst) { unsigned int len = 0; struct dsa_port *dp; list_for_each_entry(dp, &dst->ports, list) { if (dp->ds->num_lag_ids > len) len = dp->ds->num_lag_ids; } if (!len) return 0; dst->lags = kcalloc(len, sizeof(*dst->lags), GFP_KERNEL); if (!dst->lags) return -ENOMEM; dst->lags_len = len; return 0; } static void dsa_tree_teardown_lags(struct dsa_switch_tree *dst) { kfree(dst->lags); } static int dsa_tree_setup(struct dsa_switch_tree *dst) { bool complete; int err; if (dst->setup) { pr_err("DSA: tree %d already setup! Disjoint trees?\n", dst->index); return -EEXIST; } complete = dsa_tree_setup_routing_table(dst); if (!complete) return 0; err = dsa_tree_setup_cpu_ports(dst); if (err) return err; err = dsa_tree_setup_switches(dst); if (err) goto teardown_cpu_ports; err = dsa_tree_setup_ports(dst); if (err) goto teardown_switches; err = dsa_tree_setup_conduit(dst); if (err) goto teardown_ports; err = dsa_tree_setup_lags(dst); if (err) goto teardown_conduit; dst->setup = true; pr_info("DSA: tree %d setup\n", dst->index); return 0; teardown_conduit: dsa_tree_teardown_conduit(dst); teardown_ports: dsa_tree_teardown_ports(dst); teardown_switches: dsa_tree_teardown_switches(dst); teardown_cpu_ports: dsa_tree_teardown_cpu_ports(dst); return err; } static void dsa_tree_teardown(struct dsa_switch_tree *dst) { struct dsa_link *dl, *next; if (!dst->setup) return; dsa_tree_teardown_lags(dst); dsa_tree_teardown_conduit(dst); dsa_tree_teardown_ports(dst); dsa_tree_teardown_switches(dst); dsa_tree_teardown_cpu_ports(dst); list_for_each_entry_safe(dl, next, &dst->rtable, list) { list_del(&dl->list); kfree(dl); } pr_info("DSA: tree %d torn down\n", dst->index); dst->setup = false; } static int dsa_tree_bind_tag_proto(struct dsa_switch_tree *dst, const struct dsa_device_ops *tag_ops) { const struct dsa_device_ops *old_tag_ops = dst->tag_ops; struct dsa_notifier_tag_proto_info info; int err; dst->tag_ops = tag_ops; /* Notify the switches from this tree about the connection * to the new tagger */ info.tag_ops = tag_ops; err = dsa_tree_notify(dst, DSA_NOTIFIER_TAG_PROTO_CONNECT, &info); if (err && err != -EOPNOTSUPP) goto out_disconnect; /* Notify the old tagger about the disconnection from this tree */ info.tag_ops = old_tag_ops; dsa_tree_notify(dst, DSA_NOTIFIER_TAG_PROTO_DISCONNECT, &info); return 0; out_disconnect: info.tag_ops = tag_ops; dsa_tree_notify(dst, DSA_NOTIFIER_TAG_PROTO_DISCONNECT, &info); dst->tag_ops = old_tag_ops; return err; } /* Since the dsa/tagging sysfs device attribute is per conduit, the assumption * is that all DSA switches within a tree share the same tagger, otherwise * they would have formed disjoint trees (different "dsa,member" values). */ int dsa_tree_change_tag_proto(struct dsa_switch_tree *dst, const struct dsa_device_ops *tag_ops, const struct dsa_device_ops *old_tag_ops) { struct dsa_notifier_tag_proto_info info; struct dsa_port *dp; int err = -EBUSY; if (!rtnl_trylock()) return restart_syscall(); /* At the moment we don't allow changing the tag protocol under * traffic. The rtnl_mutex also happens to serialize concurrent * attempts to change the tagging protocol. If we ever lift the IFF_UP * restriction, there needs to be another mutex which serializes this. */ dsa_tree_for_each_user_port(dp, dst) { if (dsa_port_to_conduit(dp)->flags & IFF_UP) goto out_unlock; if (dp->user->flags & IFF_UP) goto out_unlock; } /* Notify the tag protocol change */ info.tag_ops = tag_ops; err = dsa_tree_notify(dst, DSA_NOTIFIER_TAG_PROTO, &info); if (err) goto out_unwind_tagger; err = dsa_tree_bind_tag_proto(dst, tag_ops); if (err) goto out_unwind_tagger; rtnl_unlock(); return 0; out_unwind_tagger: info.tag_ops = old_tag_ops; dsa_tree_notify(dst, DSA_NOTIFIER_TAG_PROTO, &info); out_unlock: rtnl_unlock(); return err; } static void dsa_tree_conduit_state_change(struct dsa_switch_tree *dst, struct net_device *conduit) { struct dsa_notifier_conduit_state_info info; struct dsa_port *cpu_dp = conduit->dsa_ptr; info.conduit = conduit; info.operational = dsa_port_conduit_is_operational(cpu_dp); dsa_tree_notify(dst, DSA_NOTIFIER_CONDUIT_STATE_CHANGE, &info); } void dsa_tree_conduit_admin_state_change(struct dsa_switch_tree *dst, struct net_device *conduit, bool up) { struct dsa_port *cpu_dp = conduit->dsa_ptr; bool notify = false; /* Don't keep track of admin state on LAG DSA conduits, * but rather just of physical DSA conduits */ if (netif_is_lag_master(conduit)) return; if ((dsa_port_conduit_is_operational(cpu_dp)) != (up && cpu_dp->conduit_oper_up)) notify = true; cpu_dp->conduit_admin_up = up; if (notify) dsa_tree_conduit_state_change(dst, conduit); } void dsa_tree_conduit_oper_state_change(struct dsa_switch_tree *dst, struct net_device *conduit, bool up) { struct dsa_port *cpu_dp = conduit->dsa_ptr; bool notify = false; /* Don't keep track of oper state on LAG DSA conduits, * but rather just of physical DSA conduits */ if (netif_is_lag_master(conduit)) return; if ((dsa_port_conduit_is_operational(cpu_dp)) != (cpu_dp->conduit_admin_up && up)) notify = true; cpu_dp->conduit_oper_up = up; if (notify) dsa_tree_conduit_state_change(dst, conduit); } static struct dsa_port *dsa_port_touch(struct dsa_switch *ds, int index) { struct dsa_switch_tree *dst = ds->dst; struct dsa_port *dp; dsa_switch_for_each_port(dp, ds) if (dp->index == index) return dp; dp = kzalloc(sizeof(*dp), GFP_KERNEL); if (!dp) return NULL; dp->ds = ds; dp->index = index; mutex_init(&dp->addr_lists_lock); mutex_init(&dp->vlans_lock); INIT_LIST_HEAD(&dp->fdbs); INIT_LIST_HEAD(&dp->mdbs); INIT_LIST_HEAD(&dp->vlans); /* also initializes &dp->user_vlans */ INIT_LIST_HEAD(&dp->list); list_add_tail(&dp->list, &dst->ports); return dp; } static int dsa_port_parse_user(struct dsa_port *dp, const char *name) { dp->type = DSA_PORT_TYPE_USER; dp->name = name; return 0; } static int dsa_port_parse_dsa(struct dsa_port *dp) { dp->type = DSA_PORT_TYPE_DSA; return 0; } static enum dsa_tag_protocol dsa_get_tag_protocol(struct dsa_port *dp, struct net_device *conduit) { enum dsa_tag_protocol tag_protocol = DSA_TAG_PROTO_NONE; struct dsa_switch *mds, *ds = dp->ds; unsigned int mdp_upstream; struct dsa_port *mdp; /* It is possible to stack DSA switches onto one another when that * happens the switch driver may want to know if its tagging protocol * is going to work in such a configuration. */ if (dsa_user_dev_check(conduit)) { mdp = dsa_user_to_port(conduit); mds = mdp->ds; mdp_upstream = dsa_upstream_port(mds, mdp->index); tag_protocol = mds->ops->get_tag_protocol(mds, mdp_upstream, DSA_TAG_PROTO_NONE); } /* If the conduit device is not itself a DSA user in a disjoint DSA * tree, then return immediately. */ return ds->ops->get_tag_protocol(ds, dp->index, tag_protocol); } static int dsa_port_parse_cpu(struct dsa_port *dp, struct net_device *conduit, const char *user_protocol) { const struct dsa_device_ops *tag_ops = NULL; struct dsa_switch *ds = dp->ds; struct dsa_switch_tree *dst = ds->dst; enum dsa_tag_protocol default_proto; /* Find out which protocol the switch would prefer. */ default_proto = dsa_get_tag_protocol(dp, conduit); if (dst->default_proto) { if (dst->default_proto != default_proto) { dev_err(ds->dev, "A DSA switch tree can have only one tagging protocol\n"); return -EINVAL; } } else { dst->default_proto = default_proto; } /* See if the user wants to override that preference. */ if (user_protocol) { if (!ds->ops->change_tag_protocol) { dev_err(ds->dev, "Tag protocol cannot be modified\n"); return -EINVAL; } tag_ops = dsa_tag_driver_get_by_name(user_protocol); if (IS_ERR(tag_ops)) { dev_warn(ds->dev, "Failed to find a tagging driver for protocol %s, using default\n", user_protocol); tag_ops = NULL; } } if (!tag_ops) tag_ops = dsa_tag_driver_get_by_id(default_proto); if (IS_ERR(tag_ops)) { if (PTR_ERR(tag_ops) == -ENOPROTOOPT) return -EPROBE_DEFER; dev_warn(ds->dev, "No tagger for this switch\n"); return PTR_ERR(tag_ops); } if (dst->tag_ops) { if (dst->tag_ops != tag_ops) { dev_err(ds->dev, "A DSA switch tree can have only one tagging protocol\n"); dsa_tag_driver_put(tag_ops); return -EINVAL; } /* In the case of multiple CPU ports per switch, the tagging * protocol is still reference-counted only per switch tree. */ dsa_tag_driver_put(tag_ops); } else { dst->tag_ops = tag_ops; } dp->conduit = conduit; dp->type = DSA_PORT_TYPE_CPU; dsa_port_set_tag_protocol(dp, dst->tag_ops); dp->dst = dst; /* At this point, the tree may be configured to use a different * tagger than the one chosen by the switch driver during * .setup, in the case when a user selects a custom protocol * through the DT. * * This is resolved by syncing the driver with the tree in * dsa_switch_setup_tag_protocol once .setup has run and the * driver is ready to accept calls to .change_tag_protocol. If * the driver does not support the custom protocol at that * point, the tree is wholly rejected, thereby ensuring that the * tree and driver are always in agreement on the protocol to * use. */ return 0; } static int dsa_port_parse_of(struct dsa_port *dp, struct device_node *dn) { struct device_node *ethernet = of_parse_phandle(dn, "ethernet", 0); const char *name = of_get_property(dn, "label", NULL); bool link = of_property_read_bool(dn, "link"); dp->dn = dn; if (ethernet) { struct net_device *conduit; const char *user_protocol; conduit = of_find_net_device_by_node(ethernet); of_node_put(ethernet); if (!conduit) return -EPROBE_DEFER; user_protocol = of_get_property(dn, "dsa-tag-protocol", NULL); return dsa_port_parse_cpu(dp, conduit, user_protocol); } if (link) return dsa_port_parse_dsa(dp); return dsa_port_parse_user(dp, name); } static int dsa_switch_parse_ports_of(struct dsa_switch *ds, struct device_node *dn) { struct device_node *ports, *port; struct dsa_port *dp; int err = 0; u32 reg; ports = of_get_child_by_name(dn, "ports"); if (!ports) { /* The second possibility is "ethernet-ports" */ ports = of_get_child_by_name(dn, "ethernet-ports"); if (!ports) { dev_err(ds->dev, "no ports child node found\n"); return -EINVAL; } } for_each_available_child_of_node(ports, port) { err = of_property_read_u32(port, "reg", ®); if (err) { of_node_put(port); goto out_put_node; } if (reg >= ds->num_ports) { dev_err(ds->dev, "port %pOF index %u exceeds num_ports (%u)\n", port, reg, ds->num_ports); of_node_put(port); err = -EINVAL; goto out_put_node; } dp = dsa_to_port(ds, reg); err = dsa_port_parse_of(dp, port); if (err) { of_node_put(port); goto out_put_node; } } out_put_node: of_node_put(ports); return err; } static int dsa_switch_parse_member_of(struct dsa_switch *ds, struct device_node *dn) { u32 m[2] = { 0, 0 }; int sz; /* Don't error out if this optional property isn't found */ sz = of_property_read_variable_u32_array(dn, "dsa,member", m, 2, 2); if (sz < 0 && sz != -EINVAL) return sz; ds->index = m[1]; ds->dst = dsa_tree_touch(m[0]); if (!ds->dst) return -ENOMEM; if (dsa_switch_find(ds->dst->index, ds->index)) { dev_err(ds->dev, "A DSA switch with index %d already exists in tree %d\n", ds->index, ds->dst->index); return -EEXIST; } if (ds->dst->last_switch < ds->index) ds->dst->last_switch = ds->index; return 0; } static int dsa_switch_touch_ports(struct dsa_switch *ds) { struct dsa_port *dp; int port; for (port = 0; port < ds->num_ports; port++) { dp = dsa_port_touch(ds, port); if (!dp) return -ENOMEM; } return 0; } static int dsa_switch_parse_of(struct dsa_switch *ds, struct device_node *dn) { int err; err = dsa_switch_parse_member_of(ds, dn); if (err) return err; err = dsa_switch_touch_ports(ds); if (err) return err; return dsa_switch_parse_ports_of(ds, dn); } static int dev_is_class(struct device *dev, void *class) { if (dev->class != NULL && !strcmp(dev->class->name, class)) return 1; return 0; } static struct device *dev_find_class(struct device *parent, char *class) { if (dev_is_class(parent, class)) { get_device(parent); return parent; } return device_find_child(parent, class, dev_is_class); } static struct net_device *dsa_dev_to_net_device(struct device *dev) { struct device *d; d = dev_find_class(dev, "net"); if (d != NULL) { struct net_device *nd; nd = to_net_dev(d); dev_hold(nd); put_device(d); return nd; } return NULL; } static int dsa_port_parse(struct dsa_port *dp, const char *name, struct device *dev) { if (!strcmp(name, "cpu")) { struct net_device *conduit; conduit = dsa_dev_to_net_device(dev); if (!conduit) return -EPROBE_DEFER; dev_put(conduit); return dsa_port_parse_cpu(dp, conduit, NULL); } if (!strcmp(name, "dsa")) return dsa_port_parse_dsa(dp); return dsa_port_parse_user(dp, name); } static int dsa_switch_parse_ports(struct dsa_switch *ds, struct dsa_chip_data *cd) { bool valid_name_found = false; struct dsa_port *dp; struct device *dev; const char *name; unsigned int i; int err; for (i = 0; i < DSA_MAX_PORTS; i++) { name = cd->port_names[i]; dev = cd->netdev[i]; dp = dsa_to_port(ds, i); if (!name) continue; err = dsa_port_parse(dp, name, dev); if (err) return err; valid_name_found = true; } if (!valid_name_found && i == DSA_MAX_PORTS) return -EINVAL; return 0; } static int dsa_switch_parse(struct dsa_switch *ds, struct dsa_chip_data *cd) { int err; ds->cd = cd; /* We don't support interconnected switches nor multiple trees via * platform data, so this is the unique switch of the tree. */ ds->index = 0; ds->dst = dsa_tree_touch(0); if (!ds->dst) return -ENOMEM; err = dsa_switch_touch_ports(ds); if (err) return err; return dsa_switch_parse_ports(ds, cd); } static void dsa_switch_release_ports(struct dsa_switch *ds) { struct dsa_port *dp, *next; dsa_switch_for_each_port_safe(dp, next, ds) { WARN_ON(!list_empty(&dp->fdbs)); WARN_ON(!list_empty(&dp->mdbs)); WARN_ON(!list_empty(&dp->vlans)); list_del(&dp->list); kfree(dp); } } static int dsa_switch_probe(struct dsa_switch *ds) { struct dsa_switch_tree *dst; struct dsa_chip_data *pdata; struct device_node *np; int err; if (!ds->dev) return -ENODEV; pdata = ds->dev->platform_data; np = ds->dev->of_node; if (!ds->num_ports) return -EINVAL; if (np) { err = dsa_switch_parse_of(ds, np); if (err) dsa_switch_release_ports(ds); } else if (pdata) { err = dsa_switch_parse(ds, pdata); if (err) dsa_switch_release_ports(ds); } else { err = -ENODEV; } if (err) return err; dst = ds->dst; dsa_tree_get(dst); err = dsa_tree_setup(dst); if (err) { dsa_switch_release_ports(ds); dsa_tree_put(dst); } return err; } int dsa_register_switch(struct dsa_switch *ds) { int err; mutex_lock(&dsa2_mutex); err = dsa_switch_probe(ds); dsa_tree_put(ds->dst); mutex_unlock(&dsa2_mutex); return err; } EXPORT_SYMBOL_GPL(dsa_register_switch); static void dsa_switch_remove(struct dsa_switch *ds) { struct dsa_switch_tree *dst = ds->dst; dsa_tree_teardown(dst); dsa_switch_release_ports(ds); dsa_tree_put(dst); } void dsa_unregister_switch(struct dsa_switch *ds) { mutex_lock(&dsa2_mutex); dsa_switch_remove(ds); mutex_unlock(&dsa2_mutex); } EXPORT_SYMBOL_GPL(dsa_unregister_switch); /* If the DSA conduit chooses to unregister its net_device on .shutdown, DSA is * blocking that operation from completion, due to the dev_hold taken inside * netdev_upper_dev_link. Unlink the DSA user interfaces from being uppers of * the DSA conduit, so that the system can reboot successfully. */ void dsa_switch_shutdown(struct dsa_switch *ds) { struct net_device *conduit, *user_dev; struct dsa_port *dp; mutex_lock(&dsa2_mutex); if (!ds->setup) goto out; rtnl_lock(); dsa_switch_for_each_user_port(dp, ds) { conduit = dsa_port_to_conduit(dp); user_dev = dp->user; netdev_upper_dev_unlink(conduit, user_dev); } /* Disconnect from further netdevice notifiers on the conduit, * since netdev_uses_dsa() will now return false. */ dsa_switch_for_each_cpu_port(dp, ds) dp->conduit->dsa_ptr = NULL; rtnl_unlock(); out: mutex_unlock(&dsa2_mutex); } EXPORT_SYMBOL_GPL(dsa_switch_shutdown); #ifdef CONFIG_PM_SLEEP static bool dsa_port_is_initialized(const struct dsa_port *dp) { return dp->type == DSA_PORT_TYPE_USER && dp->user; } int dsa_switch_suspend(struct dsa_switch *ds) { struct dsa_port *dp; int ret = 0; /* Suspend user network devices */ dsa_switch_for_each_port(dp, ds) { if (!dsa_port_is_initialized(dp)) continue; ret = dsa_user_suspend(dp->user); if (ret) return ret; } if (ds->ops->suspend) ret = ds->ops->suspend(ds); return ret; } EXPORT_SYMBOL_GPL(dsa_switch_suspend); int dsa_switch_resume(struct dsa_switch *ds) { struct dsa_port *dp; int ret = 0; if (ds->ops->resume) ret = ds->ops->resume(ds); if (ret) return ret; /* Resume user network devices */ dsa_switch_for_each_port(dp, ds) { if (!dsa_port_is_initialized(dp)) continue; ret = dsa_user_resume(dp->user); if (ret) return ret; } return 0; } EXPORT_SYMBOL_GPL(dsa_switch_resume); #endif struct dsa_port *dsa_port_from_netdev(struct net_device *netdev) { if (!netdev || !dsa_user_dev_check(netdev)) return ERR_PTR(-ENODEV); return dsa_user_to_port(netdev); } EXPORT_SYMBOL_GPL(dsa_port_from_netdev); bool dsa_db_equal(const struct dsa_db *a, const struct dsa_db *b) { if (a->type != b->type) return false; switch (a->type) { case DSA_DB_PORT: return a->dp == b->dp; case DSA_DB_LAG: return a->lag.dev == b->lag.dev; case DSA_DB_BRIDGE: return a->bridge.num == b->bridge.num; default: WARN_ON(1); return false; } } bool dsa_fdb_present_in_other_db(struct dsa_switch *ds, int port, const unsigned char *addr, u16 vid, struct dsa_db db) { struct dsa_port *dp = dsa_to_port(ds, port); struct dsa_mac_addr *a; lockdep_assert_held(&dp->addr_lists_lock); list_for_each_entry(a, &dp->fdbs, list) { if (!ether_addr_equal(a->addr, addr) || a->vid != vid) continue; if (a->db.type == db.type && !dsa_db_equal(&a->db, &db)) return true; } return false; } EXPORT_SYMBOL_GPL(dsa_fdb_present_in_other_db); bool dsa_mdb_present_in_other_db(struct dsa_switch *ds, int port, const struct switchdev_obj_port_mdb *mdb, struct dsa_db db) { struct dsa_port *dp = dsa_to_port(ds, port); struct dsa_mac_addr *a; lockdep_assert_held(&dp->addr_lists_lock); list_for_each_entry(a, &dp->mdbs, list) { if (!ether_addr_equal(a->addr, mdb->addr) || a->vid != mdb->vid) continue; if (a->db.type == db.type && !dsa_db_equal(&a->db, &db)) return true; } return false; } EXPORT_SYMBOL_GPL(dsa_mdb_present_in_other_db); static const struct dsa_stubs __dsa_stubs = { .conduit_hwtstamp_validate = __dsa_conduit_hwtstamp_validate, }; static void dsa_register_stubs(void) { dsa_stubs = &__dsa_stubs; } static void dsa_unregister_stubs(void) { dsa_stubs = NULL; } static int __init dsa_init_module(void) { int rc; dsa_owq = alloc_ordered_workqueue("dsa_ordered", WQ_MEM_RECLAIM); if (!dsa_owq) return -ENOMEM; rc = dsa_user_register_notifier(); if (rc) goto register_notifier_fail; dev_add_pack(&dsa_pack_type); rc = rtnl_link_register(&dsa_link_ops); if (rc) goto netlink_register_fail; dsa_register_stubs(); return 0; netlink_register_fail: dsa_user_unregister_notifier(); dev_remove_pack(&dsa_pack_type); register_notifier_fail: destroy_workqueue(dsa_owq); return rc; } module_init(dsa_init_module); static void __exit dsa_cleanup_module(void) { dsa_unregister_stubs(); rtnl_link_unregister(&dsa_link_ops); dsa_user_unregister_notifier(); dev_remove_pack(&dsa_pack_type); destroy_workqueue(dsa_owq); } module_exit(dsa_cleanup_module); MODULE_AUTHOR("Lennert Buytenhek <buytenh@wantstofly.org>"); MODULE_DESCRIPTION("Driver for Distributed Switch Architecture switch chips"); MODULE_LICENSE("GPL"); MODULE_ALIAS("platform:dsa");
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with Cregit http://github.com/cregit/cregit
Version 2.0-RC1