Lines Matching refs:u

71 	list_del(&task->u.tk_wait.timer_list);  in __rpc_disable_timer()
95 task->u.tk_wait.expires = jiffies + task->tk_timeout; in __rpc_add_timer()
96 …if (list_empty(&queue->timer_list.list) || time_before(task->u.tk_wait.expires, queue->timer_list.… in __rpc_add_timer()
97 rpc_set_queue_timer(queue, task->u.tk_wait.expires); in __rpc_add_timer()
98 list_add(&task->u.tk_wait.timer_list, &queue->timer_list.list); in __rpc_add_timer()
107 task = list_first_entry(q, struct rpc_task, u.tk_wait.list); in rpc_rotate_queue_owner()
109 list_move_tail(&task->u.tk_wait.list, q); in rpc_rotate_queue_owner()
144 INIT_LIST_HEAD(&task->u.tk_wait.links); in __rpc_add_wait_queue_priority()
150 list_for_each_entry(t, q, u.tk_wait.list) { in __rpc_add_wait_queue_priority()
152 list_add_tail(&task->u.tk_wait.list, &t->u.tk_wait.links); in __rpc_add_wait_queue_priority()
156 list_add_tail(&task->u.tk_wait.list, q); in __rpc_add_wait_queue_priority()
178 list_add(&task->u.tk_wait.list, &queue->tasks[0]); in __rpc_add_wait_queue()
180 list_add_tail(&task->u.tk_wait.list, &queue->tasks[0]); in __rpc_add_wait_queue()
198 if (!list_empty(&task->u.tk_wait.links)) { in __rpc_remove_wait_queue_priority()
199 t = list_entry(task->u.tk_wait.links.next, struct rpc_task, u.tk_wait.list); in __rpc_remove_wait_queue_priority()
200 list_move(&t->u.tk_wait.list, &task->u.tk_wait.list); in __rpc_remove_wait_queue_priority()
201 list_splice_init(&task->u.tk_wait.links, &t->u.tk_wait.links); in __rpc_remove_wait_queue_priority()
214 list_del(&task->u.tk_wait.list); in __rpc_remove_wait_queue()
340 INIT_WORK(&task->u.tk_work, rpc_async_schedule); in rpc_make_runnable()
341 queue_work(rpciod_workqueue, &task->u.tk_work); in rpc_make_runnable()
472 task = list_entry(q->next, struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued_priority()
476 list_move_tail(&task->u.tk_wait.list, q); in __rpc_find_next_queued_priority()
493 task = list_entry(q->next, struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued_priority()
514 return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list); in __rpc_find_next_queued()
573 u.tk_wait.list); in rpc_wake_up()
602 u.tk_wait.list); in rpc_wake_up_status()
622 list_for_each_entry_safe(task, n, &queue->timer_list.list, u.tk_wait.timer_list) { in __rpc_queue_timer_fn()
623 timeo = task->u.tk_wait.expires; in __rpc_queue_timer_fn()
824 __rpc_execute(container_of(work, struct rpc_task, u.tk_work)); in rpc_async_schedule()
984 rpc_free_task(container_of(work, struct rpc_task, u.tk_work)); in rpc_async_release()
1001 INIT_WORK(&task->u.tk_work, rpc_async_release); in rpc_final_put_task()
1002 queue_work(q, &task->u.tk_work); in rpc_final_put_task()