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 /container-search | |
parent | bd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff) |
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'container-search')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcClient.java | 4 | ||||
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcClient.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcClient.java index 52cb2b4c061..9ee455c48d3 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcClient.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcClient.java @@ -25,8 +25,8 @@ class RpcClient implements Client { private final Supervisor supervisor; - public RpcClient(int transportThreads) { - supervisor = new Supervisor(new Transport(transportThreads)); + public RpcClient(String name, int transportThreads) { + supervisor = new Supervisor(new Transport(name, transportThreads)); } @Override diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java index 065489ef9a0..aada16eef9b 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java @@ -45,7 +45,7 @@ public class RpcResourcePool extends AbstractComponent { @Inject public RpcResourcePool(DispatchConfig dispatchConfig) { super(); - var client = new RpcClient(dispatchConfig.numJrtTransportThreads()); + var client = new RpcClient("dispatch-client", dispatchConfig.numJrtTransportThreads()); // Create rpc node connection pools indexed by the node distribution key var builder = new ImmutableMap.Builder<Integer, NodeConnectionPool>(); |