net/mlx5: Use own workqueue for lag netdev events processing

Instead of using the system workqueue, allocate our own workqueue.
This workqueue will be used to handle more work in the next patch.

This patch doesn't change functionality.

Signed-off-by: Roi Dayan <roid@mellanox.com>
Reviewed-by: Or Gerlitz <ogerlitz@mellanox.com>
Signed-off-by: Saeed Mahameed <saeedm@mellanox.com>

diff --git a/drivers/net/ethernet/mellanox/mlx5/core/lag.c b/drivers/net/ethernet/mellanox/mlx5/core/lag.c
index 3b0f7cf822d5878c40a18e6314d4ad2761c683ed..eff5c54818b7ccb75caa578aa8f40fd2e9f8d06b 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlx5/core/lag.c
+++ b/drivers/net/ethernet/mellanox/mlx5/core/lag.c
@@ -346,7 +346,7 @@ static void mlx5_do_bond(struct mlx5_lag *ldev)
 
 static void mlx5_queue_bond_work(struct mlx5_lag *ldev, unsigned long delay)
 {
-       schedule_delayed_work(&ldev->bond_work, delay);
+       queue_delayed_work(ldev->wq, &ldev->bond_work, delay);
 }
 
 static void mlx5_do_bond_work(struct work_struct *work)
@@ -498,6 +498,12 @@ static struct mlx5_lag *mlx5_lag_dev_alloc(void)
        if (!ldev)
                return NULL;
 
+       ldev->wq = create_singlethread_workqueue("mlx5_lag");
+       if (!ldev->wq) {
+               kfree(ldev);
+               return NULL;
+       }
+
        INIT_DELAYED_WORK(&ldev->bond_work, mlx5_do_bond_work);
 
        return ldev;
@@ -505,6 +511,7 @@ static struct mlx5_lag *mlx5_lag_dev_alloc(void)
 
 static void mlx5_lag_dev_free(struct mlx5_lag *ldev)
 {
+       destroy_workqueue(ldev->wq);
        kfree(ldev);
 }
 

diff --git a/drivers/net/ethernet/mellanox/mlx5/core/lag.h b/drivers/net/ethernet/mellanox/mlx5/core/lag.h
index a6637016c1ab1b0a48a6a0dfaee1982686fdc86c..58f93d411ad53bb1ec0eb7fcd393ca92855c203a 100644 (file)
--- a/drivers/net/ethernet/mellanox/mlx5/core/lag.h
+++ b/drivers/net/ethernet/mellanox/mlx5/core/lag.h
@@ -33,6 +33,7 @@ struct mlx5_lag {
        u8                        v2p_map[MLX5_MAX_PORTS];
        struct lag_func           pf[MLX5_MAX_PORTS];
        struct lag_tracker        tracker;
+       struct workqueue_struct   *wq;
        struct delayed_work       bond_work;
        struct notifier_block     nb;
 };