protected abstract class AbstractEpollChannel.AbstractEpollUnsafe extends AbstractChannel.AbstractUnsafe
Modifier and Type | Field and Description |
---|---|
private boolean |
rdHup |
protected boolean |
readPending |
Modifier | Constructor and Description |
---|---|
protected |
AbstractEpollUnsafe() |
Modifier and Type | Method and Description |
---|---|
protected void |
clearEpollIn0() |
private void |
clearEpollRdHup()
Clear the
Native.EPOLLRDHUP flag from EPOLL, and close on failure. |
(package private) abstract void |
epollInReady()
Called once EPOLLIN event is ready to be processed
|
(package private) void |
epollOutReady()
Called once a EPOLLOUT event is ready to be processed
|
(package private) void |
epollRdHupReady()
Called once EPOLLRDHUP event is ready to be processed
|
private void |
fireEventAndClose(java.lang.Object evt) |
protected void |
flush0() |
boolean |
isRdHup() |
(package private) void |
shutdownInput()
Shutdown the input side of the channel.
|
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect
abstract void epollInReady()
public final boolean isRdHup()
final void epollRdHupReady()
private void clearEpollRdHup()
Native.EPOLLRDHUP
flag from EPOLL, and close on failure.void shutdownInput()
private void fireEventAndClose(java.lang.Object evt)
protected void flush0()
flush0
in class AbstractChannel.AbstractUnsafe
void epollOutReady()
protected final void clearEpollIn0()