@@ -3375,7 +3375,7 @@ static int __rbd_register_watch(struct rbd_device *rbd_dev)
dout("%s rbd_dev %p\n", __func__, rbd_dev);
handle = ceph_osdc_watch(osdc, &rbd_dev->header_oid,
- &rbd_dev->header_oloc, rbd_watch_cb,
+ &rbd_dev->header_oloc, NULL, rbd_watch_cb,
rbd_watch_errcb, rbd_dev);
if (IS_ERR(handle))
return PTR_ERR(handle);
@@ -282,6 +282,7 @@ struct ceph_osd_linger_request {
rados_watcherrcb_t errcb;
void *data;
+ struct workqueue_struct *wq;
struct page ***preply_pages;
size_t *preply_len;
};
@@ -532,6 +533,7 @@ struct ceph_osd_linger_request *
ceph_osdc_watch(struct ceph_osd_client *osdc,
struct ceph_object_id *oid,
struct ceph_object_locator *oloc,
+ struct workqueue_struct *wq,
rados_watchcb2_t wcb,
rados_watcherrcb_t errcb,
void *data);
@@ -2850,7 +2850,10 @@ static void lwork_queue(struct linger_work *lwork)
lwork->queued_stamp = jiffies;
list_add_tail(&lwork->pending_item, &lreq->pending_lworks);
- queue_work(osdc->notify_wq, &lwork->work);
+ if (lreq->wq)
+ queue_work(lreq->wq, &lwork->work);
+ else
+ queue_work(osdc->notify_wq, &lwork->work);
}
static void do_watch_notify(struct work_struct *w)
@@ -4603,6 +4606,7 @@ struct ceph_osd_linger_request *
ceph_osdc_watch(struct ceph_osd_client *osdc,
struct ceph_object_id *oid,
struct ceph_object_locator *oloc,
+ struct workqueue_struct *wq,
rados_watchcb2_t wcb,
rados_watcherrcb_t errcb,
void *data)
@@ -4618,6 +4622,8 @@ struct ceph_osd_linger_request *
lreq->wcb = wcb;
lreq->errcb = errcb;
lreq->data = data;
+ if (wq)
+ lreq->wq = wq;
lreq->watch_valid_thru = jiffies;
ceph_oid_copy(&lreq->t.base_oid, oid);
Currently, if we share osdc in rbd device and journaling, they are sharing the notify_wq in osdc to complete watch_cb. When we need to close journal held with mutex of rbd device, we need to flush the notify_wq. But we don't want to flush the watch_cb of rbd_device, maybe some of it need to lock rbd mutex. To solve this problem, this patch allow user to manage the notify workqueue by themselves in watching. Signed-off-by: Dongsheng Yang <dongsheng.yang@easystack.cn> --- drivers/block/rbd.c | 2 +- include/linux/ceph/osd_client.h | 2 ++ net/ceph/osd_client.c | 8 +++++++- 3 files changed, 10 insertions(+), 2 deletions(-)