]> www.infradead.org Git - nvme.git/commitdiff
net: sparx5: add port mirroring implementation
authorDaniel Machon <daniel.machon@microchip.com>
Sat, 20 Apr 2024 19:29:12 +0000 (21:29 +0200)
committerDavid S. Miller <davem@davemloft.net>
Wed, 24 Apr 2024 12:08:06 +0000 (13:08 +0100)
The hardware supports three independent mirroring probes. Each probe can
be configured to mirror rx or tx traffic (direction).

Using tc matchall, it is now possible to add a source port and a monitor
port to a mirror probe. Depending on the mirror direction, rx or tx
traffic from a source port will be mirrored to the monitor port.

A single source port can be a member of multiple mirror probes.

Signed-off-by: Daniel Machon <daniel.machon@microchip.com>
Reviewed-by: Steen Hegelund <Steen.Hegelund@microchip.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
drivers/net/ethernet/microchip/sparx5/Makefile
drivers/net/ethernet/microchip/sparx5/sparx5_main.h
drivers/net/ethernet/microchip/sparx5/sparx5_mirror.c [new file with mode: 0644]

index 1cb1cc3f1a85463a26477278bd9c0c61eb2337c7..b68fe9c9a656dd18514240168d708303adc69d5e 100644 (file)
@@ -10,7 +10,8 @@ sparx5-switch-y  := sparx5_main.o sparx5_packet.o \
  sparx5_switchdev.o sparx5_calendar.o sparx5_ethtool.o sparx5_fdma.o \
  sparx5_ptp.o sparx5_pgid.o sparx5_tc.o sparx5_qos.o \
  sparx5_vcap_impl.o sparx5_vcap_ag_api.o sparx5_tc_flower.o \
- sparx5_tc_matchall.o sparx5_pool.o sparx5_sdlb.o sparx5_police.o sparx5_psfp.o
+ sparx5_tc_matchall.o sparx5_pool.o sparx5_sdlb.o sparx5_police.o \
+ sparx5_psfp.o sparx5_mirror.o
 
 sparx5-switch-$(CONFIG_SPARX5_DCB) += sparx5_dcb.o
 sparx5-switch-$(CONFIG_DEBUG_FS) += sparx5_vcap_debugfs.o
index 4de37a5387a4991882703290eee393002e78fdad..5d026e1670f5afc15c4f05364f3e4093577c3886 100644 (file)
@@ -228,12 +228,20 @@ struct sparx5_mdb_entry {
        u16 pgid_idx;
 };
 
+struct sparx5_mall_mirror_entry {
+       u32 idx;
+       struct sparx5_port *port;
+};
+
 struct sparx5_mall_entry {
        struct list_head list;
        struct sparx5_port *port;
        unsigned long cookie;
        enum flow_action_id type;
        bool ingress;
+       union {
+               struct sparx5_mall_mirror_entry mirror;
+       };
 };
 
 #define SPARX5_PTP_TIMEOUT             msecs_to_jiffies(10)
@@ -551,6 +559,10 @@ void sparx5_psfp_init(struct sparx5 *sparx5);
 void sparx5_new_base_time(struct sparx5 *sparx5, const u32 cycle_time,
                          const ktime_t org_base_time, ktime_t *new_base_time);
 
