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

distributed_loader: process_upload_dir: pass owned_ranges_ptr to reshard

Browse Source 
To facilitate implicit cleanup of sstables via resharding.

Refs #11933

Signed-off-by: Benny Halevy <bhalevy@scylladb.com>
This commit is contained in:
Benny Halevy
2022-12-27 13:12:41 +02:00
parent aa4b18f8fb
commit 3ccbb28f2a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
replica/distributed_loader.cc
View File

@@ -459,9 +459,10 @@ distributed_loader::process_upload_dir(distributed<replica::database>& db, distr
return sstables::generation_type(gen);
};
auto owned_ranges_ptr = compaction::make_owned_ranges_ptr(db.local().get_keyspace_local_ranges(ks));
reshard(directory, db, ks, cf, [&] (shard_id shard) mutable {
return make_sstable(*global_table, upload, new_generation_for_shard(shard));
}, service::get_local_streaming_priority()).get();
}, service::get_local_streaming_priority(), owned_ranges_ptr).get();
reshape(directory, db, sstables::reshape_mode::strict, ks, cf, [&] (shard_id shard) {
return make_sstable(*global_table, upload, new_generation_for_shard(shard));