diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-08-04 18:34:18 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-08-04 18:34:18 +0000 |
commit | af72753359ee72003d10d92e3c7355a156d3e6d7 (patch) | |
tree | df01de4919739a944082c72a2d805482a625e9e9 /configserver | |
parent | bd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff) |
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'configserver')
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; |