lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复WriteMoreCompletionHandler的bug

Browse Source
This commit is contained in:
Redkale
2019-11-30 11:14:44 +08:00
parent 131855cdc5
commit bed81bd93d
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/org/redkale/net/TcpAioAsyncConnection.java
View File

@@ -300,16 +300,16 @@ public class TcpAioAsyncConnection extends AsyncConnection {
if (result >= 0) { if (result >= 0) {
writeCount += result; writeCount += result;
try { try {
int index = -1; int incre = -1;
for (int i = writeOffset; i < (writeOffset + writeLength); i++) { for (int i = writeOffset; i < (writeOffset + writeLength); i++) {
if (writeBuffers[i].hasRemaining()) { if (writeBuffers[i].hasRemaining()) {
index = i; incre = i - writeOffset;
break; break;
} }
} }
if (index >= 0) { if (incre >= 0) {
writeOffset += index; writeOffset += incre;
writeLength -= index; writeLength -= incre;
channel.write(writeBuffers, writeOffset, writeLength, writeTimeoutSeconds > 0 ? writeTimeoutSeconds : 60, TimeUnit.SECONDS, attachment, this); channel.write(writeBuffers, writeOffset, writeLength, writeTimeoutSeconds > 0 ? writeTimeoutSeconds : 60, TimeUnit.SECONDS, attachment, this);
return; return;
} }