Lines Matching refs:rpc_wait_queue
52 static struct rpc_wait_queue delay_queue;
66 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
78 rpc_set_queue_timer(struct rpc_wait_queue *queue, unsigned long expires) in rpc_set_queue_timer()
88 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_add_timer()
102 static void rpc_rotate_queue_owner(struct rpc_wait_queue *queue) in rpc_rotate_queue_owner()
114 static void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority) in rpc_set_waitqueue_priority()
123 static void rpc_set_waitqueue_owner(struct rpc_wait_queue *queue, pid_t pid) in rpc_set_waitqueue_owner()
129 static void rpc_reset_waitqueue_priority(struct rpc_wait_queue *queue) in rpc_reset_waitqueue_priority()
138 static void __rpc_add_wait_queue_priority(struct rpc_wait_queue *queue, in __rpc_add_wait_queue_priority()
168 static void __rpc_add_wait_queue(struct rpc_wait_queue *queue, in __rpc_add_wait_queue()
210 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_remove_wait_queue()
221 static void __rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname, unsigne… in __rpc_init_priority_wait_queue()
236 void rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_priority_wait_queue()
242 void rpc_init_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_wait_queue()
248 void rpc_destroy_wait_queue(struct rpc_wait_queue *queue) in rpc_destroy_wait_queue()
353 static void __rpc_sleep_on_priority(struct rpc_wait_queue *q, in __rpc_sleep_on_priority()
370 void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, in rpc_sleep_on()
390 void rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task, in rpc_sleep_on_priority()
419 struct rpc_wait_queue *queue, in __rpc_do_wake_up_task_on_wq()
444 struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_task_on_wq_queue_locked()
456 static void rpc_wake_up_task_queue_locked(struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_task_queue_locked()
465 struct rpc_wait_queue *queue, in rpc_wake_up_queued_task_on_wq()
476 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_queued_task()
487 static struct rpc_task *__rpc_find_next_queued_priority(struct rpc_wait_queue *queue) in __rpc_find_next_queued_priority()
534 static struct rpc_task *__rpc_find_next_queued(struct rpc_wait_queue *queue) in __rpc_find_next_queued()
547 struct rpc_wait_queue *queue, in rpc_wake_up_first_on_wq()
570 struct rpc_task *rpc_wake_up_first(struct rpc_wait_queue *queue, in rpc_wake_up_first()
585 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue) in rpc_wake_up_next()
597 void rpc_wake_up(struct rpc_wait_queue *queue) in rpc_wake_up()
626 void rpc_wake_up_status(struct rpc_wait_queue *queue, int status) in rpc_wake_up_status()
651 struct rpc_wait_queue *queue = from_timer(queue, t, timer_list.timer); in __rpc_queue_timer_fn()
755 struct rpc_wait_queue *queue; in __rpc_execute()