diff --git oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/StandbyServer.java oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/StandbyServer.java index 3551aa20c6..4386aaa8f3 100644 --- oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/StandbyServer.java +++ oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/server/StandbyServer.java @@ -55,7 +55,7 @@ import org.slf4j.LoggerFactory; class StandbyServer implements AutoCloseable { private static final Logger log = LoggerFactory.getLogger(StandbyServer.class); - + /** * If a persisted head state cannot be acquired in less than this timeout, * the 'get head' request from the client will be discarded. @@ -84,7 +84,7 @@ class StandbyServer implements AutoCloseable { private final int port; private final StoreProvider storeProvider; - + private final int blobChunkSize; private boolean secure; @@ -163,7 +163,7 @@ class StandbyServer implements AutoCloseable { // Decoders - p.addLast(new LineBasedFrameDecoder(8192)); + p.addLast(new LineBasedFrameDecoder(Integer.MAX_VALUE)); p.addLast(new StringDecoder(CharsetUtil.UTF_8)); p.addLast(new RequestDecoder()); p.addLast(new StateHandler(builder.stateConsumer)); @@ -173,12 +173,12 @@ class StandbyServer implements AutoCloseable { p.addLast(new SnappyFrameEncoder()); - // Use chunking transparently - + // Use chunking transparently + p.addLast(new ChunkedWriteHandler()); - + // Other Encoders - + p.addLast(new GetHeadResponseEncoder()); p.addLast(new GetSegmentResponseEncoder()); p.addLast(new GetBlobResponseEncoder(builder.blobChunkSize));