protected abstract class AbstractEpollChannel.AbstractEpollUnsafe extends AbstractChannel.AbstractUnsafe
Modifier and Type | Field and Description |
---|---|
private EpollRecvByteAllocatorHandle |
allocHandle |
private java.lang.Runnable |
epollInReadyRunnable |
(package private) boolean |
maybeMoreDataToRead |
(package private) 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) void |
epollInBefore() |
(package private) void |
epollInFinally(ChannelConfig config) |
(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
|
(package private) void |
executeEpollInReadyRunnable(ChannelConfig config) |
private void |
fireEventAndClose(java.lang.Object evt) |
protected void |
flush0() |
(package private) EpollRecvByteAllocatorHandle |
newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)
Create a new
EpollRecvByteAllocatorHandle instance. |
EpollRecvByteAllocatorHandle |
recvBufAllocHandle()
Return the assigned
RecvByteBufAllocator.Handle which will be used to allocate ByteBuf 's when
receiving data. |
(package private) void |
shutdownInput(boolean rdHup)
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
boolean readPending
boolean maybeMoreDataToRead
private EpollRecvByteAllocatorHandle allocHandle
private final java.lang.Runnable epollInReadyRunnable
abstract void epollInReady()
final void epollInBefore()
final void epollInFinally(ChannelConfig config)
final void executeEpollInReadyRunnable(ChannelConfig config)
final void epollRdHupReady()
private void clearEpollRdHup()
Native.EPOLLRDHUP
flag from EPOLL, and close on failure.void shutdownInput(boolean rdHup)
private void fireEventAndClose(java.lang.Object evt)
public EpollRecvByteAllocatorHandle recvBufAllocHandle()
Channel.Unsafe
RecvByteBufAllocator.Handle
which will be used to allocate ByteBuf
's when
receiving data.recvBufAllocHandle
in interface Channel.Unsafe
recvBufAllocHandle
in class AbstractChannel.AbstractUnsafe
EpollRecvByteAllocatorHandle newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)
EpollRecvByteAllocatorHandle
instance.handle
- The handle to wrap with EPOLL specific logic.protected void flush0()
flush0
in class AbstractChannel.AbstractUnsafe
void epollOutReady()
protected final void clearEpollIn0()