Commit 6bf08b53 authored by Nogah Frankel's avatar Nogah Frankel Committed by David S. Miller

mlxsw: switchx2: Use generic listener struct for events

Change the events to use the generic listener struct.
Merge the event list into the trap list, so the same functions will
handle both.
Signed-off-by: default avatarNogah Frankel <nogahf@mellanox.com>
Signed-off-by: default avatarJiri Pirko <jiri@mellanox.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 4544913e
...@@ -1396,52 +1396,6 @@ static void mlxsw_sx_pude_event_func(const struct mlxsw_reg_info *reg, ...@@ -1396,52 +1396,6 @@ static void mlxsw_sx_pude_event_func(const struct mlxsw_reg_info *reg,
mlxsw_sx_pude_ib_event_func(mlxsw_sx_port, status); mlxsw_sx_pude_ib_event_func(mlxsw_sx_port, status);
} }
static struct mlxsw_event_listener mlxsw_sx_pude_event = {
.func = mlxsw_sx_pude_event_func,
.trap_id = MLXSW_TRAP_ID_PUDE,
};
static int mlxsw_sx_event_register(struct mlxsw_sx *mlxsw_sx,
enum mlxsw_event_trap_id trap_id)
{
struct mlxsw_event_listener *el;
char hpkt_pl[MLXSW_REG_HPKT_LEN];
int err;
switch (trap_id) {
case MLXSW_TRAP_ID_PUDE:
el = &mlxsw_sx_pude_event;
break;
}
err = mlxsw_core_event_listener_register(mlxsw_sx->core, el, mlxsw_sx);
if (err)
return err;
mlxsw_reg_hpkt_pack(hpkt_pl, MLXSW_REG_HPKT_ACTION_FORWARD, trap_id);
err = mlxsw_reg_write(mlxsw_sx->core, MLXSW_REG(hpkt), hpkt_pl);
if (err)
goto err_event_trap_set;
return 0;
err_event_trap_set:
mlxsw_core_event_listener_unregister(mlxsw_sx->core, el, mlxsw_sx);
return err;
}
static void mlxsw_sx_event_unregister(struct mlxsw_sx *mlxsw_sx,
enum mlxsw_event_trap_id trap_id)
{
struct mlxsw_event_listener *el;
switch (trap_id) {
case MLXSW_TRAP_ID_PUDE:
el = &mlxsw_sx_pude_event;
break;
}
mlxsw_core_event_listener_unregister(mlxsw_sx->core, el, mlxsw_sx);
}
static void mlxsw_sx_rx_listener_func(struct sk_buff *skb, u8 local_port, static void mlxsw_sx_rx_listener_func(struct sk_buff *skb, u8 local_port,
void *priv) void *priv)
{ {
...@@ -1497,7 +1451,8 @@ static int mlxsw_sx_port_type_set(struct mlxsw_core *mlxsw_core, u8 local_port, ...@@ -1497,7 +1451,8 @@ static int mlxsw_sx_port_type_set(struct mlxsw_core *mlxsw_core, u8 local_port,
#define MLXSW_SX_RXL(_trap_id) \ #define MLXSW_SX_RXL(_trap_id) \
MLXSW_RXL(mlxsw_sx_rx_listener_func, _trap_id, TRAP_TO_CPU, FORWARD) MLXSW_RXL(mlxsw_sx_rx_listener_func, _trap_id, TRAP_TO_CPU, FORWARD)
static const struct mlxsw_listener mlxsw_sx_rx_listener[] = { static const struct mlxsw_listener mlxsw_sx_listener[] = {
MLXSW_EVENTL(mlxsw_sx_pude_event_func, PUDE),
MLXSW_SX_RXL(FDB_MC), MLXSW_SX_RXL(FDB_MC),
MLXSW_SX_RXL(STP), MLXSW_SX_RXL(STP),
MLXSW_SX_RXL(LACP), MLXSW_SX_RXL(LACP),
...@@ -1530,20 +1485,20 @@ static int mlxsw_sx_traps_init(struct mlxsw_sx *mlxsw_sx) ...@@ -1530,20 +1485,20 @@ static int mlxsw_sx_traps_init(struct mlxsw_sx *mlxsw_sx)
if (err) if (err)
return err; return err;
for (i = 0; i < ARRAY_SIZE(mlxsw_sx_rx_listener); i++) { for (i = 0; i < ARRAY_SIZE(mlxsw_sx_listener); i++) {
err = mlxsw_core_trap_register(mlxsw_sx->core, err = mlxsw_core_trap_register(mlxsw_sx->core,
&mlxsw_sx_rx_listener[i], &mlxsw_sx_listener[i],
mlxsw_sx); mlxsw_sx);
if (err) if (err)
goto err_rx_listener_register; goto err_listener_register;
} }
return 0; return 0;
err_rx_listener_register: err_listener_register:
for (i--; i >= 0; i--) { for (i--; i >= 0; i--) {
mlxsw_core_trap_unregister(mlxsw_sx->core, mlxsw_core_trap_unregister(mlxsw_sx->core,
&mlxsw_sx_rx_listener[i], &mlxsw_sx_listener[i],
mlxsw_sx); mlxsw_sx);
} }
return err; return err;
...@@ -1553,9 +1508,9 @@ static void mlxsw_sx_traps_fini(struct mlxsw_sx *mlxsw_sx) ...@@ -1553,9 +1508,9 @@ static void mlxsw_sx_traps_fini(struct mlxsw_sx *mlxsw_sx)
{ {
int i; int i;
for (i = 0; i < ARRAY_SIZE(mlxsw_sx_rx_listener); i++) { for (i = 0; i < ARRAY_SIZE(mlxsw_sx_listener); i++) {
mlxsw_core_trap_unregister(mlxsw_sx->core, mlxsw_core_trap_unregister(mlxsw_sx->core,
&mlxsw_sx_rx_listener[i], &mlxsw_sx_listener[i],
mlxsw_sx); mlxsw_sx);
} }
} }
...@@ -1649,16 +1604,10 @@ static int mlxsw_sx_init(struct mlxsw_core *mlxsw_core, ...@@ -1649,16 +1604,10 @@ static int mlxsw_sx_init(struct mlxsw_core *mlxsw_core,
return err; return err;
} }
err = mlxsw_sx_event_register(mlxsw_sx, MLXSW_TRAP_ID_PUDE);
if (err) {
dev_err(mlxsw_sx->bus_info->dev, "Failed to register for PUDE events\n");
goto err_event_register;
}
err = mlxsw_sx_traps_init(mlxsw_sx); err = mlxsw_sx_traps_init(mlxsw_sx);
if (err) { if (err) {
dev_err(mlxsw_sx->bus_info->dev, "Failed to set traps for RX\n"); dev_err(mlxsw_sx->bus_info->dev, "Failed to set traps\n");
goto err_rx_listener_register; goto err_listener_register;
} }
err = mlxsw_sx_flood_init(mlxsw_sx); err = mlxsw_sx_flood_init(mlxsw_sx);
...@@ -1671,9 +1620,7 @@ static int mlxsw_sx_init(struct mlxsw_core *mlxsw_core, ...@@ -1671,9 +1620,7 @@ static int mlxsw_sx_init(struct mlxsw_core *mlxsw_core,
err_flood_init: err_flood_init:
mlxsw_sx_traps_fini(mlxsw_sx); mlxsw_sx_traps_fini(mlxsw_sx);
err_rx_listener_register: err_listener_register:
mlxsw_sx_event_unregister(mlxsw_sx, MLXSW_TRAP_ID_PUDE);
err_event_register:
mlxsw_sx_ports_remove(mlxsw_sx); mlxsw_sx_ports_remove(mlxsw_sx);
return err; return err;
} }
...@@ -1683,7 +1630,6 @@ static void mlxsw_sx_fini(struct mlxsw_core *mlxsw_core) ...@@ -1683,7 +1630,6 @@ static void mlxsw_sx_fini(struct mlxsw_core *mlxsw_core)
struct mlxsw_sx *mlxsw_sx = mlxsw_core_driver_priv(mlxsw_core); struct mlxsw_sx *mlxsw_sx = mlxsw_core_driver_priv(mlxsw_core);
mlxsw_sx_traps_fini(mlxsw_sx); mlxsw_sx_traps_fini(mlxsw_sx);
mlxsw_sx_event_unregister(mlxsw_sx, MLXSW_TRAP_ID_PUDE);
mlxsw_sx_ports_remove(mlxsw_sx); mlxsw_sx_ports_remove(mlxsw_sx);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment