diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-03 09:39:05 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-02-03 09:39:05 +0100 |
commit | 0414eda77c5afd8c90a0f90cde25e2c356a5cca1 (patch) | |
tree | 9da2358bf1c7f38fcf4818b593fcc18aaa081bda /container-search/src/main/java/com/yahoo/search/cluster | |
parent | b18b79462651ff94daa9de70040961d838803157 (diff) |
- Name the monitor thread and make it a daemon.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/cluster')
3 files changed, 13 insertions, 4 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 016e22839c1..360dcd38d3b 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 @@ -47,7 +47,7 @@ public class ClusterMonitor<T> { public ClusterMonitor(NodeManager<T> manager, boolean startPingThread) { nodeManager = manager; - monitorThread = new MonitorThread("search.clustermonitor"); + monitorThread = new MonitorThread("search.clustermonitor." + manager.name()); if (startPingThread) { monitorThread.start(); } @@ -81,7 +81,9 @@ public class ClusterMonitor<T> { /** * Returns the monitor of the given node, or null if this node has not been added + * @deprecated Will be removed in Vespa 8. */ + @Deprecated(forRemoval = true, since = "7.537") public BaseNodeMonitor<T> getNodeMonitor(T node) { return nodeMonitors.get(node); } @@ -147,6 +149,7 @@ public class ClusterMonitor<T> { private class MonitorThread extends Thread { MonitorThread(String name) { super(name); + setDaemon(true); } public void run() { diff --git a/container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java b/container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java index 51ae2ee432d..097d714b47b 100644 --- a/container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java +++ b/container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java @@ -51,7 +51,7 @@ public abstract class ClusterSearcher<T> extends PingableSearcher implements Nod * @param internal whether or not this cluster is internal (part of the same installation) */ public ClusterSearcher(ComponentId id, List<T> connections, boolean internal) { - this(id, connections, new Hasher<T>(), internal); + this(id, connections, new Hasher<>(), internal); } public ClusterSearcher(ComponentId id, List<T> connections, Hasher<T> hasher, boolean internal) { @@ -68,6 +68,9 @@ public abstract class ClusterSearcher<T> extends PingableSearcher implements Nod } } + @Override + public String name() { return getIdString(); } + /** Pinging a node, called from ClusterMonitor */ @Override public final void ping(ClusterMonitor<T> clusterMonitor, T p, Executor executor) { @@ -112,7 +115,7 @@ public abstract class ClusterSearcher<T> extends PingableSearcher implements Nod if (k == null) { b.append("null\n"); } else { - b.append(k.toString()).append('\n'); + b.append(k).append('\n'); } } traceAsString = b.toString(); @@ -303,7 +306,7 @@ public abstract class ClusterSearcher<T> extends PingableSearcher implements Nod private class Pinger implements Callable<Pong> { - private T connection; + private final T connection; public Pinger(T connection) { this.connection = connection; diff --git a/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java b/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java index 1a74194d694..db583a65606 100644 --- a/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java +++ b/container-search/src/main/java/com/yahoo/search/cluster/NodeManager.java @@ -11,6 +11,9 @@ import java.util.concurrent.Executor; */ public interface NodeManager<T> { + /** Name to identify Nodemanager */ + default String name() { return ""; } + /** Called when a failed node is working (ready for production) again */ void working(T node); |