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

writePending

Browse Source
This commit is contained in:
redkale
2024-11-10 00:05:47 +08:00
parent 84ac030c42
commit fa982b33cc
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -220,13 +220,13 @@ abstract class AsyncNioConnection extends AsyncConnection {
CompletionHandler<Integer, ? super A> handler) { CompletionHandler<Integer, ? super A> handler) {
Objects.requireNonNull(src); Objects.requireNonNull(src);
Objects.requireNonNull(handler); Objects.requireNonNull(handler);
if (this.writePending) {
handler.failed(new WritePendingException(), attachment);
return;
}
int total = 0; int total = 0;
Exception t = null; Exception t = null;
try { try {
if (this.writePending) {
handler.failed(new WritePendingException(), attachment);
return;
}
this.writePending = true; this.writePending = true;
while (src.hasRemaining()) { // 必须要将buffer写完为止 while (src.hasRemaining()) { // 必须要将buffer写完为止
int c = implWrite(src); int c = implWrite(src);
@@ -239,8 +239,9 @@ abstract class AsyncNioConnection extends AsyncConnection {
} }
} catch (Exception e) { } catch (Exception e) {
t = e; t = e;
} finally {
this.writePending = false;
} }
this.writePending = false;
if (consumer != null) { if (consumer != null) {
consumer.accept(src); consumer.accept(src);
} }
@@ -261,16 +262,16 @@ abstract class AsyncNioConnection extends AsyncConnection {
CompletionHandler<Integer, ? super A> handler) { CompletionHandler<Integer, ? super A> handler) {
Objects.requireNonNull(srcs); Objects.requireNonNull(srcs);
Objects.requireNonNull(handler); Objects.requireNonNull(handler);
if (this.writePending) {
handler.failed(new WritePendingException(), attachment);
return;
}
int total = 0; int total = 0;
Exception t = null; Exception t = null;
int batchOffset = offset; int batchOffset = offset;
int batchLength = length; int batchLength = length;
ByteBuffer[] batchBuffers = srcs; ByteBuffer[] batchBuffers = srcs;
try { try {
if (this.writePending) {
handler.failed(new WritePendingException(), attachment);
return;
}
this.writePending = true; this.writePending = true;
boolean hasRemain = true; boolean hasRemain = true;
while (hasRemain) { // 必须要将buffer写完为止 while (hasRemain) { // 必须要将buffer写完为止
@@ -294,8 +295,9 @@ abstract class AsyncNioConnection extends AsyncConnection {
} }
} catch (Exception e) { } catch (Exception e) {
t = e; t = e;
} finally {
this.writePending = false;
} }
this.writePending = false;
if (consumer != null) { if (consumer != null) {
for (int i = 0; i < length; i++) { for (int i = 0; i < length; i++) {
consumer.accept(srcs[offset + i]); consumer.accept(srcs[offset + i]);