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/05/11 16:59:22 UTC
svn commit: r1337198 -
/karaf/cellar/trunk/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java
Author: jbonofre
Date: Fri May 11 14:59:21 2012
New Revision: 1337198
URL: http://svn.apache.org/viewvc?rev=1337198&view=rev
Log:
Ignore InterruptedException in the cluster:node-ping command
Modified:
karaf/cellar/trunk/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java
Modified: karaf/cellar/trunk/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java
URL: http://svn.apache.org/viewvc/karaf/cellar/trunk/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java?rev=1337198&r1=1337197&r2=1337198&view=diff
==============================================================================
--- karaf/cellar/trunk/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java (original)
+++ karaf/cellar/trunk/shell/src/main/java/org/apache/karaf/cellar/shell/NodePingCommand.java Fri May 11 14:59:21 2012
@@ -44,19 +44,25 @@ public class NodePingCommand extends Clu
}
System.out.println("PING " + node.getId());
- for (int i = 1; i <= iterations; i++) {
- Long start = System.currentTimeMillis();
- Ping ping = new Ping(clusterManager.generateId());
- ping.setDestination(new HashSet(Arrays.asList(node)));
- executionContext.execute(ping);
- Long stop = System.currentTimeMillis();
- Long delay = stop - start;
- if (delay >= TIMEOUT) {
- System.err.println(String.format("TIMEOUT %s %s", i, node.getId()));
- } else {
- System.out.println(String.format("from %s: req=%s time=%s ms", i, node.getId(), delay));
+ try {
+ for (int i = 1; i <= iterations; i++) {
+ Long start = System.currentTimeMillis();
+ Ping ping = new Ping(clusterManager.generateId());
+ ping.setDestination(new HashSet(Arrays.asList(node)));
+ executionContext.execute(ping);
+ Long stop = System.currentTimeMillis();
+ Long delay = stop - start;
+ if (delay >= TIMEOUT) {
+ System.err.println(String.format("TIMEOUT %s %s", i, node.getId()));
+ } else {
+ System.out.println(String.format("from %s: req=%s time=%s ms", i, node.getId(), delay));
+ }
+ Thread.sleep(interval);
}
- Thread.sleep(interval);
+ } catch (InterruptedException e) {
+ // nothing to do
+ } catch (Exception e) {
+ throw e;
}
return null;
}