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

public abstract Class AbstractKQueueServerChannel

extends AbstractKQueueChannel
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.kqueue.KQueueServerDomainSocketChannel, io.netty.channel.kqueue.KQueueServerSocketChannel
Annotations
@UnstableApi
Imports
io.netty.channel.Channel, .ChannelConfig, .ChannelMetadata, .ChannelOutboundBuffer, .ChannelPipeline, .EventLoop, .ServerChannel, io.netty.util.internal.UnstableApi, java.net.InetSocketAddress, .SocketAddress

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
AbstractKQueueServerChannel.KQueueServerSocketUnsafe

Field Summary

Modifier and TypeField and Description
private static final ChannelMetadata
METADATA

Hides io.netty.channel.kqueue.AbstractKQueueChannel.METADATA.

Inherited from io.netty.channel.kqueue.AbstractKQueueChannel:
activeinputClosedSeenErrorOnReadreadReadyRunnablePendingsocket

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractKQueueServerChannel(BsdSocket fd)

pack-priv
AbstractKQueueServerChannel(BsdSocket fd, boolean active)

Method Summary

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

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.isCompatible.

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

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.metadata.

Implements io.netty.channel.Channel.metadata.

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

protected AbstractKQueueChannel.AbstractKQueueUnsafe
newUnsafe()

Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.newUnsafe.

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

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.remoteAddress0.

Return the SocketAddress which the Channel is connected to.
Inherited from io.netty.channel.kqueue.AbstractKQueueChannel:
checkResolvableclearReadFilterconfigdoBeginReaddoBinddoClosedoConnect0doDeregisterdoDisconnectdoReadBytesdoRegisterdoWriteBytesfdisActiveisOpenisSoErrorZerolocalAddress0newDirectBuffernewDirectBufferreadFilterresetCachedAddressesshouldBreakReadReadyunregisterFilterswriteFilter

Field Detail

METADATAback to summary
private static final ChannelMetadata METADATA

Hides io.netty.channel.kqueue.AbstractKQueueChannel.METADATA.

Constructor Detail

AbstractKQueueServerChannelback to summary
pack-priv AbstractKQueueServerChannel(BsdSocket fd)
AbstractKQueueServerChannelback to summary
pack-priv AbstractKQueueServerChannel(BsdSocket fd, boolean active)

Method Detail

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

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doConnect.

Doc from io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.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
pack-priv abstract Channel newChildChannel(int fd, byte[] remote, int offset, int len) throws Exception
newUnsafeback to summary
protected AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()

Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.remoteAddress0.

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

Return the SocketAddress which the Channel is connected to.

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

pack-priv final Class AbstractKQueueServerChannel.KQueueServerSocketUnsafe

extends AbstractKQueueUnsafe
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final byte[]
acceptedAddress

Inherited from io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe:
maybeMoreDataToReadreadPending

Constructor Summary

AccessConstructor and Description
pack-priv
KQueueServerSocketUnsafe()

Method Summary

Modifier and TypeMethod and Description
pack-priv void
readReady(KQueueRecvByteAllocatorHandle allocHandle)

Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe.readReady.

Deprecated as a consequence of KQueueRecvByteAllocatorHandle being deprecated.
Inherited from io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe:
clearReadFilter0connectexecuteReadReadyRunnablefailConnectPromiseflush0readEOFreadReadyreadReadyBeforereadReadyFinallyrecvBufAllocHandleshutdownInputwriteReady

Field Detail

acceptedAddressback to summary
private final byte[] acceptedAddress

Constructor Detail

KQueueServerSocketUnsafeback to summary
pack-priv KQueueServerSocketUnsafe()

Method Detail

readReadyback to summary
pack-priv void readReady(KQueueRecvByteAllocatorHandle allocHandle)

Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe.readReady.

Deprecated

as a consequence of KQueueRecvByteAllocatorHandle being deprecated. See corresponding docs for further information.

Annotations
@Override