Lines Matching refs:seqRunner

30 …enceRunner::SeqRunnerConstructorInner(napi_env env, napi_value &thisVar, SequenceRunner *seqRunner)  in SeqRunnerConstructorInner()  argument
33 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); 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()
45 …napi_status status = napi_wrap(env, thisVar, seqRunner, SequenceRunnerDestructor, nullptr, nullptr… in SeqRunnerConstructorInner()
48 SequenceRunnerDestructor(env, seqRunner, nullptr); in SeqRunnerConstructorInner()
93 SequenceRunner* seqRunner = nullptr; in SeqRunnerConstructor() local
95seqRunner = SequenceRunnerManager::GetInstance().CreateOrGetGlobalRunner(env, thisVar, argc, name,… in SeqRunnerConstructor()
96 if (seqRunner == nullptr) { in SeqRunnerConstructor()
101 seqRunner = new SequenceRunner(); in SeqRunnerConstructor()
102 seqRunner->priority_ = static_cast<Priority>(priority); in SeqRunnerConstructor()
103 napi_create_reference(env, thisVar, 0, &seqRunner->seqRunnerRef_); in SeqRunnerConstructor()
106 if (!SeqRunnerConstructorInner(env, thisVar, seqRunner)) { in SeqRunnerConstructor()
134 SequenceRunner* seqRunner = TaskGroupManager::GetInstance().GetSeqRunner(seqRunnerId); in Execute() local
135 if (seqRunner == nullptr) { in Execute()
148 …napi_value promise = task->GetTaskInfoPromise(env, args[0], TaskType::SEQRUNNER_TASK, seqRunner->p… in Execute()
152 if (!SequenceRunnerManager::GetInstance().IncreaseGlobalSeqRunner(env, seqRunner)) { in Execute()
155 if (seqRunner->currentTaskId_ == 0) { in Execute()
158 seqRunner->currentTaskId_ = task->taskId_; in Execute()
161 ExecuteTaskImmediately(task->taskId_, seqRunner->priority_); in Execute()
177 SequenceRunner* seqRunner = static_cast<SequenceRunner*>(data); variable
178 if (seqRunner->isGlobalRunner_) {
179 SequenceRunnerManager::GetInstance().GlobalSequenceRunnerDestructor(env, seqRunner);
181 TaskGroupManager::GetInstance().RemoveSequenceRunner(seqRunner->seqRunnerId_);
182 napi_delete_reference(env, seqRunner->seqRunnerRef_);
183 delete seqRunner;