Lines Matching defs:queue
62 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer()
74 rpc_set_queue_timer(struct rpc_wait_queue *queue, unsigned long expires) in rpc_set_queue_timer()
84 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_add_timer()
101 static void __rpc_add_wait_queue_priority(struct rpc_wait_queue *queue, in __rpc_add_wait_queue_priority()
129 static void __rpc_add_wait_queue(struct rpc_wait_queue *queue, in __rpc_add_wait_queue()
167 static void __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_remove_wait_queue()
178 static inline void rpc_set_waitqueue_priority(struct rpc_wait_queue *queue, int priority) in rpc_set_waitqueue_priority()
184 static inline void rpc_set_waitqueue_owner(struct rpc_wait_queue *queue, pid_t pid) in rpc_set_waitqueue_owner()
190 static inline void rpc_reset_waitqueue_priority(struct rpc_wait_queue *queue) in rpc_reset_waitqueue_priority()
196 static void __rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname, unsigne… in __rpc_init_priority_wait_queue()
213 void rpc_init_priority_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_priority_wait_queue()
219 void rpc_init_wait_queue(struct rpc_wait_queue *queue, const char *qname) in rpc_init_wait_queue()
225 void rpc_destroy_wait_queue(struct rpc_wait_queue *queue) in rpc_destroy_wait_queue()
370 static void __rpc_do_wake_up_task(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_do_wake_up_task()
391 static void rpc_wake_up_task_queue_locked(struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_task_queue_locked()
400 int rpc_queue_empty(struct rpc_wait_queue *queue) in rpc_queue_empty()
414 void rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task) in rpc_wake_up_queued_task()
425 static struct rpc_task * __rpc_wake_up_next_priority(struct rpc_wait_queue *queue) in __rpc_wake_up_next_priority()
477 struct rpc_task * rpc_wake_up_next(struct rpc_wait_queue *queue) in rpc_wake_up_next()
502 void rpc_wake_up(struct rpc_wait_queue *queue) in rpc_wake_up()
527 void rpc_wake_up_status(struct rpc_wait_queue *queue, int status) in rpc_wake_up_status()
549 struct rpc_wait_queue *queue = (struct rpc_wait_queue *)ptr; in __rpc_queue_timer_fn() local
652 struct rpc_wait_queue *queue; in __rpc_execute() local