Home
last modified time | relevance | path

Searched refs:taskIds_ (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Druntime_context_impl.cpp998 if (taskIds_.find(timerId) == taskIds_.end()) { in SetTimerByThreadPool()
1007 if (!allocTimerId && taskIds_.find(timerId) == taskIds_.end()) { in SetTimerByThreadPool()
1017 taskIds_[timerId] = taskId; in SetTimerByThreadPool()
1030 if (taskIds_.find(timerId) == taskIds_.end()) { in ModifyTimerByThreadPool()
1033 taskId = taskIds_[timerId]; in ModifyTimerByThreadPool()
1053 if (taskIds_.find(timerId) == taskIds_.end()) { in RemoveTimerByThreadPool()
1056 taskId = taskIds_[timerId]; in RemoveTimerByThreadPool()
1057 taskIds_.erase(timerId); in RemoveTimerByThreadPool()
1083 if (taskIds_.find(timerId) == taskIds_.end()) { in ThreadPoolTimerAction()
1101 taskIds_.erase(timerId); in ThreadPoolTimerAction()
H A Druntime_context_impl.h275 std::map<TimerId, TaskId> taskIds_; variable
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_group.h80 std::list<uint64_t> taskIds_ {};
H A Dtask_group.cpp163 for (uint32_t id : taskIds_) { in GetTaskIndex()
214 for (size_t i = 0; i < taskIds_.size(); i++) { in CancelPendingGroup()
H A Dtaskpool.cpp394 napi_create_array_with_length(env, taskGroup->taskIds_.size(), &resArr); in ExecuteGroup()
567 for (uint64_t taskId : taskGroup->taskIds_) { in UpdateGroupInfoByResult()
577 auto iter = taskGroup->taskIds_.begin(); in UpdateGroupInfoByResult()
579 …auto task = iter != taskGroup->taskIds_.end() ? TaskManager::GetInstance().GetTask(*iter) : nullpt… in UpdateGroupInfoByResult()
H A Dtask_manager.cpp1513 taskGroup->taskIds_.push_back(taskId); in AddTask()
1523 for (uint64_t taskId : group->taskIds_) { in ReleaseTaskGroupData()
1564 for (uint64_t taskId : taskGroup->taskIds_) { in CancelGroup()
1575 for (size_t i = 0; i < taskGroup->taskIds_.size(); i++) { in CancelGroup()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp876 taskGroup.taskIds_.push_back(taskId);
886 taskGroup.taskIds_.push_back(taskId);
962 taskGroup.taskIds_.push_back(taskId);
2020 taskGroup->taskIds_.push_back(taskId);
2025 taskGroup->taskIds_.push_back(2);
2613 group->taskIds_.push_back(taskId);
2616 napi_create_array_with_length(env, group->taskIds_.size(), &resArr);
2644 group->taskIds_.push_back(taskId);
2651 napi_create_array_with_length(env, group->taskIds_.size(), &resArr);
4561 group->taskIds_.push_back(taskId);
[all …]
H A Dtest.cpp634 group->taskIds_.push_back(task->taskId_); in CheckTask()
640 napi_create_array_with_length(env, group->taskIds_.size(), &resArr); in CheckTask()