From 3bda28d373d0a18bffe2d699b6b0d0341c535a82 Mon Sep 17 00:00:00 2001 From: mugdha273 Date: Sat, 4 Oct 2025 12:51:04 +0530 Subject: [PATCH] [UNDERTOW-2494]-Create a default constant for UndertowOptions.QUEUED_FRAMES_HIGH_WATER_MARK --- core/src/main/java/io/undertow/UndertowOptions.java | 9 +++++++-- .../server/protocol/framed/AbstractFramedChannel.java | 2 +- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/io/undertow/UndertowOptions.java b/core/src/main/java/io/undertow/UndertowOptions.java index 7e813d945f..eecf4442f5 100644 --- a/core/src/main/java/io/undertow/UndertowOptions.java +++ b/core/src/main/java/io/undertow/UndertowOptions.java @@ -431,11 +431,16 @@ public class UndertowOptions { */ public static final Option ENDPOINT_IDENTIFICATION_ALGORITHM = Option.simple(UndertowOptions.class, "ENDPOINT_IDENTIFICATION_ALGORITHM", String.class); + /** + * Default value of {@link #QUEUED_FRAMES_HIGH_WATER_MARK} option. + */ + public static final int DEFAULT_QUEUED_FRAMES_HIGH_WATER_MARK = 50; + /** * The maximum numbers of frames that can be queued before reads are suspended. Once this number is hit then reads will not be resumed until {@link #QUEUED_FRAMES_LOW_WATER_MARK} * is hit. - * - * Defaults to 50 + *

+ * Defaults to {@link #DEFAULT_QUEUED_FRAMES_HIGH_WATER_MARK} */ public static final Option QUEUED_FRAMES_HIGH_WATER_MARK = Option.simple(UndertowOptions.class, "QUEUED_FRAMES_HIGH_WATER_MARK", Integer.class); diff --git a/core/src/main/java/io/undertow/server/protocol/framed/AbstractFramedChannel.java b/core/src/main/java/io/undertow/server/protocol/framed/AbstractFramedChannel.java index b6dadca1a8..ac74b6df40 100644 --- a/core/src/main/java/io/undertow/server/protocol/framed/AbstractFramedChannel.java +++ b/core/src/main/java/io/undertow/server/protocol/framed/AbstractFramedChannel.java @@ -237,7 +237,7 @@ protected AbstractFramedChannel(final StreamConnection connectedStreamChannel, B FrameCloseListener closeListener = new FrameCloseListener(); connectedStreamChannel.getSinkChannel().getCloseSetter().set(closeListener); connectedStreamChannel.getSourceChannel().getCloseSetter().set(closeListener); - this.queuedFrameHighWaterMark = settings.get(UndertowOptions.QUEUED_FRAMES_HIGH_WATER_MARK, 50); + this.queuedFrameHighWaterMark = settings.get(UndertowOptions.QUEUED_FRAMES_HIGH_WATER_MARK, UndertowOptions.DEFAULT_QUEUED_FRAMES_HIGH_WATER_MARK); this.queuedFrameLowWaterMark = settings.get(UndertowOptions.QUEUED_FRAMES_LOW_WATER_MARK, 10); }