Home
last modified time | relevance | path

Searched refs:group (Results 1 - 6 of 6) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/
H A Dselect.rs68 group: &Group, in parse_group()
77 builder.len = group_num(group.stream()) - 1; in parse_group()
83 builder.except_index = group.stream().into_iter().count(); in parse_group()
97 TokenTree::Group(group) => { in parse_token()
98 if !parse_group(group, idx, flags, builder) { in parse_token()
133 Some(TokenTree::Group(group)) => group_num(group.stream()) + 1, in group_num()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_group.cpp48 TaskGroup* group = new TaskGroup(); in TaskGroupConstructor() local
49 uint64_t groupId = reinterpret_cast<uint64_t>(group); in TaskGroupConstructor()
50 group->groupId_ = groupId; in TaskGroupConstructor()
51 TaskGroupManager::GetInstance().StoreTaskGroup(groupId, group); in TaskGroupConstructor()
59 napi_wrap(env, thisVar, group, TaskGroupDestructor, nullptr, nullptr); in TaskGroupConstructor()
60 napi_create_reference(env, thisVar, 0, &group->groupRef_); in TaskGroupConstructor()
67 TaskGroup* group = static_cast<TaskGroup*>(data); in TaskGroupDestructor() local
68 TaskGroupManager::GetInstance().ReleaseTaskGroupData(env, group); in TaskGroupDestructor()
69 napi_delete_reference(env, group->groupRef_); in TaskGroupDestructor()
70 delete group; in TaskGroupDestructor()
89 TaskGroup* group = TaskGroupManager::GetInstance().GetTaskGroup(groupId); AddTask() local
[all...]
H A Dtask_manager.cpp1484 void TaskGroupManager::ReleaseTaskGroupData(napi_env env, TaskGroup* group) in ReleaseTaskGroupData() argument
1486 HILOG_DEBUG("taskpool:: ReleaseTaskGroupData group"); in ReleaseTaskGroupData()
1487 TaskGroupManager::GetInstance().RemoveTaskGroup(group->groupId_); in ReleaseTaskGroupData()
1488 for (uint64_t taskId : group->taskIds_) { in ReleaseTaskGroupData()
1496 if (group->currentGroupInfo_ != nullptr) { in ReleaseTaskGroupData()
1497 delete group->currentGroupInfo_; in ReleaseTaskGroupData()
1500 group->CancelPendingGroup(env); in ReleaseTaskGroupData()
1510 HILOG_ERROR("taskpool:: CancelGroup group is nullptr"); in CancelGroup()
1546 void TaskGroupManager::CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group) in CancelGroupTask() argument
1682 // During the modification process of the group, preven in UpdateGroupState()
1689 TaskGroup* group = reinterpret_cast<TaskGroup*>(groupIter->second); UpdateGroupState() local
[all...]
H A Dtask_manager.h256 void CancelGroupTask(napi_env env, uint64_t taskId, TaskGroup* group);
257 void ReleaseTaskGroupData(napi_env env, TaskGroup* group);
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp608 TaskGroup* group = new TaskGroup(); in CheckTask() local
611 group->groupRef_ = ref; in CheckTask()
612 uint64_t groupId = reinterpret_cast<uint64_t>(group); in CheckTask()
616 groupManager.StoreTaskGroup(groupId, group); in CheckTask()
617 group->groupState_ = ExecuteState::CANCELED; in CheckTask()
620 group->groupState_ = ExecuteState::WAITING; in CheckTask()
625 group->currentGroupInfo_ = groupInfo; in CheckTask()
626 group->groupState_ = ExecuteState::NOT_FOUND; in CheckTask()
629 group->groupState_ = ExecuteState::FINISHED; in CheckTask()
632 group in CheckTask()
651 TaskGroup* group = new TaskGroup(); CancelGroupTask() local
714 TaskGroup* group = new TaskGroup(); UpdateGroupState() local
801 TaskGroup* group = new TaskGroup(); PerformTask() local
[all...]
H A Dtest_taskpool.cpp58 napi_value group = nullptr; in GeneratorTaskGroup() local
60 napi_call_function(env, thisVar, cb, 0, argv, &group); in GeneratorTaskGroup()
61 return group; in GeneratorTaskGroup()
71 napi_value group = nullptr; in GeneratorTaskGroupWithName() local
73 napi_call_function(env, thisVar, cb, 1, argv, &group); in GeneratorTaskGroupWithName()
74 return group; in GeneratorTaskGroupWithName()
381 TaskGroup* group = new TaskGroup(); in HWTEST_F() local
382 uint64_t groupId = reinterpret_cast<uint64_t>(group); in HWTEST_F()
390 delete group; in HWTEST_F()
396 TaskGroup* group in HWTEST_F() local
743 TaskGroup* group = taskGroupManager.GetTaskGroup(groupId); HWTEST_F() local
770 TaskGroup* group = taskGroupManager.GetTaskGroup(taskId); HWTEST_F() local
1254 TaskGroup* group = new TaskGroup(); HWTEST_F() local
1665 auto group = GeneratorTaskGroup(env, obj); HWTEST_F() local
1686 auto group = GeneratorTaskGroup(env, obj); HWTEST_F() local
2388 TaskGroup* group = new TaskGroup(); HWTEST_F() local
2409 TaskGroup* group = new TaskGroup(); HWTEST_F() local
2443 TaskGroup* group = taskGroupManager.GetTaskGroup(groupId); HWTEST_F() local
2597 TaskGroup* group = new TaskGroup(); HWTEST_F() local
2625 TaskGroup* group = new TaskGroup(); HWTEST_F() local
2695 TaskGroup* group = new TaskGroup(); HWTEST_F() local
4280 TaskGroup* group = taskGroupManager.GetTaskGroup(groupId); HWTEST_F() local
4301 TaskGroup* group = taskGroupManager.GetTaskGroup(groupId); HWTEST_F() local
4370 auto group = GeneratorTaskGroup(env, obj); HWTEST_F() local
4545 TaskGroup* group = new TaskGroup(); HWTEST_F() local
[all...]

Completed in 12 milliseconds