cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [4/8] cassandra git commit: Fix commit
Date Fri, 17 Apr 2015 23:43:45 GMT
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/trunk
Commit: 738229bd7900b21a83ea322b1e394b8c20c0b82f
Parents: 54140bf
Author: Brandon Williams <brandonwilliams@apache.org>
Authored: Fri Apr 17 18:42:38 2015 -0500
Committer: Brandon Williams <brandonwilliams@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);
     }
 


Mime
View raw message