diff --git a/core/src/main/java/com/google/bitcoin/net/discovery/TorDiscovery.java b/core/src/main/java/com/google/bitcoin/net/discovery/TorDiscovery.java index a65f6165..1f535e6a 100644 --- a/core/src/main/java/com/google/bitcoin/net/discovery/TorDiscovery.java +++ b/core/src/main/java/com/google/bitcoin/net/discovery/TorDiscovery.java @@ -154,13 +154,16 @@ public class TorDiscovery implements PeerDiscovery { })); } + int timeouts = 0; threadPool.awaitTermination(timeoutValue, timeoutUnit); for (ListenableFuture future : circuitFutures) { if (!future.isDone()) { - log.warn("circuit timed out"); + timeouts++; future.cancel(true); } } + if (timeouts > 0) + log.warn("{} DNS lookup circuits timed out", timeouts); try { List circuits = new ArrayList(Futures.successfulAsList(circuitFutures).get()); @@ -192,12 +195,15 @@ public class TorDiscovery implements PeerDiscovery { } threadPool.awaitTermination(timeoutValue, timeoutUnit); + int timeouts = 0; for (ListenableFuture future : lookupFutures) { if (!future.isDone()) { - log.warn("circuit timed out"); + timeouts++; future.cancel(true); } } + if (timeouts > 0) + log.warn("{} DNS lookup circuits timed out", timeouts); try { List lookups = new ArrayList(Futures.successfulAsList(lookupFutures).get());