Searched refs:seqRunner (Results 1 - 6 of 6) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | sequence_runner.cpp | 30 void SequenceRunner::SeqRunnerConstructorInner(napi_env env, napi_value &thisVar, SequenceRunner *seqRunner) in SeqRunnerConstructorInner() argument
32 // update seqRunner.seqRunnerId in SeqRunnerConstructorInner()
33 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in SeqRunnerConstructorInner()
35 TaskGroupManager::GetInstance().StoreSequenceRunner(seqRunnerId, seqRunner); in SeqRunnerConstructorInner()
41 HILOG_INFO("taskpool:: construct seqRunner name is %{public}s, seqRunnerid %{public}s.", in SeqRunnerConstructorInner()
42 seqRunner->seqName_.c_str(), std::to_string(seqRunnerId).c_str()); in SeqRunnerConstructorInner()
44 seqRunner->seqRunnerId_ = seqRunnerId; in SeqRunnerConstructorInner()
45 napi_wrap(env, thisVar, seqRunner, SequenceRunnerDestructor, nullptr, nullptr); in SeqRunnerConstructorInner()
58 if (argc == 2) { // 2: The number of parameters is 2, if the first is seqRunner name, the second must be priority in SeqRunnerConstructor()
86 SequenceRunner* seqRunner in SeqRunnerConstructor() local
124 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); Execute() local
165 SequenceRunner* seqRunner = static_cast<SequenceRunner*>(data); SequenceRunnerDestructor() local
[all...] |
| 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()
1593 HILOG_ERROR("seqRunner:: seqRunner not found."); in AddTaskToSeqRunner()
1604 SequenceRunner* seqRunner = GetSeqRunner(seqRunnerId); in TriggerSeqRunner() local
1605 if (seqRunner == nullptr) { in TriggerSeqRunner()
1606 HILOG_ERROR("seqRunner:: trigger seqRunner not exist."); in TriggerSeqRunner()
1609 if (!SequenceRunnerManager::GetInstance().TriggerGlobalSeqRunner(env, seqRunner)) { in TriggerSeqRunner()
1610 HILOG_ERROR("seqRunner in TriggerSeqRunner()
1709 SequenceRunner *seqRunner = nullptr; CreateOrGetGlobalRunner() local
1738 TriggerGlobalSeqRunner(napi_env env, SequenceRunner* seqRunner) TriggerGlobalSeqRunner() argument
1753 DecreaseSeqCount(SequenceRunner* seqRunner) DecreaseSeqCount() argument
1759 RemoveGlobalSeqRunnerRef(napi_env env, SequenceRunner* seqRunner) RemoveGlobalSeqRunnerRef() argument
1778 GlobalSequenceRunnerDestructor(napi_env env, SequenceRunner *seqRunner) GlobalSequenceRunnerDestructor() argument
[all...] |
| H A D | task_manager.h | 263 void StoreSequenceRunner(uint64_t seqRunnerId, SequenceRunner* seqRunner);
291 uint64_t DecreaseSeqCount(SequenceRunner* seqRunner);
292 void RemoveGlobalSeqRunnerRef(napi_env env, SequenceRunner* seqRunner);
294 bool TriggerGlobalSeqRunner(napi_env env, SequenceRunner* seqRunner);
295 void GlobalSequenceRunnerDestructor(napi_env env, SequenceRunner *seqRunner);
303 // <<name1, seqRunner>, <name2, seqRunner>, ...>
|
| H A D | sequence_runner.h | 41 static void SeqRunnerConstructorInner(napi_env env, napi_value &thisVar, SequenceRunner *seqRunner);
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 666 SequenceRunner* seqRunner = new SequenceRunner();
in CancelGroupTask() local
667 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
in CancelGroupTask()
668 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner);
in CancelGroupTask()
679 SequenceRunner* seqRunner = new SequenceRunner();
in TriggerSeqRunner() local
680 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
in TriggerSeqRunner()
681 seqRunner->priority_ = Priority::DEFAULT;
in TriggerSeqRunner()
683 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner);
in TriggerSeqRunner()
684 seqRunner->isGlobalRunner_ = true;
in TriggerSeqRunner()
687 seqRunner->globalSeqRunnerRef_.emplace(env, CreateReference(env));
in TriggerSeqRunner()
688 seqRunner in TriggerSeqRunner()
727 SequenceRunner* seqRunner = runnerManager.CreateOrGetGlobalRunner(env, obj, SIZE_THREE_, "test", UINT32_ONE_); UpdateGroupState() local
[all...] |
| H A D | test_taskpool.cpp | 1990 SequenceRunner* seqRunner = new SequenceRunner(); in HWTEST_F() local
1991 seqRunner->seqRunnerId_ = reinterpret_cast<uint64_t>(seqRunner); in HWTEST_F()
1992 seqRunner->seqName_ = "seq01"; in HWTEST_F()
1993 void* data = static_cast<void*>(seqRunner); in HWTEST_F()
|
Completed in 15 milliseconds