Home
last modified time | relevance | path

Searched refs:seqRunnerId (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dsequence_runner.cpp33 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in SeqRunnerConstructorInner() local
34 napi_value napiSeqRunnerId = NapiHelper::CreateUint64(env, seqRunnerId); in SeqRunnerConstructorInner()
35 TaskGroupManager::GetInstance().StoreSequenceRunner(seqRunnerId, seqRunner); in SeqRunnerConstructorInner()
42 seqRunner->seqName_.c_str(), std::to_string(seqRunnerId).c_str()); in SeqRunnerConstructorInner()
44 seqRunner->seqRunnerId_ = seqRunnerId; in SeqRunnerConstructorInner()
133 uint64_t seqRunnerId = NapiHelper::GetUint64Value(env, napiSeqRunnerId); in Execute() local
134 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); in Execute()
147 task->seqRunnerId_ = seqRunnerId; in Execute()
157 std::to_string(task->taskId_).c_str(), std::to_string(seqRunnerId).c_str()); in Execute()
164 std::to_string(task->taskId_).c_str(), std::to_string(seqRunnerId).c_str()); in Execute()
[all …]
H A Dtask_manager.h264 void AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task);
267 void StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner);
268 void RemoveSequenceRunner(uint64_t seqRunnerId);
269 SequenceRunner* GetSeqRunner(uint64_t seqRunnerId);
H A Dtask_manager.cpp1606 void TaskGroupManager::StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner) in StoreSequenceRunner() argument
1609 seqRunners_.emplace(seqRunnerId, seqRunner); in StoreSequenceRunner()
1612 void TaskGroupManager::RemoveSequenceRunner(uint64_t seqRunnerId) in RemoveSequenceRunner() argument
1615 seqRunners_.erase(seqRunnerId); in RemoveSequenceRunner()
1618 SequenceRunner* TaskGroupManager::GetSeqRunner(uint64_t seqRunnerId) in GetSeqRunner() argument
1621 auto iter = seqRunners_.find(seqRunnerId); in GetSeqRunner()
1629 void TaskGroupManager::AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task) in AddTaskToSeqRunner() argument
1632 auto iter = seqRunners_.find(seqRunnerId); in AddTaskToSeqRunner()
1644 uint64_t seqRunnerId = lastTask->seqRunnerId_; in TriggerSeqRunner() local
1645 SequenceRunner* seqRunner = GetSeqRunner(seqRunnerId); in TriggerSeqRunner()
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp668 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in CancelGroupTask() local
669 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner); in CancelGroupTask()
670 groupManager.AddTaskToSeqRunner(seqRunnerId, task1); in CancelGroupTask()
681 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in TriggerSeqRunner() local
683 task->seqRunnerId_ = seqRunnerId; in TriggerSeqRunner()
684 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner); in TriggerSeqRunner()
H A Dtest_taskpool.cpp793 uint64_t seqRunnerId = 35; variable
796 taskGroupManager.AddTaskToSeqRunner(seqRunnerId, task);
799 taskGroupManager.StoreSequenceRunner(seqRunnerId, &sequenceRunner);
800 taskGroupManager.RemoveSequenceRunner(seqRunnerId);
801 ASSERT_EQ(seqRunnerId, 35);
802 SequenceRunner *res = taskGroupManager.GetSeqRunner(seqRunnerId);