Adding some logging for evictor thread

elastic · Oct 11, 2023 · b70f418 · b70f418
1 parent 6f1911e
commit b70f418
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/...ence/src/main/java/org/elasticsearch/xpack/inference/external/http/HttpClientManager.java b/...ence/src/main/java/org/elasticsearch/xpack/inference/external/http/HttpClientManager.java
@@ -24,6 +24,8 @@
 import java.io.IOException;
 import java.util.List;
 
+import static org.elasticsearch.core.Strings.format;
+
 public class HttpClientManager implements Closeable {
     private static final Logger logger = LogManager.getLogger(HttpClientManager.class);
     /**
@@ -143,6 +145,8 @@ boolean isEvictionThreadRunning() {
 
     // default for testing
     void setEvictionInterval(TimeValue evictionInterval) {
+        logger.debug(() -> format("Eviction thread's interval time updated to [%s]", evictionInterval));
+
         evictorSettings = new EvictorSettings(evictionInterval, evictorSettings.evictionMaxIdle);
 
         connectionEvictor.close();
@@ -151,6 +155,7 @@ void setEvictionInterval(TimeValue evictionInterval) {
     }
 
     void setEvictionMaxIdle(TimeValue evictionMaxIdle) {
+        logger.debug(() -> format("Eviction thread's max idle time updated to [%s]", evictionMaxIdle));
         evictorSettings = new EvictorSettings(evictorSettings.evictionInterval, evictionMaxIdle);
         connectionEvictor.setMaxIdleTime(evictionMaxIdle);
     }

diff --git a/.../src/main/java/org/elasticsearch/xpack/inference/external/http/IdleConnectionEvictor.java b/.../src/main/java/org/elasticsearch/xpack/inference/external/http/IdleConnectionEvictor.java
@@ -19,6 +19,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 
+import static org.elasticsearch.core.Strings.format;
 import static org.elasticsearch.xpack.inference.InferencePlugin.UTILITY_THREAD_POOL_NAME;
 
 /**
@@ -63,6 +64,8 @@ public synchronized void start() {
     }
 
     private void startInternal() {
+        logger.debug(() -> format("Idle connection evictor started with wait time: [%s] max idle: [%s]", sleepTime, maxIdleTime));
+
         Scheduler.Cancellable task = threadPool.scheduleWithFixedDelay(() -> {
             try {
                 connectionManager.closeExpiredConnections();
@@ -80,6 +83,7 @@ private void startInternal() {
     @Override
     public void close() {
         if (cancellableTask.get() != null) {
+            logger.debug("Idle connection evictor closing");
             cancellableTask.get().cancel();
         }
     }