(bookkeeper) branch master updated: Apply WRITE_BUFFER_WATER_MARK setting to child channels in BookieNettyServer (#4337)

[eolivelli]

This is an automated email from the ASF dual-hosted git repository.

eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git


The following commit(s) were added to refs/heads/master by this push:
     new 9b4599b0f4 Apply WRITE_BUFFER_WATER_MARK setting to child channels in 
BookieNettyServer (#4337)
9b4599b0f4 is described below

commit 9b4599b0f4ab33c91548adb902ffc7d8dab3a76c
Author: ZhangJian He <shoot...@gmail.com>
AuthorDate: Sun May 5 02:42:47 2024 +0800

    Apply WRITE_BUFFER_WATER_MARK setting to child channels in 
BookieNettyServer (#4337)
    
    Signed-off-by: ZhangJian He <shoot...@gmail.com>
---
 .../src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java
 
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java
index eeffcac0d9..a5c4b16293 100644
--- 
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java
+++ 
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java
@@ -314,7 +314,7 @@ class BookieNettyServer {
             bootstrap.childOption(ChannelOption.RCVBUF_ALLOCATOR,
                     new 
AdaptiveRecvByteBufAllocator(conf.getRecvByteBufAllocatorSizeMin(),
                             conf.getRecvByteBufAllocatorSizeInitial(), 
conf.getRecvByteBufAllocatorSizeMax()));
-            bootstrap.option(ChannelOption.WRITE_BUFFER_WATER_MARK, new 
WriteBufferWaterMark(
+            bootstrap.childOption(ChannelOption.WRITE_BUFFER_WATER_MARK, new 
WriteBufferWaterMark(
                     conf.getServerWriteBufferLowWaterMark(), 
conf.getServerWriteBufferHighWaterMark()));
 
             if (eventLoopGroup instanceof IOUringEventLoopGroup){