From 07d9434f7a7b2b52a28c850ae3a5881ce74ca8e1 Mon Sep 17 00:00:00 2001
From: jonmv <venstad@gmail.com>
Date: Fri, 1 Sep 2023 14:33:16 +0200
Subject: Add debug-logging to search cluster dispatch health tracking

---
 .../java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'container-search')

diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java
index 5005c772e0e..59b4637a627 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java
@@ -12,7 +12,6 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.List;
-import java.util.ListIterator;
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.Executor;
@@ -144,6 +143,7 @@ public class SearchCluster implements NodeManager<Node> {
     }
 
     private void updateWorkingState(Node node, boolean isWorking) {
+        log.fine(() -> "Updating working state of " + node + " to " + isWorking);
         node.setWorking(isWorking);
         updateVipStatusOnNodeChange(node, isWorking);
     }
@@ -219,6 +219,7 @@ public class SearchCluster implements NodeManager<Node> {
     /** Used by the cluster monitor to manage node status */
     @Override
     public void ping(ClusterMonitor<Node> clusterMonitor, Node node, Executor executor) {
+        log.fine(() -> "Pinging " + node);
         Pinger pinger = pingFactory.createPinger(node, clusterMonitor, new PongCallback(node, clusterMonitor));
         pinger.ping();
     }
@@ -305,6 +306,7 @@ public class SearchCluster implements NodeManager<Node> {
 
         @Override
         public void handle(Pong pong) {
+            log.fine(() -> "Got pong from " + node + ": " + pong);
             if (pong.badResponse()) {
                 clusterMonitor.failed(node, pong.error().get());
             } else {
-- 
cgit v1.2.3