Home
last modified time | relevance | path

Searched refs:localFifo (Results 1 - 6 of 6) sorted by relevance

/foundation/resourceschedule/ffrt/src/eu/
H A Dcpu_worker.cpp41 worker->localFifo.PushTail(task); in Run()
176 return worker->localFifo.PopHead(); in GetTask()
191 return ((worker->priority_task == nullptr) && (worker->localFifo.GetLength() == 0)); in LocalEmpty()
205 ctx->localFifo = &(worker->localFifo); in Dispatch()
265 if (worker->localFifo.GetLength() == 0) { in WorkerLooperDefault()
H A Dcpu_worker.h33 localFifo.Init(LOCAL_QUEUE_SIZE); in CPUWorker()
42 SpmcQueue localFifo; member in ffrt::CPUWorker
H A Dcpuworker_manager.cpp100 void* task = worker->localFifo.PopHead(); in PickUpTaskFromLocalQueue()
119 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(iter->first)->localFifo); in StealTaskBatch()
123 reinterpret_cast<CPUWorker*>(thread)->localFifo, (queueLen + 1) / 2, thread->GetQos(), InsertTask); in StealTaskBatch()
H A Dscpuworker_manager.cpp119 reinterpret_cast<const CPUWorker*>(thread)->localFifo.GetLength(); in WorkerIdleAction()
140 reinterpret_cast<const CPUWorker*>(thread)->localFifo.GetLength(); in WorkerIdleAction()
186 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(thread)->localFifo); in PickUpTaskBatch()
/foundation/resourceschedule/ffrt/src/core/
H A Dtask_io.cpp121 if (ffrt::ExecuteCtx::Cur()->localFifo != nullptr && in ffrt_wake_coroutine()
122 ffrt::ExecuteCtx::Cur()->localFifo->PushTail(task) == 0) { in ffrt_wake_coroutine()
/foundation/resourceschedule/ffrt/src/sched/
H A Dexecute_ctx.h90 SpmcQueue* localFifo = nullptr; member

Completed in 3 milliseconds