46 static void			 rpc_release_task(struct rpc_task *task);
65 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_disable_timer()
87 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_add_timer()
104 	struct rpc_task *task;  in rpc_rotate_queue_owner()
107 		task = list_first_entry(q, struct rpc_task, u.tk_wait.list);  in rpc_rotate_queue_owner()
138 		struct rpc_task *task,  in __rpc_add_wait_queue_priority()
142 	struct rpc_task *t;  in __rpc_add_wait_queue_priority()
168 		struct rpc_task *task,  in __rpc_add_wait_queue()
194 static void __rpc_remove_wait_queue_priority(struct rpc_task *task)  in __rpc_remove_wait_queue_priority()
196 	struct rpc_task *t;  in __rpc_remove_wait_queue_priority()
199 		t = list_entry(task->u.tk_wait.links.next, struct rpc_task, u.tk_wait.list);  in __rpc_remove_wait_queue_priority()
209 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_remove_wait_queue()
262 static void rpc_task_set_debuginfo(struct rpc_task *task)  in rpc_task_set_debuginfo()
269 static inline void rpc_task_set_debuginfo(struct rpc_task *task)  in rpc_task_set_debuginfo()
274 static void rpc_set_active(struct rpc_task *task)  in rpc_set_active()
286 static int rpc_complete_task(struct rpc_task *task)  in rpc_complete_task()
312 int __rpc_wait_for_completion_task(struct rpc_task *task, wait_bit_action_f *action)  in __rpc_wait_for_completion_task()
332 static void rpc_make_runnable(struct rpc_task *task)  in rpc_make_runnable()
353 		struct rpc_task *task,  in __rpc_sleep_on_priority()
369 void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task,  in rpc_sleep_on()
389 void rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task,  in rpc_sleep_on_priority()
416 static void __rpc_do_wake_up_task(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_do_wake_up_task()
439 static void rpc_wake_up_task_queue_locked(struct rpc_wait_queue *queue, struct rpc_task *task)  in rpc_wake_up_task_queue_locked()
451 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task)  in rpc_wake_up_queued_task()
462 static struct rpc_task *__rpc_find_next_queued_priority(struct rpc_wait_queue *queue)  in __rpc_find_next_queued_priority()
465 	struct rpc_task *task;  in __rpc_find_next_queued_priority()
472 		task = list_entry(q->next, struct rpc_task, u.tk_wait.list);  in __rpc_find_next_queued_priority()
493 			task = list_entry(q->next, struct rpc_task, u.tk_wait.list);  in __rpc_find_next_queued_priority()
509 static struct rpc_task *__rpc_find_next_queued(struct rpc_wait_queue *queue)  in __rpc_find_next_queued()
514 		return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list);  in __rpc_find_next_queued()
521 struct rpc_task *rpc_wake_up_first(struct rpc_wait_queue *queue,  in rpc_wake_up_first()
522 		bool (*func)(struct rpc_task *, void *), void *data)  in rpc_wake_up_first()  argument
524 	struct rpc_task	*task = NULL;  in rpc_wake_up_first()
542 static bool rpc_wake_up_next_func(struct rpc_task *task, void *data)  in rpc_wake_up_next_func()
550 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue)  in rpc_wake_up_next()
570 			struct rpc_task *task;  in rpc_wake_up()
572 					struct rpc_task,  in rpc_wake_up()
599 			struct rpc_task *task;  in rpc_wake_up_status()
601 					struct rpc_task,  in rpc_wake_up_status()
617 	struct rpc_task *task, *n;  in __rpc_queue_timer_fn()
638 static void __rpc_atrun(struct rpc_task *task)  in __rpc_atrun()
647 void rpc_delay(struct rpc_task *task, unsigned long delay)  in rpc_delay()
657 void rpc_prepare_task(struct rpc_task *task)  in rpc_prepare_task()
663 rpc_init_task_statistics(struct rpc_task *task)  in rpc_init_task_statistics()
675 rpc_reset_task_statistics(struct rpc_task *task)  in rpc_reset_task_statistics()
686 void rpc_exit_task(struct rpc_task *task)  in rpc_exit_task()
700 void rpc_exit(struct rpc_task *task, int status)  in rpc_exit()
718 static void __rpc_execute(struct rpc_task *task)  in __rpc_execute()
732 		void (*do_action)(struct rpc_task *);  in __rpc_execute()
812 void rpc_execute(struct rpc_task *task)  in rpc_execute()
824 	__rpc_execute(container_of(work, struct rpc_task, u.tk_work));  in rpc_async_schedule()
844 void *rpc_malloc(struct rpc_task *task, size_t size)  in rpc_malloc()
897 static void rpc_init_task(struct rpc_task *task, const struct rpc_task_setup *task_setup_data)  in rpc_init_task()
921 static struct rpc_task *
924 	return (struct rpc_task *)mempool_alloc(rpc_task_mempool, GFP_NOIO);  in rpc_alloc_task()
930 struct rpc_task *rpc_new_task(const struct rpc_task_setup *setup_data)  in rpc_new_task()
932 	struct rpc_task	*task = setup_data->task;  in rpc_new_task()
970 static void rpc_free_task(struct rpc_task *task)  in rpc_free_task()
984 	rpc_free_task(container_of(work, struct rpc_task, u.tk_work));  in rpc_async_release()
987 static void rpc_release_resources_task(struct rpc_task *task)  in rpc_release_resources_task()
997 static void rpc_final_put_task(struct rpc_task *task,  in rpc_final_put_task()
1007 static void rpc_do_put_task(struct rpc_task *task, struct workqueue_struct *q)  in rpc_do_put_task()
1015 void rpc_put_task(struct rpc_task *task)  in rpc_put_task()
1021 void rpc_put_task_async(struct rpc_task *task)  in rpc_put_task_async()
1027 static void rpc_release_task(struct rpc_task *task)  in rpc_release_task()
1114 					     sizeof(struct rpc_task),  in rpc_init_mempool()