| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task_group.cpp | 49 uint64_t groupId = reinterpret_cast<uint64_t>(group); in TaskGroupConstructor() local
50 group->groupId_ = groupId; in TaskGroupConstructor()
51 TaskGroupManager::GetInstance().StoreTaskGroup(groupId, group); in TaskGroupConstructor()
52 napi_value napiGroupId = NapiHelper::CreateUint64(env, groupId); in TaskGroupConstructor()
88 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); in AddTask() local
89 TaskGroup* group = TaskGroupManager::GetInstance().GetTaskGroup(groupId); in AddTask()
109 task->groupId_ = groupId; in AddTask()
111 TaskGroupManager::GetInstance().AddTask(groupId, task->taskRef_, task->taskId_); in AddTask()
119 task->groupId_ = groupId; in AddTask()
123 TaskGroupManager::GetInstance().AddTask(groupId, tas in AddTask()
[all...] |
| H A D | task_manager.h | 42 static constexpr char GROUP_ID_STR[] = "groupId";
251 void AddTask(uint64_t groupId, napi_ref taskRef, uint64_t taskId);
252 void StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup);
253 void RemoveTaskGroup(uint64_t groupId);
254 TaskGroup* GetTaskGroup(uint64_t groupId);
255 void CancelGroup(napi_env env, uint64_t groupId);
258 bool UpdateGroupState(uint64_t groupId);
273 // <groupId, TaskGroup>
|
| H A D | task_manager.cpp | 1466 void TaskGroupManager::AddTask(uint64_t groupId, napi_ref taskRef, uint64_t taskId) in AddTask() argument
1469 auto groupIter = taskGroups_.find(groupId); in AddTask()
1503 void TaskGroupManager::CancelGroup(napi_env env, uint64_t groupId) in CancelGroup() argument
1505 std::string strTrace = "CancelGroup: groupId: " + std::to_string(groupId); in CancelGroup()
1508 TaskGroup* taskGroup = GetTaskGroup(groupId); in CancelGroup()
1657 void TaskGroupManager::StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup) in StoreTaskGroup() argument
1660 taskGroups_.emplace(groupId, taskGroup); in StoreTaskGroup()
1663 void TaskGroupManager::RemoveTaskGroup(uint64_t groupId) in RemoveTaskGroup() argument
1666 taskGroups_.erase(groupId); in RemoveTaskGroup()
1669 GetTaskGroup(uint64_t groupId) GetTaskGroup() argument
1679 UpdateGroupState(uint64_t groupId) UpdateGroupState() argument
[all...] |
| H A D | taskpool.cpp | 366 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId);
in ExecuteGroup() local
367 HILOG_INFO("taskpool::ExecuteGroup groupId %{public}s", std::to_string(groupId).c_str());
in ExecuteGroup()
368 auto taskGroup = TaskGroupManager::GetInstance().GetTaskGroup(groupId);
in ExecuteGroup()
606 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId);
in Cancel() local
607 TaskGroupManager::GetInstance().CancelGroup(env, groupId);
in Cancel()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 382 uint64_t groupId = reinterpret_cast<uint64_t>(group); in HWTEST_F() local
385 napi_value value = NapiHelper::CreateUint64(env, groupId); in HWTEST_F()
387 taskGroupManager.AddTask(groupId, reference, taskId); in HWTEST_F()
397 uint64_t groupId = reinterpret_cast<uint64_t>(group); in HWTEST_F() local
398 TaskGroup* taskGroup = taskGroupManager.GetTaskGroup(groupId); in HWTEST_F()
742 uint64_t groupId = 30; in HWTEST_F() local
743 TaskGroup* group = taskGroupManager.GetTaskGroup(groupId); in HWTEST_F()
744 taskGroupManager.StoreTaskGroup(groupId, group); in HWTEST_F()
745 ASSERT_EQ(groupId, 30); in HWTEST_F()
751 uint64_t groupId in HWTEST_F() local
760 uint64_t groupId = 32; HWTEST_F() local
778 uint64_t groupId = 34; HWTEST_F() local
902 uint64_t groupId = reinterpret_cast<uint64_t>(taskGroup); HWTEST_F() local
918 uint64_t groupId = reinterpret_cast<uint64_t>(taskGroup); HWTEST_F() local
1251 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
2385 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
2406 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
2440 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
2598 uint64_t groupId = reinterpret_cast<uint64_t>(group); HWTEST_F() local
2626 uint64_t groupId = reinterpret_cast<uint64_t>(group); HWTEST_F() local
2693 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
2709 uint64_t groupId = reinterpret_cast<uint64_t>(taskGroup); HWTEST_F() local
2742 uint64_t groupId = reinterpret_cast<uint64_t>(taskGroup); HWTEST_F() local
4277 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
4298 uint64_t groupId = NapiHelper::GetUint64Value(env, napiGroupId); HWTEST_F() local
4546 uint64_t groupId = reinterpret_cast<uint64_t>(group); HWTEST_F() local
[all...] |
| H A D | test.cpp | 612 uint64_t groupId = reinterpret_cast<uint64_t>(group);
in CheckTask() local
613 groupManager.StoreTaskGroup(groupId, nullptr);
in CheckTask()
614 groupManager.AddTask(groupId, nullptr, task->taskId_);
in CheckTask()
616 groupManager.StoreTaskGroup(groupId, group);
in CheckTask()
618 groupManager.CancelGroup(env, groupId);
in CheckTask()
621 groupManager.CancelGroup(env, groupId);
in CheckTask()
627 groupManager.CancelGroup(env, groupId);
in CheckTask()
630 groupManager.CancelGroup(env, groupId);
in CheckTask()
635 groupManager.CancelGroup(env, groupId);
in CheckTask()
644 groupManager.CancelGroup(env, groupId);
in CheckTask()
715 uint64_t groupId = reinterpret_cast<uint64_t>(group); UpdateGroupState() local
802 uint64_t groupId = reinterpret_cast<uint64_t>(group); PerformTask() local
[all...] |