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, EpollDomainDatagramChannel.EpollDomainDatagramChannelUnsafe

Enclosing class:

AbstractEpollChannel

protected abstract class AbstractEpollChannel.AbstractEpollUnsafe
extends AbstractChannel.AbstractUnsafe

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractEpollUnsafe()

Method Summary

Modifier and Type	Method	Description
protected final void	clearEpollIn0()
private void	clearEpollRdHup()	Clear the Native.EPOLLRDHUP flag from EPOLL, and close on failure.
void	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
private boolean	doFinishConnect()	Finish the connect
(package private) final void	epollInBefore()
(package private) final void	epollInFinally(ChannelConfig config)
(package private) abstract void	epollInReady()	Called once EPOLLIN event is ready to be processed
(package private) final void	epollOutReady()	Called once a EPOLLOUT event is ready to be processed
(package private) final void	epollRdHupReady()	Called once EPOLLRDHUP event is ready to be processed
(package private) final void	executeEpollInReadyRunnable(ChannelConfig config)
private void	finishConnect()
private void	fireEventAndClose(Object evt)
protected final void	flush0()
private void	fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(ChannelPromise promise, Throwable cause)
(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 AbstractChannel.AbstractUnsafe

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

Methods inherited from class Object

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

Field Details

readPending

boolean readPending

maybeMoreDataToRead

boolean maybeMoreDataToRead

allocHandle

private EpollRecvByteAllocatorHandle allocHandle

epollInReadyRunnable

private final Runnable epollInReadyRunnable

Constructor Details

AbstractEpollUnsafe

protected AbstractEpollUnsafe()

Method Details

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(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 final void flush0()

Overrides:

flush0 in class AbstractChannel.AbstractUnsafe

epollOutReady

final void epollOutReady()

Called once a EPOLLOUT event is ready to be processed

clearEpollIn0

protected final void clearEpollIn0()

connect

public void connect(SocketAddress remoteAddress,
 SocketAddress localAddress,
 ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
 boolean wasActive)

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
 Throwable cause)

finishConnect

private void finishConnect()

doFinishConnect

private boolean doFinishConnect()
                         throws Exception

Finish the connect

Throws:

Exception