From 4c230a023fccdc9308b7daa5c8a5f3861c5507d4 Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Mon, 21 Sep 2020 07:42:58 +0000 Subject: Shutdown and join the rpc client transport threads. --- .../src/test/java/com/yahoo/search/dispatch/rpc/MockClient.java | 2 ++ .../java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java | 5 +++-- 2 files changed, 5 insertions(+), 2 deletions(-) (limited to 'container-search/src/test/java/com/yahoo/search') 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 @@ -31,6 +31,8 @@ public class MockClient implements Client { /** Set to true to cause this to produce an error instead of a regular response */ 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 @@ -79,6 +79,8 @@ public class RpcSearchInvokerTest { private Client parameterCollectorClient(AtomicReference compressionTypeHolder, AtomicReference payloadHolder, AtomicInteger lengthHolder) { return new Client() { + @Override + public void close() { } @Override public NodeConnection createConnection(String hostname, int port) { return new NodeConnection() { @@ -97,8 +99,7 @@ public class RpcSearchInvokerTest { } @Override - public void close() { - } + public void close() { } }; } }; -- cgit v1.2.3