Lines Matching refs:rpc_task

49 static void			 rpc_release_task(struct rpc_task *task);
65 rpc_task_timeout(const struct rpc_task *task) in rpc_task_timeout()
84 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
111 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer()
140 __rpc_list_enqueue_task(struct list_head *q, struct rpc_task *task) in __rpc_list_enqueue_task()
142 struct rpc_task *t; in __rpc_list_enqueue_task()
162 __rpc_list_dequeue_task(struct rpc_task *task) in __rpc_list_dequeue_task()
165 struct rpc_task *t; in __rpc_list_dequeue_task()
173 struct rpc_task, in __rpc_list_dequeue_task()
187 struct rpc_task *task, in __rpc_add_wait_queue_priority()
204 struct rpc_task *task, in __rpc_add_wait_queue()
231 static void __rpc_remove_wait_queue_priority(struct rpc_task *task) in __rpc_remove_wait_queue_priority()
240 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_remove_wait_queue()
295 static void rpc_task_set_debuginfo(struct rpc_task *task) in rpc_task_set_debuginfo()
302 static inline void rpc_task_set_debuginfo(struct rpc_task *task) in rpc_task_set_debuginfo()
307 static void rpc_set_active(struct rpc_task *task) in rpc_set_active()
318 static int rpc_complete_task(struct rpc_task *task) in rpc_complete_task()
344 int __rpc_wait_for_completion_task(struct rpc_task *task, wait_bit_action_f *action) in __rpc_wait_for_completion_task()
365 struct rpc_task *task) in rpc_make_runnable()
386 struct rpc_task *task, in __rpc_sleep_on_priority()
399 struct rpc_task *task, unsigned long timeout, in __rpc_sleep_on_priority_timeout()
409 static void rpc_set_tk_callback(struct rpc_task *task, rpc_action action) in rpc_set_tk_callback()
415 static bool rpc_sleep_check_activated(struct rpc_task *task) in rpc_sleep_check_activated()
426 void rpc_sleep_on_timeout(struct rpc_wait_queue *q, struct rpc_task *task, in rpc_sleep_on_timeout()
443 void rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, in rpc_sleep_on()
462 struct rpc_task *task, unsigned long timeout, int priority) in rpc_sleep_on_priority_timeout()
477 void rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task, in rpc_sleep_on_priority()
504 struct rpc_task *task) in __rpc_do_wake_up_task_on_wq()
527 static struct rpc_task *
529 struct rpc_wait_queue *queue, struct rpc_task *task, in rpc_wake_up_task_on_wq_queue_action_locked()
530 bool (*action)(struct rpc_task *, void *), void *data) in rpc_wake_up_task_on_wq_queue_action_locked() argument
548 struct rpc_task *task) in rpc_wake_up_task_queue_locked()
557 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_queued_task()
567 static bool rpc_task_action_set_status(struct rpc_task *task, void *status) in rpc_task_action_set_status()
575 struct rpc_task *task, int status) in rpc_wake_up_task_queue_set_status_locked()
592 struct rpc_task *task, int status) in rpc_wake_up_queued_task_set_status()
604 static struct rpc_task *__rpc_find_next_queued_priority(struct rpc_wait_queue *queue) in __rpc_find_next_queued_priority()
607 struct rpc_task *task; in __rpc_find_next_queued_priority()
614 task = list_first_entry(q, struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued_priority()
627 task = list_first_entry(q, struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued_priority()
641 static struct rpc_task *__rpc_find_next_queued(struct rpc_wait_queue *queue) in __rpc_find_next_queued()
646 return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued()
653 struct rpc_task *rpc_wake_up_first_on_wq(struct workqueue_struct *wq, in rpc_wake_up_first_on_wq()
655 bool (*func)(struct rpc_task *, void *), void *data) in rpc_wake_up_first_on_wq() argument
657 struct rpc_task *task = NULL; in rpc_wake_up_first_on_wq()
674 struct rpc_task *rpc_wake_up_first(struct rpc_wait_queue *queue, in rpc_wake_up_first()
675 bool (*func)(struct rpc_task *, void *), void *data) in rpc_wake_up_first() argument
681 static bool rpc_wake_up_next_func(struct rpc_task *task, void *data) in rpc_wake_up_next_func()
689 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue) in rpc_wake_up_next()
709 struct rpc_task *task; in rpc_wake_up()
711 struct rpc_task, in rpc_wake_up()
738 struct rpc_task *task; in rpc_wake_up_status()
740 struct rpc_task, in rpc_wake_up_status()
758 struct rpc_task *task, *n; in __rpc_queue_timer_fn()
779 static void __rpc_atrun(struct rpc_task *task) in __rpc_atrun()
788 void rpc_delay(struct rpc_task *task, unsigned long delay) in rpc_delay()
797 void rpc_prepare_task(struct rpc_task *task) in rpc_prepare_task()
803 rpc_init_task_statistics(struct rpc_task *task) in rpc_init_task_statistics()
815 rpc_reset_task_statistics(struct rpc_task *task) in rpc_reset_task_statistics()
825 void rpc_exit_task(struct rpc_task *task) in rpc_exit_task()
842 void rpc_signal_task(struct rpc_task *task) in rpc_signal_task()
855 void rpc_exit(struct rpc_task *task, int status) in rpc_exit()
872 static void __rpc_execute(struct rpc_task *task) in __rpc_execute()
886 void (*do_action)(struct rpc_task *); in __rpc_execute()
974 void rpc_execute(struct rpc_task *task) in rpc_execute()
988 __rpc_execute(container_of(work, struct rpc_task, u.tk_work)); in rpc_async_schedule()
1009 int rpc_malloc(struct rpc_task *task) in rpc_malloc()
1042 void rpc_free(struct rpc_task *task) in rpc_free()
1064 static void rpc_init_task(struct rpc_task *task, const struct rpc_task_setup *task_setup_data) in rpc_init_task()
1093 static struct rpc_task *
1096 return (struct rpc_task *)mempool_alloc(rpc_task_mempool, GFP_NOFS); in rpc_alloc_task()
1102 struct rpc_task *rpc_new_task(const struct rpc_task_setup *setup_data) in rpc_new_task()
1104 struct rpc_task *task = setup_data->task; in rpc_new_task()
1137 static void rpc_free_task(struct rpc_task *task) in rpc_free_task()
1154 rpc_free_task(container_of(work, struct rpc_task, u.tk_work)); in rpc_async_release()
1158 static void rpc_release_resources_task(struct rpc_task *task) in rpc_release_resources_task()
1168 static void rpc_final_put_task(struct rpc_task *task, in rpc_final_put_task()
1178 static void rpc_do_put_task(struct rpc_task *task, struct workqueue_struct *q) in rpc_do_put_task()
1186 void rpc_put_task(struct rpc_task *task) in rpc_put_task()
1192 void rpc_put_task_async(struct rpc_task *task) in rpc_put_task_async()
1198 static void rpc_release_task(struct rpc_task *task) in rpc_release_task()
1300 sizeof(struct rpc_task), in rpc_init_mempool()