• Home
  • Raw
  • Download

Lines Matching refs:wq

321 	wait_queue_head_t *wq = bit_waitqueue(m, RPC_TASK_ACTIVE);  in rpc_complete_task()  local
328 spin_lock_irqsave(&wq->lock, flags); in rpc_complete_task()
331 if (waitqueue_active(wq)) in rpc_complete_task()
332 __wake_up_locked_key(wq, TASK_NORMAL, &k); in rpc_complete_task()
333 spin_unlock_irqrestore(&wq->lock, flags); in rpc_complete_task()
364 static void rpc_make_runnable(struct workqueue_struct *wq, in rpc_make_runnable() argument
374 queue_work(wq, &task->u.tk_work); in rpc_make_runnable()
502 static void __rpc_do_wake_up_task_on_wq(struct workqueue_struct *wq, in __rpc_do_wake_up_task_on_wq() argument
519 rpc_make_runnable(wq, task); in __rpc_do_wake_up_task_on_wq()
528 rpc_wake_up_task_on_wq_queue_action_locked(struct workqueue_struct *wq, in rpc_wake_up_task_on_wq_queue_action_locked() argument
536 __rpc_do_wake_up_task_on_wq(wq, queue, task); in rpc_wake_up_task_on_wq_queue_action_locked()
653 struct rpc_task *rpc_wake_up_first_on_wq(struct workqueue_struct *wq, in rpc_wake_up_first_on_wq() argument
664 task = rpc_wake_up_task_on_wq_queue_action_locked(wq, queue, in rpc_wake_up_first_on_wq()
1237 struct workqueue_struct *wq; in rpciod_start() local
1243 wq = alloc_workqueue("rpciod", WQ_MEM_RECLAIM | WQ_UNBOUND, 0); in rpciod_start()
1244 if (!wq) in rpciod_start()
1246 rpciod_workqueue = wq; in rpciod_start()
1248 wq = alloc_workqueue("xprtiod", WQ_UNBOUND|WQ_MEM_RECLAIM|WQ_HIGHPRI, 0); in rpciod_start()
1249 if (!wq) in rpciod_start()
1251 xprtiod_workqueue = wq; in rpciod_start()
1254 wq = rpciod_workqueue; in rpciod_start()
1256 destroy_workqueue(wq); in rpciod_start()
1263 struct workqueue_struct *wq = NULL; in rpciod_stop() local
1269 wq = rpciod_workqueue; in rpciod_stop()
1271 destroy_workqueue(wq); in rpciod_stop()
1272 wq = xprtiod_workqueue; in rpciod_stop()
1274 destroy_workqueue(wq); in rpciod_stop()