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

Modifier and Type	Field and Description
private RecvByteBufAllocator.Handle	allocHandle

Fields inherited from class io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe

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 boolean	handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close)
protected java.util.concurrent.Executor	prepareToClose() Prepares to close the Channel.

Methods inherited from class io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe

clearEpollIn0, epollRdHupReady, flush0, isRdHup, 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

Field Detail

allocHandle

private RecvByteBufAllocator.Handle allocHandle

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 boolean handleReadException(ChannelPipeline pipeline,
                                    ByteBuf byteBuf,
                                    java.lang.Throwable cause,
                                    boolean close)

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

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