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

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, Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle)
(package private) EpollRecvByteAllocatorHandle	newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)	Create a new EpollRecvByteAllocatorHandle instance.
protected Executor	prepareToClose()	Prepares to close the Channel.

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

Methods inherited from class java.lang.Object

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

Constructor Details

EpollStreamUnsafe

EpollStreamUnsafe()

Method Details

prepareToClose

protected 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,
 Throwable cause,
 boolean close,
 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