Lines Matching refs:recv_workqueue
182 static struct workqueue_struct *recv_workqueue; variable
512 queue_work(recv_workqueue, &con->rwork); in lowcomms_data_ready()
520 queue_work(recv_workqueue, &listen_con.rwork); in lowcomms_listen_data_ready()
971 queue_work(recv_workqueue, &con->rwork); in receive_from_sock()
1127 queue_work(recv_workqueue, &addcon->rwork); in accept_from_sock()
1646 if (recv_workqueue) { in work_stop()
1647 destroy_workqueue(recv_workqueue); in work_stop()
1648 recv_workqueue = NULL; in work_stop()
1659 recv_workqueue = alloc_ordered_workqueue("dlm_recv", WQ_MEM_RECLAIM); in work_start()
1660 if (!recv_workqueue) { in work_start()
1668 destroy_workqueue(recv_workqueue); in work_start()
1669 recv_workqueue = NULL; in work_start()
1691 if (recv_workqueue) in dlm_lowcomms_shutdown()
1692 flush_workqueue(recv_workqueue); in dlm_lowcomms_shutdown()
1756 if (recv_workqueue) in work_flush()
1757 flush_workqueue(recv_workqueue); in work_flush()