Searched refs:ExecuteState (Results 1 - 9 of 9) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | taskpool.cpp | 73 napi_value waitingState = NapiHelper::CreateUint32(env, ExecuteState::WAITING);
in InitTaskPool()
74 napi_value runningState = NapiHelper::CreateUint32(env, ExecuteState::RUNNING);
in InitTaskPool()
75 napi_value canceledState = NapiHelper::CreateUint32(env, ExecuteState::CANCELED);
in InitTaskPool()
278 } else if (task->taskState_ == ExecuteState::CANCELED) {
in DelayTask()
290 if (task->taskState_ == ExecuteState::DELAYED || task->taskState_ == ExecuteState::FINISHED) {
in DelayTask()
291 task->taskState_ = ExecuteState::WAITING;
in DelayTask()
325 if (!task->IsExecuted() || task->taskState_ == ExecuteState::CANCELED ||
in ExecuteDelayed()
326 task->taskState_ == ExecuteState::FINISHED) {
in ExecuteDelayed()
327 task->taskState_ = ExecuteState in ExecuteDelayed()
[all...] |
| H A D | task_group.h | 60 std::atomic<ExecuteState> groupState_ {ExecuteState::NOT_FOUND};
|
| H A D | task_manager.cpp | 183 if (task->taskState_ == ExecuteState::NOT_FOUND || task->taskState_ == ExecuteState::DELAYED || in GetTaskInfos()
184 task->taskState_ == ExecuteState::FINISHED) { in GetTaskInfos()
193 ExecuteState state = task->taskState_; in GetTaskInfos()
195 if (state == ExecuteState::RUNNING || state == ExecuteState::ENDING) { in GetTaskInfos()
603 if (task->taskState_ == ExecuteState::CANCELED) { in CancelTask()
620 if ((task->currentTaskInfo_ == nullptr && task->taskState_ != ExecuteState::DELAYED) || in CancelTask()
621 task->taskState_ == ExecuteState::NOT_FOUND || task->taskState_ == ExecuteState in CancelTask()
[all...] |
| H A D | task.h | 43 enum ExecuteState { NOT_FOUND, WAITING, RUNNING, CANCELED, FINISHED, DELAYED, ENDING}; enum
172 std::atomic<ExecuteState> taskState_ {ExecuteState::NOT_FOUND};
|
| H A D | task_group.cpp | 90 if (group->groupState_ != ExecuteState::NOT_FOUND) { in AddTask()
149 groupState_ = ExecuteState::WAITING; in NotifyGroupTask()
169 task->taskState_ = ExecuteState::WAITING; in NotifyGroupTask()
|
| H A D | task.cpp | 375 isCanceled = task->taskState_ == ExecuteState::CANCELED ? true : false; in IsCanceled()
728 if (task->taskState_ != ExecuteState::NOT_FOUND) { in OnEnqueued()
766 if (task->taskState_ != ExecuteState::NOT_FOUND) { in OnStartExecution()
816 if (task->taskState_ != ExecuteState::NOT_FOUND) { in OnExecutionFailed()
854 if (task->taskState_ != ExecuteState::NOT_FOUND) { in OnExecutionSucceeded()
876 if (task->taskState_ == ExecuteState::FINISHED || task->taskState_ == ExecuteState::ENDING) { in IsDone()
1050 taskState_ = ExecuteState::WAITING; in NotifyPendingTask()
1080 if (taskState_ == ExecuteState::CANCELED) { // task may have been canceled in UpdateTask()
1084 taskState_ = ExecuteState in UpdateTask()
[all...] |
| H A D | sequence_runner.cpp | 148 task->taskState_ = ExecuteState::WAITING; in Execute()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 336 task->taskState_ = ExecuteState::CANCELED;
in CancelTask()
342 task->taskState_ = ExecuteState::RUNNING;
in CancelTask()
350 task->taskState_ = ExecuteState::FINISHED;
in CancelTask()
354 task->taskState_ = ExecuteState::WAITING;
in CancelTask()
617 group->groupState_ = ExecuteState::CANCELED;
in CheckTask()
620 group->groupState_ = ExecuteState::WAITING;
in CheckTask()
626 group->groupState_ = ExecuteState::NOT_FOUND;
in CheckTask()
629 group->groupState_ = ExecuteState::FINISHED;
in CheckTask()
632 group->groupState_ = ExecuteState::RUNNING;
in CheckTask()
638 group->groupState_ = ExecuteState in CheckTask()
[all...] |
| H A D | test_taskpool.cpp | 78 ExecuteState state = ExecuteState::NOT_FOUND, bool needStoreTask = false) in CreateTaskObject()
88 if (state != ExecuteState::NOT_FOUND) { in CreateTaskObject()
2342 obj = CreateTaskObject(env, TaskType::TASK, ExecuteState::CANCELED); in HWTEST_F()
2572 task->taskState_ = ExecuteState::CANCELED; in HWTEST_F()
2697 group->groupState_ = ExecuteState::RUNNING; in HWTEST_F()
3527 task->taskState_ = ExecuteState::WAITING; in HWTEST_F()
3533 task->taskState_ = ExecuteState::NOT_FOUND; in HWTEST_F()
3609 task->taskState_ = ExecuteState::WAITING; in HWTEST_F()
3615 task->taskState_ = ExecuteState in HWTEST_F()
77 CreateTaskObject(napi_env env, TaskType taskType = TaskType::TASK, ExecuteState state = ExecuteState::NOT_FOUND, bool needStoreTask = false) CreateTaskObject() argument
[all...] |
Completed in 17 milliseconds