Lines Matching refs:tk_wait
72 list_del(&task->u.tk_wait.timer_list); in __rpc_disable_timer()
96 task->u.tk_wait.expires = jiffies + task->tk_timeout; in __rpc_add_timer()
97 …if (list_empty(&queue->timer_list.list) || time_before(task->u.tk_wait.expires, queue->timer_list.… in __rpc_add_timer()
98 rpc_set_queue_timer(queue, task->u.tk_wait.expires); in __rpc_add_timer()
99 list_add(&task->u.tk_wait.timer_list, &queue->timer_list.list); in __rpc_add_timer()
108 task = list_first_entry(q, struct rpc_task, u.tk_wait.list); in rpc_rotate_queue_owner()
110 list_move_tail(&task->u.tk_wait.list, q); in rpc_rotate_queue_owner()
145 INIT_LIST_HEAD(&task->u.tk_wait.links); in __rpc_add_wait_queue_priority()
151 list_for_each_entry(t, q, u.tk_wait.list) { in __rpc_add_wait_queue_priority()
153 list_add_tail(&task->u.tk_wait.list, &t->u.tk_wait.links); in __rpc_add_wait_queue_priority()
157 list_add_tail(&task->u.tk_wait.list, q); in __rpc_add_wait_queue_priority()
179 list_add(&task->u.tk_wait.list, &queue->tasks[0]); in __rpc_add_wait_queue()
181 list_add_tail(&task->u.tk_wait.list, &queue->tasks[0]); in __rpc_add_wait_queue()
199 if (!list_empty(&task->u.tk_wait.links)) { in __rpc_remove_wait_queue_priority()
200 t = list_entry(task->u.tk_wait.links.next, struct rpc_task, u.tk_wait.list); in __rpc_remove_wait_queue_priority()
201 list_move(&t->u.tk_wait.list, &task->u.tk_wait.list); in __rpc_remove_wait_queue_priority()
202 list_splice_init(&task->u.tk_wait.links, &t->u.tk_wait.links); in __rpc_remove_wait_queue_priority()
215 list_del(&task->u.tk_wait.list); in __rpc_remove_wait_queue()
497 task = list_entry(q->next, struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued_priority()
501 list_move_tail(&task->u.tk_wait.list, q); in __rpc_find_next_queued_priority()
518 task = list_entry(q->next, struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued_priority()
539 return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued()
608 u.tk_wait.list); in rpc_wake_up()
637 u.tk_wait.list); in rpc_wake_up_status()
657 list_for_each_entry_safe(task, n, &queue->timer_list.list, u.tk_wait.timer_list) { in __rpc_queue_timer_fn()
658 timeo = task->u.tk_wait.expires; in __rpc_queue_timer_fn()