aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-10-20 14:16:10 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-10-20 14:16:10 +0200
commit6ad5a779f95141d0b6de1597bcb4cde6f91814c6 (patch)
treec62ab5941d4efc12b64d4dfdc49c061f13d15794 /vespaclient-container-plugin
parentfe92f94becab1750853cac77464bb710374e56dd (diff)
Limit to 16MB outstanding visit response data
Diffstat (limited to 'vespaclient-container-plugin')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
index f1d6b4825c6..865aed221c5 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
@@ -9,6 +9,7 @@ import com.yahoo.concurrent.DaemonThreadFactory;
import com.yahoo.container.core.HandlerMetricContextUtil;
import com.yahoo.container.core.documentapi.VespaDocumentAccess;
import com.yahoo.container.jdisc.ContentChannelOutputStream;
+import com.yahoo.container.jdisc.MaxPendingContentChannelOutputStream;
import com.yahoo.document.Document;
import com.yahoo.document.DocumentId;
import com.yahoo.document.DocumentOperation;
@@ -582,7 +583,8 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler {
private JsonResponse(ResponseHandler handler, boolean streaming) throws IOException {
this.handler = handler;
- out = new ContentChannelOutputStream(buffer);
+ out = streaming ? new MaxPendingContentChannelOutputStream(buffer, 1 << 24)
+ : new ContentChannelOutputStream(buffer);
json = jsonFactory.createGenerator(out);
json.writeStartObject();
}