]> git.itanic.dy.fi Git - linux-stable/commitdiff
net/mlx5: split mlx5_cmd_init() to probe and reload routines
authorShay Drory <shayd@nvidia.com>
Wed, 18 Jan 2023 18:55:54 +0000 (20:55 +0200)
committerSaeed Mahameed <saeedm@nvidia.com>
Thu, 27 Jul 2023 18:37:29 +0000 (11:37 -0700)
There is no need to destroy and allocate cmd SW structs during reload,
this is time consuming for no reason.
Hence, split mlx5_cmd_init() to probe and reload routines.

Signed-off-by: Shay Drory <shayd@nvidia.com>
Reviewed-by: Moshe Shemesh <moshe@nvidia.com>
Signed-off-by: Saeed Mahameed <saeedm@nvidia.com>
drivers/net/ethernet/mellanox/mlx5/core/cmd.c
drivers/net/ethernet/mellanox/mlx5/core/main.c
drivers/net/ethernet/mellanox/mlx5/core/mlx5_core.h

index 9ced943ebd0d192d4a3ffd0b4c27c2d183266002..45edd5a110c8682e5088e3e4f66640011cd50903 100644 (file)
@@ -1548,7 +1548,6 @@ static void clean_debug_files(struct mlx5_core_dev *dev)
        if (!mlx5_debugfs_root)
                return;
 
-       mlx5_cmdif_debugfs_cleanup(dev);
        debugfs_remove_recursive(dbg->dbg_root);
 }
 
@@ -1563,8 +1562,6 @@ static void create_debugfs_files(struct mlx5_core_dev *dev)
        debugfs_create_file("out_len", 0600, dbg->dbg_root, dev, &olfops);
        debugfs_create_u8("status", 0600, dbg->dbg_root, &dbg->status);
        debugfs_create_file("run", 0200, dbg->dbg_root, dev, &fops);
-
-       mlx5_cmdif_debugfs_init(dev);
 }
 
 void mlx5_cmd_allowed_opcode(struct mlx5_core_dev *dev, u16 opcode)
@@ -2190,19 +2187,10 @@ int mlx5_cmd_init(struct mlx5_core_dev *dev)
        int size = sizeof(struct mlx5_cmd_prot_block);
        int align = roundup_pow_of_two(size);
        struct mlx5_cmd *cmd = &dev->cmd;
-       u32 cmd_h, cmd_l;
+       u32 cmd_l;
        int err;
        int i;
 
-       memset(cmd, 0, sizeof(*cmd));
-       cmd->vars.cmdif_rev = cmdif_rev(dev);
-       if (cmd->vars.cmdif_rev != CMD_IF_REV) {
-               mlx5_core_err(dev,
-                             "Driver cmdif rev(%d) differs from firmware's(%d)\n",
-                             CMD_IF_REV, cmd->vars.cmdif_rev);
-               return -EINVAL;
-       }
-
        cmd->pool = dma_pool_create("mlx5_cmd", mlx5_core_dma_dev(dev), size, align, 0);
        if (!cmd->pool)
                return -ENOMEM;
@@ -2211,43 +2199,93 @@ int mlx5_cmd_init(struct mlx5_core_dev *dev)
        if (err)
                goto err_free_pool;
 
