Package io.netty.channel.kqueue
Class AbstractKQueueStreamChannel.KQueueStreamUnsafe
- java.lang.Object
-
- io.netty.channel.AbstractChannel.AbstractUnsafe
-
- io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
-
- io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe
-
- All Implemented Interfaces:
Channel.Unsafe
- Direct Known Subclasses:
KQueueDomainSocketChannel.KQueueDomainUnsafe
,KQueueSocketChannel.KQueueSocketChannelUnsafe
- Enclosing class:
- AbstractKQueueStreamChannel
class AbstractKQueueStreamChannel.KQueueStreamUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe
-
-
Field Summary
-
Fields inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
maybeMoreDataToRead, readPending
-
-
Constructor Summary
Constructors Constructor Description KQueueStreamUnsafe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)
protected java.util.concurrent.Executor
prepareToClose()
Prepares to close theChannel
.(package private) void
readReady(KQueueRecvByteAllocatorHandle allocHandle)
-
Methods inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe
clearReadFilter0, connect, executeReadReadyRunnable, failConnectPromise, flush0, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput, writeReady
-
Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write
-
-
-
-
Method Detail
-
prepareToClose
protected java.util.concurrent.Executor prepareToClose()
Description copied from class:AbstractChannel.AbstractUnsafe
Prepares to close theChannel
. If this method returns anExecutor
, the caller must call theExecutor.execute(Runnable)
method with a task that callsAbstractChannel.doClose()
on the returnedExecutor
. If this method returnsnull
,AbstractChannel.doClose()
must be called from the caller thread. (i.e.EventLoop
)- Overrides:
prepareToClose
in classAbstractChannel.AbstractUnsafe
-
readReady
void readReady(KQueueRecvByteAllocatorHandle allocHandle)
- Specified by:
readReady
in classAbstractKQueueChannel.AbstractKQueueUnsafe
-
handleReadException
private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)
-
-