Lines Matching refs:task
152 FiberContext* TaskScheduler::RequestFiberContext(internal::GroupedTask& task) in RequestFiberContext() argument
154 FiberContext *fiberContext = task.awaitingFiber; in RequestFiberContext()
157 task.awaitingFiber = nullptr; in RequestFiberContext()
161 MT::StackRequirements::Type stackRequirements = task.desc.stackRequirements; in RequestFiberContext()
184 fiberContext->currentTask = task.desc; in RequestFiberContext()
185 fiberContext->currentGroup = task.group; in RequestFiberContext()
186 fiberContext->parentFiber = task.parentFiber; in RequestFiberContext()
341 …l TaskScheduler::TryStealTask(internal::ThreadContext& threadContext, internal::GroupedTask & task) in TryStealTask() argument
357 if (victimContext.queue.TryPopNewest(task)) in TryStealTask()
506 internal::GroupedTask task; in SchedulerFiberMain() local
507 if ( context.queue.TryPopOldest(task) ) in SchedulerFiberMain()
513 SchedulerFiberProcessTask(context, task); in SchedulerFiberMain()
541 …heduler::SchedulerFiberProcessTask( internal::ThreadContext& context, internal::GroupedTask& task ) in SchedulerFiberProcessTask() argument
544 bool isNewTask = (task.awaitingFiber == nullptr); in SchedulerFiberProcessTask()
548 FiberContext* fiberContext = context.taskScheduler->RequestFiberContext(task); in SchedulerFiberProcessTask()
551 MT_ASSERT(fiberContext->stackRequirements == task.desc.stackRequirements, "Sanity check failed"); in SchedulerFiberProcessTask()
618 internal::GroupedTask task; in SchedulerFiberStep() local
619 …if ( context.queue.TryPopOldest(task) || (disableTaskStealing == false && TryStealTask(context, ta… in SchedulerFiberStep()
621 SchedulerFiberProcessTask(context, task); in SchedulerFiberStep()
658 internal::GroupedTask & task = bucket.tasks[taskIndex]; in RunTasksImpl() local
660 task.parentFiber = parentFiber; in RunTasksImpl()
662 int idx = task.group.GetValidIndex(); in RunTasksImpl()