diff --git a/src/java/org/apache/cassandra/tcm/listeners/LegacyStateListener.java b/src/java/org/apache/cassandra/tcm/listeners/LegacyStateListener.java index 0c72eef202..05915e03bc 100644 --- a/src/java/org/apache/cassandra/tcm/listeners/LegacyStateListener.java +++ b/src/java/org/apache/cassandra/tcm/listeners/LegacyStateListener.java @@ -112,6 +112,7 @@ public class LegacyStateListener implements ChangeListener.Async Gossiper.instance.addLocalApplicationState(SCHEMA, StorageService.instance.valueFactory.schema(next.schema.getVersion())); } + if (next.directory.peerState(change) == LEFT) { Gossiper.instance.mergeNodeToGossip(change, next, prev.tokenMap.tokens(change)); @@ -122,6 +123,11 @@ public class LegacyStateListener implements ChangeListener.Async GossipHelper.removeFromGossip(endpoint); } } + else if(next.directory.peerState(change) == MOVING) + { + // legacy log messages for tests + logger.debug("Node {} state MOVING, tokens {}", next.directory.endpoint(change), prev.tokenMap.tokens(change)); + } else if (NodeState.isBootstrap(next.directory.peerState(change))) { // For compatibility with clients, ensure we set TOKENS for bootstrapping nodes in gossip.