Lines Matching refs:task
182 Task* task = reinterpret_cast<Task*>(handle->data); in UpdateGroupInfoByResult() local
183 TaskPool::UpdateGroupInfoByResult(env, task, res, success); in UpdateGroupInfoByResult()
329 Task* task = new Task(); in CancelTask() local
330 task->taskType_ = TaskType::COMMON_TASK; in CancelTask()
331 task->taskId_ = reinterpret_cast<uint64_t>(task); in CancelTask()
334 task->taskRef_ = ref; in CancelTask()
335 taskManager.StoreTask(task->taskId_, task); in CancelTask()
336 task->taskState_ = ExecuteState::CANCELED; in CancelTask()
337 taskManager.CancelTask(env, task->taskId_); in CancelTask()
340 task->timer_ = new uv_timer_t; in CancelTask()
341 uv_timer_init(loop, task->timer_); in CancelTask()
342 task->taskState_ = ExecuteState::RUNNING; in CancelTask()
343 task->isPeriodicTask_ = true; in CancelTask()
344 taskManager.CancelTask(env, task->taskId_); in CancelTask()
346 task->isPeriodicTask_ = false; in CancelTask()
347 task->taskType_ = TaskType::SEQRUNNER_TASK; in CancelTask()
348 taskManager.CancelTask(env, task->taskId_); in CancelTask()
350 task->taskState_ = ExecuteState::FINISHED; in CancelTask()
351 taskManager.CancelTask(env, task->taskId_); in CancelTask()
354 task->taskState_ = ExecuteState::WAITING; in CancelTask()
355 task->currentTaskInfo_ = taskInfo; in CancelTask()
356 taskManager.CancelTask(env, task->taskId_); in CancelTask()
358 delete task; in CancelTask()
364 Task* task = new Task(); in NotifyWorkerIdle() local
365 task->taskId_ = reinterpret_cast<uint64_t>(task); in NotifyWorkerIdle()
366 taskManager.taskQueues_[Priority::DEFAULT]->EnqueueTaskId(task->taskId_); in NotifyWorkerIdle()
375 delete task; in NotifyWorkerIdle()
381 Task* task = new Task(); in EnqueueTaskId() local
382 task->taskId_ = reinterpret_cast<uint64_t>(task); in EnqueueTaskId()
383 taskManager.StoreTask(task->taskId_, task); in EnqueueTaskId()
386 task->onEnqueuedCallBackInfo_ = new ListenerCallBackInfo(env, callbackRef, nullptr); in EnqueueTaskId()
387 taskManager.EnqueueTaskId(task->taskId_); in EnqueueTaskId()
396 delete task; in EnqueueTaskId()
402 Task* task = new Task(); in GetTaskByPriority() local
403 task->taskId_ = reinterpret_cast<uint64_t>(task); in GetTaskByPriority()
404 taskManager.StoreTask(task->taskId_, task); in GetTaskByPriority()
410 taskManager.EnqueueTaskId(task->taskId_); in GetTaskByPriority()
411 std::set<uint64_t> set{task->taskId_}; in GetTaskByPriority()
412 taskManager.dependTaskInfos_.emplace(task->taskId_, std::move(set)); in GetTaskByPriority()
416 delete task; in GetTaskByPriority()
427 Task* task = new Task(); in RestoreWorker() local
428 task->taskId_ = reinterpret_cast<uint64_t>(task); in RestoreWorker()
429 taskManager.EnqueueTaskId(task->taskId_); in RestoreWorker()
476 Task* task = new Task(); in NotifyDependencyTaskInfo() local
477 task->taskId_ = reinterpret_cast<uint64_t>(task); in NotifyDependencyTaskInfo()
478 task->env_ = env; in NotifyDependencyTaskInfo()
481 task->worker_ = worker; in NotifyDependencyTaskInfo()
482 uint64_t id = task->taskId_ + MAX_TIMEOUT_TIME; in NotifyDependencyTaskInfo()
483 std::set<uint64_t> set{ task->taskId_, id }; in NotifyDependencyTaskInfo()
484 taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set)); in NotifyDependencyTaskInfo()
485 taskManager.NotifyDependencyTaskInfo(task->taskId_); in NotifyDependencyTaskInfo()
486 std::set<uint64_t> set1{ task->taskId_, id }; in NotifyDependencyTaskInfo()
487 taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set1)); in NotifyDependencyTaskInfo()
490 taskManager.EnqueuePendingTaskInfo(task->taskId_, Priority::DEFAULT); in NotifyDependencyTaskInfo()
491 taskManager.NotifyDependencyTaskInfo(task->taskId_); in NotifyDependencyTaskInfo()
492 std::set<uint64_t> set2{ task->taskId_, id }; in NotifyDependencyTaskInfo()
493 taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set2)); in NotifyDependencyTaskInfo()
494 taskManager.IsDependentByTaskId(task->taskId_); in NotifyDependencyTaskInfo()
500 Task* task = new Task(); in StoreTaskDependency() local
501 task->taskId_ = reinterpret_cast<uint64_t>(task); in StoreTaskDependency()
502 task->env_ = env; in StoreTaskDependency()
510 uint64_t id1 = task->taskId_; in StoreTaskDependency()
511 uint64_t id2 = task->taskId_ + MAX_TIMEOUT_TIME; in StoreTaskDependency()
538 Task* task = new Task(); in RemoveTaskDependency() local
539 task->taskId_ = reinterpret_cast<uint64_t>(task); in RemoveTaskDependency()
540 uint64_t id = task->taskId_ + MAX_TIMEOUT_TIME; in RemoveTaskDependency()
546 taskManager.dependTaskInfos_.emplace(task->taskId_, std::move(set)); in RemoveTaskDependency()
547 taskManager.RemoveTaskDependency(task->taskId_, task1->taskId_); in RemoveTaskDependency()
548 taskManager.RemoveTaskDependency(task->taskId_, id); in RemoveTaskDependency()
550 taskManager.dependentTaskInfos_.emplace(task->taskId_, std::move(set2)); in RemoveTaskDependency()
551 std::set<uint64_t> dependentTaskIdSet{ task->taskId_ }; in RemoveTaskDependency()
553 taskManager.RemoveDependentTaskInfo(task->taskId_, id2); in RemoveTaskDependency()
554 taskManager.RemoveDependentTaskInfo(task->taskId_, id); in RemoveTaskDependency()
556 …taskManager.taskDurationInfos_.emplace(task->taskId_, std::make_pair(UINT64_ZERO_, task1->taskId_)… in RemoveTaskDependency()
557 taskManager.StoreTaskDuration(task->taskId_, UINT64_ZERO_, UINT64_ZERO_); in RemoveTaskDependency()
558 taskManager.GetTaskDuration(task->taskId_, ""); in RemoveTaskDependency()
559 taskManager.RemoveTaskDuration(task->taskId_); in RemoveTaskDependency()
565 Task* task = new Task(); in ReleaseTaskData() local
566 task->taskId_ = reinterpret_cast<uint64_t>(task); in ReleaseTaskData()
567 task->onResultSignal_ = nullptr; in ReleaseTaskData()
568 task->taskType_ = TaskType::FUNCTION_TASK; in ReleaseTaskData()
569 taskManager.StoreTask(task->taskId_, task); in ReleaseTaskData()
570 taskManager.ReleaseTaskData(env, task); in ReleaseTaskData()
571 task->taskType_ = TaskType::GROUP_FUNCTION_TASK; in ReleaseTaskData()
572 taskManager.StoreTask(task->taskId_, task); in ReleaseTaskData()
573 taskManager.ReleaseTaskData(env, task); in ReleaseTaskData()
574 std::set<uint64_t> set{ task->taskId_ }; in ReleaseTaskData()
575 taskManager.dependTaskInfos_.emplace(task->taskId_, std::move(set)); in ReleaseTaskData()
576 task->taskType_ = TaskType::COMMON_TASK; in ReleaseTaskData()
577 taskManager.StoreTask(task->taskId_, task); in ReleaseTaskData()
578 taskManager.ReleaseTaskData(env, task); in ReleaseTaskData()
593 … ConcurrentHelper::UvHandleInit(loop, task->onStartExecutionSignal_, NativeEngineTest::foo, task2); in ReleaseTaskData()
600 Task* task = new Task(); in CheckTask() local
601 task->taskId_ = reinterpret_cast<uint64_t>(task); in CheckTask()
604 taskManager.StoreTask(task->taskId_, task); in CheckTask()
614 groupManager.AddTask(groupId, nullptr, task->taskId_); in CheckTask()
634 group->taskIds_.push_back(task->taskId_); in CheckTask()
653 Task* task = new Task(); in CancelGroupTask() local
654 task->taskId_ = reinterpret_cast<uint64_t>(task); in CancelGroupTask()
655 taskManager.StoreTask(task->taskId_, task); in CancelGroupTask()
656 task->taskState_ = ExecuteState::RUNNING; in CancelGroupTask()
657 groupManager.CancelGroupTask(env, task->taskId_, group); in CancelGroupTask()
658 task->taskState_ = ExecuteState::WAITING; in CancelGroupTask()
659 groupManager.CancelGroupTask(env, task->taskId_, group); in CancelGroupTask()
660 task->taskState_ = ExecuteState::WAITING; in CancelGroupTask()
662 task->currentTaskInfo_ = taskInfo; in CancelGroupTask()
663 groupManager.CancelGroupTask(env, task->taskId_, group); in CancelGroupTask()
676 Task* task = new Task(); in TriggerSeqRunner() local
677 task->taskId_ = reinterpret_cast<uint64_t>(task); in TriggerSeqRunner()
683 task->seqRunnerId_ = seqRunnerId; in TriggerSeqRunner()
686 bool res = groupManager.TriggerSeqRunner(env, task); in TriggerSeqRunner()
690 groupManager.TriggerSeqRunner(env, task); in TriggerSeqRunner()
693 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
694 groupManager.TriggerSeqRunner(env, task); in TriggerSeqRunner()
700 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
701 groupManager.TriggerSeqRunner(env, task); in TriggerSeqRunner()
706 seqRunner->seqRunnerTasks_.push(task); in TriggerSeqRunner()
707 task->taskState_ = ExecuteState::RUNNING; in TriggerSeqRunner()
708 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
709 groupManager.TriggerSeqRunner(env, task); in TriggerSeqRunner()
717 Task* task = new Task(); in UpdateGroupState() local
718 task->taskId_ = reinterpret_cast<uint64_t>(task); in UpdateGroupState()
720 groupManager.UpdateGroupState(task->taskId_); in UpdateGroupState()
808 Task* task = new Task(); in PerformTask() local
809 task->taskId_ = reinterpret_cast<uint64_t>(task); in PerformTask()
810 taskManager.StoreTask(task->taskId_, task); in PerformTask()
817 mediumTaskQueue->EnqueueTaskId(task->taskId_); in PerformTask()
821 task->taskState_ = ExecuteState::WAITING; in PerformTask()
822 task->taskType_ = TaskType::GROUP_COMMON_TASK; in PerformTask()
823 task->groupId_ = groupId; in PerformTask()
832 Task* task = new Task(); in NotifyHandleTaskResult() local
833 task->taskId_ = reinterpret_cast<uint64_t>(task); in NotifyHandleTaskResult()
834 task->env_ = worker->workerEnv_; in NotifyHandleTaskResult()
836 ConcurrentHelper::UvHandleInit(loop, task->onResultSignal_, NativeEngineTest::foo, task); in NotifyHandleTaskResult()
840 task->worker_ = worker; in NotifyHandleTaskResult()
841 task->isMainThreadTask_ = true; in NotifyHandleTaskResult()
842 task->taskRefCount_.fetch_add(1); in NotifyHandleTaskResult()
843 TaskManager::GetInstance().StoreTask(task->taskId_, task); in NotifyHandleTaskResult()
844 Worker::NotifyHandleTaskResult(task); in NotifyHandleTaskResult()
851 Task* task = new Task(); in TaskResultCallback() local
852 task->taskId_ = reinterpret_cast<uint64_t>(task); in TaskResultCallback()
853 task->env_ = worker->workerEnv_; in TaskResultCallback()
854 task->taskRefCount_.fetch_add(1); in TaskResultCallback()
855 task->worker_ = worker; in TaskResultCallback()
856 task->cpuTime_ = UINT64_ZERO_; in TaskResultCallback()
857 Worker::TaskResultCallback(worker->workerEnv_, nullptr, false, reinterpret_cast<void*>(task)); in TaskResultCallback()
858 task->taskRefCount_.fetch_add(1); in TaskResultCallback()
859 task->cpuTime_ = task->taskId_; in TaskResultCallback()
860 Worker::TaskResultCallback(worker->workerEnv_, nullptr, true, reinterpret_cast<void*>(task)); in TaskResultCallback()
874 uint64_t id = task->taskId_ + MAX_TIMEOUT_TIME; in TaskResultCallback()
875 std::unordered_set<uint64_t> set{ task->taskId_, id }; in TaskResultCallback()
877 worker->TerminateTask(task->taskId_); in TaskResultCallback()
887 Task* task = new Task(); in HandleFunctionException() local
888 task->taskId_ = reinterpret_cast<uint64_t>(task); in HandleFunctionException()
889 task->env_ = workerEnv; in HandleFunctionException()
890 TaskResultInfo* resultInfo = new TaskResultInfo(env, workerEnv, task->taskId_, nullptr); in HandleFunctionException()
891 TaskManager::GetInstance().NotifyCallbackExecute(env, resultInfo, task); in HandleFunctionException()
892 task->IncreaseRefCount(); in HandleFunctionException()
894 ConcurrentHelper::UvHandleInit(loop, task->onResultSignal_, NativeEngineTest::foo, task); in HandleFunctionException()
895 task->worker_ = worker; in HandleFunctionException()
896 Worker::HandleFunctionException(env, task); in HandleFunctionException()
897 task->IncreaseRefCount(); in HandleFunctionException()
898 Worker::HandleFunctionException(env, task); in HandleFunctionException()