Lines Matching refs:taskMessage
283 TaskMessage *taskMessage = static_cast<TaskMessage *>(handle->data); in DelayTask() local
284 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); in DelayTask()
296 napi_reject_deferred(task->env_, taskMessage->deferred, error); in DelayTask()
298 … HILOG_INFO("taskpool:: DelayTask taskId %{public}s", std::to_string(taskMessage->taskId).c_str()); in DelayTask()
304 TaskManager::GetInstance().IncreaseRefCount(taskMessage->taskId); in DelayTask()
307 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, taskMessage->priority); in DelayTask()
309 taskInfo->deferred = taskMessage->deferred; in DelayTask()
312 … TaskManager::GetInstance().EnqueueTaskId(taskMessage->taskId, Priority(taskMessage->priority)); in DelayTask()
318 napi_reject_deferred(task->env_, taskMessage->deferred, execption); in DelayTask()
328 delete taskMessage; in DelayTask()
329 taskMessage = nullptr; in DelayTask()
352 TaskMessage *taskMessage = new TaskMessage(); in ExecuteDelayed() local
353 taskMessage->priority = static_cast<Priority>(priority); in ExecuteDelayed()
354 taskMessage->taskId = task->taskId_; in ExecuteDelayed()
355 napi_value promise = NapiHelper::CreatePromise(env, &taskMessage->deferred); in ExecuteDelayed()
356 timer->data = taskMessage; in ExecuteDelayed()