net: dsa: xrs700x: allow HSR/PRP supervision dupes for node_table
authorGeorge McCollister <george.mccollister@gmail.com>
Fri, 4 Jun 2021 16:29:22 +0000 (11:29 -0500)
committerDavid S. Miller <davem@davemloft.net>
Fri, 4 Jun 2021 21:49:28 +0000 (14:49 -0700)
Add an inbound policy filter which matches the HSR/PRP supervision
MAC range and forwards to the CPU port without discarding duplicates.
This is required to correctly populate time_in[A] and time_in[B] in the
HSR/PRP node_table. Leave the policy disabled by default and
enable/disable it when joining/leaving hsr.

Signed-off-by: George McCollister <george.mccollister@gmail.com>
Reviewed-by: Vladimir Oltean <olteanv@gmail.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
drivers/net/dsa/xrs700x/xrs700x.c

index fde6e99..a790661 100644 (file)
@@ -79,6 +79,9 @@ static const struct xrs700x_mib xrs700x_mibs[] = {
        XRS700X_MIB(XRS_EARLY_DROP_L, "early_drop", tx_dropped),
 };
 
+static const u8 eth_hsrsup_addr[ETH_ALEN] = {
+       0x01, 0x15, 0x4e, 0x00, 0x01, 0x00};
+
 static void xrs700x_get_strings(struct dsa_switch *ds, int port,
                                u32 stringset, u8 *data)
 {
@@ -329,6 +332,50 @@ static int xrs700x_port_add_bpdu_ipf(struct dsa_switch *ds, int port)
        return 0;
 }
 
+/* Add an inbound policy filter which matches the HSR/PRP supervision MAC
+ * range and forwards to the CPU port without discarding duplicates.
+ * This is required to correctly populate the HSR/PRP node_table.
+ * Leave the policy disabled, it will be enabled as needed.
+ */
+static int xrs700x_port_add_hsrsup_ipf(struct dsa_switch *ds, int port)
+{
+       struct xrs700x *priv = ds->priv;
+       unsigned int val = 0;
+       int i = 0;
+       int ret;
+
+       /* Compare 40 bits of the destination MAC address. */
+       ret = regmap_write(priv->regmap, XRS_ETH_ADDR_CFG(port, 1), 40 << 2);
+       if (ret)
+               return ret;
+
+       /* match HSR/PRP supervision destination 01:15:4e:00:01:XX */
+       for (i = 0; i < sizeof(eth_hsrsup_addr); i += 2) {
+               ret = regmap_write(priv->regmap, XRS_ETH_ADDR_0(port, 1) + i,
+                                  eth_hsrsup_addr[i] |
+                                  (eth_hsrsup_addr[i + 1] << 8));
+               if (ret)
+                       return ret;
+       }
+
+       /* Mirror HSR/PRP supervision to CPU port */
+       for (i = 0; i < ds->num_ports; i++) {
+               if (dsa_is_cpu_port(ds, i))
+                       val |= BIT(i);
+       }
+
+       ret = regmap_write(priv->regmap, XRS_ETH_ADDR_FWD_MIRROR(port, 1), val);
+       if (ret)
+               return ret;
+
+       /* Allow must be set prevent duplicate discard */
+       ret = regmap_write(priv->regmap, XRS_ETH_ADDR_FWD_ALLOW(port, 1), val);
+       if (ret)
+               return ret;
+
+       return 0;
+}
+
 static int xrs700x_port_setup(struct dsa_switch *ds, int port)
 {
        bool cpu_port = dsa_is_cpu_port(ds, port);
@@ -358,6 +405,10 @@ static int xrs700x_port_setup(struct dsa_switch *ds, int port)
                ret = xrs700x_port_add_bpdu_ipf(ds, port);
                if (ret)
                        return ret;
+
+               ret = xrs700x_port_add_hsrsup_ipf(ds, port);
+               if (ret)
+                       return ret;
        }
 
        return 0;
@@ -565,6 +616,14 @@ static int xrs700x_hsr_join(struct dsa_switch *ds, int port,
                            XRS_PORT_FORWARDING);
        regmap_fields_write(priv->ps_forward, port, XRS_PORT_FORWARDING);
 
+       /* Enable inbound policy added by xrs700x_port_add_hsrsup_ipf()
+        * which allows HSR/PRP supervision forwarding to the CPU port without
+        * discarding duplicates.
+        */
+       regmap_update_bits(priv->regmap,
+                          XRS_ETH_ADDR_CFG(partner->index, 1), 1, 1);
+       regmap_update_bits(priv->regmap, XRS_ETH_ADDR_CFG(port, 1), 1, 1);
+
        hsr_pair[0] = port;
        hsr_pair[1] = partner->index;
        for (i = 0; i < ARRAY_SIZE(hsr_pair); i++) {
@@ -611,6 +670,14 @@ static int xrs700x_hsr_leave(struct dsa_switch *ds, int port,
                            XRS_PORT_FORWARDING);
        regmap_fields_write(priv->ps_forward, port, XRS_PORT_FORWARDING);
 
+       /* Disable inbound policy added by xrs700x_port_add_hsrsup_ipf()
+        * which allows HSR/PRP supervision forwarding to the CPU port without
+        * discarding duplicates.
+        */
+       regmap_update_bits(priv->regmap,
+                          XRS_ETH_ADDR_CFG(partner->index, 1), 1, 0);
+       regmap_update_bits(priv->regmap, XRS_ETH_ADDR_CFG(port, 1), 1, 0);
+
        hsr_pair[0] = port;
        hsr_pair[1] = partner->index;
        for (i = 0; i < ARRAY_SIZE(hsr_pair); i++) {