• Home
  • Raw
  • Download

Lines Matching defs:queue

80 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task)  in __rpc_disable_timer()
91 rpc_set_queue_timer(struct rpc_wait_queue *queue, unsigned long expires) in rpc_set_queue_timer()
106 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer()
115 static void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority) in rpc_set_waitqueue_priority()
123 static void rpc_reset_waitqueue_priority(struct rpc_wait_queue *queue) in rpc_reset_waitqueue_priority()
178 static void __rpc_add_wait_queue_priority(struct rpc_wait_queue *queue, in __rpc_add_wait_queue_priority()
195 static void __rpc_add_wait_queue(struct rpc_wait_queue *queue, in __rpc_add_wait_queue()
225 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_remove_wait_queue()
235 static void __rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname, unsigne… in __rpc_init_priority_wait_queue()
251 void rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_priority_wait_queue()
257 void rpc_init_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_wait_queue()
263 void rpc_destroy_wait_queue(struct rpc_wait_queue *queue) in rpc_destroy_wait_queue()
493 struct rpc_wait_queue *queue, in __rpc_do_wake_up_task_on_wq()
514 struct rpc_wait_queue *queue, struct rpc_task *task, in rpc_wake_up_task_on_wq_queue_action_locked()
532 static void rpc_wake_up_task_queue_locked(struct rpc_wait_queue *queue, in rpc_wake_up_task_queue_locked()
542 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_queued_task()
559 rpc_wake_up_task_queue_set_status_locked(struct rpc_wait_queue *queue, in rpc_wake_up_task_queue_set_status_locked()
576 rpc_wake_up_queued_task_set_status(struct rpc_wait_queue *queue, in rpc_wake_up_queued_task_set_status()
589 static struct rpc_task *__rpc_find_next_queued_priority(struct rpc_wait_queue *queue) in __rpc_find_next_queued_priority()
636 static struct rpc_task *__rpc_find_next_queued(struct rpc_wait_queue *queue) in __rpc_find_next_queued()
649 struct rpc_wait_queue *queue, in rpc_wake_up_first_on_wq()
667 struct rpc_task *rpc_wake_up_first(struct rpc_wait_queue *queue, in rpc_wake_up_first()
682 struct rpc_task *rpc_wake_up_next(struct rpc_wait_queue *queue) in rpc_wake_up_next()
693 static void rpc_wake_up_locked(struct rpc_wait_queue *queue) in rpc_wake_up_locked()
711 void rpc_wake_up(struct rpc_wait_queue *queue) in rpc_wake_up()
724 static void rpc_wake_up_status_locked(struct rpc_wait_queue *queue, int status) in rpc_wake_up_status_locked()
743 void rpc_wake_up_status(struct rpc_wait_queue *queue, int status) in rpc_wake_up_status()
753 struct rpc_wait_queue *queue = container_of(work, in __rpc_queue_timer_fn() local
843 struct rpc_wait_queue *queue; in rpc_signal_task() local
875 struct rpc_wait_queue *queue; in __rpc_execute() local