You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2015/04/18 01:43:46 UTC
[5/8] cassandra git commit: Fix commit
Fix commit
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/738229bd
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/738229bd
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/738229bd
Branch: refs/heads/cassandra-2.0
Commit: 738229bd7900b21a83ea322b1e394b8c20c0b82f
Parents: 54140bf
Author: Brandon Williams <br...@apache.org>
Authored: Fri Apr 17 18:42:38 2015 -0500
Committer: Brandon Williams <br...@apache.org>
Committed: Fri Apr 17 18:42:38 2015 -0500
----------------------------------------------------------------------
.../org/apache/cassandra/locator/ReconnectableSnitchHelper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/738229bd/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java b/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java
index 1642561..e5dbdeb 100644
--- a/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java
+++ b/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java
@@ -81,7 +81,7 @@ public class ReconnectableSnitchHelper implements IEndpointStateChangeSubscriber
public void onChange(InetAddress endpoint, ApplicationState state, VersionedValue value)
{
- if (preferLocal && !Gossiper.instance.isDeadState(epState) && state == ApplicationState.INTERNAL_IP)
+ if (preferLocal && !Gossiper.instance.isDeadState(Gossiper.instance.getEndpointStateForEndpoint(endpoint)) && state == ApplicationState.INTERNAL_IP)
reconnect(endpoint, value);
}