Lines Matching refs:tasks
49 * RPC tasks sit here while waiting for conditions to improve.
199 __rpc_list_enqueue_task(&queue->tasks[queue_priority], task);
213 list_add_tail(&task->u.tk_wait.list, &queue->tasks[0]);
248 for (i = 0; i < ARRAY_SIZE(queue->tasks); i++)
249 INIT_LIST_HEAD(&queue->tasks[i]);
315 * and then waking up all tasks that were sleeping.
378 * By always appending tasks to the list we ensure FIFO behavior.
611 q = &queue->tasks[RPC_NR_PRIORITY - 1];
618 * Service a batch of tasks from a single owner.
620 q = &queue->tasks[queue->priority];
631 if (q == &queue->tasks[0])
632 q = &queue->tasks[queue->maxpriority];
639 } while (q != &queue->tasks[queue->priority]);
645 rpc_set_waitqueue_priority(queue, (unsigned int)(q - &queue->tasks[0]));
654 if (!list_empty(&queue->tasks[0]))
655 return list_first_entry(&queue->tasks[0], struct rpc_task, u.tk_wait.list);
704 * @queue: rpc_wait_queue on which the tasks are sleeping
721 * @queue: rpc_wait_queue on which the tasks are sleeping
735 * @queue: rpc_wait_queue on which the tasks are sleeping
752 * @queue: rpc_wait_queue on which the tasks are sleeping
1115 /* Initialize workqueue for async tasks */