Lines Matching refs:task1
503 Task* task1 = new Task(); in StoreTaskDependency() local
504 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in StoreTaskDependency()
505 task1->env_ = env; in StoreTaskDependency()
507 task2->taskId_ = reinterpret_cast<uint64_t>(task1); in StoreTaskDependency()
512 uint64_t id3 = task1->taskId_; in StoreTaskDependency()
513 uint64_t id4 = task1->taskId_ + MAX_TIMEOUT_TIME; in StoreTaskDependency()
541 Task* task1 = new Task(); in RemoveTaskDependency() local
542 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in RemoveTaskDependency()
543 uint64_t id2 = task1->taskId_ + MAX_TIMEOUT_TIME; in RemoveTaskDependency()
547 taskManager.RemoveTaskDependency(task->taskId_, task1->taskId_); in RemoveTaskDependency()
552 taskManager.StoreDependentTaskInfo(dependentTaskIdSet, task1->taskId_); in RemoveTaskDependency()
555 taskManager.GetTaskDependInfoToString(task1->taskId_); in RemoveTaskDependency()
556 …taskManager.taskDurationInfos_.emplace(task->taskId_, std::make_pair(UINT64_ZERO_, task1->taskId_)… in RemoveTaskDependency()
579 Task* task1 = new Task(); in ReleaseTaskData() local
580 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in ReleaseTaskData()
581 task1->onEnqueuedCallBackInfo_ = new ListenerCallBackInfo(env, nullptr, nullptr); in ReleaseTaskData()
582 task1->onStartExecutionCallBackInfo_ = new ListenerCallBackInfo(env, nullptr, nullptr); in ReleaseTaskData()
583 task1->onExecutionFailedCallBackInfo_ = new ListenerCallBackInfo(env, nullptr, nullptr); in ReleaseTaskData()
584 task1->onExecutionSucceededCallBackInfo_ = new ListenerCallBackInfo(env, nullptr, nullptr); in ReleaseTaskData()
585 taskManager.ReleaseCallBackInfo(task1); in ReleaseTaskData()
602 Task* task1 = new Task(); in CheckTask() local
603 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in CheckTask()
605 taskManager.CheckTask(task1->taskId_); in CheckTask()
665 Task* task1 = new Task(); in CancelGroupTask() local
666 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in CancelGroupTask()
670 groupManager.AddTaskToSeqRunner(seqRunnerId, task1); in CancelGroupTask()
678 Task* task1 = new Task(); in TriggerSeqRunner() local
679 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in TriggerSeqRunner()
689 seqRunner->currentTaskId_ = task1->taskId_; in TriggerSeqRunner()
696 task1->taskState_ = ExecuteState::CANCELED; in TriggerSeqRunner()
697 seqRunner->seqRunnerTasks_.push(task1); in TriggerSeqRunner()
699 task1->currentTaskInfo_ = taskInfo; in TriggerSeqRunner()
704 task1->currentTaskInfo_ = taskInfo1; in TriggerSeqRunner()
705 seqRunner->seqRunnerTasks_.push(task1); in TriggerSeqRunner()
837 Task* task1 = new Task(); in NotifyHandleTaskResult() local
838 task1->taskId_ = reinterpret_cast<uint64_t>(task1); in NotifyHandleTaskResult()
839 worker->currentTaskId_.push_back(task1->taskId_); in NotifyHandleTaskResult()