Skip to content

Commit 5c69e7d

Browse files
vporyadkevporyadke
committed
remove all processing
1 parent 0f49b1b commit 5c69e7d

File tree

1 file changed

+34
-30
lines changed

1 file changed

+34
-30
lines changed

‎ydb/core/mind/hive/tx__load_everything.cpp‎

Lines changed: 34 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
1818
TAppData* appData = AppData();
1919
TDomainsInfo* domainsInfo = appData->DomainsInfo.Get();
2020
TTabletId rootHiveId = domainsInfo->GetHive();
21-
bool isRootHive = (rootHiveId == Self->TabletID());
21+
//bool isRootHive = (rootHiveId == Self->TabletID());
2222

2323
NIceDb::TNiceDb db(txc.DB);
2424

@@ -201,6 +201,10 @@ class TTxLoadEverything : public TTransactionBase<THive> {
201201
auto end = owners.GetValue<Schema::TabletOwners::End>();
202202
auto ownerId = owners.GetValue<Schema::TabletOwners::OwnerId>();
203203

204+
Y_UNUSED(begin);
205+
Y_UNUSED(end);
206+
Y_UNUSED(ownerId);
207+
204208
// Self->Keeper.AddOwnedSequence(ownerId, {begin, end});
205209
if (!owners.Next()) {
206210
return false;
@@ -265,7 +269,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
265269
return false;
266270
while (!domainRowset.EndOfSet()) {
267271
++numSubDomains;
268-
TSubDomainKey key(domainRowset.GetKey());
272+
/*TSubDomainKey key(domainRowset.GetKey());
269273
TDomainInfo& domain = Self->Domains.emplace(key, TDomainInfo()).first->second;
270274
domain.Path = domainRowset.GetValueOrDefault<Schema::SubDomain::Path>();
271275
domain.HiveId = domainRowset.GetValueOrDefault<Schema::SubDomain::HiveId>();
@@ -277,7 +281,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
277281
}
278282
if (domainRowset.HaveValue<Schema::SubDomain::ServerlessComputeResourcesMode>()) {
279283
domain.ServerlessComputeResourcesMode = domainRowset.GetValue<Schema::SubDomain::ServerlessComputeResourcesMode>();
280-
}
284+
}*/
281285

282286
if (!domainRowset.Next())
283287
return false;
@@ -292,7 +296,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
292296
return false;
293297
while (!blockedOwnerRowset.EndOfSet()) {
294298
++numBlockedOwners;
295-
Self->BlockedOwners.emplace(blockedOwnerRowset.GetKey());
299+
/*Self->BlockedOwners.emplace(blockedOwnerRowset.GetKey());*/
296300
if (!blockedOwnerRowset.Next())
297301
return false;
298302
}
@@ -306,7 +310,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
306310
return false;
307311
while (!nodeRowset.EndOfSet()) {
308312
++numNodes;
309-
TNodeId nodeId = nodeRowset.GetValue<Schema::Node::ID>();
313+
/*TNodeId nodeId = nodeRowset.GetValue<Schema::Node::ID>();
310314
TNodeInfo& node = Self->Nodes.emplace(std::piecewise_construct, std::tuple<TNodeId>(nodeId), std::tuple<TNodeId, THive&>(nodeId, *Self)).first->second;
311315
node.Local = nodeRowset.GetValue<Schema::Node::Local>();
312316
node.Down = nodeRowset.GetValue<Schema::Node::Down>();
@@ -342,7 +346,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
342346
db.Table<Schema::Node>().Key(nodeId).Delete();
343347
} else if (node.IsUnknown() && node.LocationAcquired) {
344348
Self->AddRegisteredDataCentersNode(node.Location.GetDataCenterId(), node.Id);
345-
}
349+
}*/
346350
if (!nodeRowset.Next())
347351
return false;
348352
}
@@ -372,7 +376,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
372376
systemCategory.StickTogetherInDC = true;
373377
}
374378

375-
TTabletId maxTabletId = 0;
379+
//TTabletId maxTabletId = 0;
376380

377381
{
378382
size_t numTablets = 0;
@@ -381,7 +385,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
381385
return false;
382386
while (!tabletRowset.EndOfSet()) {
383387
++numTablets;
384-
TTabletId tabletId = tabletRowset.GetValue<Schema::Tablet::ID>();
388+
/*TTabletId tabletId = tabletRowset.GetValue<Schema::Tablet::ID>();
385389
maxTabletId = std::max(maxTabletId, UniqPartFromTabletID(tabletId));
386390
TLeaderTabletInfo& tablet = Self->Tablets.emplace(
387391
std::piecewise_construct,
@@ -467,7 +471,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
467471
468472
tablet.TabletStorageInfo.Reset(new TTabletStorageInfo(tabletId, tablet.Type));
469473
tablet.TabletStorageInfo->Version = tabletRowset.GetValueOrDefault<Schema::Tablet::TabletStorageVersion>();
470-
tablet.TabletStorageInfo->TenantPathId = tablet.GetTenant();
474+
tablet.TabletStorageInfo->TenantPathId = tablet.GetTenant();*/
471475

472476
if (!tabletRowset.Next())
473477
return false;
@@ -484,7 +488,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
484488

485489
while (!tabletChannelRowset.EndOfSet()) {
486490
++numTabletChannels;
487-
TTabletId tabletId = tabletChannelRowset.GetValue<Schema::TabletChannel::Tablet>();
491+
/*TTabletId tabletId = tabletChannelRowset.GetValue<Schema::TabletChannel::Tablet>();
488492
TLeaderTabletInfo* tablet = Self->FindTabletEvenInDeleting(tabletId);
489493
if (tablet) {
490494
ui32 channelId = tabletChannelRowset.GetValue<Schema::TabletChannel::Channel>();
@@ -504,7 +508,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
504508
}
505509
} else {
506510
++numMissingTablets;
507-
}
511+
}*/
508512
if (!tabletChannelRowset.Next())
509513
return false;
510514
}
@@ -521,7 +525,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
521525

522526
while (!tabletChannelGenRowset.EndOfSet()) {
523527
++numTabletChannelHistories;
524-
TTabletId tabletId = tabletChannelGenRowset.GetValue<Schema::TabletChannelGen::Tablet>();
528+
/*TTabletId tabletId = tabletChannelGenRowset.GetValue<Schema::TabletChannelGen::Tablet>();
525529
TLeaderTabletInfo* tablet = Self->FindTabletEvenInDeleting(tabletId);
526530
if (tablet) {
527531
ui32 channelId = tabletChannelGenRowset.GetValue<Schema::TabletChannelGen::Channel>();
@@ -542,7 +546,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
542546
}
543547
} else {
544548
++numMissingTablets;
545-
}
549+
}*/
546550
if (!tabletChannelGenRowset.Next())
547551
return false;
548552
}
@@ -563,7 +567,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
563567
return false;
564568
while (!tabletFollowerGroupRowset.EndOfSet()) {
565569
++numTabletFollowerGroups;
566-
TTabletId tabletId = tabletFollowerGroupRowset.GetValue<Schema::TabletFollowerGroup::TabletID>();
570+
/*TTabletId tabletId = tabletFollowerGroupRowset.GetValue<Schema::TabletFollowerGroup::TabletID>();
567571
TLeaderTabletInfo* tablet = Self->FindTabletEvenInDeleting(tabletId);
568572
if (tablet) {
569573
TFollowerGroup& followerGroup = tablet->AddFollowerGroup();
@@ -589,7 +593,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
589593
followerGroup.RequireDifferentNodes = tabletFollowerGroupRowset.GetValueOrDefault<Schema::TabletFollowerGroup::RequireDifferentNodes>();
590594
} else {
591595
++numMissingTablets;
592-
}
596+
}*/
593597
if (!tabletFollowerGroupRowset.Next())
594598
return false;
595599
}
@@ -605,7 +609,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
605609
return false;
606610
while (!tabletFollowerRowset.EndOfSet()) {
607611
++numTabletFollowers;
608-
TTabletId tabletId = tabletFollowerRowset.GetValue<Schema::TabletFollowerTablet::TabletID>();
612+
/*TTabletId tabletId = tabletFollowerRowset.GetValue<Schema::TabletFollowerTablet::TabletID>();
609613
TLeaderTabletInfo* tablet = Self->FindTabletEvenInDeleting(tabletId);
610614
if (tablet) {
611615
TFollowerGroupId followerGroupId = tabletFollowerRowset.GetValue<Schema::TabletFollowerTablet::GroupID>();
@@ -632,7 +636,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
632636
follower.InitTabletMetrics();
633637
} else {
634638
++numMissingTablets;
635-
}
639+
}*/
636640
if (!tabletFollowerRowset.Next())
637641
return false;
638642
}
@@ -641,7 +645,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
641645
}
642646

643647
// Compatability: some per-dc followers do not have their datacenter set - try to set it now
644-
for (auto& [tabletId, tablet] : Self->Tablets) {
648+
/*for (auto& [tabletId, tablet] : Self->Tablets) {
645649
for (auto& group : tablet.FollowerGroups) {
646650
if (!group.FollowerCountPerDataCenter) {
647651
continue;
@@ -690,7 +694,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
690694
--dcIt->second;
691695
}
692696
}
693-
}
697+
}*/
694698

695699
{
696700
size_t numMetrics = 0;
@@ -700,7 +704,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
700704
return false;
701705
while (!metricsRowset.EndOfSet()) {
702706
++numMetrics;
703-
TTabletId tabletId = metricsRowset.GetValue<Schema::Metrics::TabletID>();
707+
/*TTabletId tabletId = metricsRowset.GetValue<Schema::Metrics::TabletID>();
704708
TLeaderTabletInfo* tablet = Self->FindTabletEvenInDeleting(tabletId);
705709
if (tablet) {
706710
TFollowerId followerId = metricsRowset.GetValue<Schema::Metrics::FollowerID>();
@@ -714,7 +718,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
714718
}
715719
} else {
716720
++numMissingTablets;
717-
}
721+
}*/
718722
if (!metricsRowset.Next())
719723
return false;
720724
}
@@ -731,15 +735,15 @@ class TTxLoadEverything : public TTransactionBase<THive> {
731735
}
732736
while (!availabilityRestrictionsRowset.EndOfSet()) {
733737
++numRestrictions;
734-
TNodeId nodeId = availabilityRestrictionsRowset.GetValue<Schema::TabletAvailabilityRestrictions::Node>();
738+
/*TNodeId nodeId = availabilityRestrictionsRowset.GetValue<Schema::TabletAvailabilityRestrictions::Node>();
735739
auto node = Self->FindNode(nodeId);
736740
if (node) {
737741
auto tabletType = availabilityRestrictionsRowset.GetValue<Schema::TabletAvailabilityRestrictions::TabletType>();
738742
auto maxCount = availabilityRestrictionsRowset.GetValue<Schema::TabletAvailabilityRestrictions::MaxCount>();
739743
node->TabletAvailabilityRestrictions[tabletType] = maxCount;
740744
} else {
741745
++numMissingNodes;
742-
}
746+
}*/
743747
if (!availabilityRestrictionsRowset.Next()) {
744748
return false;
745749
}
@@ -748,7 +752,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
748752
<< numMissingNodes << " for missing nodes)");
749753
}
750754

751-
size_t numDeletedNodes = 0;
755+
/*size_t numDeletedNodes = 0;
752756
size_t numDeletedRestrictions = 0;
753757
for (auto itNode = Self->Nodes.begin(); itNode != Self->Nodes.end();) {
754758
if (itNode->second.CanBeDeleted()) {
@@ -767,19 +771,19 @@ class TTxLoadEverything : public TTransactionBase<THive> {
767771
++itNode;
768772
}
769773
}
770-
BLOG_NOTICE("THive::TTxLoadEverything deleted " << numDeletedNodes << " unnecessary nodes << (and " << numDeletedRestrictions << " restrictions for them)");
774+
BLOG_NOTICE("THive::TTxLoadEverything deleted " << numDeletedNodes << " unnecessary nodes << (and " << numDeletedRestrictions << " restrictions for them)");*/
771775

772-
TTabletId nextTabletId = Max(maxTabletId + 1, Self->NextTabletId);
776+
//TTabletId nextTabletId = Max(maxTabletId + 1, Self->NextTabletId);
773777

774778
auto operationsRowset = db.Table<Schema::OperationsLog>().All().Reverse().Select();
775779
if (!operationsRowset.IsReady()) {
776780
return false;
777781
}
778-
if (operationsRowset.IsValid()) {
782+
/*if (operationsRowset.IsValid()) {
779783
Self->OperationsLogIndex = operationsRowset.GetValue<Schema::OperationsLog::Index>();
780-
}
784+
}*/
781785

782-
if (isRootHive) {
786+
/*if (isRootHive) {
783787
if (numSequences == 0) {
784788
ui64 freeSequenceIdx = 0;
785789
BLOG_D("THive::TTxLoadEverything Self->NextTabletId = " << Self->NextTabletId << " NextTabletId = " << nextTabletId);
@@ -822,7 +826,7 @@ class TTxLoadEverything : public TTransactionBase<THive> {
822826
.Update<Schema::Sequences::Begin, Schema::Sequences::Next, Schema::Sequences::End>(sequence.Begin, sequence.Next, sequence.End);
823827
}
824828
}
825-
}
829+
}*/
826830

827831
return true;
828832
}

0 commit comments

Comments
 (0)