From 071a009c0cc00b8906790105e91ba5da817f983f Mon Sep 17 00:00:00 2001 From: Jon Bratseth Date: Wed, 1 Jul 2020 08:50:59 +0200 Subject: Use existing uncompressed length --- .../test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java') 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 3b362963c8c..c421e9523ed 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 @@ -40,7 +40,7 @@ public class RpcSearchInvokerTest { Query q = new Query("search/?query=test&hits=10&offset=3"); RpcSearchInvoker.RpcContext context = (RpcSearchInvoker.RpcContext) invoker.sendSearchRequest(q, null); - assertTrue( context.payloadLength == lengthHolder.get()); + assertEquals(lengthHolder.get(), context.compressedPayload.uncompressedSize()); assertSame(context.compressedPayload.data(), payloadHolder.get()); var bytes = mockPool.compressor().decompress(payloadHolder.get(), compressionTypeHolder.get(), lengthHolder.get()); @@ -53,7 +53,7 @@ public class RpcSearchInvokerTest { var invoker2 = new RpcSearchInvoker(mockSearcher(), new Node(8, "eight", 1), mockPool, 1000); RpcSearchInvoker.RpcContext context2 = (RpcSearchInvoker.RpcContext)invoker2.sendSearchRequest(q, context); assertSame(context, context2); - assertTrue( context.payloadLength == lengthHolder.get()); + assertEquals(lengthHolder.get(), context.compressedPayload.uncompressedSize()); assertSame(context.compressedPayload.data(), payloadHolder.get()); } -- cgit v1.2.3