fix PingTest

2014-02-11 19:45:52 +00:00
parent 53efb7119a
commit 66d9017d58
1 changed files with 10 additions and 0 deletions
--- a/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionManager.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionManager.java
@ -612,6 +612,16 @@ class ConnectionManager {
            return new HashSet<Connection>(_connectionByInboundId.values());
    }

+    /**
+     *  blocking
+     *
+     *  @param timeoutMs greater than zero
+     *  @return true if pong received
+     */
+    public boolean ping(Destination peer, long timeoutMs) {
+        return ping(peer, 0, 0, timeoutMs, true, null);
+    }
+
    /**
     *  blocking
     *