add nodetool statusbinary command
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/530f5ba1 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/530f5ba1 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/530f5ba1 Branch: refs/heads/trunk Commit: 530f5ba1e490457239e76b9472ee7c3bf8fd2138 Parents: 7039168 Author: Brandon Williams <[email protected]> Authored: Fri Apr 5 12:02:33 2013 -0500 Committer: Brandon Williams <[email protected]> Committed: Fri Apr 5 12:02:33 2013 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/tools/NodeCmd.java | 7 +++++++ src/java/org/apache/cassandra/tools/NodeProbe.java | 5 +++++ .../org/apache/cassandra/tools/NodeToolHelp.yaml | 3 +++ 3 files changed, 15 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/530f5ba1/src/java/org/apache/cassandra/tools/NodeCmd.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/tools/NodeCmd.java b/src/java/org/apache/cassandra/tools/NodeCmd.java index 4f3e1e1..ed82e32 100644 --- a/src/java/org/apache/cassandra/tools/NodeCmd.java +++ b/src/java/org/apache/cassandra/tools/NodeCmd.java @@ -145,6 +145,7 @@ public class NodeCmd SETTRACEPROBABILITY, SNAPSHOT, STATUS, + STATUSBINARY, STATUSTHRIFT, STOP, TPSTATS, @@ -912,6 +913,11 @@ public class NodeCmd } } + private void printIsNativeTransportRunning(PrintStream outs) + { + outs.println(probe.isNativeTransportRunning() ? "running" : "not running"); + } + private void printIsThriftServerRunning(PrintStream outs) { outs.println(probe.isThriftServerRunning() ? "running" : "not running"); @@ -1052,6 +1058,7 @@ public class NodeCmd case COMPACTIONSTATS : nodeCmd.printCompactionStats(System.out); break; case DISABLEBINARY : probe.stopNativeTransport(); break; case ENABLEBINARY : probe.startNativeTransport(); break; + case STATUSBINARY : nodeCmd.printIsNativeTransportRunning(System.out); break; case DISABLEGOSSIP : probe.stopGossiping(); break; case ENABLEGOSSIP : probe.startGossiping(); break; case DISABLEHANDOFF : probe.disableHintedHandoff(); break; http://git-wip-us.apache.org/repos/asf/cassandra/blob/530f5ba1/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 43d99d2..e6eca7b 100644 --- a/src/java/org/apache/cassandra/tools/NodeProbe.java +++ b/src/java/org/apache/cassandra/tools/NodeProbe.java @@ -710,6 +710,11 @@ public class NodeProbe ssProxy.startNativeTransport(); } + public boolean isNativeTransportRunning() + { + return ssProxy.isNativeTransportRunning(); + } + public void stopGossiping() { ssProxy.stopGossiping(); http://git-wip-us.apache.org/repos/asf/cassandra/blob/530f5ba1/src/resources/org/apache/cassandra/tools/NodeToolHelp.yaml ---------------------------------------------------------------------- diff --git a/src/resources/org/apache/cassandra/tools/NodeToolHelp.yaml b/src/resources/org/apache/cassandra/tools/NodeToolHelp.yaml index 6551b07..f3cd88e 100644 --- a/src/resources/org/apache/cassandra/tools/NodeToolHelp.yaml +++ b/src/resources/org/apache/cassandra/tools/NodeToolHelp.yaml @@ -55,6 +55,9 @@ commands: - name: enablebinary help: | Reenable native transport (binary protocol) + - name: statusbinary + help: | + Status of native transport (binary protocol) - name: disablehandoff help: | Disable the future hints storing on the current node
