45 static void			 rpc_release_task(struct rpc_task *task);
68 bool rpc_task_set_rpc_status(struct rpc_task *task, int rpc_status)  in rpc_task_set_rpc_status()
76 rpc_task_timeout(const struct rpc_task *task)  in rpc_task_timeout()
95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_disable_timer()
121 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task,  in __rpc_add_timer()
147 __rpc_list_enqueue_task(struct list_head *q, struct rpc_task *task)  in __rpc_list_enqueue_task()
149 	struct rpc_task *t;  in __rpc_list_enqueue_task()
169 __rpc_list_dequeue_task(struct rpc_task *task)  in __rpc_list_dequeue_task()
172 	struct rpc_task *t;  in __rpc_list_dequeue_task()
180 				struct rpc_task,  in __rpc_list_dequeue_task()
194 		struct rpc_task *task,  in __rpc_add_wait_queue_priority()
206 		struct rpc_task *task,  in __rpc_add_wait_queue()
224 static void __rpc_remove_wait_queue_priority(struct rpc_task *task)  in __rpc_remove_wait_queue_priority()
233 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_remove_wait_queue()
286 static void rpc_task_set_debuginfo(struct rpc_task *task)  in rpc_task_set_debuginfo()
301 static inline void rpc_task_set_debuginfo(struct rpc_task *task)  in rpc_task_set_debuginfo()
306 static void rpc_set_active(struct rpc_task *task)  in rpc_set_active()
317 static int rpc_complete_task(struct rpc_task *task)  in rpc_complete_task()
343 int rpc_wait_for_completion_task(struct rpc_task *task)  in rpc_wait_for_completion_task()
362 		struct rpc_task *task)  in rpc_make_runnable()
385 		struct rpc_task *task,  in __rpc_do_sleep_on_priority()
394 		struct rpc_task *task,  in __rpc_sleep_on_priority()
403 		struct rpc_task *task, unsigned long timeout,  in __rpc_sleep_on_priority_timeout()
415 static void rpc_set_tk_callback(struct rpc_task *task, rpc_action action)  in rpc_set_tk_callback()
421 static bool rpc_sleep_check_activated(struct rpc_task *task)  in rpc_sleep_check_activated()
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()
468 		struct rpc_task *task, unsigned long timeout, int priority)  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()
510 		struct rpc_task *task)  in __rpc_do_wake_up_task_on_wq()
528 static struct rpc_task *
530 		struct rpc_wait_queue *queue, struct rpc_task *task,  in rpc_wake_up_task_on_wq_queue_action_locked()
531 		bool (*action)(struct rpc_task *, void *), void *data)  in rpc_wake_up_task_on_wq_queue_action_locked()  argument
549 					  struct rpc_task *task)  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()
568 static bool rpc_task_action_set_status(struct rpc_task *task, void *status)  in rpc_task_action_set_status()
576 		struct rpc_task *task, int status)  in rpc_wake_up_task_queue_set_status_locked()
593 		struct rpc_task *task, int status)  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()
608 	struct rpc_task *task;  in __rpc_find_next_queued_priority()
615 		task = list_first_entry(q, struct rpc_task, u.tk_wait.list);  in __rpc_find_next_queued_priority()
625 		task = list_first_entry(q, struct rpc_task, u.tk_wait.list);  in __rpc_find_next_queued_priority()
638 			task = list_first_entry(q, struct rpc_task, u.tk_wait.list);  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()
657 		return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list);  in __rpc_find_next_queued()
664 struct rpc_task *rpc_wake_up_first_on_wq(struct workqueue_struct *wq,  in rpc_wake_up_first_on_wq()
666 		bool (*func)(struct rpc_task *, void *), void *data)  in rpc_wake_up_first_on_wq()  argument
668 	struct rpc_task	*task = NULL;  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()
684 		bool (*func)(struct rpc_task *, void *), void *data)  in rpc_wake_up_first()  argument
690 static bool rpc_wake_up_next_func(struct rpc_task *task, void *data)  in rpc_wake_up_next_func()
698 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue)  in rpc_wake_up_next()
711 	struct rpc_task *task;  in rpc_wake_up_locked()
742 	struct rpc_task *task;  in rpc_wake_up_status_locked()
772 	struct rpc_task *task, *n;  in __rpc_queue_timer_fn()
793 static void __rpc_atrun(struct rpc_task *task)  in __rpc_atrun()
802 void rpc_delay(struct rpc_task *task, unsigned long delay)  in rpc_delay()
811 void rpc_prepare_task(struct rpc_task *task)  in rpc_prepare_task()
817 rpc_init_task_statistics(struct rpc_task *task)  in rpc_init_task_statistics()
828 rpc_reset_task_statistics(struct rpc_task *task)  in rpc_reset_task_statistics()
838 void rpc_exit_task(struct rpc_task *task)  in rpc_exit_task()
857 void rpc_signal_task(struct rpc_task *task)  in rpc_signal_task()
872 void rpc_task_try_cancel(struct rpc_task *task, int error)  in rpc_task_try_cancel()
883 void rpc_exit(struct rpc_task *task, int status)  in rpc_exit()
897 static bool xprt_needs_memalloc(struct rpc_xprt *xprt, struct rpc_task *tk)  in xprt_needs_memalloc()
909 static void __rpc_execute(struct rpc_task *task)  in __rpc_execute()
921 		void (*do_action)(struct rpc_task *);  in __rpc_execute()
1015 void rpc_execute(struct rpc_task *task)  in rpc_execute()
1032 	__rpc_execute(container_of(work, struct rpc_task, u.tk_work));  in rpc_async_schedule()
1053 int rpc_malloc(struct rpc_task *task)  in rpc_malloc()
1083 void rpc_free(struct rpc_task *task)  in rpc_free()
1101 static void rpc_init_task(struct rpc_task *task, const struct rpc_task_setup *task_setup_data)  in rpc_init_task()
1127 static struct rpc_task *rpc_alloc_task(void)  in rpc_alloc_task()
1129 	struct rpc_task *task;  in rpc_alloc_task()
1140 struct rpc_task *rpc_new_task(const struct rpc_task_setup *setup_data)  in rpc_new_task()
1142 	struct rpc_task	*task = setup_data->task;  in rpc_new_task()
1179 static void rpc_free_task(struct rpc_task *task)  in rpc_free_task()
1194 	rpc_free_task(container_of(work, struct rpc_task, u.tk_work));  in rpc_async_release()
1198 static void rpc_release_resources_task(struct rpc_task *task)  in rpc_release_resources_task()
1209 static void rpc_final_put_task(struct rpc_task *task,  in rpc_final_put_task()
1219 static void rpc_do_put_task(struct rpc_task *task, struct workqueue_struct *q)  in rpc_do_put_task()
1227 void rpc_put_task(struct rpc_task *task)  in rpc_put_task()
1233 void rpc_put_task_async(struct rpc_task *task)  in rpc_put_task_async()
1239 static void rpc_release_task(struct rpc_task *task)  in rpc_release_task()
1336 					     sizeof(struct rpc_task),  in rpc_init_mempool()