PoolId -> GroupId

Author: ssmike

ydb/core/kqp/runtime/kqp_compute_scheduler.cpp

@@ -241,7 +241,7 @@ class TSchedulerEntity {
 };
 
 struct TComputeScheduler::TImpl {
-    THashMap<TString, size_t> PoolId;
+    THashMap<TString, size_t> GroupId;
     std::vector<std::unique_ptr<TSchedulerEntity::TGroupRecord>> Records;
 
     double SumCores;
@@ -273,7 +273,7 @@ struct TComputeScheduler::TImpl {
         group->Share = maxShare;
         if (groupName) {
             group->Name = *groupName;
-            PoolId[*groupName] = Records.size();
+            GroupId[*groupName] = Records.size();
         }
         AdvanceTime(now, group.get());
         Records.push_back(std::move(group));
@@ -308,15 +308,15 @@ struct TComputeScheduler::TImpl {
         Records.swap(records);
 
         std::vector<TString> toerase;
-        for (auto& [k, v] : PoolId) {
+        for (auto& [k, v] : GroupId) {
             if (remap[v] >= 0) {
                 v = remap[v];
             } else {
                 toerase.push_back(k);
             }
         }
         for (auto& k: toerase) {
-            PoolId.erase(k);
+            GroupId.erase(k);
         }
 
         for (auto& record : Records) {
@@ -343,8 +343,8 @@ void TComputeScheduler::AddToGroup(TMonotonic now, ui64 id, TSchedulerEntityHand
 }
 
 TSchedulerEntityHandle TComputeScheduler::Enroll(TString groupName, i64 weight, TMonotonic now) {
-    Y_ENSURE(Impl->PoolId.contains(groupName), "unknown scheduler group");
-    auto id = Impl->PoolId.at(groupName);
+    Y_ENSURE(Impl->GroupId.contains(groupName), "unknown scheduler group");
+    auto id = Impl->GroupId.at(groupName);
 
     TSchedulerEntityHandle result{new TSchedulerEntity()};
     (*result).Weight = weight;
@@ -412,7 +412,7 @@ ui64 TComputeScheduler::MakeAnonymousGroup(TMonotonic now, double share, std::op
     Impl->CreateGroup(share, now);
     ui64 res = Impl->Records.size() - 1;
     if (baseGroup) {
-        auto id = Impl->PoolId.at(*baseGroup);
+        auto id = Impl->GroupId.at(*baseGroup);
         Impl->Records[res]->BaseGroup = id;
         Impl->AdvanceTime(now, Impl->Records[res].get());
     }
@@ -456,13 +456,13 @@ void TComputeScheduler::SetForgetInterval(TDuration period) {
 }
 
 bool TComputeScheduler::Disabled(TString group) {
-    auto ptr = Impl->PoolId.FindPtr(group);
+    auto ptr = Impl->GroupId.FindPtr(group);
     return !ptr || Impl->Records[*ptr]->MutableStats.Current().get()->Disabled;
 }
 
 
 bool TComputeScheduler::Disable(TString group, TMonotonic now) {
-    auto ptr = Impl->PoolId.FindPtr(group);
+    auto ptr = Impl->GroupId.FindPtr(group);
     if (Impl->Records[*ptr]->MutableStats.Current().get()->EntitiesWeight > 0) {
         return false;
     }
@@ -472,7 +472,7 @@ bool TComputeScheduler::Disable(TString group, TMonotonic now) {
 }
 
 void TComputeScheduler::UpdateMaxShare(TString group, double share, TMonotonic now) {
-    auto ptr = Impl->PoolId.FindPtr(group);
+    auto ptr = Impl->GroupId.FindPtr(group);
     if (!ptr) {
         Impl->CreateGroup(share, now, group);
     } else {