aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@gmail.com>2020-07-01 08:50:59 +0200
committerJon Bratseth <bratseth@gmail.com>2020-07-01 08:50:59 +0200
commit071a009c0cc00b8906790105e91ba5da817f983f (patch)
tree1cbdc4144248fa28cb1ce805e6141459c55390cb /container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java
parent906cbed5b431c8df1325441907c1602241f3f6ef (diff)
Use existing uncompressed length
Diffstat (limited to 'container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java')
-rw-r--r--container-search/src/test/java/com/yahoo/search/dispatch/rpc/RpcSearchInvokerTest.java4
1 files changed, 2 insertions, 2 deletions
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());
}