public abstract class AbstractOioChannel extends AbstractChannel
Channel
implementations that use Old-Blocking-IOModifier and Type | Class and Description |
---|---|
private class |
AbstractOioChannel.DefaultOioUnsafe |
AbstractChannel.AbstractUnsafe
Channel.Unsafe
Modifier and Type | Field and Description |
---|---|
private java.lang.Runnable |
clearReadPendingRunnable |
(package private) boolean |
readPending |
private java.lang.Runnable |
readTask |
protected static int |
SO_TIMEOUT |
Modifier | Constructor and Description |
---|---|
protected |
AbstractOioChannel(Channel parent) |
Modifier and Type | Method and Description |
---|---|
protected void |
clearReadPending()
Set read pending to
false . |
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()
Deprecated.
No longer supported.
No longer supported.
|
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)
Deprecated.
Use
clearReadPending() if appropriate instead.
No longer supported. |
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doClose, doDeregister, doDisconnect, doRegister, doWrite, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
attr, hasAttr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
attr, hasAttr
protected static final int SO_TIMEOUT
boolean readPending
private final java.lang.Runnable readTask
private final java.lang.Runnable clearReadPendingRunnable
protected AbstractOioChannel(Channel parent)
AbstractChannel(Channel)
protected AbstractChannel.AbstractUnsafe newUnsafe()
AbstractChannel
AbstractChannel.AbstractUnsafe
instance which will be used for the life-time of the Channel
newUnsafe
in class AbstractChannel
protected boolean isCompatible(EventLoop loop)
AbstractChannel
true
if the given EventLoop
is compatible with this instance.isCompatible
in class AbstractChannel
protected abstract void doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) throws java.lang.Exception
null
otherwise.java.lang.Exception
protected void doBeginRead() throws java.lang.Exception
AbstractChannel
doBeginRead
in class AbstractChannel
java.lang.Exception
protected abstract void doRead()
@Deprecated protected boolean isReadPending()
@Deprecated protected void setReadPending(boolean readPending)
clearReadPending()
if appropriate instead.
No longer supported.protected final void clearReadPending()
false
.