Home
last modified time | relevance | path

Searched refs:GetQos (Results 1 – 16 of 16) sorted by relevance

/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dcpuworker_manager.cpp168 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) { in StealTaskBatch()
172 AddStealingWorker(thread->GetQos()); in StealTaskBatch()
174 groupCtl[thread->GetQos()].threads.begin(); in StealTaskBatch()
181 SubStealingWorker(thread->GetQos()); in StealTaskBatch()
186 SubStealingWorker(thread->GetQos()); in StealTaskBatch()
195 auto& pollerMtx = pollersMtx[thread->GetQos()]; in TryPoll()
197 polling_[thread->GetQos()] = 1; in TryPoll()
199 monitor->IntoPollWait(thread->GetQos()); in TryPoll()
203 monitor->OutOfPollWait(thread->GetQos()); in TryPoll()
205 polling_[thread->GetQos()] = 0; in TryPoll()
[all …]
H A Dscpuworker_manager.cpp82 int qos = static_cast<int>(thread->GetQos()); in WorkerRetiredSimplified()
158 auto& ctl = sleepCtl[thread->GetQos()]; in WorkerIdleAction()
160 monitor->IntoSleep(thread->GetQos()); in WorkerIdleAction()
161 FFRT_PERF_WORKER_IDLE(static_cast<int>(thread->GetQos())); in WorkerIdleAction()
166 bool taskExistence = GetTaskCount(thread->GetQos()); in WorkerIdleAction()
168 (polling_[thread->GetQos()] == 0); in WorkerIdleAction()
171 monitor->WakeupSleep(thread->GetQos()); in WorkerIdleAction()
179 monitor->IntoDeepSleep(thread->GetQos()); in WorkerIdleAction()
189 monitor->WakeupDeepSleep(thread->GetQos()); in WorkerIdleAction()
192 monitor->TimeoutCount(thread->GetQos()); in WorkerIdleAction()
[all …]
H A Dcpu_worker.cpp136 Run(curtask, static_cast<ffrt_qos_t>(worker->GetQos())); in RunTask()
226 ctx->qos = worker->GetQos(); in Dispatch()
230 FFRT_LOGI("qos[%d] thread start succ", static_cast<int>(worker->GetQos())); in Dispatch()
232 FFRT_PERF_WORKER_AWAKE(static_cast<int>(worker->GetQos())); in Dispatch()
H A Dworker_thread.h103 const QoS& GetQos() const in GetQos() function
H A Dco_routine.cpp409 FFRTTraceRecord::TaskRun(task->GetQos(), task); in CoStart()
/ohos5.0/foundation/resourceschedule/ffrt/src/tm/
H A Dscpu_task.cpp50 FFRTTraceRecord::TaskEnqueue<ffrt_normal_task>(GetQos()); in DecDepRef()
116 FFRTTraceRecord::TaskEnqueue<ffrt_normal_task>(GetQos()); in DecWaitDataRef()
H A Dtask_base.h40 virtual int GetQos() const in GetQos() function
H A Dqueue_task.h42 inline int GetQos() const override in GetQos() function
H A Dcpu_task.h69 int GetQos() const override in GetQos() function
/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_strategy.h42 if (next->GetQos() != head->GetQos()) { in DequeBatch()
H A Dqueue_handler.cpp125 if (task->GetQos() == qos_inherit || task->GetQos() == qos_default) { in Submit()
246 FFRTTraceRecord::TaskDone<ffrt_queue_task>(task->GetQos(), task); in Dispatch()
287 if (!sch->InsertNode(&entry->node, task->GetQos())) { in TransferTask()
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/
H A Dworker_thread_test.cpp113 QoS ret = wt->GetQos();
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_thread.cpp104 QoS ret = wt->GetQos();
/ohos5.0/foundation/resourceschedule/ffrt/src/dm/
H A Dsdependence_manager.cpp276 FFRTTraceRecord::TaskDone<ffrt_normal_task>(task->GetQos()); in onTaskDone()
277 FFRTTraceRecord::TaskDone<ffrt_normal_task>(task->GetQos(), task); in onTaskDone()
/ohos5.0/foundation/resourceschedule/ffrt/src/dfx/trace_record/
H A Dffrt_trace_record.h174 …g_recordTaskCounter_[task->type][task->GetQos()].coSwitchCounter.fetch_add(1, std::memory_order_re… in TaskCoSwitchOut()
/ohos5.0/foundation/resourceschedule/ffrt/src/dfx/bbox/
H A Dbbox.cpp230 tmp.size(), t->gid, t->GetQos(), t->label.c_str()); in SaveQueueTaskStatus()
637 << t->GetQos() << "name" << t->label.c_str(); in SaveQueueTaskStatusInfo()