Lines Matching refs:send_workqueue
135 static struct workqueue_struct *send_workqueue; variable
429 queue_work(send_workqueue, &con->swork); in lowcomms_write_space()
438 queue_work(send_workqueue, &con->swork); in lowcomms_connect_sock()
1399 queue_work(send_workqueue, &con->swork); in dlm_lowcomms_commit_buffer()
1471 queue_work(send_workqueue, &con->swork); in send_to_sock()
1476 queue_work(send_workqueue, &con->swork); in send_to_sock()
1548 if (send_workqueue) in work_stop()
1549 destroy_workqueue(send_workqueue); in work_stop()
1561 send_workqueue = alloc_workqueue("dlm_send", in work_start()
1563 if (!send_workqueue) { in work_start()
1632 if (send_workqueue) in work_flush()
1633 flush_workqueue(send_workqueue); in work_flush()
1661 if (send_workqueue) in dlm_lowcomms_stop()
1662 flush_workqueue(send_workqueue); in dlm_lowcomms_stop()