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 -
Method Summary
Modifier and TypeMethodDescriptionprivate void
handleReadException
(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle) protected Executor
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
-
Constructor Details
-
KQueueStreamUnsafe
KQueueStreamUnsafe()
-
-
Method Details
-
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
- Specified by:
readReady
in classAbstractKQueueChannel.AbstractKQueueUnsafe
-
handleReadException
private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)
-