Repository: cassandra Updated Branches: refs/heads/trunk 2188bec56 -> 73793d6f0
avoid Gossiper dead checks on irrelevant ApplicationStates Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/73793d6f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/73793d6f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/73793d6f Branch: refs/heads/trunk Commit: 73793d6f0e03f72e561b994577f48e119715d353 Parents: 2188bec Author: Dave Brosius <dbros...@mebigfatguy.com> Authored: Mon Jan 4 23:59:35 2016 -0500 Committer: Dave Brosius <dbros...@mebigfatguy.com> Committed: Mon Jan 4 23:59:35 2016 -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/73793d6f/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 3277af7..6b6182f 100644 --- a/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java +++ b/src/java/org/apache/cassandra/locator/ReconnectableSnitchHelper.java @@ -80,7 +80,7 @@ public class ReconnectableSnitchHelper implements IEndpointStateChangeSubscriber public void onChange(InetAddress endpoint, ApplicationState state, VersionedValue value) { - if (preferLocal && !Gossiper.instance.isDeadState(Gossiper.instance.getEndpointStateForEndpoint(endpoint)) && state == ApplicationState.INTERNAL_IP) + if (preferLocal && state == ApplicationState.INTERNAL_IP && !Gossiper.instance.isDeadState(Gossiper.instance.getEndpointStateForEndpoint(endpoint))) reconnect(endpoint, value); }