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
class AbstractEpollStreamChannel.EpollStreamUnsafe extends AbstractEpollChannel.AbstractEpollUnsafe
-
-
Field Summary
-
Fields inherited from class io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe
maybeMoreDataToRead, readPending
-
-
Constructor Summary
Constructors Constructor Description EpollStreamUnsafe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
epollInReady()
Called once EPOLLIN event is ready to be processedprivate void
handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle)
(package private) EpollRecvByteAllocatorHandle
newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)
Create a newEpollRecvByteAllocatorHandle
instance.protected java.util.concurrent.Executor
prepareToClose()
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
-
-
-
-
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
-
handleReadException
private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle)
-
newEpollHandle
EpollRecvByteAllocatorHandle newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)
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
-
-