Lines Matching refs:tk_wait
86 if (list_empty(&task->u.tk_wait.timer_list)) in __rpc_disable_timer()
90 list_del(&task->u.tk_wait.timer_list); in __rpc_disable_timer()
120 list_add(&task->u.tk_wait.timer_list, &queue->timer_list.list); in __rpc_add_timer()
144 list_for_each_entry(t, q, u.tk_wait.list) { in __rpc_list_enqueue_task()
146 list_add_tail(&task->u.tk_wait.links, in __rpc_list_enqueue_task()
147 &t->u.tk_wait.links); in __rpc_list_enqueue_task()
149 task->u.tk_wait.list.next = q; in __rpc_list_enqueue_task()
150 task->u.tk_wait.list.prev = NULL; in __rpc_list_enqueue_task()
154 INIT_LIST_HEAD(&task->u.tk_wait.links); in __rpc_list_enqueue_task()
155 list_add_tail(&task->u.tk_wait.list, q); in __rpc_list_enqueue_task()
167 if (task->u.tk_wait.list.prev == NULL) { in __rpc_list_dequeue_task()
168 list_del(&task->u.tk_wait.links); in __rpc_list_dequeue_task()
171 if (!list_empty(&task->u.tk_wait.links)) { in __rpc_list_dequeue_task()
172 t = list_first_entry(&task->u.tk_wait.links, in __rpc_list_dequeue_task()
174 u.tk_wait.links); in __rpc_list_dequeue_task()
176 q = t->u.tk_wait.list.next; in __rpc_list_dequeue_task()
177 list_add_tail(&t->u.tk_wait.list, q); in __rpc_list_dequeue_task()
178 list_del(&task->u.tk_wait.links); in __rpc_list_dequeue_task()
180 list_del(&task->u.tk_wait.list); in __rpc_list_dequeue_task()
211 INIT_LIST_HEAD(&task->u.tk_wait.timer_list); in __rpc_add_wait_queue()
215 list_add(&task->u.tk_wait.list, &queue->tasks[0]); in __rpc_add_wait_queue()
217 list_add_tail(&task->u.tk_wait.list, &queue->tasks[0]); in __rpc_add_wait_queue()
246 list_del(&task->u.tk_wait.list); in __rpc_remove_wait_queue()
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()
646 return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued()
712 u.tk_wait.list); in rpc_wake_up()
741 u.tk_wait.list); in rpc_wake_up_status()
763 list_for_each_entry_safe(task, n, &queue->timer_list.list, u.tk_wait.timer_list) { in __rpc_queue_timer_fn()