mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-22 17:40:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

storage_service: Wire up update_tokens in handle_state_normal

Browse Source
This commit is contained in:
Asias He
2015-08-05 11:27:45 +08:00
parent 1b7b199bdf
commit f7be7c9cee
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
service/storage_service.cc
View File

@@ -489,7 +489,13 @@ void storage_service::handle_state_normal(inet_address endpoint) {
// Gossiper.instance.replacementQuarantine(ep); // quarantine locally longer than normally; see CASSANDRA-8260
// }
if (!tokens_to_update_in_system_keyspace.empty()) {
// SystemKeyspace.updateTokens(endpoint, tokens_to_update_in_system_keyspace);
db::system_keyspace::update_tokens(endpoint, tokens_to_update_in_system_keyspace).then_wrapped([endpoint] (auto&& f) {
try {
f.get();
} catch (...) {
logger.error("fail to update tokens for {}: {}", endpoint, std::current_exception());
}
});
}
if (!local_tokens_to_remove.empty()) {
// SystemKeyspace.updateLocalTokens(Collections.<Token>emptyList(), local_tokens_to_remove);