diff --git a/src/org/redkale/net/AsyncConnection.java b/src/org/redkale/net/AsyncConnection.java index 331f83cc7..30a331725 100644 --- a/src/org/redkale/net/AsyncConnection.java +++ b/src/org/redkale/net/AsyncConnection.java @@ -118,7 +118,6 @@ public abstract class AsyncConnection implements ReadableByteChannel, WritableBy public abstract void read(CompletionHandler handler); - public abstract void read(long timeout, TimeUnit unit, CompletionHandler handler); @Override public abstract int write(ByteBuffer src) throws IOException; diff --git a/src/org/redkale/net/PrepareRunner.java b/src/org/redkale/net/PrepareRunner.java index 900f1d3ca..5e3325474 100644 --- a/src/org/redkale/net/PrepareRunner.java +++ b/src/org/redkale/net/PrepareRunner.java @@ -8,7 +8,6 @@ package org.redkale.net; import java.io.IOException; import java.nio.*; import java.nio.channels.*; -import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.logging.*; import org.redkale.util.*; @@ -44,7 +43,6 @@ public class PrepareRunner implements Runnable { @Override public void run() { - final boolean keepalive = response != null; if (data != null) { //BIO模式的UDP连接创建AsyncConnection时已经获取到ByteBuffer数据了 if (response == null) response = responsePool.get(); try { @@ -58,8 +56,7 @@ public class PrepareRunner implements Runnable { } if (response == null) response = responsePool.get(); try { - channel.read(keepalive ? context.getAliveTimeoutSeconds() : context.getReadTimeoutSeconds(), TimeUnit.SECONDS, - new CompletionHandler() { + channel.read(new CompletionHandler() { @Override public void completed(Integer count, ByteBuffer buffer) { if (count < 1) { diff --git a/src/org/redkale/net/TcpAioAsyncConnection.java b/src/org/redkale/net/TcpAioAsyncConnection.java index 6d69919cd..91d839899 100644 --- a/src/org/redkale/net/TcpAioAsyncConnection.java +++ b/src/org/redkale/net/TcpAioAsyncConnection.java @@ -103,13 +103,6 @@ public class TcpAioAsyncConnection extends AsyncConnection { } } - @Override - public void read(long timeout, TimeUnit unit, CompletionHandler handler) { - this.readtime = System.currentTimeMillis(); - ByteBuffer dst = pollReadBuffer(); - channel.read(dst, timeout < 0 ? 0 : timeout, unit, dst, handler); - } - private void nextWrite(Throwable exc, A attachment) { BlockingQueue queue = this.writeQueue; if (queue != null && exc != null && !isOpen()) { diff --git a/src/org/redkale/net/UdpBioAsyncConnection.java b/src/org/redkale/net/UdpBioAsyncConnection.java index 552e1afe7..391589758 100644 --- a/src/org/redkale/net/UdpBioAsyncConnection.java +++ b/src/org/redkale/net/UdpBioAsyncConnection.java @@ -10,7 +10,6 @@ import java.net.*; import java.nio.ByteBuffer; import java.nio.channels.*; import java.util.Set; -import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicLong; import java.util.function.*; import javax.net.ssl.SSLContext; @@ -142,11 +141,6 @@ public class UdpBioAsyncConnection extends AsyncConnection { } } - @Override - public void read(long timeout, TimeUnit unit, CompletionHandler handler) { - read(handler); - } - @Override public int read(ByteBuffer dst) throws IOException { int rs = channel.read(dst);