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 /jrt/tests/com | |
parent | bd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff) |
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'jrt/tests/com')
-rw-r--r-- | jrt/tests/com/yahoo/jrt/EchoTest.java | 4 | ||||
-rw-r--r-- | jrt/tests/com/yahoo/jrt/LatencyTest.java | 4 | ||||
-rw-r--r-- | jrt/tests/com/yahoo/jrt/SessionTest.java | 7 |
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)); |