diff options
author | Harald Musum <musum@verizonmedia.com> | 2021-03-10 22:50:21 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-03-10 22:50:21 +0100 |
commit | f9b4a509c0acd9499fe885f5b71c771bef5300e7 (patch) | |
tree | a8ee1253c51c50d251bd6719b76a361f6b4849a2 | |
parent | 95e943313575d8bc5f9b85b1b0d4ba61c0124ca6 (diff) | |
parent | f9ab99539958e0daba8dbb114e03daf4373354f7 (diff) |
Merge pull request #16889 from vespa-engine/balder/add-debug-logging-to-shutdown
Add debug logging to shutdown
-rw-r--r-- | config-proxy/src/main/java/com/yahoo/vespa/config/proxy/RpcConfigSourceClient.java | 8 |
1 files changed, 8 insertions, 0 deletions
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(); } |