Lines Matching refs:groupInfo
391 GroupInfo* groupInfo = new GroupInfo(); in ExecuteGroup() local
392 groupInfo->priority = priority; in ExecuteGroup()
396 groupInfo->resArr = arrRef; in ExecuteGroup()
397 napi_value promise = NapiHelper::CreatePromise(env, &groupInfo->deferred); in ExecuteGroup()
401 napi_resolve_deferred(env, groupInfo->deferred, resArr); in ExecuteGroup()
403 napi_delete_reference(env, groupInfo->resArr); in ExecuteGroup()
405 delete groupInfo; in ExecuteGroup()
410 taskGroup->currentGroupInfo_ = groupInfo; in ExecuteGroup()
426 taskGroup->pendingGroupInfos_.push_back(groupInfo); in ExecuteGroup()
550 auto groupInfo = taskGroup->currentGroupInfo_; in UpdateGroupInfoByResult() local
551 napi_ref arrRef = groupInfo->resArr; in UpdateGroupInfoByResult()
554 groupInfo->finishedTaskNum++; in UpdateGroupInfoByResult()
556 if (!success && !groupInfo->HasException()) { in UpdateGroupInfoByResult()
557 groupInfo->SetFailedIndex(index); in UpdateGroupInfoByResult()
560 if (groupInfo->finishedTaskNum < taskGroup->taskNum_) { in UpdateGroupInfoByResult()
564 if (!groupInfo->HasException()) { in UpdateGroupInfoByResult()
566 napi_resolve_deferred(env, groupInfo->deferred, resArr); in UpdateGroupInfoByResult()
575 napi_get_element(env, resArr, groupInfo->GetFailedIndex(), &res); in UpdateGroupInfoByResult()
576 napi_reject_deferred(env, groupInfo->deferred, res); in UpdateGroupInfoByResult()
578 std::advance(iter, groupInfo->GetFailedIndex()); in UpdateGroupInfoByResult()
586 napi_delete_reference(env, groupInfo->resArr); in UpdateGroupInfoByResult()
588 delete groupInfo; in UpdateGroupInfoByResult()