mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

db: ignore sstables that clearly don't belong to this shard

Browse Source
This commit is contained in:
Avi Kivity
2015-08-03 19:18:37 +03:00
parent ad443e4771
commit c1a2831d41
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
database.cc
View File

@@ -349,6 +349,16 @@ future<> column_family::probe_file(sstring sstdir, sstring fname) {
}
void column_family::add_sstable(sstables::sstable&& sstable) {
auto key_shard = [this] (const partition_key& pk) {
auto token = dht::global_partitioner().get_token(*_schema, pk);
return dht::shard_of(token);
};
auto s1 = key_shard(sstable.get_first_partition_key(*_schema));
auto s2 = key_shard(sstable.get_last_partition_key(*_schema));
if (s1 > engine().cpu_id() || engine().cpu_id() < s2) {
dblog.info("sstable {} not relevant for this shard, ignoring", sstable.get_filename());
return;
}
auto generation = sstable.generation();
// allow in-progress reads to continue using old list
_sstables = make_lw_shared<sstable_list>(*_sstables);