+/* sparx5_mirror.c */
+int sparx5_mirror_add(struct sparx5_mall_entry *entry);
+void sparx5_mirror_del(struct sparx5_mall_entry *entry);
+
 /* Clock period in picoseconds */
 static inline u32 sparx5_clk_period(enum sparx5_core_clockfreq cclock)
 {
diff --git a/drivers/net/ethernet/microchip/sparx5/sparx5_mirror.c b/drivers/net/ethernet/microchip/sparx5/sparx5_mirror.c
new file mode 100644 (file)
index 0000000..f029634
--- /dev/null
@@ -0,0 +1,198 @@
+// SPDX-License-Identifier: GPL-2.0+
+/* Microchip Sparx5 Switch driver
+ *
+ * Copyright (c) 2024 Microchip Technology Inc. and its subsidiaries.
+ */
+
+#include "sparx5_main.h"
+#include "sparx5_main_regs.h"
+#include "sparx5_tc.h"
+
+#define SPX5_MIRROR_PROBE_MAX 3
+#define SPX5_MIRROR_DISABLED 0
+#define SPX5_MIRROR_EGRESS 1
+#define SPX5_MIRROR_INGRESS 2
+#define SPX5_MIRROR_MONITOR_PORT_DEFAULT 65
+#define SPX5_QFWD_MP_OFFSET 9 /* Mirror port offset in the QFWD register */
+
+/* Convert from bool ingress/egress to mirror direction */
+static u32 sparx5_mirror_to_dir(bool ingress)
+{
+       return ingress ? SPX5_MIRROR_INGRESS : SPX5_MIRROR_EGRESS;
+}
+
+/* Get ports belonging to this mirror */
+static u64 sparx5_mirror_port_get(struct sparx5 *sparx5, u32 idx)
+{
+       return (u64)spx5_rd(sparx5, ANA_AC_PROBE_PORT_CFG1(idx)) << 32 |
+              spx5_rd(sparx5, ANA_AC_PROBE_PORT_CFG(idx));
+}
+
+/* Add port to mirror (only front ports) */
+static void sparx5_mirror_port_add(struct sparx5 *sparx5, u32 idx, u32 portno)
+{
+       u32 val, reg = portno;
+
+       reg = portno / BITS_PER_BYTE;
+       val = BIT(portno % BITS_PER_BYTE);
+
+       if (reg == 0)
+               return spx5_rmw(val, val, sparx5, ANA_AC_PROBE_PORT_CFG(idx));
+       else
+               return spx5_rmw(val, val, sparx5, ANA_AC_PROBE_PORT_CFG1(idx));
+}
+
+/* Delete port from mirror (only front ports) */
+static void sparx5_mirror_port_del(struct sparx5 *sparx5, u32 idx, u32 portno)
+{
+       u32 val, reg = portno;
+
+       reg = portno / BITS_PER_BYTE;
+       val = BIT(portno % BITS_PER_BYTE);
+
+       if (reg == 0)
+               return spx5_rmw(0, val, sparx5, ANA_AC_PROBE_PORT_CFG(idx));
+       else
+               return spx5_rmw(0, val, sparx5, ANA_AC_PROBE_PORT_CFG1(idx));
+}
+
+/* Check if mirror contains port */
+static bool sparx5_mirror_contains(struct sparx5 *sparx5, u32 idx, u32 portno)
+{
+       return (sparx5_mirror_port_get(sparx5, idx) & BIT_ULL(portno)) != 0;
+}
+
+/* Check if mirror is empty */
+static bool sparx5_mirror_is_empty(struct sparx5 *sparx5, u32 idx)
+{
+       return sparx5_mirror_port_get(sparx5, idx) == 0;
+}
+
+/* Get direction of mirror */
+static u32 sparx5_mirror_dir_get(struct sparx5 *sparx5, u32 idx)
+{
+       u32 val = spx5_rd(sparx5, ANA_AC_PROBE_CFG(idx));
+
+       return ANA_AC_PROBE_CFG_PROBE_DIRECTION_GET(val);
+}
+
+/* Set direction of mirror */
+static void sparx5_mirror_dir_set(struct sparx5 *sparx5, u32 idx, u32 dir)
+{
+       spx5_rmw(ANA_AC_PROBE_CFG_PROBE_DIRECTION_SET(dir),
+                ANA_AC_PROBE_CFG_PROBE_DIRECTION, sparx5,
+                ANA_AC_PROBE_CFG(idx));
+}
+
+/* Set the monitor port for this mirror */
+static void sparx5_mirror_monitor_set(struct sparx5 *sparx5, u32 idx,
+                                     u32 portno)
+{
+       spx5_rmw(QFWD_FRAME_COPY_CFG_FRMC_PORT_VAL_SET(portno),
+                QFWD_FRAME_COPY_CFG_FRMC_PORT_VAL, sparx5,
+                QFWD_FRAME_COPY_CFG(idx + SPX5_QFWD_MP_OFFSET));
+}
+
+/* Get the monitor port of this mirror */
+static u32 sparx5_mirror_monitor_get(struct sparx5 *sparx5, u32 idx)
+{
+       u32 val = spx5_rd(sparx5,
+                         QFWD_FRAME_COPY_CFG(idx + SPX5_QFWD_MP_OFFSET));
+
+       return QFWD_FRAME_COPY_CFG_FRMC_PORT_VAL_GET(val);
+}
+
+/* Check if port is the monitor port of this mirror */
+static bool sparx5_mirror_has_monitor(struct sparx5 *sparx5, u32 idx,
+                                     u32 portno)
+{
+       return sparx5_mirror_monitor_get(sparx5, idx) == portno;
+}
+
+/* Get a suitable mirror for this port */
+static int sparx5_mirror_get(struct sparx5_port *sport,
+                            struct sparx5_port *mport, u32 dir, u32 *idx)
+{
+       struct sparx5 *sparx5 = sport->sparx5;
+       u32 i;
+
+       /* Check if this port is already used as a monitor port */
+       for (i = 0; i < SPX5_MIRROR_PROBE_MAX; i++)
+               if (sparx5_mirror_has_monitor(sparx5, i, sport->portno))
+                       return -EINVAL;
+
+       /* Check if existing mirror can be reused
+        * (same direction and monitor port).
+        */
+       for (i = 0; i < SPX5_MIRROR_PROBE_MAX; i++) {
+               if (sparx5_mirror_dir_get(sparx5, i) == dir &&
+                   sparx5_mirror_has_monitor(sparx5, i, mport->portno)) {
+                       *idx = i;
+                       return 0;
+               }
+       }
+
+       /* Return free mirror */
+       for (i = 0; i < SPX5_MIRROR_PROBE_MAX; i++) {
+               if (sparx5_mirror_is_empty(sparx5, i)) {
+                       *idx = i;
+                       return 0;
+               }
+       }
+
+       return -ENOENT;
+}
+
+int sparx5_mirror_add(struct sparx5_mall_entry *entry)
+{
+       u32 mirror_idx, dir = sparx5_mirror_to_dir(entry->ingress);
+       struct sparx5_port *sport, *mport;
+       struct sparx5 *sparx5;
+       int err;
+
+       /* Source port */
+       sport = entry->port;
+       /* monitor port */
+       mport = entry->mirror.port;
+       sparx5 = sport->sparx5;
+
+       if (sport->portno == mport->portno)
+               return -EINVAL;
+
+       err = sparx5_mirror_get(sport, mport, dir, &mirror_idx);
+       if (err)
+               return err;
+
+       if (sparx5_mirror_contains(sparx5, mirror_idx, sport->portno))
+               return -EEXIST;
+
+       /* Add port to mirror */
+       sparx5_mirror_port_add(sparx5, mirror_idx, sport->portno);
+
+       /* Set direction of mirror */
+       sparx5_mirror_dir_set(sparx5, mirror_idx, dir);
+
+       /* Set monitor port for mirror */
+       sparx5_mirror_monitor_set(sparx5, mirror_idx, mport->portno);
+
+       entry->mirror.idx = mirror_idx;
+
+       return 0;
+}
+
+void sparx5_mirror_del(struct sparx5_mall_entry *entry)
+{
+       struct sparx5_port *port = entry->port;
+       struct sparx5 *sparx5 = port->sparx5;
+       u32 mirror_idx = entry->mirror.idx;
+
+       sparx5_mirror_port_del(sparx5, mirror_idx, port->portno);
+       if (!sparx5_mirror_is_empty(sparx5, mirror_idx))
+               return;
+
+       sparx5_mirror_dir_set(sparx5, mirror_idx, SPX5_MIRROR_DISABLED);
+
+       sparx5_mirror_monitor_set(sparx5,
+                                 mirror_idx,
+                                 SPX5_MIRROR_MONITOR_PORT_DEFAULT);
+}