Support offloading of LAGs to hardware. LAGs may be attached to a
bridge in which case VLANs, multicast groups, etc. are also offloaded
as usual.

Signed-off-by: Tobias Waldekranz <tob...@waldekranz.com>
---
 drivers/net/dsa/mv88e6xxx/chip.c    | 234 +++++++++++++++++++++++++++-
 drivers/net/dsa/mv88e6xxx/chip.h    |   4 +
 drivers/net/dsa/mv88e6xxx/global2.c |   8 +-
 drivers/net/dsa/mv88e6xxx/global2.h |   5 +
 drivers/net/dsa/mv88e6xxx/port.c    |  21 +++
 drivers/net/dsa/mv88e6xxx/port.h    |   5 +
 6 files changed, 269 insertions(+), 8 deletions(-)

diff --git a/drivers/net/dsa/mv88e6xxx/chip.c b/drivers/net/dsa/mv88e6xxx/chip.c
index e7f68ac0c7e3..3c4b795ac7e4 100644
--- a/drivers/net/dsa/mv88e6xxx/chip.c
+++ b/drivers/net/dsa/mv88e6xxx/chip.c
@@ -1189,7 +1189,8 @@ static int mv88e6xxx_set_mac_eee(struct dsa_switch *ds, 
int port,
 }
 
 /* Mask of the local ports allowed to receive frames from a given fabric port 
*/
-static u16 mv88e6xxx_port_vlan(struct mv88e6xxx_chip *chip, int dev, int port)
+static u16 mv88e6xxx_port_vlan(struct mv88e6xxx_chip *chip, int dev, int port,
+                              struct dsa_lag **lag)
 {
        struct dsa_switch *ds = chip->ds;
        struct dsa_switch_tree *dst = ds->dst;
@@ -1201,6 +1202,9 @@ static u16 mv88e6xxx_port_vlan(struct mv88e6xxx_chip 
*chip, int dev, int port)
        list_for_each_entry(dp, &dst->ports, list) {
                if (dp->ds->index == dev && dp->index == port) {
                        found = true;
+
+                       if (dp->lag && lag)
+                               *lag = dp->lag;
                        break;
                }
        }
@@ -1231,7 +1235,9 @@ static u16 mv88e6xxx_port_vlan(struct mv88e6xxx_chip 
*chip, int dev, int port)
 
 static int mv88e6xxx_port_vlan_map(struct mv88e6xxx_chip *chip, int port)
 {
-       u16 output_ports = mv88e6xxx_port_vlan(chip, chip->ds->index, port);
+       u16 output_ports;
+
+       output_ports = mv88e6xxx_port_vlan(chip, chip->ds->index, port, NULL);
 
        /* prevent frames from going back out of the port they came in on */
        output_ports &= ~BIT(port);
@@ -1389,14 +1395,21 @@ static int mv88e6xxx_mac_setup(struct mv88e6xxx_chip 
*chip)
 
 static int mv88e6xxx_pvt_map(struct mv88e6xxx_chip *chip, int dev, int port)
 {
+       struct dsa_lag *lag = NULL;
        u16 pvlan = 0;
 
        if (!mv88e6xxx_has_pvt(chip))
                return 0;
 
        /* Skip the local source device, which uses in-chip port VLAN */
-       if (dev != chip->ds->index)
-               pvlan = mv88e6xxx_port_vlan(chip, dev, port);
+       if (dev != chip->ds->index) {
+               pvlan = mv88e6xxx_port_vlan(chip, dev, port, &lag);
+
+               if (lag) {
+                       dev = MV88E6XXX_G2_PVT_ADRR_DEV_TRUNK;
+                       port = lag->id;
+               }
+       }
 
        return mv88e6xxx_g2_pvt_write(chip, dev, port, pvlan);
 }
@@ -5368,6 +5381,207 @@ static int mv88e6xxx_port_egress_floods(struct 
dsa_switch *ds, int port,
        return err;
 }
 
+static int mv88e6xxx_lag_sync_map(struct dsa_switch *ds, struct dsa_lag *lag)
+{
+       struct mv88e6xxx_chip *chip = ds->priv;
+       struct dsa_port *dp;
+       u16 map = 0;
+
+       /* Build the map of all ports to distribute flows destined for
+        * this LAG. This can be either a local user port, or a DSA
+        * port if the LAG port is on a remote chip.
+        */
+       list_for_each_entry(dp, &lag->ports, lag_list) {
+               map |= BIT(dsa_towards_port(ds, dp->ds->index, dp->index));
+       }
+
+       return mv88e6xxx_g2_trunk_mapping_write(chip, lag->id, map);
+}
+
+static const u8 mv88e6xxx_lag_mask_table[8][8] = {
+       /* Row number corresponds to the number of active members in a
+        * LAG. Each column states which of the eight hash buckets are
+        * mapped to the column:th port in the LAG.
+        *
+        * Example: In a LAG with three active ports, the second port
+        * ([2][1]) would be selected for traffic mapped to buckets
+        * 3,4,5 (0x38).
+        */
+       { 0xff,    0,    0,    0,    0,    0,    0,    0 },
+       { 0x0f, 0xf0,    0,    0,    0,    0,    0,    0 },
+       { 0x07, 0x38, 0xc0,    0,    0,    0,    0,    0 },
+       { 0x03, 0x0c, 0x30, 0xc0,    0,    0,    0,    0 },
+       { 0x03, 0x0c, 0x30, 0x40, 0x80,    0,    0,    0 },
+       { 0x03, 0x0c, 0x10, 0x20, 0x40, 0x80,    0,    0 },
+       { 0x03, 0x04, 0x08, 0x10, 0x20, 0x40, 0x80,    0 },
+       { 0x01, 0x02, 0x04, 0x08, 0x10, 0x20, 0x40, 0x80 },
+};
+
+static void mv88e6xxx_lag_set_port_mask(u16 *mask, int port,
+                                       int num_tx, int nth)
+{
+       u8 active = 0;
+       int i;
+
+       num_tx = num_tx <= 8 ? num_tx : 8;
+       if (nth < num_tx)
+               active = mv88e6xxx_lag_mask_table[num_tx - 1][nth];
+
+       for (i = 0; i < 8; i++) {
+               if (BIT(i) & active)
+                       mask[i] |= BIT(port);
+       }
+}
+
+static int mv88e6xxx_lag_sync_masks(struct dsa_switch *ds)
+{
+       struct mv88e6xxx_chip *chip = ds->priv;
+       struct dsa_port *dp;
+       struct dsa_lag *lag;
+       int i, id, err, nth;
+       u16 mask[8] = { 0 };
+       u16 ivec;
+
+       /* Assume no port is a member of any LAG. */
+       ivec = BIT(mv88e6xxx_num_ports(chip)) - 1;
+
+       /* Disable all masks for ports that _are_ members of a LAG. */
+       dsa_lag_foreach(id, ds->dst) {
+               lag = dsa_lag_by_id(ds->dst, id);
+               list_for_each_entry(dp, &lag->ports, lag_list) {
+                       if (dp->ds != ds)
+                               continue;
+
+                       ivec &= ~BIT(dp->index);
+               }
+       }
+
+       for (i = 0; i < 8; i++)
+               mask[i] = ivec;
+
+       /* Enable the correct subset of masks for all LAG ports that
+        * are in the Tx set.
+        */
+       dsa_lag_foreach(id, ds->dst) {
+               lag = dsa_lag_by_id(ds->dst, id);
+               if (!lag->num_tx)
+                       continue;
+
+               nth = 0;
+               list_for_each_entry(dp, &lag->tx_ports, lag_tx_list) {
+                       if (dp->ds == ds)
+                               mv88e6xxx_lag_set_port_mask(mask, dp->index,
+                                                           lag->num_tx, nth);
+
+                       nth++;
+               }
+       }
+
+       for (i = 0; i < 8; i++) {
+               err = mv88e6xxx_g2_trunk_mask_write(chip, i, true, mask[i]);
+               if (err)
+                       return err;
+       }
+
+       return 0;
+}
+
+static int mv88e6xxx_lag_sync_masks_map(struct dsa_switch *ds,
+                                       struct dsa_lag *lag)
+{
+       int err;
+
+       err = mv88e6xxx_lag_sync_masks(ds);
+
+       if (!err)
+               err = mv88e6xxx_lag_sync_map(ds, lag);
+
+       return err;
+}
+
+static int mv88e6xxx_port_lag_change(struct dsa_switch *ds, int port,
+                                    struct netdev_lag_lower_state_info *info)
+{
+       struct mv88e6xxx_chip *chip = ds->priv;
+       int err;
+
+       mv88e6xxx_reg_lock(chip);
+       err = mv88e6xxx_lag_sync_masks(ds);
+       mv88e6xxx_reg_unlock(chip);
+       return err;
+}
+
+static int mv88e6xxx_port_lag_join(struct dsa_switch *ds, int port,
+                                  struct net_device *lag_dev)
+{
+       struct dsa_lag *lag = dsa_to_port(ds, port)->lag;
+       struct mv88e6xxx_chip *chip = ds->priv;
+       int err;
+
+       mv88e6xxx_reg_lock(chip);
+
+       err = mv88e6xxx_port_set_trunk(chip, port, true, lag->id);
+       if (err)
+               goto unlock;
+
+       err = mv88e6xxx_lag_sync_masks_map(ds, lag);
+       if (err)
+               mv88e6xxx_port_set_trunk(chip, port, false, 0);
+
+unlock:
+       mv88e6xxx_reg_unlock(chip);
+       return err;
+}
+
+static void mv88e6xxx_port_lag_leave(struct dsa_switch *ds, int port,
+                                    struct net_device *lag_dev)
+{
+       struct dsa_lag *lag = dsa_to_port(ds, port)->lag;
+       struct mv88e6xxx_chip *chip = ds->priv;
+
+       mv88e6xxx_reg_lock(chip);
+       mv88e6xxx_lag_sync_masks_map(ds, lag);
+       mv88e6xxx_port_set_trunk(chip, port, false, 0);
+       mv88e6xxx_reg_unlock(chip);
+}
+
+static int mv88e6xxx_crosschip_lag_change(struct dsa_switch *ds, int sw_index,
+                                         int port, struct net_device *lag_dev,
+                                         struct netdev_lag_lower_state_info 
*info)
+{
+       struct mv88e6xxx_chip *chip = ds->priv;
+       int err;
+
+       mv88e6xxx_reg_lock(chip);
+       err = mv88e6xxx_lag_sync_masks(ds);
+       mv88e6xxx_reg_unlock(chip);
+       return err;
+}
+
+static int mv88e6xxx_crosschip_lag_join(struct dsa_switch *ds, int sw_index,
+                                       int port, struct net_device *lag_dev)
+{
+       struct dsa_lag *lag = dsa_lag_by_dev(ds->dst, lag_dev);
+       struct mv88e6xxx_chip *chip = ds->priv;
+       int err;
+
+       mv88e6xxx_reg_lock(chip);
+       err = mv88e6xxx_lag_sync_masks_map(ds, lag);
+       mv88e6xxx_reg_unlock(chip);
+       return err;
+}
+
+static void mv88e6xxx_crosschip_lag_leave(struct dsa_switch *ds, int sw_index,
+                                         int port, struct net_device *lag_dev)
+{
+       struct dsa_lag *lag = dsa_lag_by_dev(ds->dst, lag_dev);
+       struct mv88e6xxx_chip *chip = ds->priv;
+
+       mv88e6xxx_reg_lock(chip);
+       mv88e6xxx_lag_sync_masks_map(ds, lag);
+       mv88e6xxx_reg_unlock(chip);
+}
+
 static const struct dsa_switch_ops mv88e6xxx_switch_ops = {
        .get_tag_protocol       = mv88e6xxx_get_tag_protocol,
        .setup                  = mv88e6xxx_setup,
@@ -5422,6 +5636,12 @@ static const struct dsa_switch_ops mv88e6xxx_switch_ops 
= {
        .devlink_param_get      = mv88e6xxx_devlink_param_get,
        .devlink_param_set      = mv88e6xxx_devlink_param_set,
        .devlink_info_get       = mv88e6xxx_devlink_info_get,
+       .port_lag_change        = mv88e6xxx_port_lag_change,
+       .port_lag_join          = mv88e6xxx_port_lag_join,
+       .port_lag_leave         = mv88e6xxx_port_lag_leave,
+       .crosschip_lag_change   = mv88e6xxx_crosschip_lag_change,
+       .crosschip_lag_join     = mv88e6xxx_crosschip_lag_join,
+       .crosschip_lag_leave    = mv88e6xxx_crosschip_lag_leave,
 };
 
 static int mv88e6xxx_register_switch(struct mv88e6xxx_chip *chip)
@@ -5441,6 +5661,12 @@ static int mv88e6xxx_register_switch(struct 
mv88e6xxx_chip *chip)
        ds->ageing_time_min = chip->info->age_time_coeff;
        ds->ageing_time_max = chip->info->age_time_coeff * U8_MAX;
 
+       /* Some chips support up to 32, but that requires enabling the
+        * 5-bit port mode, which we do not support. 640k^W16 ought to
+        * be enough for anyone.
+        */
+       ds->num_lags = 16;
+
        dev_set_drvdata(dev, ds);
 
        return dsa_register_switch(ds);
diff --git a/drivers/net/dsa/mv88e6xxx/chip.h b/drivers/net/dsa/mv88e6xxx/chip.h
index e196d7270606..fc7625593c81 100644
--- a/drivers/net/dsa/mv88e6xxx/chip.h
+++ b/drivers/net/dsa/mv88e6xxx/chip.h
@@ -580,6 +580,10 @@ struct mv88e6xxx_ops {
 
        /* Max Frame Size */
        int (*set_max_frame_size)(struct mv88e6xxx_chip *chip, int mtu);
+
+       /* Link aggregation */
+       int (*lag_set_map)(struct mv88e6xxx_chip *chip, struct dsa_lag *lag);
+       int (*lag_set_masks)(struct mv88e6xxx_chip *chip, struct dsa_lag *lag);
 };
 
 struct mv88e6xxx_irq_ops {
diff --git a/drivers/net/dsa/mv88e6xxx/global2.c 
b/drivers/net/dsa/mv88e6xxx/global2.c
index 8dbb1ae723ae..fa65ecd9cb85 100644
--- a/drivers/net/dsa/mv88e6xxx/global2.c
+++ b/drivers/net/dsa/mv88e6xxx/global2.c
@@ -126,8 +126,8 @@ int mv88e6xxx_g2_device_mapping_write(struct mv88e6xxx_chip 
*chip, int target,
 
 /* Offset 0x07: Trunk Mask Table register */
 
-static int mv88e6xxx_g2_trunk_mask_write(struct mv88e6xxx_chip *chip, int num,
-                                        bool hash, u16 mask)
+int mv88e6xxx_g2_trunk_mask_write(struct mv88e6xxx_chip *chip, int num,
+                                 bool hash, u16 mask)
 {
        u16 val = (num << 12) | (mask & mv88e6xxx_port_mask(chip));
 
@@ -140,8 +140,8 @@ static int mv88e6xxx_g2_trunk_mask_write(struct 
mv88e6xxx_chip *chip, int num,
 
 /* Offset 0x08: Trunk Mapping Table register */
 
-static int mv88e6xxx_g2_trunk_mapping_write(struct mv88e6xxx_chip *chip, int 
id,
-                                           u16 map)
+int mv88e6xxx_g2_trunk_mapping_write(struct mv88e6xxx_chip *chip, int id,
+                                    u16 map)
 {
        const u16 port_mask = BIT(mv88e6xxx_num_ports(chip)) - 1;
        u16 val = (id << 11) | (map & port_mask);
diff --git a/drivers/net/dsa/mv88e6xxx/global2.h 
b/drivers/net/dsa/mv88e6xxx/global2.h
index 1510a1c810c8..621bbc4a1d80 100644
--- a/drivers/net/dsa/mv88e6xxx/global2.h
+++ b/drivers/net/dsa/mv88e6xxx/global2.h
@@ -101,6 +101,7 @@
 #define MV88E6XXX_G2_PVT_ADDR_OP_WRITE_PVLAN   0x3000
 #define MV88E6XXX_G2_PVT_ADDR_OP_READ          0x4000
 #define MV88E6XXX_G2_PVT_ADDR_PTR_MASK         0x01ff
+#define MV88E6XXX_G2_PVT_ADRR_DEV_TRUNK                0x1f
 
 /* Offset 0x0C: Cross-chip Port VLAN Data Register */
 #define MV88E6XXX_G2_PVT_DATA          0x0c
@@ -347,6 +348,10 @@ int mv88e6352_g2_mgmt_rsvd2cpu(struct mv88e6xxx_chip 
*chip);
 
 int mv88e6xxx_g2_pot_clear(struct mv88e6xxx_chip *chip);
 
+int mv88e6xxx_g2_trunk_mask_write(struct mv88e6xxx_chip *chip, int num,
+                                 bool hash, u16 mask);
+int mv88e6xxx_g2_trunk_mapping_write(struct mv88e6xxx_chip *chip, int id,
+                                    u16 map);
 int mv88e6xxx_g2_trunk_clear(struct mv88e6xxx_chip *chip);
 
 int mv88e6xxx_g2_device_mapping_write(struct mv88e6xxx_chip *chip, int target,
diff --git a/drivers/net/dsa/mv88e6xxx/port.c b/drivers/net/dsa/mv88e6xxx/port.c
index 77a5fd1798cd..4b46e10a2dde 100644
--- a/drivers/net/dsa/mv88e6xxx/port.c
+++ b/drivers/net/dsa/mv88e6xxx/port.c
@@ -851,6 +851,27 @@ int mv88e6xxx_port_set_message_port(struct mv88e6xxx_chip 
*chip, int port,
        return mv88e6xxx_port_write(chip, port, MV88E6XXX_PORT_CTL1, val);
 }
 
+int mv88e6xxx_port_set_trunk(struct mv88e6xxx_chip *chip, int port,
+                            bool trunk, u8 id)
+{
+       u16 val;
+       int err;
+
+       err = mv88e6xxx_port_read(chip, port, MV88E6XXX_PORT_CTL1, &val);
+       if (err)
+               return err;
+
+       val &= ~MV88E6XXX_PORT_CTL1_TRUNK_ID_MASK;
+
+       if (trunk)
+               val |= MV88E6XXX_PORT_CTL1_TRUNK_PORT |
+                       (id << MV88E6XXX_PORT_CTL1_TRUNK_ID_SHIFT);
+       else
+               val &= ~MV88E6XXX_PORT_CTL1_TRUNK_PORT;
+
+       return mv88e6xxx_port_write(chip, port, MV88E6XXX_PORT_CTL1, val);
+}
+
 /* Offset 0x06: Port Based VLAN Map */
 
 int mv88e6xxx_port_set_vlan_map(struct mv88e6xxx_chip *chip, int port, u16 map)
diff --git a/drivers/net/dsa/mv88e6xxx/port.h b/drivers/net/dsa/mv88e6xxx/port.h
index 500e1d4896ff..a729bba050df 100644
--- a/drivers/net/dsa/mv88e6xxx/port.h
+++ b/drivers/net/dsa/mv88e6xxx/port.h
@@ -168,6 +168,9 @@
 /* Offset 0x05: Port Control 1 */
 #define MV88E6XXX_PORT_CTL1                    0x05
 #define MV88E6XXX_PORT_CTL1_MESSAGE_PORT       0x8000
+#define MV88E6XXX_PORT_CTL1_TRUNK_PORT         0x4000
+#define MV88E6XXX_PORT_CTL1_TRUNK_ID_MASK      0x0f00
+#define MV88E6XXX_PORT_CTL1_TRUNK_ID_SHIFT     8
 #define MV88E6XXX_PORT_CTL1_FID_11_4_MASK      0x00ff
 
 /* Offset 0x06: Port Based VLAN Map */
@@ -351,6 +354,8 @@ int mv88e6351_port_set_ether_type(struct mv88e6xxx_chip 
*chip, int port,
                                  u16 etype);
 int mv88e6xxx_port_set_message_port(struct mv88e6xxx_chip *chip, int port,
                                    bool message_port);
+int mv88e6xxx_port_set_trunk(struct mv88e6xxx_chip *chip, int port,
+                            bool trunk, u8 id);
 int mv88e6165_port_set_jumbo_size(struct mv88e6xxx_chip *chip, int port,
                                  size_t size);
 int mv88e6095_port_egress_rate_limiting(struct mv88e6xxx_chip *chip, int port);
-- 
2.17.1

Reply via email to