+       cmd_l = (u32)(cmd->dma);
+       if (cmd_l & 0xfff) {
+               mlx5_core_err(dev, "invalid command queue address\n");
+               err = -ENOMEM;
+               goto err_cmd_page;
+       }
+       cmd->checksum_disabled = 1;
+
+       spin_lock_init(&cmd->alloc_lock);
+       spin_lock_init(&cmd->token_lock);
+       for (i = 0; i < MLX5_CMD_OP_MAX; i++)
+               spin_lock_init(&cmd->stats[i].lock);
+
+       create_msg_cache(dev);
+
+       set_wqname(dev);
+       cmd->wq = create_singlethread_workqueue(cmd->wq_name);
+       if (!cmd->wq) {
+               mlx5_core_err(dev, "failed to create command workqueue\n");
+               err = -ENOMEM;
+               goto err_cache;
+       }
+
+       mlx5_cmdif_debugfs_init(dev);
+
+       return 0;
+
+err_cache:
+       destroy_msg_cache(dev);
+err_cmd_page:
+       free_cmd_page(dev, cmd);
+err_free_pool:
+       dma_pool_destroy(cmd->pool);
+       return err;
+}
+
+void mlx5_cmd_cleanup(struct mlx5_core_dev *dev)
+{
+       struct mlx5_cmd *cmd = &dev->cmd;
+
+       mlx5_cmdif_debugfs_cleanup(dev);
+       destroy_workqueue(cmd->wq);
+       destroy_msg_cache(dev);
+       free_cmd_page(dev, cmd);
+       dma_pool_destroy(cmd->pool);
+}
+
+int mlx5_cmd_enable(struct mlx5_core_dev *dev)
+{
+       struct mlx5_cmd *cmd = &dev->cmd;
+       u32 cmd_h, cmd_l;
+
+       memset(&cmd->vars, 0, sizeof(cmd->vars));
+       cmd->vars.cmdif_rev = cmdif_rev(dev);
+       if (cmd->vars.cmdif_rev != CMD_IF_REV) {
+               mlx5_core_err(dev,
+                             "Driver cmdif rev(%d) differs from firmware's(%d)\n",
+                             CMD_IF_REV, cmd->vars.cmdif_rev);
+               return -EINVAL;
+       }
+
        cmd_l = ioread32be(&dev->iseg->cmdq_addr_l_sz) & 0xff;
        cmd->vars.log_sz = cmd_l >> 4 & 0xf;
        cmd->vars.log_stride = cmd_l & 0xf;
        if (1 << cmd->vars.log_sz > MLX5_MAX_COMMANDS) {
                mlx5_core_err(dev, "firmware reports too many outstanding commands %d\n",
                              1 << cmd->vars.log_sz);
-               err = -EINVAL;
-               goto err_free_page;
+               return -EINVAL;
        }
 
        if (cmd->vars.log_sz + cmd->vars.log_stride > MLX5_ADAPTER_PAGE_SHIFT) {
                mlx5_core_err(dev, "command queue size overflow\n");
-               err = -EINVAL;
-               goto err_free_page;
+               return -EINVAL;
        }
 
        cmd->state = MLX5_CMDIF_STATE_DOWN;
-       cmd->checksum_disabled = 1;
        cmd->vars.max_reg_cmds = (1 << cmd->vars.log_sz) - 1;
        cmd->vars.bitmask = (1UL << cmd->vars.max_reg_cmds) - 1;
 
-       spin_lock_init(&cmd->alloc_lock);
-       spin_lock_init(&cmd->token_lock);
-       for (i = 0; i < MLX5_CMD_OP_MAX; i++)
-               spin_lock_init(&cmd->stats[i].lock);
-
        sema_init(&cmd->vars.sem, cmd->vars.max_reg_cmds);
        sema_init(&cmd->vars.pages_sem, 1);
        sema_init(&cmd->vars.throttle_sem, DIV_ROUND_UP(cmd->vars.max_reg_cmds, 2));
 
        cmd_h = (u32)((u64)(cmd->dma) >> 32);
        cmd_l = (u32)(cmd->dma);
-       if (cmd_l & 0xfff) {
-               mlx5_core_err(dev, "invalid command queue address\n");
-               err = -ENOMEM;
-               goto err_free_page;
-       }
+       if (WARN_ON(cmd_l & 0xfff))
+               return -EINVAL;
 
        iowrite32be(cmd_h, &dev->iseg->cmdq_addr_h);
        iowrite32be(cmd_l, &dev->iseg->cmdq_addr_l_sz);
@@ -2260,40 +2298,17 @@ int mlx5_cmd_init(struct mlx5_core_dev *dev)
        cmd->mode = CMD_MODE_POLLING;
        cmd->allowed_opcode = CMD_ALLOWED_OPCODE_ALL;
 
-       create_msg_cache(dev);
-
-       set_wqname(dev);
-       cmd->wq = create_singlethread_workqueue(cmd->wq_name);
-       if (!cmd->wq) {
-               mlx5_core_err(dev, "failed to create command workqueue\n");
-               err = -ENOMEM;
-               goto err_cache;
-       }
-
        create_debugfs_files(dev);
 
        return 0;
-
-err_cache:
-       destroy_msg_cache(dev);
-
-err_free_page:
-       free_cmd_page(dev, cmd);
-
-err_free_pool:
-       dma_pool_destroy(cmd->pool);
-       return err;
 }
 
