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, EpollIoHandle, IoHandle, java.lang.AutoCloseable

Direct Known Subclasses:

EpollDomainSocketChannel.EpollDomainUnsafe, EpollSocketChannel.EpollSocketChannelUnsafe

Enclosing class:

AbstractEpollStreamChannel

class AbstractEpollStreamChannel.EpollStreamUnsafe
extends AbstractEpollChannel.AbstractEpollUnsafe

Field Summary

Fields inherited from class AbstractEpollChannel.AbstractEpollUnsafe

readPending

Constructor Summary

Constructors

Constructor	Description
EpollStreamUnsafe()

Method Summary

Modifier and Type	Method	Description
(package private) void	epollInReady()	Called once EPOLLIN event is ready to be processed
private void	handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean allDataRead, EpollRecvByteAllocatorHandle allocHandle)
(package private) EpollRecvByteAllocatorHandle	newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)	Create a new EpollRecvByteAllocatorHandle instance.
protected java.util.concurrent.Executor	prepareToClose()	Prepares to close the Channel.

Methods inherited from class AbstractEpollChannel.AbstractEpollUnsafe

channel, clearEpollIn0, close, connect, epollOutReady, epollRdHupReady, fd, flush0, handle, recvBufAllocHandle, shouldStopReading, shutdownInput

Methods inherited from class AbstractChannel.AbstractUnsafe

annotateConnectException, beginRead, bind, close, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, handleWriteError, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface IoHandle

registered, unregistered

Constructor Details

EpollStreamUnsafe

EpollStreamUnsafe()

Method Details

prepareToClose

protected java.util.concurrent.Executor prepareToClose()

Description copied from class: AbstractChannel.AbstractUnsafe

Prepares to close the Channel. If this method returns an Executor, the caller must call the Executor.execute(Runnable) method with a task that calls AbstractChannel.doClose() on the returned Executor. If this method returns null, AbstractChannel.doClose() must be called from the caller thread. (i.e. EventLoop)

Overrides:

prepareToClose in class AbstractChannel.AbstractUnsafe

handleReadException

private void handleReadException(ChannelPipeline pipeline,
 ByteBuf byteBuf,
 java.lang.Throwable cause,
 boolean allDataRead,
 EpollRecvByteAllocatorHandle allocHandle)

newEpollHandle

EpollRecvByteAllocatorHandle newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)

Description copied from class: AbstractEpollChannel.AbstractEpollUnsafe

Create a new EpollRecvByteAllocatorHandle instance.

Overrides:

newEpollHandle in class AbstractEpollChannel.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 class AbstractEpollChannel.AbstractEpollUnsafe