(ignite-3) branch main updated: IGNITE-22371 Increase Netty IO buffer size (#3841)

[rpuch]

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

rpuch pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 533d6c2917 IGNITE-22371 Increase Netty IO buffer size (#3841)
533d6c2917 is described below

commit 533d6c29177547e93a11cc1c52d35b0da76c7919
Author: Roman Puchkovskiy <roman.puchkovs...@gmail.com>
AuthorDate: Thu May 30 09:37:05 2024 +0400

    IGNITE-22371 Increase Netty IO buffer size (#3841)
---
 .../org/apache/ignite/internal/network/netty/OutboundEncoder.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/modules/network/src/main/java/org/apache/ignite/internal/network/netty/OutboundEncoder.java
 
b/modules/network/src/main/java/org/apache/ignite/internal/network/netty/OutboundEncoder.java
index f4602dbeff..bf63ed9182 100644
--- 
a/modules/network/src/main/java/org/apache/ignite/internal/network/netty/OutboundEncoder.java
+++ 
b/modules/network/src/main/java/org/apache/ignite/internal/network/netty/OutboundEncoder.java
@@ -41,6 +41,8 @@ public class OutboundEncoder extends 
MessageToMessageEncoder<OutNetworkObject> {
     /** Handler name. */
     public static final String NAME = "outbound-encoder";
 
+    private static final int IO_BUFFER_CAPACITY = 16 * 1024;
+
     private static final NetworkMessagesFactory MSG_FACTORY = new 
NetworkMessagesFactory();
 
     /** Serialization registry. */
@@ -136,8 +138,8 @@ public class OutboundEncoder extends 
MessageToMessageEncoder<OutNetworkObject> {
 
         /** {@inheritDoc} */
         @Override
-        public ByteBuf readChunk(ByteBufAllocator allocator) throws Exception {
-            ByteBuf buffer = allocator.ioBuffer();
+        public ByteBuf readChunk(ByteBufAllocator allocator) {
+            ByteBuf buffer = allocator.ioBuffer(IO_BUFFER_CAPACITY);
             int capacity = buffer.capacity();
 
             ByteBuffer byteBuffer = buffer.internalNioBuffer(0, capacity);