mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-13 03:12:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

replica: Wire add_new_sstables_and_update_cache() into intra-node streaming

Browse Source 
Signed-off-by: Raphael S. Carvalho <raphaelsc@scylladb.com>
(cherry picked from commit d9d58780e2)
This commit is contained in:
Raphael S. Carvalho
2025-12-12 13:33:44 -03:00
committed by Botond Dénes
parent 9b6ff15a72
commit 2f1880ce20
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
service/storage_service.cc
View File

@@ -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);
}