Searched refs:GetQos (Results 1 - 17 of 17) sorted by relevance
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpuworker_manager.cpp | 110 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) { in StealTaskBatch()
114 std::shared_lock<std::shared_mutex> lck(groupCtl[thread->GetQos()].tgMutex); in StealTaskBatch()
115 AddStealingWorker(thread->GetQos()); in StealTaskBatch()
117 groupCtl[thread->GetQos()].threads.begin(); in StealTaskBatch()
118 while (iter != groupCtl[thread->GetQos()].threads.end()) { in StealTaskBatch()
123 reinterpret_cast<CPUWorker*>(thread)->localFifo, (queueLen + 1) / 2, thread->GetQos(), InsertTask); in StealTaskBatch()
124 SubStealingWorker(thread->GetQos()); in StealTaskBatch()
129 SubStealingWorker(thread->GetQos()); in StealTaskBatch()
135 if (tearDown || FFRTFacade::GetPPInstance().GetPoller(thread->GetQos()) in TryPoll()
[all...] |
| H A D | scpuworker_manager.cpp | 109 auto& ctl = sleepCtl[thread->GetQos()]; in WorkerIdleAction()
111 (void)monitor->IntoSleep(thread->GetQos()); in WorkerIdleAction()
112 FFRT_PERF_WORKER_IDLE(static_cast<int>(thread->GetQos())); in WorkerIdleAction()
117 bool taskExistence = GetTaskCount(thread->GetQos()) || in WorkerIdleAction()
120 bool needPoll = !FFRTFacade::GetPPInstance().GetPoller(thread->GetQos()).DetermineEmptyMap() && in WorkerIdleAction()
121 (polling_[thread->GetQos()] == 0); in WorkerIdleAction()
124 monitor->WakeupCount(thread->GetQos()); in WorkerIdleAction()
125 FFRT_PERF_WORKER_AWAKE(static_cast<int>(thread->GetQos())); in WorkerIdleAction()
132 monitor->IntoDeepSleep(thread->GetQos()); in WorkerIdleAction()
138 return tearDown || GetTaskCount(thread->GetQos()) || in WorkerIdleAction()
[all...] |
| H A D | cpu_worker.cpp | 126 Run(curtask, static_cast<ffrt_qos_t>(worker->GetQos())); in RunTask()
207 ctx->qos = worker->GetQos(); in Dispatch()
211 FFRT_LOGI("qos[%d] thread start succ", static_cast<int>(worker->GetQos())); in Dispatch()
213 FFRT_PERF_WORKER_AWAKE(static_cast<int>(worker->GetQos())); in Dispatch()
|
| H A D | worker_thread.h | 103 const QoS& GetQos() const in GetQos() function in ffrt::WorkerThread
|
| H A D | co_routine.cpp | 428 FFRTTraceRecord::TaskRun(task->GetQos(), task);
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | queue_strategy.h | 42 if (next->GetQos() != head->GetQos()) {
in DequeBatch()
|
| H A D | queue_handler.cpp | 121 if (task->GetQos() == qos_inherit || task->GetQos() == qos_default) { in Submit()
224 FFRTTraceRecord::TaskDone<ffrt_queue_task>(task->GetQos(), task); in Dispatch()
263 if (!sch->InsertNode(&entry->node, task->GetQos())) { in TransferTask()
|
| /foundation/resourceschedule/ffrt/src/tm/ |
| H A D | scpu_task.cpp | 50 FFRTTraceRecord::TaskEnqueue<ffrt_normal_task>(GetQos()); in DecDepRef()
118 FFRTTraceRecord::TaskEnqueue<ffrt_normal_task>(GetQos()); in DecWaitDataRef()
|
| H A D | task_base.h | 39 virtual int GetQos() const in GetQos() function in ffrt::TaskBase
|
| H A D | cpu_task.h | 69 int GetQos() const override
|
| H A D | queue_task.h | 42 inline int GetQos() const override
|
| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_worker_manager.cpp | 224 auto& sched = FFRTScheduler::Instance()->GetScheduler(worker->GetQos()); in HWTEST_F()
252 auto& sched1 = FFRTScheduler::Instance()->GetScheduler(worker1->GetQos()); in HWTEST_F()
253 auto& sched2 = FFRTScheduler::Instance()->GetScheduler(worker2->GetQos()); in HWTEST_F()
|
| H A D | ut_thread.cpp | 109 QoS ret = wt->GetQos(); in HWTEST_F()
|
| /foundation/resourceschedule/ffrt/test/ut/ |
| H A D | worker_thread_test.cpp | 107 * @tc.desc: Test whether the GetQos interface are normal.
113 QoS ret = wt->GetQos(); in HWTEST_F()
|
| /foundation/resourceschedule/ffrt/src/dfx/trace_record/ |
| H A D | ffrt_trace_record.h | 182 g_recordTaskCounter_[task->type][task->GetQos()].coSwitchCounter.fetch_add(1, std::memory_order_relaxed); in TaskCoSwitchOut()
|
| /foundation/resourceschedule/ffrt/src/dm/ |
| H A D | sdependence_manager.cpp | 274 FFRTTraceRecord::TaskDone<ffrt_normal_task>(task->GetQos()); in onTaskDone()
275 FFRTTraceRecord::TaskDone<ffrt_normal_task>(task->GetQos(), task); in onTaskDone()
|
| /foundation/resourceschedule/ffrt/src/dfx/bbox/ |
| H A D | bbox.cpp | 195 tmp.size(), t->gid, t->GetQos(), t->label.c_str()); in SaveQueueTaskStatus()
567 << t->GetQos() << "name" << t->label.c_str(); in SaveQueueTaskStatusInfo()
|
Completed in 8 milliseconds