summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-12-19 10:20:21 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2019-12-19 10:20:21 +0000
commit0c73d159fb48cea0bf2d1dc62708aff09c82cf99 (patch)
treefb8834ed860d4b130033e46a978d780a19015b23 /container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java
parentae0f989de2585ed10b751ce3340a43fe24c2ef88 (diff)
Avoid starting the ping thread automatically for tests.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java12
1 files changed, 10 insertions, 2 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java b/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java
index 2aa896948a1..d4b6279be89 100644
--- a/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java
+++ b/container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java
@@ -39,9 +39,15 @@ public class ClusterMonitor<T> {
private final Map<T, TrafficNodeMonitor<T>> nodeMonitors = Collections.synchronizedMap(new java.util.LinkedHashMap<>());
public ClusterMonitor(NodeManager<T> manager) {
+ this(manager, true);
+ }
+
+ public ClusterMonitor(NodeManager<T> manager, boolean startPingThread) {
nodeManager = manager;
monitorThread = new MonitorThread("search.clustermonitor");
- monitorThread.start();
+ if (startPingThread) {
+ monitorThread.start();
+ }
}
/** Returns the configuration of this cluster monitor */
@@ -121,7 +127,9 @@ public class ClusterMonitor<T> {
nodeManager.notifyAll();
}
try {
- monitorThread.join();
+ if (monitorThread.isAlive()) {
+ monitorThread.join();
+ }
} catch (InterruptedException e) {}
}