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

AsyncConnection

Browse Source
This commit is contained in:
redkale
2024-10-31 08:47:56 +08:00
parent e6d4b26c9d
commit 0895c82525
1 changed files with 0 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/org/redkale/net/AsyncConnection.java
View File

@@ -289,28 +289,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
} }
} }
public final void readRegisterInIOThread(CompletionHandler<Integer, ByteBuffer> handler) {
if (inCurrReadThread()) {
readRegister(handler);
} else {
executeRead(() -> readRegister(handler));
}
}
public final void readRegisterInIOThreadSafe(CompletionHandler<Integer, ByteBuffer> handler) {
if (inCurrReadThread()) {
if (!readPending) {
readRegister(handler);
}
} else {
executeRead(() -> {
if (!readPending) {
readRegister(handler);
}
});
}
}
public final void read(CompletionHandler<Integer, ByteBuffer> handler) { public final void read(CompletionHandler<Integer, ByteBuffer> handler) {
if (sslEngine == null) { if (sslEngine == null) {
readImpl(handler); readImpl(handler);
@@ -327,20 +305,6 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
} }
} }
public final void readInIOThreadSafe(CompletionHandler<Integer, ByteBuffer> handler) {
if (inCurrReadThread()) {
if (!readPending) {
read(handler);
}
} else {
executeRead(() -> {
if (!readPending) {
read(handler);
}
});
}
}
// src写完才会回调 // src写完才会回调
public final <A> void write(ByteBuffer src, A attachment, CompletionHandler<Integer, ? super A> handler) { public final <A> void write(ByteBuffer src, A attachment, CompletionHandler<Integer, ? super A> handler) {
if (sslEngine == null) { if (sslEngine == null) {