• Home
  • Raw
  • Download

Lines Matching refs:wq

297 	wait_queue_head_t *wq = bit_waitqueue(m, RPC_TASK_ACTIVE);  in rpc_complete_task()  local
304 spin_lock_irqsave(&wq->lock, flags); in rpc_complete_task()
307 if (waitqueue_active(wq)) in rpc_complete_task()
308 __wake_up_locked_key(wq, TASK_NORMAL, &k); in rpc_complete_task()
309 spin_unlock_irqrestore(&wq->lock, flags); in rpc_complete_task()
340 static void rpc_make_runnable(struct workqueue_struct *wq, in rpc_make_runnable() argument
350 queue_work(wq, &task->u.tk_work); in rpc_make_runnable()
485 static void __rpc_do_wake_up_task_on_wq(struct workqueue_struct *wq, in __rpc_do_wake_up_task_on_wq() argument
499 rpc_make_runnable(wq, task); in __rpc_do_wake_up_task_on_wq()
506 rpc_wake_up_task_on_wq_queue_action_locked(struct workqueue_struct *wq, in rpc_wake_up_task_on_wq_queue_action_locked() argument
514 __rpc_do_wake_up_task_on_wq(wq, queue, task); in rpc_wake_up_task_on_wq_queue_action_locked()
641 struct rpc_task *rpc_wake_up_first_on_wq(struct workqueue_struct *wq, in rpc_wake_up_first_on_wq() argument
650 task = rpc_wake_up_task_on_wq_queue_action_locked(wq, queue, in rpc_wake_up_first_on_wq()
1218 struct workqueue_struct *wq; in rpciod_start() local
1223 wq = alloc_workqueue("rpciod", WQ_MEM_RECLAIM | WQ_UNBOUND, 0); in rpciod_start()
1224 if (!wq) in rpciod_start()
1226 rpciod_workqueue = wq; in rpciod_start()
1228 wq = alloc_workqueue("xprtiod", WQ_UNBOUND|WQ_MEM_RECLAIM|WQ_HIGHPRI, 0); in rpciod_start()
1229 if (!wq) in rpciod_start()
1231 xprtiod_workqueue = wq; in rpciod_start()
1234 wq = rpciod_workqueue; in rpciod_start()
1236 destroy_workqueue(wq); in rpciod_start()
1243 struct workqueue_struct *wq = NULL; in rpciod_stop() local
1248 wq = rpciod_workqueue; in rpciod_stop()
1250 destroy_workqueue(wq); in rpciod_stop()
1251 wq = xprtiod_workqueue; in rpciod_stop()
1253 destroy_workqueue(wq); in rpciod_stop()