You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@karaf.apache.org by jb...@apache.org on 2012/04/18 18:48:13 UTC
svn commit: r1327577 -
/karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java
Author: jbonofre
Date: Wed Apr 18 16:48:13 2012
New Revision: 1327577
URL: http://svn.apache.org/viewvc?rev=1327577&view=rev
Log:
[KARAF-1194] Add a timeout message for Ping command
Modified:
karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java
Modified: karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java
URL: http://svn.apache.org/viewvc/karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java?rev=1327577&r1=1327576&r2=1327577&view=diff
==============================================================================
--- karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java (original)
+++ karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java Wed Apr 18 16:48:13 2012
@@ -24,6 +24,8 @@ import java.util.HashSet;
@Command(scope = "cluster", name = "node-ping", description = "Ping a cluster node.")
public class NodePingCommand extends ClusterCommandSupport {
+ private static Long TIMEOUT = 5000L;
+
@Argument(index = 0, name = "node", description = "The node ID to ping.", required = true, multiValued = false)
String nodeId;
@@ -48,7 +50,11 @@ public class NodePingCommand extends Clu
executionContext.execute(ping);
Long stop = System.currentTimeMillis();
Long delay = stop - start;
- System.out.println(String.format("PING %s %s %sms", i, node.getId(), delay));
+ if (delay > TIMEOUT) {
+ System.err.println(String.format("TIMEOUT %s %s %sms", i, node.getId(), delay));
+ } else {
+ System.out.println(String.format("PING %s %s %sms", i, node.getId(), delay));
+ }
Thread.sleep(interval);
}
return null;