aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-02-03 09:39:05 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-02-03 09:39:05 +0100
commit0414eda77c5afd8c90a0f90cde25e2c356a5cca1 (patch)
tree9da2358bf1c7f38fcf4818b593fcc18aaa081bda /container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java
parentb18b79462651ff94daa9de70040961d838803157 (diff)
- Name the monitor thread and make it a daemon.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/cluster/ClusterSearcher.java9
1 files changed, 6 insertions, 3 deletions
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;