summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-08-04 18:34:18 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-08-04 18:34:18 +0000
commitaf72753359ee72003d10d92e3c7355a156d3e6d7 (patch)
treedf01de4919739a944082c72a2d805482a625e9e9 /configserver
parentbd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff)
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/application/FileDistributionStatus.java2
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionFactory.java2
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java2
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java2
4 files changed, 4 insertions, 4 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/application/FileDistributionStatus.java b/configserver/src/main/java/com/yahoo/vespa/config/server/application/FileDistributionStatus.java
index 092db354ffd..012d0d52275 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/application/FileDistributionStatus.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/application/FileDistributionStatus.java
@@ -39,7 +39,7 @@ public class FileDistributionStatus extends AbstractComponent {
enum Status {UNKNOWN, FINISHED, IN_PROGRESS}
private final ExecutorService rpcExecutor = Executors.newCachedThreadPool(new DaemonThreadFactory("filedistribution status"));
- private final Supervisor supervisor = new Supervisor(new Transport());
+ private final Supervisor supervisor = new Supervisor(new Transport("filedistribution-status"));
public StatusAllHosts status(Application application, Duration timeout) {
List<HostStatus> hostStatuses = new ArrayList<>();
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionFactory.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionFactory.java
index ae18c3e6e95..fd71afedec1 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionFactory.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionFactory.java
@@ -17,7 +17,7 @@ import java.io.File;
public class FileDistributionFactory {
protected final ConfigserverConfig configserverConfig;
- private final Supervisor supervisor = new Supervisor(new Transport());
+ private final Supervisor supervisor = new Supervisor(new Transport("filedistribution"));
@Inject
public FileDistributionFactory(ConfigserverConfig configserverConfig) {
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java
index 305bc71e66a..4ed93f0aa64 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDistributionUtil.java
@@ -87,7 +87,7 @@ public class FileDistributionUtil {
public Supervisor getSupervisor() {
synchronized (this) {
if (supervisor == null) {
- supervisor = new Supervisor(new Transport());
+ supervisor = new Supervisor(new Transport("empty-connectionpool"));
}
}
return supervisor;
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
index 388ddb4048c..2ebfd6a11d3 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/rpc/RpcServer.java
@@ -82,7 +82,7 @@ public class RpcServer implements Runnable, ReloadListener, TenantListener {
private static final long SHUTDOWN_TIMEOUT = 60;
private static final int JRT_RPC_TRANSPORT_THREADS = threadsToUse();
- private final Supervisor supervisor = new Supervisor(new Transport(JRT_RPC_TRANSPORT_THREADS));
+ private final Supervisor supervisor = new Supervisor(new Transport("rpc", JRT_RPC_TRANSPORT_THREADS));
private final Spec spec;
private final boolean useRequestVersion;
private final boolean hostedVespa;