Lines Matching refs:TaskManager
72 TaskManager::GetInstance().StoreTask(task->taskId_, task); in TaskConstructor()
81 TaskManager::GetInstance().ReleaseTaskData(env, task); in TaskDestructor()
357 TaskManager::GetInstance().RegisterCallback(env, taskId, nullptr); in OnReceiveData()
379 TaskManager::GetInstance().RegisterCallback(env, taskId, callbackInfo); in OnReceiveData()
425 return TaskManager::GetInstance().NotifyCallbackExecute(env, resultInfo, task); in SendData()
488 if (!TaskManager::GetInstance().StoreTaskDependency(task->taskId_, idSet)) { in AddDependency()
521 … if (!TaskManager::GetInstance().RemoveTaskDependency(task->taskId_, dependentTask->taskId_)) { in RemoveDependency()
536 uint64_t totalDuration = TaskManager::GetInstance().GetTaskDuration(taskId, durationType); in GetTaskDuration()
644 TaskManager::GetInstance().NotifyDependencyTaskInfo(taskId_); in NotifyPendingTask()
654 TaskManager::GetInstance().EnqueueTaskId(taskId_, currentTaskInfo_->priority); in NotifyPendingTask()
736 …TaskManager::GetInstance().StoreTaskDuration(taskId_, std::max(cpuDuration, ioDuration), cpuDurati… in StoreTaskDuration()
738 TaskManager::GetInstance().StoreTaskDuration(taskId_, 0, cpuDuration); in StoreTaskDuration()
746 if (TaskManager::GetInstance().IsDependendByTaskId(taskId_)) { in CanForSequenceRunner()
770 if (TaskManager::GetInstance().IsDependendByTaskId(taskId_)) { in CanForTaskGroup()