From b6206314db3250df9adb1c64432f3ffc9ab6c0b5 Mon Sep 17 00:00:00 2001
From: Jon Bratseth <bratseth@gmail.com>
Date: Wed, 9 Mar 2022 11:23:13 +0100
Subject: Cleanup

---
 .../dispatch/searchcluster/SearchCluster.java      | 50 +++++++++++-----------
 1 file changed, 25 insertions(+), 25 deletions(-)

(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 e5b8d799bbf..0df7fb0c154 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
@@ -255,31 +255,6 @@ public class SearchCluster implements NodeManager<Node> {
         return localCorpusDispatchTarget.isPresent() && localCorpusDispatchTarget.get().group() == group.id();
     }
 
-    private static class PongCallback implements PongHandler {
-
-        private final ClusterMonitor<Node> clusterMonitor;
-        private final Node node;
-
-        PongCallback(Node node, ClusterMonitor<Node> clusterMonitor) {
-            this.node = node;
-            this.clusterMonitor = clusterMonitor;
-        }
-
-        @Override
-        public void handle(Pong pong) {
-            if (pong.badResponse()) {
-                clusterMonitor.failed(node, pong.error().get());
-            } else {
-                if (pong.activeDocuments().isPresent()) {
-                    node.setActiveDocuments(pong.activeDocuments().get());
-                    node.setBlockingWrites(pong.isBlockingWrites());
-                }
-                clusterMonitor.responded(node);
-            }
-        }
-
-    }
-
     /** Used by the cluster monitor to manage node status */
     @Override
     public void ping(ClusterMonitor clusterMonitor, Node node, Executor executor) {
@@ -368,4 +343,29 @@ public class SearchCluster implements NodeManager<Node> {
         }
     }
 
+    private static class PongCallback implements PongHandler {
+
+        private final ClusterMonitor<Node> clusterMonitor;
+        private final Node node;
+
+        PongCallback(Node node, ClusterMonitor<Node> clusterMonitor) {
+            this.node = node;
+            this.clusterMonitor = clusterMonitor;
+        }
+
+        @Override
+        public void handle(Pong pong) {
+            if (pong.badResponse()) {
+                clusterMonitor.failed(node, pong.error().get());
+            } else {
+                if (pong.activeDocuments().isPresent()) {
+                    node.setActiveDocuments(pong.activeDocuments().get());
+                    node.setBlockingWrites(pong.isBlockingWrites());
+                }
+                clusterMonitor.responded(node);
+            }
+        }
+
+    }
+
 }
-- 
cgit v1.2.3