Damnit, Carl
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/dd1dd8eb Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/dd1dd8eb Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/dd1dd8eb Branch: refs/heads/trunk Commit: dd1dd8eb76767d4d81feb3d5c35b78a12bb61162 Parents: 6424871 Author: Brandon Williams <brandonwilli...@apache.org> Authored: Mon Dec 1 13:17:15 2014 -0600 Committer: Brandon Williams <brandonwilli...@apache.org> Committed: Mon Dec 1 13:17:15 2014 -0600 ---------------------------------------------------------------------- src/java/org/apache/cassandra/service/StorageService.java | 5 +++++ src/java/org/apache/cassandra/service/StorageServiceMBean.java | 3 +++ src/java/org/apache/cassandra/tools/NodeProbe.java | 5 +++++ 3 files changed, 13 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/dd1dd8eb/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 19b4615..332fbe5 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -3567,6 +3567,11 @@ public class StorageService extends NotificationBroadcasterSupport implements IE return operationMode.toString(); } + public boolean isStarting() + { + return operationMode == Mode.STARTING; + } + public String getDrainProgress() { return String.format("Drained %s/%s ColumnFamilies", remainingCFs, totalCFs); http://git-wip-us.apache.org/repos/asf/cassandra/blob/dd1dd8eb/src/java/org/apache/cassandra/service/StorageServiceMBean.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageServiceMBean.java b/src/java/org/apache/cassandra/service/StorageServiceMBean.java index e7d6f14..a661b97 100644 --- a/src/java/org/apache/cassandra/service/StorageServiceMBean.java +++ b/src/java/org/apache/cassandra/service/StorageServiceMBean.java @@ -365,6 +365,9 @@ public interface StorageServiceMBean extends NotificationEmitter /** get the operational mode (leaving, joining, normal, decommissioned, client) **/ public String getOperationMode(); + /** Returns whether the storage service is starting or not */ + public boolean isStarting(); + /** get the progress of a drain operation */ public String getDrainProgress(); http://git-wip-us.apache.org/repos/asf/cassandra/blob/dd1dd8eb/src/java/org/apache/cassandra/tools/NodeProbe.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/tools/NodeProbe.java b/src/java/org/apache/cassandra/tools/NodeProbe.java index 38d0f74..9c9e93d 100644 --- a/src/java/org/apache/cassandra/tools/NodeProbe.java +++ b/src/java/org/apache/cassandra/tools/NodeProbe.java @@ -650,6 +650,11 @@ public class NodeProbe implements AutoCloseable return ssProxy.getOperationMode(); } + public boolean isStarting() + { + return ssProxy.isStarting(); + } + public void truncate(String keyspaceName, String cfName) { try