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 and Description
EpollStreamUnsafe()

Method Summary

Modifier and Type	Method and Description
void	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
(package private) boolean	doFinishConnect() Finish the connect
(package private) 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
private void	finishConnect()
private void	fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
private void	handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, 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 io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe

clearEpollIn0, epollInBefore, epollInFinally, epollRdHupReady, executeEpollInReadyRunnable, flush0, recvBufAllocHandle, shutdownInput

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

EpollStreamUnsafe

EpollStreamUnsafe()

Method Detail

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 close,
                                 EpollRecvByteAllocatorHandle allocHandle)

connect

public void connect(java.net.SocketAddress remoteAddress,
                    java.net.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,
                                   java.lang.Throwable cause)

finishConnect

private void finishConnect()

epollOutReady

void epollOutReady()

Description copied from class: AbstractEpollChannel.AbstractEpollUnsafe

Called once a EPOLLOUT event is ready to be processed

Overrides:

epollOutReady in class AbstractEpollChannel.AbstractEpollUnsafe

doFinishConnect

boolean doFinishConnect()
                 throws java.lang.Exception

Finish the connect

Throws:

java.lang.Exception

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