abstract class AbstractKQueueChannel.AbstractKQueueUnsafe extends AbstractChannel.AbstractUnsafe
Modifier and Type | Field and Description |
---|---|
private KQueueRecvByteAllocatorHandle |
allocHandle |
(package private) boolean |
maybeMoreDataToRead |
(package private) boolean |
readPending |
private java.lang.Runnable |
readReadyRunnable |
Constructor and Description |
---|
AbstractKQueueUnsafe() |
Modifier and Type | Method and Description |
---|---|
protected void |
clearReadFilter0() |
(package private) void |
executeReadReadyRunnable(ChannelConfig config) |
private void |
fireEventAndClose(java.lang.Object evt) |
(package private) void |
readEOF() |
(package private) abstract void |
readReady(KQueueRecvByteAllocatorHandle allocHandle) |
(package private) void |
readReady(long numberBytesPending) |
(package private) void |
readReadyBefore() |
(package private) void |
readReadyFinally(ChannelConfig config) |
KQueueRecvByteAllocatorHandle |
recvBufAllocHandle()
Return the assigned
RecvByteBufAllocator.Handle which will be used to allocate ByteBuf 's when
receiving data. |
(package private) void |
shutdownInput(boolean readEOF)
Shutdown the input side of the channel.
|
(package private) void |
writeReady() |
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, 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 KQueueRecvByteAllocatorHandle allocHandle
private final java.lang.Runnable readReadyRunnable
final void readReady(long numberBytesPending)
abstract void readReady(KQueueRecvByteAllocatorHandle allocHandle)
final void readReadyBefore()
final void readReadyFinally(ChannelConfig config)
void writeReady()
void shutdownInput(boolean readEOF)
final void readEOF()
public KQueueRecvByteAllocatorHandle 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
final void executeReadReadyRunnable(ChannelConfig config)
protected final void clearReadFilter0()
private void fireEventAndClose(java.lang.Object evt)