diff options
author | Harald Musum <musum@yahooinc.com> | 2021-11-15 10:43:11 +0100 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2021-11-15 10:43:11 +0100 |
commit | d1a26a18f8843fc916e87de6ae19d96e766747ff (patch) | |
tree | 1b672584b814243f3d61e5ec55d56634355d24cb /configserver | |
parent | 958567df05ad3b168a0a1f83813d1385a18b5122 (diff) |
Log number of active threads
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java index f34beae9c46..6f0f128e360 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileServer.java @@ -30,6 +30,7 @@ import java.nio.file.Path; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +import java.util.concurrent.ThreadPoolExecutor; import java.util.logging.Level; import java.util.logging.Logger; @@ -153,6 +154,8 @@ public class FileServer { } public void serveFile(String fileReference, boolean downloadFromOtherSourceIfNotFound, Request request, Receiver receiver) { + if (executor instanceof ThreadPoolExecutor) + log.log(Level.FINE, () -> "Active threads is now " + ((ThreadPoolExecutor) executor).getActiveCount()); executor.execute(() -> serveFileInternal(fileReference, downloadFromOtherSourceIfNotFound, request, receiver)); } |