Home
last modified time | relevance | path

Searched refs:CPUWorker (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dcpu_worker.h30 class CPUWorker : public WorkerThread {
32 CPUWorker(const QoS& qos, CpuWorkerOps&& ops, void* worker_mgr) : WorkerThread(qos), ops(ops) in CPUWorker() function
37 Start(CPUWorker::WrapDispatch, this); in CPUWorker()
39 Start(CPUWorker::Dispatch, this); in CPUWorker()
53 static void Run(CPUEUTask* task, CoRoutineEnv* coRoutineEnv, CPUWorker* worker);
57 static void Dispatch(CPUWorker* worker);
59 static void RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker);
61 static void RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker);
62 static void* GetTask(CPUWorker* worker);
63 static PollerRet TryPoll(CPUWorker* worker, int timeout);
[all …]
H A Dcpu_worker.cpp41 void CPUWorker::Run(CPUEUTask* task, CoRoutineEnv* coRoutineEnv, CPUWorker* worker) in Run()
102 void* CPUWorker::WrapDispatch(void* worker) in WrapDispatch()
105 Dispatch(reinterpret_cast<CPUWorker*>(worker)); in WrapDispatch()
109 void CPUWorker::RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker) in RunTask()
116 void CPUWorker::RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker, ExecuteCtx* ctx, CoRoutin… in RunTask()
145 void CPUWorker::RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker) in RunTaskLifo()
160 void* CPUWorker::GetTask(CPUWorker* worker) in GetTask()
198 PollerRet CPUWorker::TryPoll(CPUWorker* worker, int timeout) in TryPoll()
208 bool CPUWorker::LocalEmpty(CPUWorker* worker) in LocalEmpty()
213 void CPUWorker::Dispatch(CPUWorker* worker) in Dispatch()
[all …]
H A Dcpuworker_manager.cpp114 CPUWorker* worker = reinterpret_cast<CPUWorker*>(thread); in PickUpTaskFromLocalQueue()
142 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(thread)->localFifo); in PickUpTaskBatch()
176 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(iter->first)->localFifo); in StealTaskBatch()
180 …reinterpret_cast<CPUWorker*>(thread)->localFifo, (queueLen + 1) / 2, thread->GetQos(), InsertTask); in StealTaskBatch()
H A Dcpu_manager_strategy.cpp41 CPUWorker::WorkerLooperDefault, in CreateCPUWorker()
63 return new (std::nothrow) CPUWorker(qos, std::move(ops), pIns); in CreateCPUWorker()
H A Dscpuworker_manager.cpp186 reinterpret_cast<const CPUWorker*>(thread)->priority_task || in WorkerIdleAction()
187 reinterpret_cast<const CPUWorker*>(thread)->localFifo.GetLength(); in WorkerIdleAction()
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_worker_manager.cpp120 CPUWorker::WorkerLooperDefault,
127 WorkerThread* worker = new CPUWorker(QoS(2), std::move(ops));
/ohos5.0/foundation/resourceschedule/ffrt/src/dfx/bbox/
H A Dbbox.cpp102 CPUWorker* worker = reinterpret_cast<CPUWorker*>(thread); in SaveLocalFifoStatus()