public abstract class AbstractOioChannel extends AbstractChannel
Channel implementations that use Old-Blocking-IOAbstractChannel.AbstractUnsafeChannel.Unsafe| 限定符和类型 | 字段和说明 |
|---|---|
protected static int |
SO_TIMEOUT |
| 限定符 | 构造器和说明 |
|---|---|
protected |
AbstractOioChannel(Channel parent) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected void |
doBeginRead()
Schedule a read operation.
|
protected abstract void |
doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
Connect to the remote peer using the given localAddress if one is specified or
null otherwise. |
protected abstract void |
doRead() |
protected boolean |
isCompatible(EventLoop loop)
Return
true if the given EventLoop is compatible with this instance. |
protected boolean |
isReadPending() |
protected AbstractChannel.AbstractUnsafe |
newUnsafe()
Create a new
AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel |
protected void |
setReadPending(boolean readPending) |
alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doClose, doDeregister, doDisconnect, doRegister, doShutdownOutput, doWrite, equals, eventLoop, filterOutboundMessage, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattrattrprotected static final int SO_TIMEOUT
protected AbstractOioChannel(Channel parent)
protected AbstractChannel.AbstractUnsafe newUnsafe()
AbstractChannelAbstractChannel.AbstractUnsafe instance which will be used for the life-time of the ChannelnewUnsafe 在类中 AbstractChannelprotected boolean isCompatible(EventLoop loop)
AbstractChanneltrue if the given EventLoop is compatible with this instance.isCompatible 在类中 AbstractChannelprotected abstract void doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
throws java.lang.Exception
null otherwise.java.lang.Exceptionprotected void doBeginRead()
throws java.lang.Exception
AbstractChanneldoBeginRead 在类中 AbstractChanneljava.lang.Exceptionprotected abstract void doRead()
protected boolean isReadPending()
protected void setReadPending(boolean readPending)