diff options
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcSearchInvoker.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcSearchInvoker.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcSearchInvoker.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcSearchInvoker.java index 6ffc809bc45..4c0b77207d5 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcSearchInvoker.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcSearchInvoker.java @@ -58,8 +58,12 @@ public class RpcSearchInvoker extends SearchInvoker implements Client.ResponseRe RpcContext context = getContext(incomingContext); double timeoutSeconds = ((double) query.getTimeLeft() - 3.0) / 1000.0; - nodeConnection.request(RPC_METHOD, context.compressedPayload.type(), context.payloadLength, - context.compressedPayload.data(), this, timeoutSeconds); + nodeConnection.request(RPC_METHOD, + context.compressedPayload.type(), + context.compressedPayload.uncompressedSize(), + context.compressedPayload.data(), + this, + timeoutSeconds); return context; } @@ -120,10 +124,8 @@ public class RpcSearchInvoker extends SearchInvoker implements Client.ResponseRe static class RpcContext { final Compressor.Compression compressedPayload; - final int payloadLength; RpcContext(RpcResourcePool resourcePool, Query query, byte[] payload) { - this.payloadLength = payload.length; compressedPayload = resourcePool.compress(query, payload); } |