diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-21 07:42:58 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-09-21 07:42:58 +0000 |
commit | 4c230a023fccdc9308b7daa5c8a5f3861c5507d4 (patch) | |
tree | 25595f245aabcffee8953264188d73722ab22ec5 /container-search/src/test/java/com | |
parent | db8e597ba18aba45aa07d6185fbb86d81246e542 (diff) |
Shutdown and join the rpc client transport threads.
Diffstat (limited to 'container-search/src/test/java/com')
-rw-r--r-- | container-search/src/test/java/com/yahoo/search/dispatch/rpc/MockClient.java | 2 | ||||
-rw-r--r-- | container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java | 5 |
2 files changed, 5 insertions, 2 deletions
diff --git a/container-search/src/test/java/com/yahoo/search/dispatch/rpc/MockClient.java b/container-search/src/test/java/com/yahoo/search/dispatch/rpc/MockClient.java index 2fc8c0fd620..1a0037e4b8a 100644 --- a/container-search/src/test/java/com/yahoo/search/dispatch/rpc/MockClient.java +++ b/container-search/src/test/java/com/yahoo/search/dispatch/rpc/MockClient.java @@ -32,6 +32,8 @@ public class MockClient implements Client { public void setMalfunctioning(boolean malfunctioning) { this.malfunctioning = malfunctioning; } @Override + public void close() { } + @Override public NodeConnection createConnection(String hostname, int port) { return new MockNodeConnection(hostname, port); } diff --git a/container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java b/container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java index c421e9523ed..27fc3f85136 100644 --- a/container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java +++ b/container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java @@ -80,6 +80,8 @@ public class RpcSearchInvokerTest { AtomicInteger lengthHolder) { return new Client() { @Override + public void close() { } + @Override public NodeConnection createConnection(String hostname, int port) { return new NodeConnection() { @Override @@ -97,8 +99,7 @@ public class RpcSearchInvokerTest { } @Override - public void close() { - } + public void close() { } }; } }; |