Searched refs:ceph_msgr_wq (Results 1 – 1 of 1) sorted by relevance
172 static struct workqueue_struct *ceph_msgr_wq; variable176 if (ceph_msgr_wq) { in _ceph_msgr_exit()177 destroy_workqueue(ceph_msgr_wq); in _ceph_msgr_exit()178 ceph_msgr_wq = NULL; in _ceph_msgr_exit()193 ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_NON_REENTRANT, 0); in ceph_msgr_init()194 if (ceph_msgr_wq) in ceph_msgr_init()206 BUG_ON(ceph_msgr_wq == NULL); in ceph_msgr_exit()214 flush_workqueue(ceph_msgr_wq); in ceph_msgr_flush()2245 if (!queue_delayed_work(ceph_msgr_wq, &con->work, 0)) { in queue_con()2298 if (queue_delayed_work(ceph_msgr_wq, &con->work, in con_work()[all …]