dmaengine: idxd: add per DSA wq workqueue for processing cr faults

[linux-2.6-block.git] / drivers / dma / idxd / cdev.c

diff --git a/drivers/dma/idxd/cdev.c b/drivers/dma/idxd/cdev.c
index 674bfefca088db7a8908866a44615343611e20be..cbe29e1a6a449cded24f68343fdf9bac10770d92 100644 (file)
--- a/drivers/dma/idxd/cdev.c
+++ b/drivers/dma/idxd/cdev.c
@@ -330,6 +330,13 @@ static int idxd_user_drv_probe(struct idxd_dev *idxd_dev)
        }
 
        mutex_lock(&wq->wq_lock);
+
+       wq->wq = create_workqueue(dev_name(wq_confdev(wq)));
+       if (!wq->wq) {
+               rc = -ENOMEM;
+               goto wq_err;
+       }
+
        wq->type = IDXD_WQT_USER;
        rc = drv_enable_wq(wq);
        if (rc < 0)
@@ -348,7 +355,9 @@ static int idxd_user_drv_probe(struct idxd_dev *idxd_dev)
 err_cdev:
        drv_disable_wq(wq);
 err:
+       destroy_workqueue(wq->wq);
        wq->type = IDXD_WQT_NONE;
+wq_err:
        mutex_unlock(&wq->wq_lock);
        return rc;
 }
@@ -361,6 +370,8 @@ static void idxd_user_drv_remove(struct idxd_dev *idxd_dev)
        idxd_wq_del_cdev(wq);
        drv_disable_wq(wq);
        wq->type = IDXD_WQT_NONE;
+       destroy_workqueue(wq->wq);
+       wq->wq = NULL;
        mutex_unlock(&wq->wq_lock);
 }