| // SPDX-License-Identifier: GPL-2.0-or-later |
| /* |
| * Distributed Switch Architecture loopback driver |
| * |
| * Copyright (C) 2016, Florian Fainelli <f.fainelli@gmail.com> |
| */ |
| |
| #include <linux/platform_device.h> |
| #include <linux/netdevice.h> |
| #include <linux/phy.h> |
| #include <linux/phy_fixed.h> |
| #include <linux/export.h> |
| #include <linux/ethtool.h> |
| #include <linux/workqueue.h> |
| #include <linux/module.h> |
| #include <linux/if_bridge.h> |
| #include <linux/dsa/loop.h> |
| #include <net/dsa.h> |
| |
| #include "dsa_loop.h" |
| |
| static struct dsa_loop_mib_entry dsa_loop_mibs[] = { |
| [DSA_LOOP_PHY_READ_OK] = { "phy_read_ok", }, |
| [DSA_LOOP_PHY_READ_ERR] = { "phy_read_err", }, |
| [DSA_LOOP_PHY_WRITE_OK] = { "phy_write_ok", }, |
| [DSA_LOOP_PHY_WRITE_ERR] = { "phy_write_err", }, |
| }; |
| |
| static struct phy_device *phydevs[PHY_MAX_ADDR]; |
| |
| static enum dsa_tag_protocol dsa_loop_get_protocol(struct dsa_switch *ds, |
| int port, |
| enum dsa_tag_protocol mp) |
| { |
| dev_dbg(ds->dev, "%s: port: %d\n", __func__, port); |
| |
| return DSA_TAG_PROTO_NONE; |
| } |
| |
| static int dsa_loop_setup(struct dsa_switch *ds) |
| { |
| struct dsa_loop_priv *ps = ds->priv; |
| unsigned int i; |
| |
| for (i = 0; i < ds->num_ports; i++) |
| memcpy(ps->ports[i].mib, dsa_loop_mibs, |
| sizeof(dsa_loop_mibs)); |
| |
| dev_dbg(ds->dev, "%s\n", __func__); |
| |
| return 0; |
| } |
| |
| static int dsa_loop_get_sset_count(struct dsa_switch *ds, int port, int sset) |
| { |
| if (sset != ETH_SS_STATS && sset != ETH_SS_PHY_STATS) |
| return 0; |
| |
| return __DSA_LOOP_CNT_MAX; |
| } |
| |
| static void dsa_loop_get_strings(struct dsa_switch *ds, int port, |
| u32 stringset, uint8_t *data) |
| { |
| struct dsa_loop_priv *ps = ds->priv; |
| unsigned int i; |
| |
| if (stringset != ETH_SS_STATS && stringset != ETH_SS_PHY_STATS) |
| return; |
| |
| for (i = 0; i < __DSA_LOOP_CNT_MAX; i++) |
| memcpy(data + i * ETH_GSTRING_LEN, |
| ps->ports[port].mib[i].name, ETH_GSTRING_LEN); |
| } |
| |
| static void dsa_loop_get_ethtool_stats(struct dsa_switch *ds, int port, |
| uint64_t *data) |
| { |
| struct dsa_loop_priv *ps = ds->priv; |
| unsigned int i; |
| |
| for (i = 0; i < __DSA_LOOP_CNT_MAX; i++) |
| data[i] = ps->ports[port].mib[i].val; |
| } |
| |
| static int dsa_loop_phy_read(struct dsa_switch *ds, int port, int regnum) |
| { |
| struct dsa_loop_priv *ps = ds->priv; |
| struct mii_bus *bus = ps->bus; |
| int ret; |
| |
| ret = mdiobus_read_nested(bus, ps->port_base + port, regnum); |
| if (ret < 0) |
| ps->ports[port].mib[DSA_LOOP_PHY_READ_ERR].val++; |
| else |
| ps->ports[port].mib[DSA_LOOP_PHY_READ_OK].val++; |
| |
| return ret; |
| } |
| |
| static int dsa_loop_phy_write(struct dsa_switch *ds, int port, |
| int regnum, u16 value) |
| { |
| struct dsa_loop_priv *ps = ds->priv; |
| struct mii_bus *bus = ps->bus; |
| int ret; |
| |
| ret = mdiobus_write_nested(bus, ps->port_base + port, regnum, value); |
| if (ret < 0) |
| ps->ports[port].mib[DSA_LOOP_PHY_WRITE_ERR].val++; |
| else |
| ps->ports[port].mib[DSA_LOOP_PHY_WRITE_OK].val++; |
| |
| return ret; |
| } |
| |
| static int dsa_loop_port_bridge_join(struct dsa_switch *ds, int port, |
| struct net_device *bridge) |
| { |
| dev_dbg(ds->dev, "%s: port: %d, bridge: %s\n", |
| __func__, port, bridge->name); |
| |
| return 0; |
| } |
| |
| static void dsa_loop_port_bridge_leave(struct dsa_switch *ds, int port, |
| struct net_device *bridge) |
| { |
| dev_dbg(ds->dev, "%s: port: %d, bridge: %s\n", |
| __func__, port, bridge->name); |
| } |
| |
| static void dsa_loop_port_stp_state_set(struct dsa_switch *ds, int port, |
| u8 state) |
| { |
| dev_dbg(ds->dev, "%s: port: %d, state: %d\n", |
| __func__, port, state); |
| } |
| |
| static int dsa_loop_port_vlan_filtering(struct dsa_switch *ds, int port, |
| bool vlan_filtering) |
| { |
| dev_dbg(ds->dev, "%s: port: %d, vlan_filtering: %d\n", |
| __func__, port, vlan_filtering); |
| |
| return 0; |
| } |
| |
| static int |
| dsa_loop_port_vlan_prepare(struct dsa_switch *ds, int port, |
| const struct switchdev_obj_port_vlan *vlan) |
| { |
| struct dsa_loop_priv *ps = ds->priv; |
| struct mii_bus *bus = ps->bus; |
| |
| dev_dbg(ds->dev, "%s: port: %d, vlan: %d-%d", |
| __func__, port, vlan->vid_begin, vlan->vid_end); |
| |
| /* Just do a sleeping operation to make lockdep checks effective */ |
| mdiobus_read(bus, ps->port_base + port, MII_BMSR); |
| |
| if (vlan->vid_end > ARRAY_SIZE(ps->vlans)) |
| return -ERANGE; |
| |
| return 0; |
| } |
| |
| static void dsa_loop_port_vlan_add(struct dsa_switch *ds, int port, |
| const struct switchdev_obj_port_vlan *vlan) |
| { |
| bool untagged = vlan->flags & BRIDGE_VLAN_INFO_UNTAGGED; |
| bool pvid = vlan->flags & BRIDGE_VLAN_INFO_PVID; |
| struct dsa_loop_priv *ps = ds->priv; |
| struct mii_bus *bus = ps->bus; |
| struct dsa_loop_vlan *vl; |
| u16 vid; |
| |
| /* Just do a sleeping operation to make lockdep checks effective */ |
| mdiobus_read(bus, ps->port_base + port, MII_BMSR); |
| |
| for (vid = vlan->vid_begin; vid <= vlan->vid_end; ++vid) { |
| vl = &ps->vlans[vid]; |
| |
| vl->members |= BIT(port); |
| if (untagged) |
| vl->untagged |= BIT(port); |
| else |
| vl->untagged &= ~BIT(port); |
| |
| dev_dbg(ds->dev, "%s: port: %d vlan: %d, %stagged, pvid: %d\n", |
| __func__, port, vid, untagged ? "un" : "", pvid); |
| } |
| |
| if (pvid) |
| ps->ports[port].pvid = vid; |
| } |
| |
| static int dsa_loop_port_vlan_del(struct dsa_switch *ds, int port, |
| const struct switchdev_obj_port_vlan *vlan) |
| { |
| bool untagged = vlan->flags & BRIDGE_VLAN_INFO_UNTAGGED; |
| struct dsa_loop_priv *ps = ds->priv; |
| struct mii_bus *bus = ps->bus; |
| struct dsa_loop_vlan *vl; |
| u16 vid, pvid = ps->ports[port].pvid; |
| |
| /* Just do a sleeping operation to make lockdep checks effective */ |
| mdiobus_read(bus, ps->port_base + port, MII_BMSR); |
| |
| for (vid = vlan->vid_begin; vid <= vlan->vid_end; ++vid) { |
| vl = &ps->vlans[vid]; |
| |
| vl->members &= ~BIT(port); |
| if (untagged) |
| vl->untagged &= ~BIT(port); |
| |
| if (pvid == vid) |
| pvid = 1; |
| |
| dev_dbg(ds->dev, "%s: port: %d vlan: %d, %stagged, pvid: %d\n", |
| __func__, port, vid, untagged ? "un" : "", pvid); |
| } |
| ps->ports[port].pvid = pvid; |
| |
| return 0; |
| } |
| |
| static int dsa_loop_port_change_mtu(struct dsa_switch *ds, int port, |
| int new_mtu) |
| { |
| struct dsa_loop_priv *priv = ds->priv; |
| |
| priv->ports[port].mtu = new_mtu; |
| |
| return 0; |
| } |
| |
| static int dsa_loop_port_max_mtu(struct dsa_switch *ds, int port) |
| { |
| return ETH_MAX_MTU; |
| } |
| |
| static const struct dsa_switch_ops dsa_loop_driver = { |
| .get_tag_protocol = dsa_loop_get_protocol, |
| .setup = dsa_loop_setup, |
| .get_strings = dsa_loop_get_strings, |
| .get_ethtool_stats = dsa_loop_get_ethtool_stats, |
| .get_sset_count = dsa_loop_get_sset_count, |
| .get_ethtool_phy_stats = dsa_loop_get_ethtool_stats, |
| .phy_read = dsa_loop_phy_read, |
| .phy_write = dsa_loop_phy_write, |
| .port_bridge_join = dsa_loop_port_bridge_join, |
| .port_bridge_leave = dsa_loop_port_bridge_leave, |
| .port_stp_state_set = dsa_loop_port_stp_state_set, |
| .port_vlan_filtering = dsa_loop_port_vlan_filtering, |
| .port_vlan_prepare = dsa_loop_port_vlan_prepare, |
| .port_vlan_add = dsa_loop_port_vlan_add, |
| .port_vlan_del = dsa_loop_port_vlan_del, |
| .port_change_mtu = dsa_loop_port_change_mtu, |
| .port_max_mtu = dsa_loop_port_max_mtu, |
| }; |
| |
| static int dsa_loop_drv_probe(struct mdio_device *mdiodev) |
| { |
| struct dsa_loop_pdata *pdata = mdiodev->dev.platform_data; |
| struct dsa_loop_priv *ps; |
| struct dsa_switch *ds; |
| int ret; |
| |
| if (!pdata) |
| return -ENODEV; |
| |
| ds = devm_kzalloc(&mdiodev->dev, sizeof(*ds), GFP_KERNEL); |
| if (!ds) |
| return -ENOMEM; |
| |
| ds->dev = &mdiodev->dev; |
| ds->num_ports = DSA_LOOP_NUM_PORTS; |
| |
| ps = devm_kzalloc(&mdiodev->dev, sizeof(*ps), GFP_KERNEL); |
| if (!ps) |
| return -ENOMEM; |
| |
| ps->netdev = dev_get_by_name(&init_net, pdata->netdev); |
| if (!ps->netdev) |
| return -EPROBE_DEFER; |
| |
| pdata->cd.netdev[DSA_LOOP_CPU_PORT] = &ps->netdev->dev; |
| |
| ds->dev = &mdiodev->dev; |
| ds->ops = &dsa_loop_driver; |
| ds->priv = ps; |
| ps->bus = mdiodev->bus; |
| |
| dev_set_drvdata(&mdiodev->dev, ds); |
| |
| ret = dsa_register_switch(ds); |
| if (!ret) |
| dev_info(&mdiodev->dev, "%s: 0x%0x\n", |
| pdata->name, pdata->enabled_ports); |
| |
| return ret; |
| } |
| |
| static void dsa_loop_drv_remove(struct mdio_device *mdiodev) |
| { |
| struct dsa_switch *ds = dev_get_drvdata(&mdiodev->dev); |
| struct dsa_loop_priv *ps = ds->priv; |
| |
| dsa_unregister_switch(ds); |
| dev_put(ps->netdev); |
| } |
| |
| static struct mdio_driver dsa_loop_drv = { |
| .mdiodrv.driver = { |
| .name = "dsa-loop", |
| }, |
| .probe = dsa_loop_drv_probe, |
| .remove = dsa_loop_drv_remove, |
| }; |
| |
| #define NUM_FIXED_PHYS (DSA_LOOP_NUM_PORTS - 2) |
| |
| static int __init dsa_loop_init(void) |
| { |
| struct fixed_phy_status status = { |
| .link = 1, |
| .speed = SPEED_100, |
| .duplex = DUPLEX_FULL, |
| }; |
| unsigned int i; |
| |
| for (i = 0; i < NUM_FIXED_PHYS; i++) |
| phydevs[i] = fixed_phy_register(PHY_POLL, &status, NULL); |
| |
| return mdio_driver_register(&dsa_loop_drv); |
| } |
| module_init(dsa_loop_init); |
| |
| static void __exit dsa_loop_exit(void) |
| { |
| unsigned int i; |
| |
| mdio_driver_unregister(&dsa_loop_drv); |
| for (i = 0; i < NUM_FIXED_PHYS; i++) |
| if (!IS_ERR(phydevs[i])) |
| fixed_phy_unregister(phydevs[i]); |
| } |
| module_exit(dsa_loop_exit); |
| |
| MODULE_SOFTDEP("pre: dsa_loop_bdinfo"); |
| MODULE_LICENSE("GPL"); |
| MODULE_AUTHOR("Florian Fainelli"); |
| MODULE_DESCRIPTION("DSA loopback driver"); |