io.netty.channel.epoll

Class AbstractEpollChannel.AbstractEpollUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe

All Implemented Interfaces:

Channel.Unsafe

Direct Known Subclasses:

AbstractEpollServerChannel.EpollServerSocketUnsafe, AbstractEpollStreamChannel.EpollStreamUnsafe, EpollDatagramChannel.EpollDatagramChannelUnsafe

Enclosing class:

AbstractEpollChannel

protected abstract class AbstractEpollChannel.AbstractEpollUnsafe
extends AbstractChannel.AbstractUnsafe

Field Summary

Fields

Modifier and Type	Field and Description
private EpollRecvByteAllocatorHandle	allocHandle
private java.lang.Runnable	epollInReadyRunnable
(package private) boolean	maybeMoreDataToRead
(package private) boolean	readPending

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEpollUnsafe()

Method Summary

Modifier and Type	Method and Description
protected void	clearEpollIn0()
private void	clearEpollRdHup() Clear the Native.EPOLLRDHUP flag from EPOLL, and close on failure.
(package private) void	epollInBefore()
(package private) void	epollInFinally(ChannelConfig config)
(package private) abstract void	epollInReady() Called once EPOLLIN event is ready to be processed
(package private) void	epollOutReady() Called once a EPOLLOUT event is ready to be processed
(package private) void	epollRdHupReady() Called once EPOLLRDHUP event is ready to be processed
(package private) void	executeEpollInReadyRunnable(ChannelConfig config)
private void	fireEventAndClose(java.lang.Object evt)
protected void	flush0()
(package private) EpollRecvByteAllocatorHandle	newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle) Create a new EpollRecvByteAllocatorHandle instance.
EpollRecvByteAllocatorHandle	recvBufAllocHandle() Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
(package private) void	shutdownInput(boolean rdHup) Shutdown the input side of the channel.

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.Channel.Unsafe

connect

Field Detail

readPending

boolean readPending

maybeMoreDataToRead

boolean maybeMoreDataToRead

allocHandle

private EpollRecvByteAllocatorHandle allocHandle

epollInReadyRunnable

private final java.lang.Runnable epollInReadyRunnable

Constructor Detail

AbstractEpollUnsafe

protected AbstractEpollUnsafe()

Method Detail

epollInReady

abstract void epollInReady()

Called once EPOLLIN event is ready to be processed

epollInBefore

final void epollInBefore()

epollInFinally

final void epollInFinally(ChannelConfig config)

executeEpollInReadyRunnable

final void executeEpollInReadyRunnable(ChannelConfig config)

epollRdHupReady

final void epollRdHupReady()

Called once EPOLLRDHUP event is ready to be processed

clearEpollRdHup

private void clearEpollRdHup()

Clear the Native.EPOLLRDHUP flag from EPOLL, and close on failure.

shutdownInput

void shutdownInput(boolean rdHup)

Shutdown the input side of the channel.

fireEventAndClose

private void fireEventAndClose(java.lang.Object evt)

recvBufAllocHandle

public EpollRecvByteAllocatorHandle recvBufAllocHandle()

Description copied from interface: Channel.Unsafe

Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.

Specified by:

recvBufAllocHandle in interface Channel.Unsafe

Overrides:

recvBufAllocHandle in class AbstractChannel.AbstractUnsafe

newEpollHandle

EpollRecvByteAllocatorHandle newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)

Create a new EpollRecvByteAllocatorHandle instance.

Parameters:

handle - The handle to wrap with EPOLL specific logic.

flush0

protected void flush0()

Overrides:

flush0 in class AbstractChannel.AbstractUnsafe

epollOutReady

void epollOutReady()

Called once a EPOLLOUT event is ready to be processed

clearEpollIn0

protected final void clearEpollIn0()