ethernet: Remove redundant 'flush_workqueue()' calls
authorChristophe JAILLET <christophe.jaillet@wanadoo.fr>
Sun, 10 Oct 2021 07:01:32 +0000 (09:01 +0200)
committerDavid S. Miller <davem@davemloft.net>
Sun, 10 Oct 2021 10:33:15 +0000 (11:33 +0100)
'destroy_workqueue()' already drains the queue before destroying it, so
there is no need to flush it explicitly.

Remove the redundant 'flush_workqueue()' calls.

This was generated with coccinelle:

@@
expression E;
@@
-  flush_workqueue(E);
destroy_workqueue(E);

Signed-off-by: Christophe JAILLET <christophe.jaillet@wanadoo.fr>
Reviewed-by: Leon Romanovsky <leonro@nvidia.com> #mlx*
Signed-off-by: David S. Miller <davem@davemloft.net>
12 files changed:
drivers/net/ethernet/amd/xgbe/xgbe-drv.c
drivers/net/ethernet/brocade/bna/bnad.c
drivers/net/ethernet/cavium/liquidio/lio_core.c
drivers/net/ethernet/emulex/benet/be_main.c
drivers/net/ethernet/marvell/octeontx2/af/cgx.c
drivers/net/ethernet/marvell/octeontx2/af/rvu.c
drivers/net/ethernet/marvell/octeontx2/af/rvu_cgx.c
drivers/net/ethernet/marvell/octeontx2/nic/otx2_vf.c
drivers/net/ethernet/mellanox/mlx4/cmd.c
drivers/net/ethernet/mellanox/mlx4/en_main.c
drivers/net/ethernet/mellanox/mlx5/core/diag/fw_tracer.c
drivers/net/ethernet/qlogic/qed/qed_sriov.c

index b5bf5af..30d24d1 100644 (file)
@@ -1912,10 +1912,8 @@ static int xgbe_close(struct net_device *netdev)
        clk_disable_unprepare(pdata->ptpclk);
        clk_disable_unprepare(pdata->sysclk);
 
-       flush_workqueue(pdata->an_workqueue);
        destroy_workqueue(pdata->an_workqueue);
 
-       flush_workqueue(pdata->dev_workqueue);
        destroy_workqueue(pdata->dev_workqueue);
 
        set_bit(XGBE_DOWN, &pdata->dev_state);
index b1947fd..bbdc829 100644 (file)
@@ -3515,7 +3515,6 @@ static void
 bnad_uninit(struct bnad *bnad)
 {
        if (bnad->work_q) {
-               flush_workqueue(bnad->work_q);
                destroy_workqueue(bnad->work_q);
                bnad->work_q = NULL;
        }
index ec7928b..73cb032 100644 (file)
@@ -490,7 +490,6 @@ void cleanup_rx_oom_poll_fn(struct net_device *netdev)
                wq = &lio->rxq_status_wq[q_no];
                if (wq->wq) {
                        cancel_delayed_work_sync(&wq->wk.work);
-                       flush_workqueue(wq->wq);
                        destroy_workqueue(wq->wq);
                        wq->wq = NULL;
                }
index ef60e2d..736a6ea 100644 (file)
@@ -4621,7 +4621,6 @@ static void be_destroy_err_recovery_workq(void)
        if (!be_err_recovery_workq)
                return;
 
-       flush_workqueue(be_err_recovery_workq);
        destroy_workqueue(be_err_recovery_workq);
        be_err_recovery_workq = NULL;
 }
index d379a35..186d00a 100644 (file)
@@ -1519,7 +1519,6 @@ static int cgx_lmac_exit(struct cgx *cgx)
        int i;
 
        if (cgx->cgx_cmd_workq) {
-               flush_workqueue(cgx->cgx_cmd_workq);
                destroy_workqueue(cgx->cgx_cmd_workq);
                cgx->cgx_cmd_workq = NULL;
        }
