From bed81bd93d9f6425db3fc905130732ec788cb5fb Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Sat, 30 Nov 2019 11:14:44 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DWriteMoreCompletionHandler?= =?UTF-8?q?=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/org/redkale/net/TcpAioAsyncConnection.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/org/redkale/net/TcpAioAsyncConnection.java b/src/org/redkale/net/TcpAioAsyncConnection.java index 91d839899..62e2585b1 100644 --- a/src/org/redkale/net/TcpAioAsyncConnection.java +++ b/src/org/redkale/net/TcpAioAsyncConnection.java @@ -300,16 +300,16 @@ public class TcpAioAsyncConnection extends AsyncConnection { if (result >= 0) { writeCount += result; try { - int index = -1; + int incre = -1; for (int i = writeOffset; i < (writeOffset + writeLength); i++) { if (writeBuffers[i].hasRemaining()) { - index = i; + incre = i - writeOffset; break; } } - if (index >= 0) { - writeOffset += index; - writeLength -= index; + if (incre >= 0) { + writeOffset += incre; + writeLength -= incre; channel.write(writeBuffers, writeOffset, writeLength, writeTimeoutSeconds > 0 ? writeTimeoutSeconds : 60, TimeUnit.SECONDS, attachment, this); return; }