Package io.netty.channel.epoll
Class AbstractEpollStreamChannel.EpollStreamUnsafe
java.lang.Object
io.netty.channel.AbstractChannel.AbstractUnsafe
io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe
io.netty.channel.epoll.AbstractEpollStreamChannel.EpollStreamUnsafe
- All Implemented Interfaces:
Channel.Unsafe
- Direct Known Subclasses:
EpollDomainSocketChannel.EpollDomainUnsafe
,EpollSocketChannel.EpollSocketChannelUnsafe
- Enclosing class:
AbstractEpollStreamChannel
-
Field Summary
Fields inherited from class io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe
maybeMoreDataToRead, readPending
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) void
Called once EPOLLIN event is ready to be processedprivate void
handleReadException
(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle) (package private) EpollRecvByteAllocatorHandle
Create a newEpollRecvByteAllocatorHandle
instance.protected Executor
Prepares to close theChannel
.Methods inherited from class io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe
clearEpollIn0, connect, epollInBefore, epollInFinally, epollOutReady, epollRdHupReady, executeEpollInReadyRunnable, flush0, recvBufAllocHandle, shutdownInput
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
-
EpollStreamUnsafe
EpollStreamUnsafe()
-
-
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
-
handleReadException
private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle) -
newEpollHandle
Description copied from class:AbstractEpollChannel.AbstractEpollUnsafe
Create a newEpollRecvByteAllocatorHandle
instance.- Overrides:
newEpollHandle
in classAbstractEpollChannel.AbstractEpollUnsafe
- Parameters:
handle
- The handle to wrap with EPOLL specific logic.
-
epollInReady
void epollInReady()Description copied from class:AbstractEpollChannel.AbstractEpollUnsafe
Called once EPOLLIN event is ready to be processed- Specified by:
epollInReady
in classAbstractEpollChannel.AbstractEpollUnsafe
-