index 4cb24e9..0a1e9f6 100644 (file)
@@ -2399,7 +2399,6 @@ static void rvu_mbox_destroy(struct mbox_wq_info *mw)
        int devid;
 
        if (mw->mbox_wq) {
-               flush_workqueue(mw->mbox_wq);
                destroy_workqueue(mw->mbox_wq);
                mw->mbox_wq = NULL;
        }
@@ -2944,7 +2943,6 @@ fail:
 static void rvu_flr_wq_destroy(struct rvu *rvu)
 {
        if (rvu->flr_wq) {
-               flush_workqueue(rvu->flr_wq);
                destroy_workqueue(rvu->flr_wq);
                rvu->flr_wq = NULL;
        }
index c3842e4..2ca182a 100644 (file)
@@ -324,7 +324,6 @@ static int cgx_lmac_event_handler_init(struct rvu *rvu)
 static void rvu_cgx_wq_destroy(struct rvu *rvu)
 {
        if (rvu->cgx_evh_wq) {
-               flush_workqueue(rvu->cgx_evh_wq);
                destroy_workqueue(rvu->cgx_evh_wq);
                rvu->cgx_evh_wq = NULL;
        }
index 980219a..e6cb8cd 100644 (file)
@@ -279,7 +279,6 @@ static void otx2vf_vfaf_mbox_destroy(struct otx2_nic *vf)
        struct mbox *mbox = &vf->mbox;
 
        if (vf->mbox_wq) {
-               flush_workqueue(vf->mbox_wq);
                destroy_workqueue(vf->mbox_wq);
                vf->mbox_wq = NULL;
        }
index 94ead26..e10b7b0 100644 (file)
@@ -2480,7 +2480,6 @@ int mlx4_multi_func_init(struct mlx4_dev *dev)
        return 0;
 
 err_thread:
-       flush_workqueue(priv->mfunc.master.comm_wq);
        destroy_workqueue(priv->mfunc.master.comm_wq);
 err_slaves:
        while (i--) {
@@ -2587,7 +2586,6 @@ void mlx4_multi_func_cleanup(struct mlx4_dev *dev)
        int i, port;
 
        if (mlx4_is_master(dev)) {
-               flush_workqueue(priv->mfunc.master.comm_wq);
                destroy_workqueue(priv->mfunc.master.comm_wq);
                for (i = 0; i < dev->num_slaves; i++) {
                        for (port = 1; port <= MLX4_MAX_PORTS; port++)
index 109472d..f1259bd 100644 (file)
@@ -237,7 +237,6 @@ static void mlx4_en_remove(struct mlx4_dev *dev, void *endev_ptr)
                if (mdev->pndev[i])
                        mlx4_en_destroy_netdev(mdev->pndev[i]);
 
-       flush_workqueue(mdev->workqueue);
        destroy_workqueue(mdev->workqueue);
        (void) mlx4_mr_free(dev, &mdev->mr);
        iounmap(mdev->uar_map);
index f9cf9fb..da1bec0 100644 (file)
@@ -1069,7 +1069,6 @@ void mlx5_fw_tracer_destroy(struct mlx5_fw_tracer *tracer)
        mlx5_fw_tracer_clean_saved_traces_array(tracer);
        mlx5_fw_tracer_free_strings_db(tracer);
        mlx5_fw_tracer_destroy_log_buf(tracer);
-       flush_workqueue(tracer->work_queue);
        destroy_workqueue(tracer->work_queue);
        kvfree(tracer);
 }
index f88f58e..8ac3882 100644 (file)
@@ -5224,7 +5224,6 @@ void qed_iov_wq_stop(struct qed_dev *cdev, bool schedule_first)
                        cancel_delayed_work_sync(&cdev->hwfns[i].iov_task);
                }
 
-               flush_workqueue(cdev->hwfns[i].iov_wq);
                destroy_workqueue(cdev->hwfns[i].iov_wq);
        }
 }