(ratis) branch master updated: RATIS-2189. Use ByteBufAllocator#ioBuffer in NettyDataStreamUtils (#1178)

[szetszwo]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 06affdf69 RATIS-2189. Use ByteBufAllocator#ioBuffer in 
NettyDataStreamUtils (#1178)
06affdf69 is described below

commit 06affdf69973c6fea57df5e601c735f3c68fc634
Author: Ivan Andika <ivan_andi...@rocketmail.com>
AuthorDate: Sat Nov 16 06:33:29 2024 +0800

    RATIS-2189. Use ByteBufAllocator#ioBuffer in NettyDataStreamUtils (#1178)
---
 .../src/main/java/org/apache/ratis/netty/NettyDataStreamUtils.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/ratis-netty/src/main/java/org/apache/ratis/netty/NettyDataStreamUtils.java 
b/ratis-netty/src/main/java/org/apache/ratis/netty/NettyDataStreamUtils.java
index aa46cba53..583d6e3e9 100644
--- a/ratis-netty/src/main/java/org/apache/ratis/netty/NettyDataStreamUtils.java
+++ b/ratis-netty/src/main/java/org/apache/ratis/netty/NettyDataStreamUtils.java
@@ -103,11 +103,11 @@ public interface NettyDataStreamUtils {
       ByteBufAllocator allocator) {
     final ByteBuffer headerBuf = 
getDataStreamRequestHeaderProtoByteBuffer(request);
 
-    final ByteBuf headerBodyLenBuf = 
allocator.directBuffer(DataStreamPacketHeader.getSizeOfHeaderBodyLen());
+    final ByteBuf headerBodyLenBuf = 
allocator.ioBuffer(DataStreamPacketHeader.getSizeOfHeaderBodyLen());
     headerBodyLenBuf.writeLong(headerBuf.remaining() + 
request.getDataLength());
     out.accept(headerBodyLenBuf);
 
-    final ByteBuf headerLenBuf = 
allocator.directBuffer(DataStreamPacketHeader.getSizeOfHeaderLen());
+    final ByteBuf headerLenBuf = 
allocator.ioBuffer(DataStreamPacketHeader.getSizeOfHeaderLen());
     headerLenBuf.writeInt(headerBuf.remaining());
     out.accept(headerLenBuf);
 
@@ -152,7 +152,7 @@ public interface NettyDataStreamUtils {
   static void encodeDataStreamReplyByteBuffer(DataStreamReplyByteBuffer reply, 
Consumer<ByteBuf> out,
       ByteBufAllocator allocator) {
     ByteBuffer headerBuf = getDataStreamReplyHeaderProtoByteBuf(reply);
-    final ByteBuf headerLenBuf = 
allocator.directBuffer(DataStreamPacketHeader.getSizeOfHeaderLen());
+    final ByteBuf headerLenBuf = 
allocator.ioBuffer(DataStreamPacketHeader.getSizeOfHeaderLen());
     headerLenBuf.writeInt(headerBuf.remaining());
     out.accept(headerLenBuf);
     out.accept(Unpooled.wrappedBuffer(headerBuf));