Top Inners Fields Constructors Methods
io.netty.channel.epoll

public abstract Class AbstractEpollServerChannel

extends AbstractEpollChannel
implements ServerChannel
Class Inheritance
All Implemented Interfaces
io.netty.channel.ServerChannel, io.netty.channel.Channel, java.lang.Comparable, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap
Known Direct Subclasses
io.netty.channel.epoll.EpollServerDomainSocketChannel, io.netty.channel.epoll.EpollServerSocketChannel
Imports
io.netty.channel.Channel, .ChannelConfig, .ChannelMetadata, .ChannelOutboundBuffer, .ChannelPipeline, .ChannelPromise, .EventLoop, .ServerChannel, java.net.InetSocketAddress, .SocketAddress

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
AbstractEpollServerChannel.EpollServerSocketUnsafe

Field Summary

Modifier and TypeField and Description
private static final ChannelMetadata
METADATA

Hides io.netty.channel.epoll.AbstractEpollChannel.METADATA.

Inherited from io.netty.channel.epoll.AbstractEpollChannel:
activeepollInReadyRunnablePendingflagsinputClosedSeenErrorOnReadsocket

Constructor Summary

AccessConstructor and Description
protected
AbstractEpollServerChannel(int fd)

protected
AbstractEpollServerChannel(LinuxSocket fd)

protected
AbstractEpollServerChannel(LinuxSocket fd, boolean active)

Method Summary

Modifier and TypeMethod and Description
protected boolean
doConnect(SocketAddress remoteAddress, SocketAddress localAddress)

Overrides io.netty.channel.epoll.AbstractEpollChannel.doConnect.

Connect to the remote peer
protected void
doWrite(ChannelOutboundBuffer in)

Implements abstract io.netty.channel.AbstractChannel.doWrite.

Flush the content of the given buffer to the remote peer.
protected Object
filterOutboundMessage(Object msg)

Overrides io.netty.channel.AbstractChannel.filterOutboundMessage.

Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another.
protected boolean
isCompatible(EventLoop loop)

Overrides io.netty.channel.epoll.AbstractEpollChannel.isCompatible.

Return true if the given EventLoop is compatible with this instance.
public ChannelMetadata
metadata()

Overrides io.netty.channel.epoll.AbstractEpollChannel.metadata.

Implements io.netty.channel.Channel.metadata.

Return the ChannelMetadata of the Channel which describe the nature of the Channel.
protected abstract Channel
newChildChannel(int fd, byte[] remote, int offset, int len)

protected AbstractEpollChannel.AbstractEpollUnsafe
newUnsafe()

Implements abstract io.netty.channel.epoll.AbstractEpollChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel
protected InetSocketAddress
remoteAddress0()

Overrides io.netty.channel.epoll.AbstractEpollChannel.remoteAddress0.

Return the SocketAddress which the Channel is connected to.
Inherited from io.netty.channel.epoll.AbstractEpollChannel:
checkResolvableclearEpollInclearFlagconfigdoBeginReaddoBinddoClosedoConnect0doDeregisterdoDisconnectdoReadBytesdoRegisterdoWriteBytesdoWriteOrSendBytesfdisActiveisFlagSetisOpenisSoErrorZerolocalAddress0newDirectBuffernewDirectBufferresetCachedAddressessetFlagshouldBreakEpollInReady

Field Detail

METADATAback to summary
private static final ChannelMetadata METADATA

Hides io.netty.channel.epoll.AbstractEpollChannel.METADATA.

Constructor Detail

AbstractEpollServerChannelback to summary
protected AbstractEpollServerChannel(int fd)
AbstractEpollServerChannelback to summary
protected AbstractEpollServerChannel(LinuxSocket fd)
AbstractEpollServerChannelback to summary
protected AbstractEpollServerChannel(LinuxSocket fd, boolean active)

Method Detail

doConnectback to summary
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception

