public abstract class AbstractOioChannel extends AbstractChannel
Channel implementations that use Old-Blocking-IO| Modifier and Type | Class and Description |
|---|---|
private class |
AbstractOioChannel.DefaultOioUnsafe |
AbstractChannel.AbstractUnsafeChannel.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, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitattr, hasAttrprotected static final int SO_TIMEOUT
boolean readPending
private final java.lang.Runnable readTask
private final java.lang.Runnable clearReadPendingRunnable
protected AbstractOioChannel(Channel parent)
AbstractChannel.AbstractChannel(Channel)protected AbstractChannel.AbstractUnsafe newUnsafe()
AbstractChannelAbstractChannel.AbstractUnsafe instance which will be used for the life-time of the ChannelnewUnsafe in class AbstractChannelprotected boolean isCompatible(EventLoop loop)
AbstractChanneltrue if the given EventLoop is compatible with this instance.isCompatible in class 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 in class AbstractChanneljava.lang.Exceptionprotected 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.