diff options
author | snaury <snaury@ydb.tech> | 2023-02-09 16:39:27 +0300 |
---|---|---|
committer | snaury <snaury@ydb.tech> | 2023-02-09 16:39:27 +0300 |
commit | c5b21b295d416f2222d7e9232de4a6f97455bcf4 (patch) | |
tree | 5982b5b2da4399bd785e84b00ce0a29173bb99e7 | |
parent | 8bc5e34ced124f057d5f18ad71408b95d8981ca8 (diff) | |
download | ydb-c5b21b295d416f2222d7e9232de4a6f97455bcf4.tar.gz |
Stop syncing touched blocks from leader to followers
-rw-r--r-- | ydb/core/tablet_flat/flat_executor.cpp | 55 |
1 files changed, 0 insertions, 55 deletions
diff --git a/ydb/core/tablet_flat/flat_executor.cpp b/ydb/core/tablet_flat/flat_executor.cpp index 5923c7c264d..1aded82071f 100644 --- a/ydb/core/tablet_flat/flat_executor.cpp +++ b/ydb/core/tablet_flat/flat_executor.cpp @@ -947,45 +947,6 @@ void TExecutor::ApplyFollowerAuxUpdate(const TString &auxBody) { const TString aux = NPageCollection::TSlicer::Lz4()->Decode(auxBody); TProtoBox<NKikimrExecutorFlat::TFollowerAux> proto(aux); - for (const auto &x : proto.GetPageCollectionsTouched()) { - const TLogoBlobID &metaId = LogoBlobIDFromLogoBlobID(x.GetMetaInfoId()); - TPrivatePageCache::TInfo *collectionInfo = PrivatePageCache->Info(metaId); - if (!collectionInfo) - continue; - - TVector<NTable::TPageId> pages; - - for (ui32 pageId : x.GetTouchedPages()) { - auto* page = collectionInfo->EnsurePage(pageId); - switch (page->LoadState) { - case TPrivatePageCache::TPage::LoadStateNo: - pages.push_back(pageId); - page->LoadState = TPrivatePageCache::TPage::LoadStateRequestedAsync; - break; - case TPrivatePageCache::TPage::LoadStateRequested: - case TPrivatePageCache::TPage::LoadStateRequestedAsync: - break; - case TPrivatePageCache::TPage::LoadStateLoaded: - PrivatePageCache->Touch(pageId, collectionInfo); - break; - default: - Y_FAIL("unknown ELoadState"); - } - } - - if (auto logl = Logger->Log(ELnLev::Debug)) { - logl - << NFmt::Do(*this) << " refresh pageCollection " << metaId - << " " << pages.size() << " pages of " << x.TouchedPagesSize(); - } - - if (pages) { - auto *req = new NPageCollection::TFetch(0, collectionInfo->PageCollection, std::move(pages)); - - RequestFromSharedCache(req, NBlockIO::EPriority::Bkgr, EPageCollectionRequest::CacheSync); - } - } - if (proto.HasUserAuxUpdate()) Owner->OnLeaderUserAuxUpdate(std::move(proto.GetUserAuxUpdate())); } @@ -2386,22 +2347,6 @@ void TExecutor::CommitTransactionLog(TAutoPtr<TSeat> seat, TPageCollectionTxEnv CompactionLogic->UpdateLogUsage(LogicRedo->GrabLogUsage()); } - if (!Stats->IsFollower && HadFollowerAttached && env.Touches) { - NKikimrExecutorFlat::TFollowerAux proto; - proto.MutablePageCollectionsTouched()->Reserve(env.Touches.size()); - for (auto &xpair : env.Touches) { - auto *px = proto.AddPageCollectionsTouched(); - LogoBlobIDFromLogoBlobID(xpair.first->Id, px->MutableMetaInfoId()); - px->MutableTouchedPages()->Reserve(xpair.second.size()); - for (ui32 blockId : xpair.second) - px->AddTouchedPages(blockId); - } - - auto coded = NPageCollection::TSlicer::Lz4()->Encode(proto.SerializeAsString()); - - Send(Owner->Tablet(), new TEvTablet::TEvAux(std::move(coded))); - } - const ui64 bookkeepingTimeuS = ui64(1000000. * (currentBookkeepingTime + bookkeepingTimer.PassedReset())); const ui64 execTimeuS = ui64(1000000. * currentExecTime); |