51 static struct rpc_wait_queue delay_queue;
95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_disable_timer()
106 rpc_set_queue_timer(struct rpc_wait_queue *queue, unsigned long expires)  in rpc_set_queue_timer()
121 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task,  in __rpc_add_timer()
130 static void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority)  in rpc_set_waitqueue_priority()
138 static void rpc_reset_waitqueue_priority(struct rpc_wait_queue *queue)  in rpc_reset_waitqueue_priority()
193 static void __rpc_add_wait_queue_priority(struct rpc_wait_queue *queue,  in __rpc_add_wait_queue_priority()
205 static void __rpc_add_wait_queue(struct rpc_wait_queue *queue,  in __rpc_add_wait_queue()
233 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_remove_wait_queue()
243 static void __rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname, unsigne…  in __rpc_init_priority_wait_queue()
259 void rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname)  in rpc_init_priority_wait_queue()
265 void rpc_init_wait_queue(struct rpc_wait_queue *queue, const char *qname)  in rpc_init_wait_queue()
271 void rpc_destroy_wait_queue(struct rpc_wait_queue *queue)  in rpc_destroy_wait_queue()
384 static void __rpc_do_sleep_on_priority(struct rpc_wait_queue *q,  in __rpc_do_sleep_on_priority()
393 static void __rpc_sleep_on_priority(struct rpc_wait_queue *q,  in __rpc_sleep_on_priority()
402 static void __rpc_sleep_on_priority_timeout(struct rpc_wait_queue *q,  in __rpc_sleep_on_priority_timeout()
432 void rpc_sleep_on_timeout(struct rpc_wait_queue *q, struct rpc_task *task,  in rpc_sleep_on_timeout()
449 void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task,  in rpc_sleep_on()
467 void rpc_sleep_on_priority_timeout(struct rpc_wait_queue *q,  in rpc_sleep_on_priority_timeout()
483 void rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task,  in rpc_sleep_on_priority()
509 		struct rpc_wait_queue *queue,  in __rpc_do_wake_up_task_on_wq()
530 		struct rpc_wait_queue *queue, struct rpc_task *task,  in rpc_wake_up_task_on_wq_queue_action_locked()
548 static void rpc_wake_up_task_queue_locked(struct rpc_wait_queue *queue,  in rpc_wake_up_task_queue_locked()
558 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task)  in rpc_wake_up_queued_task()
575 rpc_wake_up_task_queue_set_status_locked(struct rpc_wait_queue *queue,  in rpc_wake_up_task_queue_set_status_locked()
592 rpc_wake_up_queued_task_set_status(struct rpc_wait_queue *queue,  in rpc_wake_up_queued_task_set_status()
605 static struct rpc_task *__rpc_find_next_queued_priority(struct rpc_wait_queue *queue)  in __rpc_find_next_queued_priority()
652 static struct rpc_task *__rpc_find_next_queued(struct rpc_wait_queue *queue)  in __rpc_find_next_queued()
665 		struct rpc_wait_queue *queue,  in rpc_wake_up_first_on_wq()
683 struct rpc_task *rpc_wake_up_first(struct rpc_wait_queue *queue,  in rpc_wake_up_first()
698 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue)  in rpc_wake_up_next()
709 static void rpc_wake_up_locked(struct rpc_wait_queue *queue)  in rpc_wake_up_locked()
727 void rpc_wake_up(struct rpc_wait_queue *queue)  in rpc_wake_up()
740 static void rpc_wake_up_status_locked(struct rpc_wait_queue *queue, int status)  in rpc_wake_up_status_locked()
759 void rpc_wake_up_status(struct rpc_wait_queue *queue, int status)  in rpc_wake_up_status()
769 	struct rpc_wait_queue *queue = container_of(work,  in __rpc_queue_timer_fn()
770 			struct rpc_wait_queue,  in __rpc_queue_timer_fn()
859 	struct rpc_wait_queue *queue;  in rpc_signal_task()
874 	struct rpc_wait_queue *queue;  in rpc_task_try_cancel()
911 	struct rpc_wait_queue *queue;  in __rpc_execute()