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

修复AsyncNioConnection

Browse Source
This commit is contained in:
redkale
2023-03-22 23:51:55 +08:00
parent e2f331ab6b
commit f34554f2cb
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/redkale/net/AsyncNioConnection.java
View File

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