Home
last modified time | relevance | path

Searched refs:taskId_ (Results 1 - 10 of 10) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp331 task->taskId_ = reinterpret_cast<uint64_t>(task); in CancelTask()
335 taskManager.StoreTask(task->taskId_, task); in CancelTask()
337 taskManager.CancelTask(env, task->taskId_); in CancelTask()
344 taskManager.CancelTask(env, task->taskId_); in CancelTask()
348 taskManager.CancelTask(env, task->taskId_); in CancelTask()
351 taskManager.CancelTask(env, task->taskId_); in CancelTask()
356 taskManager.CancelTask(env, task->taskId_); in CancelTask()
365 task->taskId_ = reinterpret_cast<uint64_t>(task); in NotifyWorkerIdle()
366 taskManager.taskQueues_[Priority::DEFAULT]->EnqueueTaskId(task->taskId_); in NotifyWorkerIdle()
382 task->taskId_ in EnqueueTaskId()
[all...]
H A Dtest_taskpool.cpp93 taskManager.StoreTask(task->taskId_, task); in CreateTaskObject()
925 task->taskId_ = reinterpret_cast<uint64_t>(task); in HWTEST_F()
937 taskGroupManager.AddTask(groupId, ref, task->taskId_); in HWTEST_F()
984 task->taskId_ = id; in HWTEST_F()
1376 taskManager.StoreTask(pointer->taskId_, pointer); in HWTEST_F()
1383 auto res = taskManager.GetCallbackInfo(pointer->taskId_); in HWTEST_F()
1859 task->taskId_ = reinterpret_cast<uint64_t>(task.get()); in HWTEST_F()
1864 auto res = taskManager.GetTaskDuration(task->taskId_, "totalDuration"); in HWTEST_F()
1866 res = taskManager.GetTaskDuration(task->taskId_, "cpuDuration"); in HWTEST_F()
1868 res = taskManager.GetTaskDuration(task->taskId_, "ioDuratio in HWTEST_F()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtaskpool.h78 workerEnv_(workerEnv), taskId_(taskId) in CallbackScope()
84 TaskManager::GetInstance().DecreaseRefCount(env_, taskId_); in ~CallbackScope()
97 uint64_t taskId_; member in Commonlibrary::Concurrent::TaskPoolModule::CallbackScope
H A Dtask.cpp78 TaskManager::GetInstance().StoreTask(task->taskId_, task); in TaskConstructor()
99 HILOG_INFO("taskpool:: taskId:%{public}s TaskDestructor", std::to_string(task->taskId_).c_str()); in TaskDestructor()
158 task->taskId_ = reinterpret_cast<uint64_t>(task); in GenerateTask()
161 napi_value taskId = NapiHelper::CreateUint64(env, task->taskId_); in GenerateTask()
203 task->taskId_ = reinterpret_cast<uint64_t>(task); in GenerateFunctionTask()
470 TaskResultInfo* resultInfo = new TaskResultInfo(task->env_, env, task->taskId_, serializationArgs); in SendData()
528 if (dependentTask->taskId_ == task->taskId_) { in AddDependency()
550 idSet.emplace(dependentTask->taskId_); in AddDependency()
554 if (!TaskManager::GetInstance().StoreTaskDependency(task->taskId_, idSe in AddDependency()
[all...]
H A Dsequence_runner.cpp145 std::to_string(task->taskId_).c_str(), std::to_string(seqRunnerId).c_str()); in Execute()
146 seqRunner->currentTaskId_ = task->taskId_; in Execute()
149 ExecuteTaskImmediately(task->taskId_, seqRunner->priority_); in Execute()
152 std::to_string(task->taskId_).c_str(), std::to_string(seqRunnerId).c_str()); in Execute()
H A Dtaskpool.cpp266 TaskManager::GetInstance().StoreTask(task->taskId_, task); in Execute()
337 taskMessage->taskId = task->taskId_; in ExecuteDelayed()
341 std::string strTrace = "ExecuteDelayed: taskId: " + std::to_string(task->taskId_); in ExecuteDelayed()
437 std::string strTrace = "Task PerformTask End: taskId : " + std::to_string(task->taskId_); in HandleTaskResultCallback()
479 HILOG_DEBUG("taskpool:: task:%{public}s TriggerTask", std::to_string(task->taskId_).c_str()); in TriggerTask()
483 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in TriggerTask()
489 std::to_string(task->taskId_).c_str(), std::to_string(task->seqRunnerId_).c_str()); in TriggerTask()
501 TaskManager::GetInstance().RemoveTask(task->taskId_); in TriggerTask()
507 HILOG_DEBUG("taskpool:: task:%{public}s UpdateGroupInfoByResult", std::to_string(task->taskId_).c_str()); in UpdateGroupInfoByResult()
508 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in UpdateGroupInfoByResult()
[all...]
H A Dtask_group.cpp111 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
120 TaskManager::GetInstance().StoreTask(task->taskId_, task); in AddTask()
123 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
168 TaskManager::GetInstance().IncreaseRefCount(task->taskId_); in NotifyGroupTask()
170 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, priority); in NotifyGroupTask()
H A Dworker.cpp416 worker->StoreTaskId(task->taskId_); in PerformTask()
418 std::string strTrace = "Task Perform: name : " + task->name_ + ", taskId : " + std::to_string(task->taskId_) in PerformTask()
460 HILOG_DEBUG("taskpool:: NotifyTaskResult task:%{public}s", std::to_string(task->taskId_).c_str()); in NotifyTaskResult()
487 auto iter = std::find(worker->currentTaskId_.begin(), worker->currentTaskId_.end(), task->taskId_); in NotifyHandleTaskResult()
527 TaskManager::GetInstance().StoreTaskDuration(task->taskId_, std::max(ioDuration, cpuDuration), cpuDuration); in TaskResultCallback()
603 HILOG_DEBUG("taskpool:: UpdateLongTaskInfo task:%{public}s", std::to_string(task->taskId_).c_str()); in UpdateLongTaskInfo()
604 TaskManager::GetInstance().StoreLongTaskInfo(task->taskId_, this); in UpdateLongTaskInfo()
608 longTasksSet_.emplace(task->taskId_); in UpdateLongTaskInfo()
H A Dtask_manager.cpp189 napi_value taskId = NapiHelper::CreateUint32(env, task->taskId_); in GetTaskInfos()
635 EraseWaitingTaskId(task->taskId_, task->currentTaskInfo_->priority); in CancelTask()
964 HILOG_DEBUG("taskpool:: task:%{public}s NotifyCallbackExecute", std::to_string(task->taskId_).c_str()); in NotifyCallbackExecute()
966 auto iter = callbackTable_.find(task->taskId_); in NotifyCallbackExecute()
1304 uint64_t taskId = task->taskId_; in ReleaseTaskData()
1352 HILOG_DEBUG("taskpool:: ReleaseCallBackInfo task:%{public}s", std::to_string(task->taskId_).c_str()); in ReleaseCallBackInfo()
1558 TaskManager::GetInstance().EraseWaitingTaskId(task->taskId_, task->currentTaskInfo_->priority); in CancelGroupTask()
1613 if (seqRunner->currentTaskId_ != lastTask->taskId_) { in TriggerSeqRunner()
1637 seqRunner->currentTaskId_ = task->taskId_; in TriggerSeqRunner()
1641 std::to_string(task->taskId_) in TriggerSeqRunner()
[all...]
H A Dtask.h171 uint64_t taskId_ {};

Completed in 18 milliseconds