Lines Matching refs:recv_workq
114 struct workqueue_struct *recv_workq; member
1143 queue_work(nbd->recv_workq, &args->work); in nbd_reconnect_socket()
1245 if (nbd->recv_workq) in nbd_config_put()
1246 destroy_workqueue(nbd->recv_workq); in nbd_config_put()
1247 nbd->recv_workq = NULL; in nbd_config_put()
1277 nbd->recv_workq = alloc_workqueue("knbd%d-recv", in nbd_start_device()
1280 if (!nbd->recv_workq) { in nbd_start_device()
1313 flush_workqueue(nbd->recv_workq); in nbd_start_device()
1325 queue_work(nbd->recv_workq, &args->work); in nbd_start_device()
1350 flush_workqueue(nbd->recv_workq); in nbd_start_device_ioctl()
2052 if (nbd->recv_workq) in nbd_disconnect_and_put()
2053 flush_workqueue(nbd->recv_workq); in nbd_disconnect_and_put()