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 /clustercontroller-core | |
| parent | bd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff) | |
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'clustercontroller-core')
3 files changed, 3 insertions, 3 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java index d8a72a9272c..4441501da01 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RPCCommunicator.java @@ -54,7 +54,7 @@ public class RPCCommunicator implements Communicator { private final int fleetControllerIndex; public static Supervisor createRealSupervisor() { - return new Supervisor(new Transport()); + return new Supervisor(new Transport("rpc-communicator")); } public RPCCommunicator(Supervisor supervisor, diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java index bdce2b31036..519f4c2d171 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java @@ -99,7 +99,7 @@ public class RpcServer { disconnect(); log.log(Level.FINE, "Fleetcontroller " + fleetControllerIndex + ": Connecting RPC server."); if (supervisor != null) disconnect(); - supervisor = new Supervisor(new Transport()); + supervisor = new Supervisor(new Transport("rpc" + port)); addMethods(); log.log(Level.FINE, "Fleetcontroller " + fleetControllerIndex + ": Attempting to bind to port " + port); acceptor = supervisor.listen(new Spec(port)); diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java index c31fee36521..b3bb458ed74 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/SlobrokClient.java @@ -52,7 +52,7 @@ public class SlobrokClient implements NodeLookup { if (equalsExistingSpec(slobrokConnectionSpecs)) return; this.connectionSpecs = slobrokConnectionSpecs; shutdown(); - supervisor = new Supervisor(new Transport()); + supervisor = new Supervisor(new Transport("slobrok-client")); SlobrokList slist = new SlobrokList(); slist.setup(slobrokConnectionSpecs); mirror = new Mirror(supervisor, slist); |