ninja: fix isDecomissioning check from CASSANDRA-12008
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/39d77f43 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/39d77f43 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/39d77f43 Branch: refs/heads/trunk Commit: 39d77f43e38ae085d6049740d3d86c629b3b5f94 Parents: cbb9d5d Author: Paulo Motta <[email protected]> Authored: Wed Dec 21 22:41:14 2016 -0200 Committer: Paulo Motta <[email protected]> Committed: Fri Dec 23 21:26:52 2016 -0200 ---------------------------------------------------------------------- src/java/org/apache/cassandra/service/StorageService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/39d77f43/src/java/org/apache/cassandra/service/StorageService.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 834008d..3fc7d54 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -3876,7 +3876,7 @@ public class StorageService extends NotificationBroadcasterSupport implements IE if (operationMode != Mode.NORMAL) throw new UnsupportedOperationException("Node in " + operationMode + " state; wait for status to become normal or restart"); } - if (isDecommissioning.compareAndSet(true, true)) + if (!isDecommissioning.compareAndSet(false, true)) throw new IllegalStateException("Node is still decommissioning. Check nodetool netstats."); if (logger.isDebugEnabled())
