You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by pa...@apache.org on 2016/12/23 23:30:52 UTC
[2/2] cassandra git commit: ninja: fix isDecomissioning check from
CASSANDRA-12008
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/cassandra-3.X
Commit: 39d77f43e38ae085d6049740d3d86c629b3b5f94
Parents: cbb9d5d
Author: Paulo Motta <pa...@gmail.com>
Authored: Wed Dec 21 22:41:14 2016 -0200
Committer: Paulo Motta <pa...@apache.org>
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())