Lines Matching refs:seqRunner
666 SequenceRunner* seqRunner = new SequenceRunner();
667 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
668 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner);
679 SequenceRunner* seqRunner = new SequenceRunner();
680 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner);
681 seqRunner->priority_ = Priority::DEFAULT;
683 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner);
684 seqRunner->isGlobalRunner_ = true;
687 seqRunner->globalSeqRunnerRef_.emplace(env, CreateReference(env));
688 seqRunner->currentTaskId_ = task1->taskId_;
690 seqRunner->isGlobalRunner_ = false;
691 seqRunner->seqRunnerRef_ = CreateReference(env);
692 seqRunner->currentTaskId_ = task->taskId_;
694 seqRunner->seqRunnerRef_ = CreateReference(env);
696 seqRunner->seqRunnerTasks_.push(task1);
699 seqRunner->currentTaskId_ = task->taskId_;
701 seqRunner->seqRunnerRef_ = CreateReference(env);
704 seqRunner->seqRunnerTasks_.push(task1);
705 seqRunner->seqRunnerTasks_.push(task);
707 seqRunner->currentTaskId_ = task->taskId_;
727 SequenceRunner* seqRunner = runnerManager.CreateOrGetGlobalRunner(env, obj, SIZE_THREE_, "test", UINT32_ONE_);
728 seqRunner->priority_ = Priority::MEDIUM;
731 runnerManager.DecreaseSeqCount(seqRunner);
732 runnerManager.RemoveGlobalSeqRunnerRef(env, seqRunner);