aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsnaury <snaury@ydb.tech>2023-02-09 16:39:27 +0300
committersnaury <snaury@ydb.tech>2023-02-09 16:39:27 +0300
commitc5b21b295d416f2222d7e9232de4a6f97455bcf4 (patch)
tree5982b5b2da4399bd785e84b00ce0a29173bb99e7
parent8bc5e34ced124f057d5f18ad71408b95d8981ca8 (diff)
downloadydb-c5b21b295d416f2222d7e9232de4a6f97455bcf4.tar.gz
Stop syncing touched blocks from leader to followers
-rw-r--r--ydb/core/tablet_flat/flat_executor.cpp55
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);