Skip to content

Commit

Permalink
Fix sync (ydb-platform#2566)
Browse files Browse the repository at this point in the history
  • Loading branch information
alexvru authored Mar 7, 2024
1 parent 61cd3dd commit 4616d9d
Showing 1 changed file with 15 additions and 6 deletions.
21 changes: 15 additions & 6 deletions ydb/core/driver_lib/run/run.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -173,18 +173,27 @@ class TDomainsInitializer : public IAppDataInitializer {
}

bool isExplicitTabletIds = domain.ExplicitCoordinatorsSize() + domain.ExplicitMediatorsSize() + domain.ExplicitAllocatorsSize();
Y_ABORT_UNLESS(isExplicitTabletIds);
Y_ABORT_UNLESS(domain.SSIdSize() == 0 || (domain.SSIdSize() == 1 && domain.GetSSId(0) == 1));
Y_ABORT_UNLESS(domain.HiveUidSize() == 0 || (domain.HiveUidSize() == 1 && domain.GetHiveUid(0) == 1));

TDomainsInfo::TDomain::TPtr domainPtr = nullptr;
if (isExplicitTabletIds) {
domainPtr = TDomainsInfo::TDomain::ConstructDomainWithExplicitTabletIds(domainName, domainId, schemeRoot,
planResolution,
domain.GetExplicitCoordinators(),
domain.GetExplicitMediators(),
domain.GetExplicitAllocators(),
poolTypes);
planResolution, domain.GetExplicitCoordinators(), domain.GetExplicitMediators(),
domain.GetExplicitAllocators(), poolTypes);
} else { // compatibility code
std::vector<ui64> coordinators, mediators, allocators;
for (ui64 x : domain.GetCoordinator()) {
coordinators.push_back(TDomainsInfo::MakeTxCoordinatorID(domainId, x));
}
for (ui64 x : domain.GetMediator()) {
mediators.push_back(TDomainsInfo::MakeTxMediatorID(domainId, x));
}
for (ui64 x : domain.GetProxy()) {
allocators.push_back(TDomainsInfo::MakeTxAllocatorID(domainId, x));
}
domainPtr = TDomainsInfo::TDomain::ConstructDomainWithExplicitTabletIds(domainName, domainId, schemeRoot,
planResolution, coordinators, mediators, allocators, poolTypes);
}

appData->DomainsInfo->AddDomain(domainPtr.Release());
Expand Down

0 comments on commit 4616d9d

Please sign in to comment.