| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_scheduler.cpp | 63 std::vector<TaskState::State> produceStatus; in HWTEST_F()
64 std::vector<TaskState::State> consumeStatus; in HWTEST_F()
67 std::array<uint64_t, static_cast<size_t>(TaskState::MAX)> expectCount; in HWTEST_F()
70 for (auto state = TaskState::PENDING; state != TaskState::MAX; ++(size_t&)state) { in HWTEST_F()
75 EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::PENDING)], 0); in HWTEST_F()
76 EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::READY)], 0); in HWTEST_F()
77 EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::RUNNING)], 0); in HWTEST_F()
78 EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::BLOCKED)], 0); in HWTEST_F()
80 auto increCount = [&expectCount](TaskState in HWTEST_F()
[all...] |
| /foundation/resourceschedule/ffrt/src/sched/ |
| H A D | task_state.cpp | 22 std::array<TaskState::Op, static_cast<size_t>(TaskState::MAX)> TaskState::ops;
24 int TaskState::OnTransition(State state, CPUEUTask* task, Op&& op) in OnTransition()
35 if (task->state == TaskState::EXITED) { in OnTransition()
59 uint64_t TaskState::TaskStateStat::WaitingTime() const in WaitingTime()
61 return CalcDuration(TaskState::READY, TaskState::RUNNING); in WaitingTime()
64 uint64_t TaskState::TaskStateStat::RunningTime() const in RunningTime()
66 return CalcDuration(TaskState in RunningTime()
[all...] |
| H A D | task_state.h | 29 class TaskState { class
35 TaskState() = default;
37 TaskState(const TaskState&) = delete;
38 TaskState(TaskState&&) = delete;
40 TaskState& operator=(const TaskState&) = delete;
41 TaskState& operator=(TaskState
[all...] |
| H A D | task_manager.cpp | 49 case TaskState::RUNNING: in CalcTaskTime()
50 calc(task->state.WaitingTime(), GetCount(TaskState::READY), maxWaitingTime, avgWaitingTime); in CalcTaskTime()
52 case TaskState::EXITED: { in CalcTaskTime()
53 uint64_t count = GetCount(TaskState::EXITED); in CalcTaskTime()
|
| H A D | task_manager.h | 33 uint64_t GetCount(TaskState::State state) const in GetCount()
64 std::array<std::atomic_uint64_t, static_cast<size_t>(TaskState::MAX)> taskCount;
|
| H A D | scheduler.h | 81 TaskState::RegisterOps(TaskState::READY, ([this] (CPUEUTask* task) { return this->WakeupTask(task); })); in FFRTScheduler()
|
| /foundation/multimedia/player_framework/services/utils/include/ |
| H A D | task_queue.h | 125 if (state_ != TaskState::IDLE) {
128 state_ = TaskState::RUNNING;
134 state_ = TaskState::FINISHED; in onstexpr()
139 state_ = TaskState::FINISHED;
151 while ((state_ != TaskState::FINISHED) && (state_ != TaskState::CANCELED)) { in GetResult()
162 [this] { return state_ == TaskState::FINISHED || state_ == TaskState::CANCELED; }); in GetResultWithTimeLimit()
165 if (state_ == TaskState::IDLE) { in GetResultWithTimeLimit()
177 state_ = TaskState
215 enum TaskState { global() enum in OHOS::Media::TaskHandler
[all...] |
| /foundation/resourceschedule/ffrt/src/tm/ |
| H A D | cpu_task.h | 54 TaskState state;
87 int UpdateState(TaskState::State taskState) in UpdateState()
89 return TaskState::OnTransition(taskState, this); in UpdateState()
92 int UpdateState(TaskState::State taskState, TaskState::Op&& op) in UpdateState()
94 return TaskState::OnTransition(taskState, this, std::move(op)); in UpdateState()
|
| H A D | scpu_task.cpp | 51 this->UpdateState(TaskState::READY); in DecDepRef()
93 parent->UpdateState(TaskState::READY); in DecChildRef()
119 this->UpdateState(TaskState::READY); in DecWaitDataRef()
|
| H A D | cpu_task.cpp | 57 UpdateState(TaskState::RUNNING); in Execute()
67 this->UpdateState(ffrt::TaskState::EXITED); in Execute()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/task/ |
| H A D | task.h | 48 TaskState GetTaskState();
49 void SetTaskState(TaskState taskState);
76 TaskState taskState_ { TaskState::INIT };
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | parallel_task_queue.cpp | 38 struct ParallelTaskQueue::TaskState { struct in ParallelTaskQueue
46 explicit Task(TaskState& state, IThreadPool::ITask& task, uint64_t id);
54 TaskState& state_;
59 ParallelTaskQueue::Task::Task(TaskState& state, IThreadPool::ITask& task, uint64_t id) in Task()
142 void ParallelTaskQueue::QueueTasks(vector<size_t>& waiting, TaskState& state) in QueueTasks()
187 TaskState state; in Execute()
|
| H A D | parallel_task_queue.h | 54 struct TaskState;
57 void QueueTasks(BASE_NS::vector<size_t>& waiting, TaskState& taskState);
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/ |
| H A D | meta_disable_task.cpp | 62 SetTaskState(TaskState::RUNNING); in DoTaskInner()
65 auto state = (result == DH_FWK_SUCCESS) ? TaskState::SUCCESS : TaskState::FAIL; in DoTaskInner()
|
| H A D | disable_task.cpp | 65 SetTaskState(TaskState::RUNNING); in DoTaskInner()
73 auto state = (result == DH_FWK_SUCCESS) ? TaskState::SUCCESS : TaskState::FAIL; in DoTaskInner()
|
| H A D | meta_enable_task.cpp | 62 SetTaskState(TaskState::RUNNING); in DoTaskInner()
65 auto state = (result == DH_FWK_SUCCESS) ? TaskState::SUCCESS : TaskState::FAIL; in DoTaskInner()
|
| H A D | enable_task.cpp | 64 SetTaskState(TaskState::RUNNING); in DoTaskInner()
66 auto state = (result == DH_FWK_SUCCESS) ? TaskState::SUCCESS : TaskState::FAIL; in DoTaskInner()
|
| H A D | task.cpp | 83 TaskState Task::GetTaskState() in GetTaskState()
88 void Task::SetTaskState(TaskState taskState) in SetTaskState()
|
| H A D | offline_task.cpp | 70 this->SetTaskState(TaskState::RUNNING); in DoTaskInner()
95 this->SetTaskState(TaskState::SUCCESS); in DoTaskInner()
|
| H A D | online_task.cpp | 56 this->SetTaskState(TaskState::RUNNING); in DoTask()
76 SetTaskState(TaskState::SUCCESS); in DoTask()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/utils/ |
| H A D | impl_utils.h | 50 enum class TaskState : int32_t { class in OHOS::DistributedHardware::TaskType::TaskStep
88 TaskState taskState;
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/hidumphelper/ |
| H A D | hidump_helper.cpp | 70 std::unordered_map<TaskState, std::string> g_mapTaskState = {
71 { TaskState::INIT, "INIT" },
72 { TaskState::RUNNING, "RUNNING" },
73 { TaskState::SUCCESS, "SUCCESS" },
74 { TaskState::FAIL, "FAIL" },
245 result.append("\n TaskState : "); in ShowAllTaskInfos()
|
| /foundation/resourceschedule/ffrt/src/dm/ |
| H A D | sdependence_manager.cpp | 42 TaskState::RegisterOps(TaskState::EXITED, in SDependenceManager()
161 task->UpdateState(TaskState::READY); in onSubmit()
190 sTask->UpdateState(ffrt::TaskState::BLOCKED); in onWait()
259 sTask->UpdateState(ffrt::TaskState::BLOCKED); in onWait()
|
| /foundation/resourceschedule/ffrt/src/dfx/bbox/ |
| H A D | bbox.cpp | 163 return (t->state == TaskState::RUNNING) && t->coRoutine && in SaveNormalTaskStatus()
167 return t->state == TaskState::BLOCKED; in SaveNormalTaskStatus()
170 return t->state == TaskState::PENDING; in SaveNormalTaskStatus()
529 return (t->state == TaskState::RUNNING) && t->coRoutine && in SaveNormalTaskStatusInfo()
533 return t->state == TaskState::BLOCKED; in SaveNormalTaskStatusInfo()
536 return t->state == TaskState::PENDING; in SaveNormalTaskStatusInfo()
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | co_routine.cpp | 437 task->UpdateState(ffrt::TaskState::RUNNING);
450 task->UpdateState(ffrt::TaskState::EXITED);
483 co->task->UpdateState(ffrt::TaskState::BLOCKED);
521 task->UpdateState(ffrt::TaskState::READY);
|