From f9ab99539958e0daba8dbb114e03daf4373354f7 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Wed, 10 Mar 2021 21:34:22 +0100 Subject: Add debug logging to shutdown --- .../java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java index 095bde76c39..3b9b101a8c6 100644 --- a/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java +++ b/config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java @@ -179,9 +179,13 @@ class RpcConfigSourceClient implements ConfigSourceClient, Runnable { @Override public void cancel() { + log.log(Level.FINE, "shutdownSourceConnections"); shutdownSourceConnections(); + log.log(Level.FINE, "delayedResponsesFuture.cancel"); delayedResponsesFuture.cancel(true); + log.log(Level.FINE, "delayedResponsesFuture.shutdownNow"); delayedResponsesScheduler.shutdownNow(); + log.log(Level.FINE, "supervisor.transport().shutdown().join()"); supervisor.transport().shutdown().join(); } @@ -190,10 +194,14 @@ class RpcConfigSourceClient implements ConfigSourceClient, Runnable { */ @Override public void shutdownSourceConnections() { + log.log(Level.FINE, "Subscriber::cancel"); activeSubscribers.values().forEach(Subscriber::cancel); activeSubscribers.clear(); + log.log(Level.FINE, "nextConfigFuture.cancel"); nextConfigFuture.cancel(true); + log.log(Level.FINE, "nextConfigScheduler.shutdownNow"); nextConfigScheduler.shutdownNow(); + log.log(Level.FINE, "requester.close"); requester.close(); } -- cgit v1.2.3