From 9cede7a7e6ca35b716c0ebb8926b6b066e99871a Mon Sep 17 00:00:00 2001 From: Andreas Schildbach Date: Mon, 16 Apr 2018 18:48:57 +0200 Subject: [PATCH] PeerGroup: Log shutdown times. --- core/src/main/java/org/bitcoinj/core/PeerGroup.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/src/main/java/org/bitcoinj/core/PeerGroup.java b/core/src/main/java/org/bitcoinj/core/PeerGroup.java index 1da3d22c..d43a8e10 100644 --- a/core/src/main/java/org/bitcoinj/core/PeerGroup.java +++ b/core/src/main/java/org/bitcoinj/core/PeerGroup.java @@ -1082,6 +1082,7 @@ public class PeerGroup implements TransactionBroadcaster { public void run() { try { log.info("Stopping ..."); + Stopwatch watch = Stopwatch.createStarted(); // Blocking close of all sockets. channels.stopAsync(); channels.awaitTerminated(); @@ -1089,7 +1090,7 @@ public class PeerGroup implements TransactionBroadcaster { peerDiscovery.shutdown(); } vRunning = false; - log.info("Stopped."); + log.info("Stopped, took {}.", watch); } catch (Throwable e) { log.error("Exception when shutting down", e); // The executor swallows exceptions :( } @@ -1102,9 +1103,11 @@ public class PeerGroup implements TransactionBroadcaster { /** Does a blocking stop */ public void stop() { try { + Stopwatch watch = Stopwatch.createStarted(); stopAsync(); log.info("Awaiting PeerGroup shutdown ..."); executor.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS); + log.info("... took {}", watch); } catch (InterruptedException e) { throw new RuntimeException(e); }