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

gms/gossiper: Fix is_gossip_only_member() logic

Browse Source 
Signed-off-by: Pekka Enberg <penberg@cloudius-systems.com>
This commit is contained in:
Pekka Enberg
2015-07-20 16:46:56 +03:00
parent 91e601ed11
commit 67f4b55b16
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
gms/gossiper.cc
View File

@@ -32,8 +32,8 @@
#include "gms/i_failure_detection_event_listener.hh" #include "gms/i_failure_detection_event_listener.hh"
#include "gms/i_endpoint_state_change_subscriber.hh" #include "gms/i_endpoint_state_change_subscriber.hh"
#include "gms/i_failure_detector.hh" #include "gms/i_failure_detector.hh"
#include "log.hh"
#include "service/storage_service.hh" #include "service/storage_service.hh"
#include "log.hh"
namespace gms { namespace gms {
@@ -780,8 +780,8 @@ bool gossiper::is_gossip_only_member(inet_address endpoint) {
return false; return false;
} }
auto& eps = it->second; auto& eps = it->second;
// FIXME: StorageService.instance.getTokenMetadata auto& ss = service::get_local_storage_service();
return !is_dead_state(eps) /* && !StorageService.instance.getTokenMetadata().isMember(endpoint); */; return !is_dead_state(eps) && !ss.get_token_metadata().is_member(endpoint);
} }
int64_t gossiper::get_expire_time_for_endpoint(inet_address endpoint) { int64_t gossiper::get_expire_time_for_endpoint(inet_address endpoint) {