Lines Matching refs:io_workqueue
184 static struct workqueue_struct *io_workqueue; variable
219 queue_work(io_workqueue, &con->swork); in lowcomms_queue_swork()
230 queue_work(io_workqueue, &con->rwork); in lowcomms_queue_rwork()
542 queue_work(io_workqueue, &listen_con.rwork); in lowcomms_listen_data_ready()
803 flush_workqueue(io_workqueue); in shutdown_connection()
1509 queue_work(io_workqueue, &con->rwork); in process_recv_sockets()
1636 queue_work(io_workqueue, &con->swork); in process_send_sockets()
1655 queue_work(io_workqueue, &con->swork); in process_send_sockets()
1675 if (io_workqueue) { in work_stop()
1676 destroy_workqueue(io_workqueue); in work_stop()
1677 io_workqueue = NULL; in work_stop()
1688 io_workqueue = alloc_workqueue("dlm_io", WQ_HIGHPRI | WQ_MEM_RECLAIM | in work_start()
1690 if (!io_workqueue) { in work_start()
1702 destroy_workqueue(io_workqueue); in work_start()
1703 io_workqueue = NULL; in work_start()