Lines Matching refs:seqRunner
667 SequenceRunner* seqRunner = new SequenceRunner(); in CancelGroupTask() local
668 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in CancelGroupTask()
669 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner); in CancelGroupTask()
680 SequenceRunner* seqRunner = new SequenceRunner(); in TriggerSeqRunner() local
681 uint64_t seqRunnerId = reinterpret_cast<uint64_t>(seqRunner); in TriggerSeqRunner()
682 seqRunner->priority_ = Priority::DEFAULT; in TriggerSeqRunner()
684 groupManager.StoreSequenceRunner(seqRunnerId, seqRunner); in TriggerSeqRunner()
685 seqRunner->isGlobalRunner_ = true; in TriggerSeqRunner()
688 seqRunner->globalSeqRunnerRef_.emplace(env, CreateReference(env)); in TriggerSeqRunner()
689 seqRunner->currentTaskId_ = task1->taskId_; in TriggerSeqRunner()
691 seqRunner->isGlobalRunner_ = false; in TriggerSeqRunner()
692 seqRunner->seqRunnerRef_ = CreateReference(env); in TriggerSeqRunner()
693 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
695 seqRunner->seqRunnerRef_ = CreateReference(env); in TriggerSeqRunner()
697 seqRunner->seqRunnerTasks_.push(task1); in TriggerSeqRunner()
700 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
702 seqRunner->seqRunnerRef_ = CreateReference(env); in TriggerSeqRunner()
705 seqRunner->seqRunnerTasks_.push(task1); in TriggerSeqRunner()
706 seqRunner->seqRunnerTasks_.push(task); in TriggerSeqRunner()
708 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
728 …SequenceRunner* seqRunner = runnerManager.CreateOrGetGlobalRunner(env, obj, SIZE_THREE_, "test", U… in UpdateGroupState() local
729 seqRunner->priority_ = Priority::MEDIUM; in UpdateGroupState()
732 runnerManager.DecreaseSeqCount(seqRunner); in UpdateGroupState()
733 runnerManager.RemoveGlobalSeqRunnerRef(env, seqRunner); in UpdateGroupState()