Searched refs:taskMessage (Results 1 - 3 of 3) sorted by relevance
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | taskpool.cpp | 274 TaskMessage *taskMessage = static_cast<TaskMessage *>(handle->data);
in DelayTask() local
275 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId);
in DelayTask()
281 napi_reject_deferred(task->env_, taskMessage->deferred, error);
in DelayTask()
283 HILOG_INFO("taskpool:: DelayTask taskId %{public}s", std::to_string(taskMessage->taskId).c_str());
in DelayTask()
284 TaskManager::GetInstance().IncreaseRefCount(taskMessage->taskId);
in DelayTask()
287 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, taskMessage->priority);
in DelayTask()
289 taskInfo->deferred = taskMessage->deferred;
in DelayTask()
292 TaskManager::GetInstance().EnqueueTaskId(taskMessage->taskId, Priority(taskMessage->priority));
in DelayTask()
298 napi_reject_deferred(task->env_, taskMessage in DelayTask()
335 TaskMessage *taskMessage = new TaskMessage(); ExecuteDelayed() local
[all...] |
| H A D | task.cpp | 1352 TaskMessage *taskMessage = nullptr; in ClearDelayedTimers() local
1357 taskMessage = static_cast<TaskMessage *>(t->data); in ClearDelayedTimers()
1359 napi_reject_deferred(env_, taskMessage->deferred, error); in ClearDelayedTimers()
1365 delete taskMessage; in ClearDelayedTimers()
1366 taskMessage = nullptr; in ClearDelayedTimers()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 2358 TaskMessage *taskMessage = new TaskMessage(); in HWTEST_F() local
2370 taskMessage->taskId = task->taskId_; in HWTEST_F()
2371 handle->data = taskMessage; in HWTEST_F()
4098 TaskMessage *taskMessage = new TaskMessage(); in HWTEST_F() local
4099 taskMessage->priority = Priority::DEFAULT; in HWTEST_F()
4100 taskMessage->taskId = task->taskId_; in HWTEST_F()
4101 napi_value promise = NapiHelper::CreatePromise(env, &taskMessage->deferred); in HWTEST_F()
4102 timer->data = taskMessage; in HWTEST_F()
4395 TaskMessage *taskMessage = new TaskMessage(); in HWTEST_F() local
4404 taskMessage in HWTEST_F()
4421 TaskMessage *taskMessage = new TaskMessage(); HWTEST_F() local
4446 TaskMessage *taskMessage = new TaskMessage(); HWTEST_F() local
[all...] |
Completed in 13 milliseconds