taskpool.cpp - OpenGrok cross reference for /commonlibrary/ets_utils/js_concurrent

Lines Matching refs:taskMessage
274     TaskMessage *taskMessage = static_cast<TaskMessage *>(handle->data);

275     auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId);

281         napi_reject_deferred(task->env_, taskMessage->deferred, error);

283         HILOG_INFO("taskpool:: DelayTask taskId %{public}s", std::to_string(taskMessage->taskId).c_str());

284         TaskManager::GetInstance().IncreaseRefCount(taskMessage->taskId);

287         TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, taskMessage->priority);

289             taskInfo->deferred = taskMessage->deferred;

292                 TaskManager::GetInstance().EnqueueTaskId(taskMessage->taskId, Priority(taskMessage->priority));

298                 napi_reject_deferred(task->env_, taskMessage->deferred, execption);

311     delete taskMessage;

312     taskMessage = nullptr;

335     TaskMessage *taskMessage = new TaskMessage();

336     taskMessage->priority = static_cast<Priority>(priority);

337     taskMessage->taskId = task->taskId_;

338     napi_value promise = NapiHelper::CreatePromise(env, &taskMessage->deferred);

339     timer->data = taskMessage;