Increase default MAX_PAYLOAD_BYTES_TO_PRINT to 100MiB

Signed-off-by: Andre Kurait <[email protected]>
opensearch-project · Apr 30, 2024 · cf3f0af · cf3f0af
1 parent 60cd859
commit cf3f0af
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/...erProvider/src/test/java/org/opensearch/migrations/replay/AddCompressionEncodingTest.java b/...erProvider/src/test/java/org/opensearch/migrations/replay/AddCompressionEncodingTest.java
@@ -67,7 +67,7 @@ public void addingCompressionRequestHeaderCompressesPayload() throws ExecutionEx
 
         EmbeddedChannel channel = new EmbeddedChannel(
             new HttpServerCodec(),
-            new HttpObjectAggregator(Utils.MAX_PAYLOAD_SIZE_TO_PRINT)  // Set max content length if needed
+            new HttpObjectAggregator(Utils.MAX_PAYLOAD_BYTES_TO_PRINT)  // Set max content length if needed
         );
 
         channel.writeInbound(Unpooled.wrappedBuffer(testPacketCapture.getBytesCaptured()));

diff --git a/.../trafficReplayer/src/main/java/org/opensearch/migrations/replay/HttpByteBufFormatter.java b/.../trafficReplayer/src/main/java/org/opensearch/migrations/replay/HttpByteBufFormatter.java
@@ -146,7 +146,7 @@ public static HttpMessage parseHttpMessageFromBufs(HttpMessageType msgType, Stre
         EmbeddedChannel channel = new EmbeddedChannel(
                 msgType == HttpMessageType.REQUEST ? new HttpServerCodec() : new HttpClientCodec(),
                 new HttpContentDecompressor(),
-                new HttpObjectAggregator(Utils.MAX_PAYLOAD_SIZE_TO_PRINT)  // Set max content length if needed
+                new HttpObjectAggregator(Utils.MAX_PAYLOAD_BYTES_TO_PRINT)  // Set max content length if needed
         );
         try {
             byteBufStream.forEachOrdered(b -> channel.writeInbound(b.retainedDuplicate()));

diff --git a/...afficReplayer/src/main/java/org/opensearch/migrations/replay/HttpMessageAndTimestamp.java b/...afficReplayer/src/main/java/org/opensearch/migrations/replay/HttpMessageAndTimestamp.java
@@ -68,7 +68,7 @@ public String format(Optional<HttpByteBufFormatter.HttpMessageType> messageTypeO
         try (var bufStream = NettyUtils.createRefCntNeutralCloseableByteBufStream(packetBytes)) {
             var packetBytesAsStr = messageTypeOp.map(mt-> HttpByteBufFormatter.httpPacketBytesToString(mt, packetBytes,
                     HttpByteBufFormatter.LF_LINE_DELIMITER))
-                .orElseGet(()-> HttpByteBufFormatter.httpPacketBufsToString(bufStream, Utils.MAX_PAYLOAD_SIZE_TO_PRINT));
+                .orElseGet(()-> HttpByteBufFormatter.httpPacketBufsToString(bufStream, Utils.MAX_PAYLOAD_BYTES_TO_PRINT));
             final StringBuilder sb = new StringBuilder("HttpMessageAndTimestamp{");
             sb.append("firstPacketTimestamp=").append(firstPacketTimestamp);
             sb.append(", lastPacketTimestamp=").append(lastPacketTimestamp);

diff --git a/TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/Utils.java b/TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/Utils.java
@@ -21,7 +21,7 @@
 @Slf4j
 public class Utils {
     public static final int MAX_BYTES_SHOWN_FOR_TO_STRING = 128;
-    public static final int MAX_PAYLOAD_SIZE_TO_PRINT = 1024 * 1024; // 1MB
+    public static final int MAX_PAYLOAD_BYTES_TO_PRINT = 100 * 1024 * 1024; // 100MiB based on https://docs.aws.amazon.com/opensearch-service/latest/developerguide/limits.html#network-limits
 
     public static Instant setIfLater(AtomicReference<Instant> referenceValue, Instant pointInTime) {
         return referenceValue.updateAndGet(existingInstant -> existingInstant.isBefore(pointInTime) ?