-void mlx5_cmd_cleanup(struct mlx5_core_dev *dev)
+void mlx5_cmd_disable(struct mlx5_core_dev *dev)
 {
        struct mlx5_cmd *cmd = &dev->cmd;
 
        clean_debug_files(dev);
-       destroy_workqueue(cmd->wq);
-       destroy_msg_cache(dev);
-       free_cmd_page(dev, cmd);
-       dma_pool_destroy(cmd->pool);
+       flush_workqueue(cmd->wq);
 }
 
 void mlx5_cmd_set_state(struct mlx5_core_dev *dev,
index a79c9b8286a7d391a4b80609e96da9e8daa21fba..740d4476c413b07e2a24a27a0ea934026b08533f 100644 (file)
@@ -1142,7 +1142,7 @@ static int mlx5_function_enable(struct mlx5_core_dev *dev, bool boot, u64 timeou
                return err;
        }
 
-       err = mlx5_cmd_init(dev);
+       err = mlx5_cmd_enable(dev);
        if (err) {
                mlx5_core_err(dev, "Failed initializing command interface, aborting\n");
                return err;
@@ -1196,7 +1196,7 @@ static int mlx5_function_enable(struct mlx5_core_dev *dev, bool boot, u64 timeou
        mlx5_stop_health_poll(dev, boot);
 err_cmd_cleanup:
        mlx5_cmd_set_state(dev, MLX5_CMDIF_STATE_DOWN);
-       mlx5_cmd_cleanup(dev);
+       mlx5_cmd_disable(dev);
 
        return err;
 }
@@ -1207,7 +1207,7 @@ static void mlx5_function_disable(struct mlx5_core_dev *dev, bool boot)
        mlx5_core_disable_hca(dev, 0);
        mlx5_stop_health_poll(dev, boot);
        mlx5_cmd_set_state(dev, MLX5_CMDIF_STATE_DOWN);
-       mlx5_cmd_cleanup(dev);
+       mlx5_cmd_disable(dev);
 }
 
 static int mlx5_function_open(struct mlx5_core_dev *dev)
@@ -1796,6 +1796,12 @@ int mlx5_mdev_init(struct mlx5_core_dev *dev, int profile_idx)
        debugfs_create_file("vhca_id", 0400, priv->dbg.dbg_root, dev, &vhca_id_fops);
        INIT_LIST_HEAD(&priv->traps);
 
+       err = mlx5_cmd_init(dev);
+       if (err) {
+               mlx5_core_err(dev, "Failed initializing cmdif SW structs, aborting\n");
+               goto err_cmd_init;
+       }
+
        err = mlx5_tout_init(dev);
        if (err) {
                mlx5_core_err(dev, "Failed initializing timeouts, aborting\n");
@@ -1841,6 +1847,8 @@ int mlx5_mdev_init(struct mlx5_core_dev *dev, int profile_idx)
 err_health_init:
        mlx5_tout_cleanup(dev);
 err_timeout_init:
+       mlx5_cmd_cleanup(dev);
+err_cmd_init:
        debugfs_remove(dev->priv.dbg.dbg_root);
        mutex_destroy(&priv->pgdir_mutex);
        mutex_destroy(&priv->alloc_mutex);
@@ -1863,6 +1871,7 @@ void mlx5_mdev_uninit(struct mlx5_core_dev *dev)
        mlx5_pagealloc_cleanup(dev);
        mlx5_health_cleanup(dev);
        mlx5_tout_cleanup(dev);
+       mlx5_cmd_cleanup(dev);
        debugfs_remove_recursive(dev->priv.dbg.dbg_root);
        mutex_destroy(&priv->pgdir_mutex);
        mutex_destroy(&priv->alloc_mutex);
index c4be257c043d4fe1702951b6178392b49b6e1ad4..43b0144121ca242e31032f7f3c7dd2a8626bd2a1 100644 (file)
@@ -178,6 +178,8 @@ int mlx5_query_hca_caps(struct mlx5_core_dev *dev);
 int mlx5_query_board_id(struct mlx5_core_dev *dev);
 int mlx5_cmd_init(struct mlx5_core_dev *dev);
 void mlx5_cmd_cleanup(struct mlx5_core_dev *dev);
+int mlx5_cmd_enable(struct mlx5_core_dev *dev);
+void mlx5_cmd_disable(struct mlx5_core_dev *dev);
 void mlx5_cmd_set_state(struct mlx5_core_dev *dev,
                        enum mlx5_cmdif_state cmdif_state);
 int mlx5_cmd_init_hca(struct mlx5_core_dev *dev, uint32_t *sw_owner_id);