Lines Matching refs:task
41 void CPUWorker::Run(CPUEUTask* task, CoRoutineEnv* coRoutineEnv, CPUWorker* worker) in Run() argument
44 while (CoStart(task, coRoutineEnv) != 0) { in Run()
50 switch (task->type) { in Run()
53 FFRTSetStackId(task->stackId); in Run()
55 task->Execute(); in Run()
59 QueueTask* sTask = reinterpret_cast<QueueTask*>(task); in Run()
69 …FFRT_LOGE("run unsupport task[%lu], type=%d, name[%s]", task->gid, task->type, task->label.c_str()… in Run()
75 void CPUWorker::Run(ffrt_executor_task_t* task, ffrt_qos_t qos) in Run() argument
77 if (task == nullptr) { in Run()
82 ffrt_executor_task_type_t type = static_cast<ffrt_executor_task_type_t>(task->type); in Run()
93 FFRT_EXECUTOR_TASK_BEGIN(task); in Run()
94 func(task, qos); in Run()
97 FFRT_EXECUTOR_TASK_FINISH_MARKER(task); // task finish marker for uv task in Run()
118 CPUEUTask* task = reinterpret_cast<CPUEUTask*>(curtask); in RunTask() local
119 worker->curTask = task; in RunTask()
120 worker->curTaskType_ = task->type; in RunTask()
125 worker->curTaskLabel_ = task->label; in RunTask()
126 worker->curTaskGid_ = task->gid; in RunTask()
128 ctx->task = task; in RunTask()
129 ctx->lastGid_ = task->gid; in RunTask()
130 Run(task, coRoutineEnv, worker); in RunTask()
131 ctx->task = nullptr; in RunTask()
145 void CPUWorker::RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker) in RunTaskLifo() argument
147 RunTask(task, worker); in RunTaskLifo()
166 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); in GetTask() local
168 if (task != nullptr) { in GetTask()
169 if (task->type == ffrt_normal_task && !task->notifyWorker_) { in GetTask()
170 task->notifyWorker_ = true; in GetTask()
171 return task; in GetTask()
175 return task; in GetTask()
180 void* task = worker->priority_task; in GetTask() local
182 if (task != &PLACE_HOLDER) { in GetTask()
183 return task; in GetTask()
189 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); in GetTask()
190 if (task != nullptr) { in GetTask()
194 return task; in GetTask()
262 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); in WorkerLooperDefault() local
264 if (task != nullptr) { in WorkerLooperDefault()
265 if (task->type == ffrt_normal_task && !task->notifyWorker_) { in WorkerLooperDefault()
266 task->notifyWorker_ = true; in WorkerLooperDefault()
270 ffrt_executor_task_t* work = reinterpret_cast<ffrt_executor_task_t*>(task); in WorkerLooperDefault()