net/sunrpc/sched.c

45 static void			 rpc_release_task(struct rpc_task *task);
68 bool rpc_task_set_rpc_status(struct rpc_task *task, int rpc_status)
76 rpc_task_timeout(const struct rpc_task *task)
95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task)
121 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task,
147 __rpc_list_enqueue_task(struct list_head *q, struct rpc_task *task)
149 	struct rpc_task *t;
169 __rpc_list_dequeue_task(struct rpc_task *task)
172 	struct rpc_task *t;
180 				struct rpc_task,
194 		struct rpc_task *task,
206 		struct rpc_task *task,
224 static void __rpc_remove_wait_queue_priority(struct rpc_task *task)
233 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task)
288 static void rpc_task_set_debuginfo(struct rpc_task *task)
303 static inline void rpc_task_set_debuginfo(struct rpc_task *task)
308 static void rpc_set_active(struct rpc_task *task)
319 static int rpc_complete_task(struct rpc_task *task)
345 int rpc_wait_for_completion_task(struct rpc_task *task)
364 		struct rpc_task *task)
387 		struct rpc_task *task,
396 		struct rpc_task *task,
405 		struct rpc_task *task, unsigned long timeout,
417 static void rpc_set_tk_callback(struct rpc_task *task, rpc_action action)
423 static bool rpc_sleep_check_activated(struct rpc_task *task)
434 void rpc_sleep_on_timeout(struct rpc_wait_queue *q, struct rpc_task *task,
451 void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task,
470 		struct rpc_task *task, unsigned long timeout, int priority)
485 void rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task,
503  * __rpc_do_wake_up_task_on_wq - wake up a single rpc_task
512 		struct rpc_task *task)
530 static struct rpc_task *
532 		struct rpc_wait_queue *queue, struct rpc_task *task,
533 		bool (*action)(struct rpc_task *, void *), void *data)
551 					  struct rpc_task *task)
560 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task)
570 static bool rpc_task_action_set_status(struct rpc_task *task, void *status)
578 		struct rpc_task *task, int status)
587  * @task: pointer to rpc_task
595 		struct rpc_task *task, int status)
607 static struct rpc_task *__rpc_find_next_queued_priority(struct rpc_wait_queue *queue)
610 	struct rpc_task *task;
617 		task = list_first_entry(q, struct rpc_task, u.tk_wait.list);
627 		task = list_first_entry(q, struct rpc_task, u.tk_wait.list);
640 			task = list_first_entry(q, struct rpc_task, u.tk_wait.list);
654 static struct rpc_task *__rpc_find_next_queued(struct rpc_wait_queue *queue)
659 		return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list);
666 struct rpc_task *rpc_wake_up_first_on_wq(struct workqueue_struct *wq,
668 		bool (*func)(struct rpc_task *, void *), void *data)
670 	struct rpc_task	*task = NULL;
685 struct rpc_task *rpc_wake_up_first(struct rpc_wait_queue *queue,
686 		bool (*func)(struct rpc_task *, void *), void *data)
692 static bool rpc_wake_up_next_func(struct rpc_task *task, void *data)
700 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue)
713 	struct rpc_task *task;
744 	struct rpc_task *task;
774 	struct rpc_task *task, *n;
795 static void __rpc_atrun(struct rpc_task *task)
804 void rpc_delay(struct rpc_task *task, unsigned long delay)
813 void rpc_prepare_task(struct rpc_task *task)
819 rpc_init_task_statistics(struct rpc_task *task)
830 rpc_reset_task_statistics(struct rpc_task *task)
840 void rpc_exit_task(struct rpc_task *task)
859 void rpc_signal_task(struct rpc_task *task)
874 void rpc_task_try_cancel(struct rpc_task *task, int error)
885 void rpc_exit(struct rpc_task *task, int status)
899 static bool xprt_needs_memalloc(struct rpc_xprt *xprt, struct rpc_task *tk)
911 static void __rpc_execute(struct rpc_task *task)
923 		void (*do_action)(struct rpc_task *);
964 		 * rpc_task, rpc_make_runnable() can assign it to a
966 		 * rpc_task pointer may still be dereferenced.
1017 void rpc_execute(struct rpc_task *task)
1034 	__rpc_execute(container_of(work, struct rpc_task, u.tk_work));
1055 int rpc_malloc(struct rpc_task *task)
1086 void rpc_free(struct rpc_task *task)
1105 static void rpc_init_task(struct rpc_task *task, const struct rpc_task_setup *task_setup_data)
1131 static struct rpc_task *rpc_alloc_task(void)
1133 	struct rpc_task *task;
1144 struct rpc_task *rpc_new_task(const struct rpc_task_setup *setup_data)
1146 	struct rpc_task	*task = setup_data->task;
1167  * Note that we free up the rpc_task _after_ rpc_release_calldata()
1183 static void rpc_free_task(struct rpc_task *task)
1198 	rpc_free_task(container_of(work, struct rpc_task, u.tk_work));
1202 static void rpc_release_resources_task(struct rpc_task *task)
1213 static void rpc_final_put_task(struct rpc_task *task,
1223 static void rpc_do_put_task(struct rpc_task *task, struct workqueue_struct *q)
1231 void rpc_put_task(struct rpc_task *task)
1237 void rpc_put_task_async(struct rpc_task *task)
1243 static void rpc_release_task(struct rpc_task *task)
1252 	 * or not any other processes still hold references to our rpc_task.
1340 					     sizeof(struct rpc_task),