Lines Matching refs:recv_workqueue
134 static struct workqueue_struct *recv_workqueue; variable
409 queue_work(recv_workqueue, &con->rwork); in lowcomms_data_ready()
743 queue_work(recv_workqueue, &con->rwork); in receive_from_sock()
887 queue_work(recv_workqueue, &addcon->rwork); in accept_from_sock()
1546 if (recv_workqueue) in work_stop()
1547 destroy_workqueue(recv_workqueue); in work_stop()
1554 recv_workqueue = alloc_workqueue("dlm_recv", in work_start()
1556 if (!recv_workqueue) { in work_start()
1565 destroy_workqueue(recv_workqueue); in work_start()
1630 if (recv_workqueue) in work_flush()
1631 flush_workqueue(recv_workqueue); in work_flush()
1659 if (recv_workqueue) in dlm_lowcomms_stop()
1660 flush_workqueue(recv_workqueue); in dlm_lowcomms_stop()