mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-06-08 07:53:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

storage_service: Enable single_datacenter_filter in rebuild

Browse Source
This commit is contained in:
Asias He
2015-10-23 15:43:33 +08:00
parent b172146223
commit 1ba20f4efd
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
service/storage_service.cc
View File

@@ -1748,11 +1748,10 @@ future<> storage_service::rebuild(sstring source_dc) {
logger.info("rebuild from dc: {}", source_dc == "" ? "(any dc)" : source_dc);
auto streamer = make_lw_shared<dht::range_streamer>(_db, _token_metadata, get_broadcast_address(), "Rebuild");
streamer->add_source_filter(std::make_unique<dht::range_streamer::failure_detector_source_filter>(gms::get_local_failure_detector()));
// FIXME: SingleDatacenterFilter
#if 0
if (source_dc != "")
streamer.addSourceFilter(new RangeStreamer.SingleDatacenterFilter(DatabaseDescriptor.getEndpointSnitch(), sourceDc));
#endif
if (source_dc != "") {
streamer->add_source_filter(std::make_unique<dht::range_streamer::single_datacenter_filter>(source_dc));
}
for (const auto& keyspace_name : _db.local().get_non_system_keyspaces()) {
streamer->add_ranges(keyspace_name, get_local_ranges(keyspace_name));