Searched refs:taskInfo (Results 1 - 6 of 6) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.cpp | 387 auto taskInfo = TaskManager::GetInstance().DequeueTaskId();
in PerformTask() local
388 if (taskInfo.first == 0) {
in PerformTask()
393 PriorityScope priorityScope(worker, taskInfo.second);
in PerformTask()
394 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first);
in PerformTask()
419 + ", priority : " + std::to_string(taskInfo.second);
in PerformTask()
442 if (!task->CheckStartExecution(taskInfo.second)) {
in PerformTask()
|
| H A D | task.cpp | 194 TaskInfo* taskInfo = GenerateTaskInfo(env, func, argsArray, undefined, undefined, Priority::DEFAULT); in GenerateFunctionTask() local
195 if (taskInfo == nullptr) { in GenerateFunctionTask()
196 HILOG_ERROR("taskpool:: task GenerateFunctionTask end, taskInfo is nullptr"); in GenerateFunctionTask()
204 task->currentTaskInfo_ = taskInfo; in GenerateFunctionTask()
214 TaskInfo* taskInfo = GetTaskInfo(env, task, priority); in GetTaskInfoPromise() local
215 if (taskInfo == nullptr) { in GetTaskInfoPromise()
219 return NapiHelper::CreatePromise(env, &taskInfo->deferred); in GetTaskInfoPromise()
1013 TaskInfo* taskInfo = new TaskInfo(); in GenerateTaskInfo() local
1014 taskInfo->serializationFunction = serializationFunction; in GenerateTaskInfo()
1015 taskInfo in GenerateTaskInfo()
[all...] |
| H A D | taskpool.cpp | 287 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, taskMessage->priority);
in DelayTask() local
288 if (taskInfo != nullptr) {
in DelayTask()
289 taskInfo->deferred = taskMessage->deferred;
in DelayTask()
648 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, task->periodicTaskPriority_);
in PeriodicTaskCallback() local
649 if (taskInfo == nullptr) {
in PeriodicTaskCallback()
650 HILOG_DEBUG("taskpool:: the periodic task taskInfo is nullptr");
in PeriodicTaskCallback()
680 TaskInfo* taskInfo = periodicTask->GetTaskInfo(env, napiTask, periodicTask->periodicTaskPriority_);
in ExecutePeriodically() local
681 if (taskInfo == nullptr) {
in ExecutePeriodically()
|
| H A D | task_manager.cpp | 589 // 1. Cannot find taskInfo by executeId, throw error in CancelTask()
590 // 2. Find executing taskInfo, skip it in CancelTask()
591 // 3. Find waiting taskInfo, cancel it in CancelTask()
592 // 4. Find canceled taskInfo, skip it in CancelTask()
1037 auto taskInfo = DequeuePendingTaskInfo(*taskIdIter); in NotifyDependencyTaskInfo() local
1040 if (taskInfo.first != 0) { in NotifyDependencyTaskInfo()
1041 EnqueueTaskId(taskInfo.first, taskInfo.second); in NotifyDependencyTaskInfo()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 353 TaskInfo* taskInfo = new TaskInfo();
in CancelTask() local
355 task->currentTaskInfo_ = taskInfo;
in CancelTask()
660 TaskInfo* taskInfo = new TaskInfo();
in CancelGroupTask() local
661 task->currentTaskInfo_ = taskInfo;
in CancelGroupTask()
697 TaskInfo* taskInfo = new TaskInfo();
in TriggerSeqRunner() local
698 task1->currentTaskInfo_ = taskInfo;
in TriggerSeqRunner()
|
| H A D | test_taskpool.cpp | 3891 TaskInfo* taskInfo = new TaskInfo(); in HWTEST_F() local
3892 task->pendingTaskInfos_.push_back(taskInfo); in HWTEST_F()
3908 TaskInfo* taskInfo = new TaskInfo(); in HWTEST_F() local
3909 napi_value promise = NapiHelper::CreatePromise(env, &taskInfo->deferred); in HWTEST_F()
3910 task->pendingTaskInfos_.push_back(taskInfo); in HWTEST_F()
3935 TaskInfo* taskInfo = new TaskInfo(); in HWTEST_F() local
3937 task->currentTaskInfo_ = taskInfo; in HWTEST_F()
4483 TaskInfo* taskInfo = new TaskInfo(); in HWTEST_F() local
4484 task->currentTaskInfo_ = taskInfo; in HWTEST_F()
4502 TaskInfo* taskInfo in HWTEST_F() local
[all...] |
Completed in 18 milliseconds