diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-12-19 10:20:21 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-12-19 10:20:21 +0000 |
commit | 0c73d159fb48cea0bf2d1dc62708aff09c82cf99 (patch) | |
tree | fb8834ed860d4b130033e46a978d780a19015b23 /container-search/src/main/java/com/yahoo/search/cluster/ClusterMonitor.java | |
parent | ae0f989de2585ed10b751ce3340a43fe24c2ef88 (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.java | 12 |
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) {} } |