Searched refs:seqRunnerId (Results 1 - 5 of 5) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | sequence_runner.cpp | 28 static constexpr char SEQ_RUNNER_ID_STR[] = "seqRunnerId";
32 // update seqRunner.seqRunnerId in SeqRunnerConstructorInner()
33 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()
123 uint64_t seqRunnerId = NapiHelper::GetUint64Value(env, napiSeqRunnerId); in Execute() local
124 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); in Execute()
137 task->seqRunnerId_ = seqRunnerId; in Execute()
[all...] |
| H A D | task_manager.h | 260 void AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task);
263 void StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner);
264 void RemoveSequenceRunner(uint64_t seqRunnerId);
265 SequenceRunner* GetSeqRunner(uint64_t seqRunnerId);
277 // <seqRunnerId, SequenceRunner>
|
| H A D | task_manager.cpp | 1565 void TaskGroupManager::StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner) in StoreSequenceRunner() argument
1568 seqRunners_.emplace(seqRunnerId, seqRunner); in StoreSequenceRunner()
1571 void TaskGroupManager::RemoveSequenceRunner(uint64_t seqRunnerId) in RemoveSequenceRunner() argument
1574 seqRunners_.erase(seqRunnerId); in RemoveSequenceRunner()
1577 SequenceRunner* TaskGroupManager::GetSeqRunner(uint64_t seqRunnerId) in GetSeqRunner() argument
1580 auto iter = seqRunners_.find(seqRunnerId); in GetSeqRunner()
1588 void TaskGroupManager::AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task) in AddTaskToSeqRunner() argument
1591 auto iter = seqRunners_.find(seqRunnerId); in AddTaskToSeqRunner()
1603 uint64_t seqRunnerId = lastTask->seqRunnerId_; in TriggerSeqRunner() local
1604 SequenceRunner* seqRunner = GetSeqRunner(seqRunnerId); in TriggerSeqRunner()
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 667 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
in CancelGroupTask() local
668 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner);
in CancelGroupTask()
669 groupManager.AddTaskToSeqRunner(seqRunnerId, task1);
in CancelGroupTask()
680 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
in TriggerSeqRunner() local
682 task->seqRunnerId_ = seqRunnerId;
in TriggerSeqRunner()
683 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner);
in TriggerSeqRunner()
|
| H A D | test_taskpool.cpp | 787 uint64_t seqRunnerId = 35; in HWTEST_F() local
790 taskGroupManager.AddTaskToSeqRunner(seqRunnerId, task); in HWTEST_F()
793 taskGroupManager.StoreSequenceRunner(seqRunnerId, &sequenceRunner); in HWTEST_F()
794 taskGroupManager.RemoveSequenceRunner(seqRunnerId); in HWTEST_F()
795 ASSERT_EQ(seqRunnerId, 35); in HWTEST_F()
796 SequenceRunner *res = taskGroupManager.GetSeqRunner(seqRunnerId); in HWTEST_F()
1223 napi_value napiSeqRunnerId = NapiHelper::GetNameProperty(env, result, "seqRunnerId"); in HWTEST_F()
4223 napi_value napiSeqRunnerId = NapiHelper::GetNameProperty(env, SeqResult, "seqRunnerId"); in HWTEST_F()
|
Completed in 17 milliseconds