Name the transport threads to understand how things are interconnected.

3 files changed, 7 insertions, 8 deletions

diff --git a/jrt/tests/com/yahoo/jrt/EchoTest.java b/jrt/tests/com/yahoo/jrt/EchoTest.java
index 97139fd60ab..c71eae78ad9 100644
--- a/jrt/tests/com/yahoo/jrt/EchoTest.java
+++ b/jrt/tests/com/yahoo/jrt/EchoTest.java
@@ -91,8 +91,8 @@ public class EchoTest {
     public void setUp() throws ListenFailedException {
         metrics =  TransportMetrics.getInstance();
         startSnapshot = metrics.snapshot();
-        server   = new Supervisor(new Transport(crypto, 1));
-        client   = new Supervisor(new Transport(crypto, 1));
+        server   = new Supervisor(new Transport("server", crypto, 1));
+        client   = new Supervisor(new Transport("client", crypto, 1));
         acceptor = server.listen(new Spec(0));
         target   = client.connect(new Spec("localhost", acceptor.port()));
         server.addMethod(new Method("echo", "*", "*", this::rpc_echo));
diff --git a/jrt/tests/com/yahoo/jrt/LatencyTest.java b/jrt/tests/com/yahoo/jrt/LatencyTest.java
index 97d7affd6ea..c8ead8ebf77 100644
--- a/jrt/tests/com/yahoo/jrt/LatencyTest.java
+++ b/jrt/tests/com/yahoo/jrt/LatencyTest.java
@@ -18,8 +18,8 @@ public class LatencyTest {
         private final Supervisor client;
         private final Acceptor acceptor;
         public Network(CryptoEngine crypto, int threads) throws ListenFailedException {
-            server = new Supervisor(new Transport(crypto, threads));
-            client = new Supervisor(new Transport(crypto, threads));
+            server = new Supervisor(new Transport("server", crypto, threads));
+            client = new Supervisor(new Transport("client", crypto, threads));
             server.addMethod(new Method("inc", "i", "i", this::rpc_inc));
             acceptor = server.listen(new Spec(0));
         }
diff --git a/jrt/tests/com/yahoo/jrt/SessionTest.java b/jrt/tests/com/yahoo/jrt/SessionTest.java
index 29d6bb21d5f..b6568c2f283 100644
--- a/jrt/tests/com/yahoo/jrt/SessionTest.java
+++ b/jrt/tests/com/yahoo/jrt/SessionTest.java
@@ -122,13 +122,12 @@ public class SessionTest implements SessionHandler {
     @Before
     public void setUp() throws ListenFailedException {
         Session.reset();
-        server   = new Test.Orb(new Transport(crypto, 1));
+        server   = new Test.Orb(new Transport("server", crypto, 1));
         server.setSessionHandler(this);
-        client   = new Test.Orb(new Transport(crypto, 1));
+        client   = new Test.Orb(new Transport("client", crypto, 1));
         client.setSessionHandler(this);
         acceptor = server.listen(new Spec(0));
-        target   = client.connect(new Spec("localhost", acceptor.port()),
-                                  new Session());
+        target   = client.connect(new Spec("localhost", acceptor.port()), new Session());
 
         server.addMethod(new Method("set", "i", "", this::rpc_set));
         server.addMethod(new Method("get", "", "i", this::rpc_get));