aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-03-10 22:50:21 +0100
committerGitHub <noreply@github.com>2021-03-10 22:50:21 +0100
commitf9b4a509c0acd9499fe885f5b71c771bef5300e7 (patch)
treea8ee1253c51c50d251bd6719b76a361f6b4849a2
parent95e943313575d8bc5f9b85b1b0d4ba61c0124ca6 (diff)
parentf9ab99539958e0daba8dbb114e03daf4373354f7 (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.java8
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();
}