svn commit: r1327577 - /karaf/cellar/branches/cellar-2.2.x/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java

[jbonofre]

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;