From f34554f2cb056e7ef8ed86158a22ec3882a7b9b0 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Wed, 22 Mar 2023 23:51:55 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DAsyncNioConnection?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/AsyncNioConnection.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java
index d5fb2a638..ce3d8094e 100644
--- a/src/main/java/org/redkale/net/AsyncNioConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioConnection.java
@@ -151,10 +151,10 @@ abstract class AsyncNioConnection extends AsyncConnection {
     }
 
     @Override
-    public void write(byte[] headerContent, int headerOffset, int headerLength, 
-        byte[] bodyContent, int bodyOffset, int bodyLength, 
+    public void write(byte[] headerContent, int headerOffset, int headerLength,
+        byte[] bodyContent, int bodyOffset, int bodyLength,
         Consumer bodyCallback, Object bodyAttachment, CompletionHandler<Integer, Void> handler) {
-        
+
         if (sslEngine != null) {
             super.write(headerContent, headerOffset, headerLength, bodyContent, bodyOffset, bodyLength, bodyCallback, bodyAttachment, handler);
             return;
@@ -322,6 +322,8 @@ abstract class AsyncNioConnection extends AsyncConnection {
                             writeByteBuffers = buffers;
                             writeOffset = 0;
                             writeLength = buffers.length;
+                            batchOffset = writeOffset;
+                            batchLength = writeLength;
                             writeByteTuple1Array = null;
                             writeByteTuple1Offset = 0;
                             writeByteTuple1Length = 0;