summaryrefslogtreecommitdiffstats
path: root/container-search
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 /container-search
parentbd3399a2677b32888ef2588adf1c976ed4cdb5cb (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.java4
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcResourcePool.java2
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>();