Home
last modified time | relevance | path

Searched refs:CPUWorker (Results 1 - 5 of 5) sorted by relevance

/foundation/resourceschedule/ffrt/src/eu/
H A Dcpu_worker.h29 class CPUWorker : public WorkerThread { class
31 CPUWorker(const QoS& qos, CpuWorkerOps&& ops) : WorkerThread(qos), ops(ops) in CPUWorker() function in ffrt::CPUWorker
35 Start(CPUWorker::WrapDispatch, this); in CPUWorker()
37 Start(CPUWorker::Dispatch, this); in CPUWorker()
54 static void Dispatch(CPUWorker* worker);
55 static void Run(CPUEUTask* task, CPUWorker* worker);
57 static void RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker);
58 static void RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker);
59 static void* GetTask(CPUWorker* worker);
60 static PollerRet TryPoll(CPUWorker* worke
[all...]
H A Dcpu_worker.cpp37 void CPUWorker::Run(CPUEUTask* task, CPUWorker* worker) in Run()
71 void CPUWorker::Run(ffrt_executor_task_t* task, ffrt_qos_t qos) in Run()
98 void* CPUWorker::WrapDispatch(void* worker) in WrapDispatch()
100 reinterpret_cast<CPUWorker*>(worker)->NativeConfig(); in WrapDispatch()
101 Dispatch(reinterpret_cast<CPUWorker*>(worker)); in WrapDispatch()
105 void CPUWorker::RunTask(ffrt_executor_task_t* curtask, CPUWorker* worker) in RunTask()
135 void CPUWorker::RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worke
[all...]
H A Dscpuworker_manager.cpp118 reinterpret_cast<const CPUWorker*>(thread)->priority_task || in WorkerIdleAction()
119 reinterpret_cast<const CPUWorker*>(thread)->localFifo.GetLength(); in WorkerIdleAction()
139 reinterpret_cast<const CPUWorker*>(thread)->priority_task || in WorkerIdleAction()
140 reinterpret_cast<const CPUWorker*>(thread)->localFifo.GetLength(); in WorkerIdleAction()
186 SpmcQueue* queue = &(reinterpret_cast<CPUWorker*>(thread)->localFifo); in PickUpTaskBatch()
232 CPUWorker::WorkerLooperDefault, in CreateCPUWorker()
247 return new (std::nothrow) CPUWorker(qos, std::move(ops)); in CreateCPUWorker()
H A Dcpuworker_manager.cpp99 CPUWorker* worker = reinterpret_cast<CPUWorker*>(thread); 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()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_worker_manager.cpp146 CPUWorker::WorkerLooperStandard, in HWTEST_F()
160 WorkerThread* worker = new CPUWorker(QoS(2), std::move(ops), manager); in HWTEST_F()

Completed in 4 milliseconds