Lines Matching refs:group
608 TaskGroup* group = new TaskGroup();
611 group->groupRef_ = ref;
612 uint64_t groupId = reinterpret_cast<uint64_t>(group);
616 groupManager.StoreTaskGroup(groupId, group);
617 group->groupState_ = ExecuteState::CANCELED;
620 group->groupState_ = ExecuteState::WAITING;
625 group->currentGroupInfo_ = groupInfo;
626 group->groupState_ = ExecuteState::NOT_FOUND;
629 group->groupState_ = ExecuteState::FINISHED;
632 group->groupState_ = ExecuteState::RUNNING;
633 group->taskNum_ = FINSHED_TASK_;
634 group->taskIds_.push_back(task->taskId_);
637 group->taskNum_ = TASK_NUMS_;
638 group->groupState_ = ExecuteState::WAITING;
640 napi_create_array_with_length(env, group->taskIds_.size(), &resArr);
651 TaskGroup* group = new TaskGroup();
656 groupManager.CancelGroupTask(env, task->taskId_, group);
658 groupManager.CancelGroupTask(env, task->taskId_, group);
662 groupManager.CancelGroupTask(env, task->taskId_, group);
714 TaskGroup* group = new TaskGroup();
715 uint64_t groupId = reinterpret_cast<uint64_t>(group);
718 groupManager.StoreTaskGroup(groupId, group);
720 group->groupState_ = ExecuteState::CANCELED;
722 group->groupState_ = ExecuteState::WAITING;
801 TaskGroup* group = new TaskGroup();
802 uint64_t groupId = reinterpret_cast<uint64_t>(group);
803 group->groupState_ = ExecuteState::WAITING;
805 groupManager.StoreTaskGroup(groupId, group);