Overrides io.netty.channel.epoll.AbstractEpollChannel.doConnect.

Doc from io.netty.channel.epoll.AbstractEpollChannel.doConnect.

Connect to the remote peer

Annotations
@Override
doWriteback to summary
protected void doWrite(ChannelOutboundBuffer in) throws Exception

Implements abstract io.netty.channel.AbstractChannel.doWrite.

Doc from io.netty.channel.AbstractChannel.doWrite.

Flush the content of the given buffer to the remote peer.

Annotations
@Override
filterOutboundMessageback to summary
protected Object filterOutboundMessage(Object msg) throws Exception

Overrides io.netty.channel.AbstractChannel.filterOutboundMessage.

Doc from io.netty.channel.AbstractChannel.filterOutboundMessage.

Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another. (e.g. heap buffer -> direct buffer)

Annotations
@Override
isCompatibleback to summary
protected boolean isCompatible(EventLoop loop)

Overrides io.netty.channel.epoll.AbstractEpollChannel.isCompatible.

Doc from io.netty.channel.AbstractChannel.isCompatible.

Return true if the given EventLoop is compatible with this instance.

Annotations
@Override
metadataback to summary
public ChannelMetadata metadata()

Overrides io.netty.channel.epoll.AbstractEpollChannel.metadata.

Implements io.netty.channel.Channel.metadata.

Doc from io.netty.channel.Channel.metadata.

Return the ChannelMetadata of the Channel which describe the nature of the Channel.

Annotations
@Override
newChildChannelback to summary
protected abstract Channel newChildChannel(int fd, byte[] remote, int offset, int len) throws Exception
newUnsafeback to summary
protected AbstractEpollChannel.AbstractEpollUnsafe newUnsafe()

Implements abstract io.netty.channel.epoll.AbstractEpollChannel.newUnsafe.

Doc from io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel

Annotations
@Override
remoteAddress0back to summary
protected InetSocketAddress remoteAddress0()

Overrides io.netty.channel.epoll.AbstractEpollChannel.remoteAddress0.

Doc from io.netty.channel.AbstractChannel.remoteAddress0.

Return the SocketAddress which the Channel is connected to.

Annotations
@Override
io.netty.channel.epoll back to summary

pack-priv final Class AbstractEpollServerChannel.EpollServerSocketUnsafe

extends AbstractEpollUnsafe
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final byte[]
acceptedAddress

Inherited from io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe:
maybeMoreDataToReadreadPending

Constructor Summary

AccessConstructor and Description
pack-priv
EpollServerSocketUnsafe()

Method Summary

Modifier and TypeMethod and Description
public void
connect(SocketAddress socketAddress, SocketAddress socketAddress2, ChannelPromise channelPromise)

Overrides io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe.connect.

Implements io.netty.channel.Channel.Unsafe.connect.

Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
pack-priv void
epollInReady()

Implements abstract io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe.epollInReady.

Called once EPOLLIN event is ready to be processed
Inherited from io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe:
clearEpollIn0epollInBeforeepollInFinallyepollOutReadyepollRdHupReadyexecuteEpollInReadyRunnableflush0newEpollHandlerecvBufAllocHandleshutdownInput

Field Detail

acceptedAddressback to summary
private final byte[] acceptedAddress

Constructor Detail

EpollServerSocketUnsafeback to summary
pack-priv EpollServerSocketUnsafe()

Method Detail

connectback to summary
public void connect(SocketAddress socketAddress, SocketAddress socketAddress2, ChannelPromise channelPromise)

Overrides io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe.connect.

Implements io.netty.channel.Channel.Unsafe.connect.

Doc from io.netty.channel.Channel.Unsafe.connect.

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.

Annotations
@Override
epollInReadyback to summary
pack-priv void epollInReady()

Implements abstract io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe.epollInReady.

Doc from io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe.epollInReady.

Called once EPOLLIN event is ready to be processed

Annotations
@Override