Lines Matching refs:taskGroup
1471 HILOG_DEBUG("taskpool:: taskGroup has been released");
1474 auto taskGroup = reinterpret_cast<TaskGroup*>(groupIter->second);
1475 if (taskGroup == nullptr) {
1476 HILOG_ERROR("taskpool:: taskGroup is null");
1479 taskGroup->taskRefs_.push_back(taskRef);
1480 taskGroup->taskNum_++;
1481 taskGroup->taskIds_.push_back(taskId);
1508 TaskGroup* taskGroup = GetTaskGroup(groupId);
1509 if (taskGroup == nullptr) {
1513 if (taskGroup->groupState_ == ExecuteState::CANCELED) {
1516 std::lock_guard<RECURSIVE_MUTEX> lock(taskGroup->taskGroupMutex_);
1517 if (taskGroup->currentGroupInfo_ == nullptr || taskGroup->groupState_ == ExecuteState::NOT_FOUND ||
1518 taskGroup->groupState_ == ExecuteState::FINISHED) {
1519 std::string errMsg = "taskpool:: taskGroup is not executed or has been executed";
1524 ExecuteState groupState = taskGroup->groupState_;
1525 taskGroup->groupState_ = ExecuteState::CANCELED;
1526 taskGroup->CancelPendingGroup(env);
1527 if (taskGroup->currentGroupInfo_->finishedTask != taskGroup->taskNum_) {
1528 for (uint64_t taskId : taskGroup->taskIds_) {
1529 CancelGroupTask(env, taskId, taskGroup);
1532 if (groupState == ExecuteState::WAITING && taskGroup->currentGroupInfo_ != nullptr) {
1534 for (size_t i = 0; i < taskGroup->taskIds_.size(); i++) {
1537 napi_value error = ErrorHelper::NewError(env, 0, "taskpool:: taskGroup has been canceled");
1538 napi_reject_deferred(env, taskGroup->currentGroupInfo_->deferred, error);
1539 napi_delete_reference(env, taskGroup->currentGroupInfo_->resArr);
1540 napi_reference_unref(env, taskGroup->groupRef_, nullptr);
1541 delete taskGroup->currentGroupInfo_;
1542 taskGroup->currentGroupInfo_ = nullptr;
1657 void TaskGroupManager::StoreTaskGroup(uint64_t groupId, TaskGroup* taskGroup)
1660 taskGroups_.emplace(groupId, taskGroup);
1691 HILOG_DEBUG("taskpool:: UpdateGroupState taskGroup has been released or canceled");