Home
last modified time | relevance | path

Searched refs:taskId (Results 1 - 17 of 17) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_queue.cpp19 void ExecuteQueue::EnqueueTaskId(uint64_t taskId) in EnqueueTaskId() argument
21 tasks_.emplace_back(taskId); in EnqueueTaskId()
24 bool ExecuteQueue::EraseWaitingTaskId(uint64_t taskId) in EraseWaitingTaskId() argument
26 auto it = std::find(tasks_.begin(), tasks_.end(), taskId); in EraseWaitingTaskId()
37 uint64_t taskId = tasks_.front(); in DequeueTaskId() local
39 return taskId; in DequeueTaskId()
H A Dtask_manager.h43 static constexpr char TASKID_STR[] = "taskId";
61 void StoreTask(uint64_t taskId, Task* task);
62 void RemoveTask(uint64_t taskId);
63 Task* GetTask(uint64_t taskId);
64 void EnqueueTaskId(uint64_t taskId, Priority priority = Priority::DEFAULT);
65 void EraseWaitingTaskId(uint64_t taskId, Priority priority);
67 void CancelTask(napi_env env, uint64_t taskId);
101 std::shared_ptr<CallbackInfo> GetCallbackInfo(uint64_t taskId);
102 void RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> callbackInfo);
103 void IncreaseRefCount(uint64_t taskId);
[all...]
H A Dtask_manager.cpp152 napi_value taskId = nullptr; in GetThreadInfos() local
153 napi_create_array(env, &taskId); in GetThreadInfos()
159 napi_set_element(env, taskId, j, id); in GetThreadInfos()
167 napi_set_named_property(env, threadInfo, "taskIds", taskId); in GetThreadInfos()
189 napi_value taskId = NapiHelper::CreateUint32(env, task->taskId_); in GetTaskInfos() local
199 napi_set_named_property(env, taskInfoValue, "taskId", taskId); in GetTaskInfos()
587 void TaskManager::CancelTask(napi_env env, uint64_t taskId) in CancelTask() argument
593 std::string strTrace = "CancelTask: taskId: " + std::to_string(taskId); in CancelTask()
738 EnqueueTaskId(uint64_t taskId, Priority priority) EnqueueTaskId() argument
757 EraseWaitingTaskId(uint64_t taskId, Priority priority) EraseWaitingTaskId() argument
812 uint64_t taskId = taskQueue->DequeueTaskId(); GetTaskByPriority() local
909 RegisterCallback(napi_env env, uint64_t taskId, std::shared_ptr<CallbackInfo> callbackInfo) RegisterCallback() argument
915 GetCallbackInfo(uint64_t taskId) GetCallbackInfo() argument
926 IncreaseRefCount(uint64_t taskId) IncreaseRefCount() argument
939 DecreaseRefCount(napi_env env, uint64_t taskId) DecreaseRefCount() argument
1026 NotifyDependencyTaskInfo(uint64_t taskId) NotifyDependencyTaskInfo() argument
1046 RemoveDependencyById(uint64_t dependentTaskId, uint64_t taskId) RemoveDependencyById() argument
1060 IsDependendByTaskId(uint64_t taskId) IsDependendByTaskId() argument
1080 StoreTaskDependency(uint64_t taskId, std::set<uint64_t> taskIdSet) StoreTaskDependency() argument
1113 CheckCircularDependency(std::set<uint64_t> dependentIdSet, std::set<uint64_t> idSet, uint64_t taskId) CheckCircularDependency() argument
1134 RemoveTaskDependency(uint64_t taskId, uint64_t dependentId) RemoveTaskDependency() argument
1151 EnqueuePendingTaskInfo(uint64_t taskId, Priority priority) EnqueuePendingTaskInfo() argument
1160 DequeuePendingTaskInfo(uint64_t taskId) DequeuePendingTaskInfo() argument
1177 RemovePendingTaskInfo(uint64_t taskId) RemovePendingTaskInfo() argument
1184 StoreDependentTaskInfo(std::set<uint64_t> dependentTaskIdSet, uint64_t taskId) StoreDependentTaskInfo() argument
1199 RemoveDependentTaskInfo(uint64_t dependentTaskId, uint64_t taskId) RemoveDependentTaskInfo() argument
1214 GetTaskDependInfoToString(uint64_t taskId) GetTaskDependInfoToString() argument
1227 StoreTaskDuration(uint64_t taskId, uint64_t totalDuration, uint64_t cpuDuration) StoreTaskDuration() argument
1245 GetTaskDuration(uint64_t taskId, std::string durationType) GetTaskDuration() argument
1262 RemoveTaskDuration(uint64_t taskId) RemoveTaskDuration() argument
1272 StoreLongTaskInfo(uint64_t taskId, Worker* worker) StoreLongTaskInfo() argument
1278 RemoveLongTaskInfo(uint64_t taskId) RemoveLongTaskInfo() argument
1284 GetLongTaskInfo(uint64_t taskId) GetLongTaskInfo() argument
1291 TerminateTask(uint64_t taskId) TerminateTask() argument
1304 uint64_t taskId = task->taskId_; ReleaseTaskData() local
1394 StoreTask(uint64_t taskId, Task* task) StoreTask() argument
1400 RemoveTask(uint64_t taskId) RemoveTask() argument
1406 GetTask(uint64_t taskId) GetTask() argument
1452 CheckTask(uint64_t taskId) CheckTask() argument
1466 AddTask(uint64_t groupId, napi_ref taskRef, uint64_t taskId) AddTask() argument
1546 CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group) CancelGroupTask() argument
[all...]
H A Dtask_queue.h27 void EnqueueTaskId(uint64_t taskId);
28 bool EraseWaitingTaskId(uint64_t taskId);
H A Dtaskpool.h31 uint64_t taskId {};
77 CallbackScope(napi_env env, napi_env workerEnv, uint64_t taskId, napi_status& status): env_(env), in CallbackScope() argument
78 workerEnv_(workerEnv), taskId_(taskId) in CallbackScope()
H A Dtaskpool.cpp136 CallbackScope callbackScope(resultInfo->hostEnv, resultInfo->workerEnv, resultInfo->taskId, status); in ExecuteCallbackInner()
142 auto callbackInfo = TaskManager::GetInstance().GetCallbackInfo(resultInfo->taskId); in ExecuteCallbackInner()
200 uint64_t taskId = NapiHelper::GetUint64Value(env, napiTaskId); in TerminateTask() local
201 auto task = TaskManager::GetInstance().GetTask(taskId); in TerminateTask()
206 TaskManager::GetInstance().TerminateTask(taskId); in TerminateTask()
275 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); 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()
292 TaskManager::GetInstance().EnqueueTaskId(taskMessage->taskId, Priorit in DelayTask()
598 uint64_t taskId = NapiHelper::GetUint64Value(env, napiTaskId); Cancel() local
[all...]
H A Dworker.cpp418 std::string strTrace = "Task Perform: name : " + task->name_ + ", taskId : " + std::to_string(task->taskId_) in PerformTask()
515 auto taskId = reinterpret_cast<uint64_t>(task); in TaskResultCallback() local
516 if (TaskManager::GetInstance().GetTask(taskId) == nullptr) { in TaskResultCallback()
550 void Worker::StoreTaskId(uint64_t taskId) in StoreTaskId() argument
553 currentTaskId_.emplace_back(taskId); in StoreTaskId()
590 void Worker::TerminateTask(uint64_t taskId) in TerminateTask() argument
592 HILOG_DEBUG("taskpool:: TerminateTask task:%{public}s", std::to_string(taskId).c_str()); in TerminateTask()
594 longTasksSet_.erase(taskId); in TerminateTask()
H A Dsequence_runner.h39 static void ExecuteTaskImmediately(uint64_t taskId, Priority priority);
H A Dtask_group.h40 uint32_t GetTaskIndex(uint32_t taskId);
H A Dtask.h117 void StoreTaskId(uint64_t taskId);
241 taskId(id), serializationArgs(args) {} in TaskResultInfo()
246 uint64_t taskId; member
H A Dsequence_runner.cpp144 HILOG_INFO("taskpool:: taskId %{public}s in seqRunner %{public}s immediately.", in Execute()
151 HILOG_INFO("taskpool:: add taskId: %{public}s to seqRunner %{public}s.", in Execute()
158 void SequenceRunner::ExecuteTaskImmediately(uint64_t taskId, Priority priority) in ExecuteTaskImmediately() argument
160 TaskManager::GetInstance().EnqueueTaskId(taskId, priority); in ExecuteTaskImmediately()
H A Dworker.h177 void StoreTaskId(uint64_t taskId);
183 void TerminateTask(uint64_t taskId);
H A Dtask.cpp99 HILOG_INFO("taskpool:: taskId:%{public}s TaskDestructor", std::to_string(task->taskId_).c_str()); in TaskDestructor()
161 napi_value taskId = NapiHelper::CreateUint64(env, task->taskId_); in GenerateTask() local
163 napi_set_named_property(env, napiTask, TASKID_STR, taskId); in GenerateTask()
394 napi_value id = NapiHelper::GetNameProperty(env, thisVar, "taskId"); in OnReceiveData()
395 uint64_t taskId = NapiHelper::GetUint64Value(env, id); in OnReceiveData() local
396 TaskManager::GetInstance().RegisterCallback(env, taskId, nullptr); in OnReceiveData()
411 napi_value napiTaskId = NapiHelper::GetNameProperty(env, thisVar, "taskId"); in OnReceiveData()
412 uint64_t taskId = NapiHelper::GetUint64Value(env, napiTaskId); in OnReceiveData() local
414 auto task = TaskManager::GetInstance().GetTask(taskId); in OnReceiveData()
425 TaskManager::GetInstance().RegisterCallback(env, taskId, callbackInf in OnReceiveData()
1376 uint64_t taskId = taskId_; VerifyAndPostResult() local
1436 uint64_t taskId = taskId_; CheckStartExecution() local
[all...]
H A Dtask_group.cpp130 uint32_t TaskGroup::GetTaskIndex(uint32_t taskId) in GetTaskIndex() argument
134 if (taskId == id) { in GetTaskIndex()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.h61 static void StoreDependentId(uint64_t taskId, uint64_t dependentId);
62 static void StoreDependentTaskId(uint64_t taskId, uint64_t dependentId);
63 static void StoreTaskDuration(uint64_t taskId);
H A Dtest_taskpool.cpp155 uint64_t taskId = 10; in HWTEST_F() local
157 Task* task = taskManager.GetTask(taskId); in HWTEST_F()
288 uint64_t taskId = reinterpret_cast<uint64_t>(task); in HWTEST_F() local
289 taskManager.CancelTask(env, taskId); in HWTEST_F()
290 ASSERT_TRUE(taskId != 0); in HWTEST_F()
300 uint64_t taskId = reinterpret_cast<uint64_t>(task); in HWTEST_F() local
302 ASSERT_TRUE(taskId != 0); in HWTEST_F()
312 uint64_t taskId = reinterpret_cast<uint64_t>(task); in HWTEST_F() local
315 ASSERT_TRUE(taskId != 0); in HWTEST_F()
384 uint64_t taskId in HWTEST_F() local
460 uint32_t taskId = 10; HWTEST_F() local
472 uint32_t taskId = 11; HWTEST_F() local
483 uint32_t taskId = 12; HWTEST_F() local
504 uint64_t taskId = 14; HWTEST_F() local
517 auto taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
566 uint64_t taskId = 16; HWTEST_F() local
576 uint64_t taskId = 16; HWTEST_F() local
586 uint64_t taskId = 17; HWTEST_F() local
596 uint64_t taskId = 18; HWTEST_F() local
606 uint64_t taskId = 19; HWTEST_F() local
616 uint64_t taskId = 20; HWTEST_F() local
626 uint64_t taskId = 21; HWTEST_F() local
639 uint64_t taskId = 22; HWTEST_F() local
650 uint64_t taskId = 23; HWTEST_F() local
664 uint64_t taskId = 24; HWTEST_F() local
676 uint64_t taskId = 24; HWTEST_F() local
686 uint64_t taskId = 25; HWTEST_F() local
697 uint64_t taskId = 26; HWTEST_F() local
709 uint64_t taskId = 27; HWTEST_F() local
723 uint64_t taskId = 28; HWTEST_F() local
734 uint64_t taskId = 29; HWTEST_F() local
769 uint64_t taskId = 33; HWTEST_F() local
817 uint64_t taskId = 36; HWTEST_F() local
869 uint32_t taskId = 10; HWTEST_F() local
879 uint32_t taskId = 11; HWTEST_F() local
955 uint64_t taskId = 68; HWTEST_F() local
2013 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
2034 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
2065 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
2099 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
2143 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
2584 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
2629 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
4523 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
4549 uint64_t taskId = reinterpret_cast<uint64_t>(task); HWTEST_F() local
[all...]
H A Dtest.cpp437 void NativeEngineTest::StoreDependentId(uint64_t taskId, uint64_t dependentId) in StoreDependentId() argument
441 taskManager.dependTaskInfos_.emplace(taskId, std::move(set)); in StoreDependentId()
444 void NativeEngineTest::StoreDependentTaskId(uint64_t taskId, uint64_t dependentId) in StoreDependentTaskId() argument
448 taskManager.dependentTaskInfos_.emplace(taskId, std::move(set)); in StoreDependentTaskId()
451 void NativeEngineTest::StoreTaskDuration(uint64_t taskId) in StoreTaskDuration() argument
454 uint64_t durationId = taskId + MAX_TIMEOUT_TIME; in StoreTaskDuration()
455 std::pair<uint64_t, uint64_t> durationData = std::make_pair(taskId, durationId); in StoreTaskDuration()
456 taskManager.taskDurationInfos_.emplace(taskId, std::move(durationData)); in StoreTaskDuration()
518 std::set<uint64_t> taskId{ id1, id2 }; in StoreTaskDependency()
519 taskManager.StoreTaskDependency(id3, taskId); in StoreTaskDependency()
[all...]

Completed in 16 milliseconds