From 2f1880ce2084f7e344f73ff6bd07ea0976d9f7b5 Mon Sep 17 00:00:00 2001 From: "Raphael S. Carvalho" Date: Fri, 12 Dec 2025 13:33:44 -0300 Subject: [PATCH] replica: Wire add_new_sstables_and_update_cache() into intra-node streaming Signed-off-by: Raphael S. Carvalho (cherry picked from commit d9d58780e23b54a2bb5b46814070ea9ddcb926a5) --- service/storage_service.cc | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/service/storage_service.cc b/service/storage_service.cc index 928b80e2bb..17963dc943 100644 --- a/service/storage_service.cc +++ b/service/storage_service.cc @@ -6437,8 +6437,11 @@ future<> storage_service::clone_locally_tablet_storage(locator::global_tablet_id for (auto&& sst_desc : d) { ssts.push_back(co_await load_sstable(sharder, table, std::move(sst_desc))); } - co_await table.add_sstables_and_update_cache(ssts); - _view_building_worker.local().load_sstables(tablet.table, ssts); + auto on_add = [] (sstables::shared_sstable loading_sst) -> future<> { + co_return; + }; + auto loaded_ssts = co_await table.add_new_sstables_and_update_cache(ssts, on_add); + _view_building_worker.local().load_sstables(tablet.table, loaded_ssts); }); rtlogger.debug("Successfully loaded storage of tablet {} into pending replica {}", tablet, pending); }