From e7d6baa6981edceff032b2d685d70b76c476828e Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Thu, 30 Mar 2023 09:30:49 +0200 Subject: Propagate the configured slime decode type into the rpc summary handling. --- .../java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java') diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java index 4e538fb54dc..8ffeecd71a8 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/rpc/RpcProtobufFillInvoker.java @@ -42,6 +42,8 @@ public class RpcProtobufFillInvoker extends FillInvoker { private static final Logger log = Logger.getLogger(RpcProtobufFillInvoker.class.getName()); + enum DecodePolicy {EAGER, ONDEMAND} + private final DocumentDatabase documentDb; private final RpcConnectionPool resourcePool; private final boolean summaryNeedsQuery; @@ -56,7 +58,8 @@ public class RpcProtobufFillInvoker extends FillInvoker { /** The number of responses we should receive (and process) before this is complete */ private int outstandingResponses; - RpcProtobufFillInvoker(RpcConnectionPool resourcePool, CompressPayload compressor, DocumentDatabase documentDb, String serverId, boolean summaryNeedsQuery) { + RpcProtobufFillInvoker(RpcConnectionPool resourcePool, CompressPayload compressor, DocumentDatabase documentDb, + String serverId, DecodePolicy decodePolicy, boolean summaryNeedsQuery) { this.documentDb = documentDb; this.resourcePool = resourcePool; this.serverId = serverId; -- cgit v1.2.3