dirty commit

Author: vporyadke

ydb/core/mind/hive/tx__load_everything.cpp

@@ -605,6 +605,11 @@ class TTxLoadEverything : public TTransactionBase<THive> {
                     followerGroup.LocalNodeOnly = tabletFollowerGroupRowset.GetValueOrDefault<Schema::TabletFollowerGroup::LocalNodeOnly>();
                     followerGroup.FollowerCountPerDataCenter = tabletFollowerGroupRowset.GetValueOrDefault<Schema::TabletFollowerGroup::FollowerCountPerDataCenter>();
                     followerGroup.RequireDifferentNodes = tabletFollowerGroupRowset.GetValueOrDefault<Schema::TabletFollowerGroup::RequireDifferentNodes>();
+
+                    if (followerGroup.RequireAllDataCenters && !followerGroup.FollowerCountPerDataCenter) {
+                        followerGroup.FollowerCountPerDataCenter = true;
+                        followerGroup.FollowerCount = (followerGroup.FollowerCount - 1) / Self.DataCenters.size() + 1;
+                    }
                 } else {
                     ++numMissingTablets;
                 }
@@ -665,8 +670,10 @@ class TTxLoadEverything : public TTransactionBase<THive> {
                     continue;
                 }
                 std::map<TDataCenterId, i32> dataCentersToCover; // dc -> need x more followers in dc
-                for (const auto& [dc, _] : Self->DataCenters) {
-                    dataCentersToCover[dc] = group.GetFollowerCountForDataCenter(dc);
+                for (const auto& [dcId, dcInfo] : Self->DataCenters) {
+                    if (dcInfo.IsRegistered()) {
+                        dataCentersToCover[dcId] = group.GetFollowerCountForDataCenter(dcId);
+                    }
                 }
                 auto groupId = group.Id;
                 auto filterGroup = [groupId](auto&& follower) { return follower->FollowerGroup.Id == groupId;};
@@ -876,6 +883,12 @@ class TTxLoadEverything : public TTransactionBase<THive> {
             Self->ProcessFollowerUpdatesScheduled = true;
         }
 
+        for (const auto& [dcId, dcInfo] : Self->DataCenters) {
+            if (!dcInfo.IsRegistered()) {
+                Self->Schedule(TDuration::Seconds(1), new TEvPrivate::TEvUpdateDataCenterFollowers(dcId));
+            }
+        }
+
         Self->ProcessPendingStopTablet();
         Self->ProcessPendingResumeTablet();