OSDN Git Service

mlx5: Use dev_net netdevice notifier registrations
authorJiri Pirko <jiri@mellanox.com>
Sat, 25 Jan 2020 11:17:09 +0000 (12:17 +0100)
committerDavid S. Miller <davem@davemloft.net>
Mon, 27 Jan 2020 10:03:44 +0000 (11:03 +0100)
Register the dev_net notifier and allow the per-net notifier to follow
the device into different namespace.

Signed-off-by: Jiri Pirko <jiri@mellanox.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
drivers/net/ethernet/mellanox/mlx5/core/en/fs.h
drivers/net/ethernet/mellanox/mlx5/core/en_main.c
drivers/net/ethernet/mellanox/mlx5/core/en_rep.c
drivers/net/ethernet/mellanox/mlx5/core/en_rep.h
drivers/net/ethernet/mellanox/mlx5/core/en_tc.c
drivers/net/ethernet/mellanox/mlx5/core/lag.c
drivers/net/ethernet/mellanox/mlx5/core/lag.h
drivers/net/ethernet/mellanox/mlx5/core/mlx5_core.h

index d48292c..0416f77 100644 (file)
@@ -21,6 +21,7 @@ struct mlx5e_tc_table {
        DECLARE_HASHTABLE(hairpin_tbl, 8);
 
        struct notifier_block     netdevice_nb;
+       struct netdev_net_notifier      netdevice_nn;
 };
 
 struct mlx5e_flow_table {
index f3600ae..454d345 100644 (file)
@@ -5144,6 +5144,7 @@ static void mlx5e_nic_enable(struct mlx5e_priv *priv)
 
 static void mlx5e_nic_disable(struct mlx5e_priv *priv)
 {
+       struct net_device *netdev = priv->netdev;
        struct mlx5_core_dev *mdev = priv->mdev;
 
 #ifdef CONFIG_MLX5_CORE_EN_DCB
@@ -5164,7 +5165,7 @@ static void mlx5e_nic_disable(struct mlx5e_priv *priv)
                mlx5e_monitor_counter_cleanup(priv);
 
        mlx5e_disable_async_events(priv);
-       mlx5_lag_remove(mdev);
+       mlx5_lag_remove(mdev, netdev);
 }
 
 int mlx5e_update_nic_rx(struct mlx5e_priv *priv)
index 09061b4..7b48cca 100644 (file)
@@ -1731,7 +1731,9 @@ static int mlx5e_init_uplink_rep_tx(struct mlx5e_rep_priv *rpriv)
        /* init indirect block notifications */
        INIT_LIST_HEAD(&uplink_priv->tc_indr_block_priv_list);
        uplink_priv->netdevice_nb.notifier_call = mlx5e_nic_rep_netdevice_event;
-       err = register_netdevice_notifier(&uplink_priv->netdevice_nb);
+       err = register_netdevice_notifier_dev_net(rpriv->netdev,
+                                                 &uplink_priv->netdevice_nb,
+                                                 &uplink_priv->netdevice_nn);
        if (err) {
                mlx5_core_err(priv->mdev, "Failed to register netdev notifier\n");
                goto tc_esw_cleanup;
@@ -1770,8 +1772,12 @@ destroy_tises:
 
 static void mlx5e_cleanup_uplink_rep_tx(struct mlx5e_rep_priv *rpriv)
 {
+       struct mlx5_rep_uplink_priv *uplink_priv = &rpriv->uplink_priv;
+
        /* clean indirect TC block notifications */
-       unregister_netdevice_notifier(&rpriv->uplink_priv.netdevice_nb);
+       unregister_netdevice_notifier_dev_net(rpriv->netdev,
+                                             &uplink_priv->netdevice_nb,
+                                             &uplink_priv->netdevice_nn);
        mlx5e_rep_indr_clean_block_privs(rpriv);
 
        /* delete shared tc flow table */
@@ -1855,6 +1861,7 @@ static void mlx5e_uplink_rep_enable(struct mlx5e_priv *priv)
 
 static void mlx5e_uplink_rep_disable(struct mlx5e_priv *priv)
 {
+       struct net_device *netdev = priv->netdev;
        struct mlx5_core_dev *mdev = priv->mdev;
        struct mlx5e_rep_priv *rpriv = priv->ppriv;
 
@@ -1863,7 +1870,7 @@ static void mlx5e_uplink_rep_disable(struct mlx5e_priv *priv)
 #endif
        mlx5_notifier_unregister(mdev, &priv->events_nb);
        cancel_work_sync(&rpriv->uplink_priv.reoffload_flows_work);
-       mlx5_lag_remove(mdev);
+       mlx5_lag_remove(mdev, netdev);
 }
 
 static MLX5E_DEFINE_STATS_GRP(sw_rep, 0);
index 31f83c8..3f756d5 100644 (file)
@@ -73,6 +73,7 @@ struct mlx5_rep_uplink_priv {
         */
        struct list_head            tc_indr_block_priv_list;
        struct notifier_block       netdevice_nb;
+       struct netdev_net_notifier  netdevice_nn;
 
        struct mlx5_tun_entropy tun_entropy;
 
index 915afb2..74091f7 100644 (file)
@@ -4251,7 +4251,10 @@ int mlx5e_tc_nic_init(struct mlx5e_priv *priv)
                return err;
 
        tc->netdevice_nb.notifier_call = mlx5e_tc_netdev_event;
-       if (register_netdevice_notifier(&tc->netdevice_nb)) {
+       err = register_netdevice_notifier_dev_net(priv->netdev,
+                                                 &tc->netdevice_nb,
+                                                 &tc->netdevice_nn);
+       if (err) {
                tc->netdevice_nb.notifier_call = NULL;
                mlx5_core_warn(priv->mdev, "Failed to register netdev notifier\n");
        }
@@ -4273,7 +4276,9 @@ void mlx5e_tc_nic_cleanup(struct mlx5e_priv *priv)
        struct mlx5e_tc_table *tc = &priv->fs.tc;
 
        if (tc->netdevice_nb.notifier_call)
-               unregister_netdevice_notifier(&tc->netdevice_nb);
+               unregister_netdevice_notifier_dev_net(priv->netdev,
+                                                     &tc->netdevice_nb,
+                                                     &tc->netdevice_nn);
 
        mutex_destroy(&tc->mod_hdr.lock);
        mutex_destroy(&tc->hairpin_tbl_lock);
index fc0d958..b91eabc 100644 (file)
@@ -586,7 +586,8 @@ void mlx5_lag_add(struct mlx5_core_dev *dev, struct net_device *netdev)
 
        if (!ldev->nb.notifier_call) {
                ldev->nb.notifier_call = mlx5_lag_netdev_event;
-               if (register_netdevice_notifier(&ldev->nb)) {
+               if (register_netdevice_notifier_dev_net(netdev, &ldev->nb,
+                                                       &ldev->nn)) {
                        ldev->nb.notifier_call = NULL;
                        mlx5_core_err(dev, "Failed to register LAG netdev notifier\n");
                }
@@ -599,7 +600,7 @@ void mlx5_lag_add(struct mlx5_core_dev *dev, struct net_device *netdev)
 }
 
 /* Must be called with intf_mutex held */
-void mlx5_lag_remove(struct mlx5_core_dev *dev)
+void mlx5_lag_remove(struct mlx5_core_dev *dev, struct net_device *netdev)
 {
        struct mlx5_lag *ldev;
        int i;
@@ -619,7 +620,8 @@ void mlx5_lag_remove(struct mlx5_core_dev *dev)
 
        if (i == MLX5_MAX_PORTS) {
                if (ldev->nb.notifier_call)
-                       unregister_netdevice_notifier(&ldev->nb);
+                       unregister_netdevice_notifier_dev_net(netdev, &ldev->nb,
+                                                             &ldev->nn);
                mlx5_lag_mp_cleanup(ldev);
                cancel_delayed_work_sync(&ldev->bond_work);
                mlx5_lag_dev_free(ldev);
index f1068aa..316ab09 100644 (file)
@@ -44,6 +44,7 @@ struct mlx5_lag {
        struct workqueue_struct   *wq;
        struct delayed_work       bond_work;
        struct notifier_block     nb;
+       struct netdev_net_notifier      nn;
        struct lag_mp             lag_mp;
 };
 
index da67b28..fcce9e0 100644 (file)
@@ -157,7 +157,7 @@ int mlx5_query_qcam_reg(struct mlx5_core_dev *mdev, u32 *qcam,
                        u8 feature_group, u8 access_reg_group);
 
 void mlx5_lag_add(struct mlx5_core_dev *dev, struct net_device *netdev);
-void mlx5_lag_remove(struct mlx5_core_dev *dev);
+void mlx5_lag_remove(struct mlx5_core_dev *dev, struct net_device *netdev);
 
 int mlx5_irq_table_init(struct mlx5_core_dev *dev);
 void mlx5_irq_table_cleanup(struct mlx5_core_dev *dev);