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

public final Class EpollDomainDatagramChannel

extends AbstractEpollChannel
implements DomainDatagramChannel
Class Inheritance
All Implemented Interfaces
io.netty.channel.unix.DomainDatagramChannel, io.netty.channel.Channel, java.lang.Comparable, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap, io.netty.channel.unix.UnixChannel
Annotations
@UnstableApi
Imports
io.netty.buffer.ByteBuf, .ByteBufAllocator, io.netty.channel.AddressedEnvelope, .ChannelMetadata, .ChannelOutboundBuffer, .ChannelPipeline, .DefaultAddressedEnvelope, io.netty.channel.unix.DomainDatagramChannel, .DomainDatagramChannelConfig, .DomainDatagramPacket, .DomainDatagramSocketAddress, .DomainSocketAddress, .IovArray, .PeerCredentials, .UnixChannelUtil, io.netty.util.CharsetUtil, .UncheckedBooleanSupplier, io.netty.util.internal.StringUtil, .UnstableApi, java.io.IOException, java.net.SocketAddress, java.nio.ByteBuffer

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class

Field Summary

Modifier and TypeField and Description
private final EpollDomainDatagramChannelConfig
private volatile boolean
private static final String
private volatile DomainSocketAddress
private static final ChannelMetadata
private volatile DomainSocketAddress
Inherited from io.netty.channel.epoll.AbstractEpollChannel:
activeepollInReadyRunnablePendingflagsinputClosedSeenErrorOnReadsocket

Constructor Summary

AccessConstructor and Description
public
public
private
EpollDomainDatagramChannel(LinuxSocket socket, boolean active)

Method Summary

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

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

Connect to the remote peer
protected void
doDisconnect()

Overrides io.netty.channel.epoll.AbstractEpollChannel.doDisconnect.

Disconnect this Channel from its 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.
private boolean
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.
public boolean
isActive()

Overrides io.netty.channel.epoll.AbstractEpollChannel.isActive.

Implements io.netty.channel.Channel.isActive.

Return true if the Channel is active and so connected.
public boolean
isConnected()

Implements io.netty.channel.unix.DomainDatagramChannel.isConnected.

Return true if the DomainDatagramChannel is connected to the remote peer.
public DomainSocketAddress
protected DomainSocketAddress
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 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
public PeerCredentials
peerCredentials()

Returns the unix credentials (uid, gid, pid) of the peer SO_PEERCRED

public DomainSocketAddress
protected DomainSocketAddress
Inherited from io.netty.channel.epoll.AbstractEpollChannel:
checkResolvableclearEpollInclearFlagdoBeginReaddoConnect0doDeregisterdoReadBytesdoRegisterdoWriteBytesdoWriteOrSendBytesfdisCompatibleisFlagSetisOpenisSoErrorZeronewDirectBuffernewDirectBufferresetCachedAddressessetFlagshouldBreakEpollInReady

Field Detail

configback to summary
private final EpollDomainDatagramChannelConfig config
connectedback to summary
private volatile boolean connected
EXPECTED_TYPESback to summary
private static final String EXPECTED_TYPES
localback to summary
private volatile DomainSocketAddress local

Hides io.netty.channel.epoll.AbstractEpollChannel.local.

METADATAback to summary
private static final ChannelMetadata METADATA

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

remoteback to summary
private volatile DomainSocketAddress remote

Hides io.netty.channel.epoll.AbstractEpollChannel.remote.

Constructor Detail

EpollDomainDatagramChannelback to summary
public EpollDomainDatagramChannel()
EpollDomainDatagramChannelback to summary
public EpollDomainDatagramChannel(int fd)
EpollDomainDatagramChannelback to summary
private EpollDomainDatagramChannel(LinuxSocket socket, boolean active)

Method Detail

configback to summary
public EpollDomainDatagramChannelConfig config()

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

Implements io.netty.channel.unix.DomainDatagramChannel.config, io.netty.channel.Channel.config.

Doc from io.netty.channel.Channel.config.

Returns the configuration of this channel.

Annotations
@Override
doBindback to summary
protected void doBind(SocketAddress localAddress) throws Exception

Overrides io.netty.channel.epoll.AbstractEpollChannel.doBind.

Doc from io.netty.channel.AbstractChannel.doBind.

Bind the Channel to the SocketAddress

Annotations
@Override
doCloseback to summary
protected void doClose() throws Exception

Overrides io.netty.channel.epoll.AbstractEpollChannel.doClose.

Doc from io.netty.channel.AbstractChannel.doClose.

Close the Channel

Annotations
@Override
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
doDisconnectback to summary
protected void doDisconnect() throws Exception

Overrides io.netty.channel.epoll.AbstractEpollChannel.doDisconnect.

Doc from io.netty.channel.AbstractChannel.doDisconnect.

Disconnect this Channel from its 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
doWriteMessageback to summary
private boolean doWriteMessage(Object msg) throws Exception
filterOutboundMessageback to summary
protected Object filterOutboundMessage(Object msg)

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
isActiveback to summary
public boolean isActive()

Overrides io.netty.channel.epoll.AbstractEpollChannel.isActive.

Implements io.netty.channel.Channel.isActive.

Doc from io.netty.channel.Channel.isActive.

Return true if the Channel is active and so connected.

Annotations
@Override
isConnectedback to summary
public boolean isConnected()

Implements io.netty.channel.unix.DomainDatagramChannel.isConnected.

Doc from io.netty.channel.unix.DomainDatagramChannel.isConnected.

Return true if the DomainDatagramChannel is connected to the remote peer.

Annotations
@Override
localAddressback to summary
public DomainSocketAddress localAddress()

Overrides io.netty.channel.AbstractChannel.localAddress.

Implements io.netty.channel.unix.DomainDatagramChannel.localAddress, io.netty.channel.Channel.localAddress.

Doc from io.netty.channel.Channel.localAddress.

Returns the local address where this channel is bound to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Returns:DomainSocketAddress

the local address of this channel. null if this channel is not bound.

Annotations
@Override
localAddress0back to summary
protected DomainSocketAddress localAddress0()

Overrides io.netty.channel.epoll.AbstractEpollChannel.localAddress0.

Doc from io.netty.channel.AbstractChannel.localAddress0.

Returns the SocketAddress which is bound locally.

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
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
peerCredentialsback to summary
public PeerCredentials peerCredentials() throws IOException

Returns the unix credentials (uid, gid, pid) of the peer SO_PEERCRED

remoteAddressback to summary
public DomainSocketAddress remoteAddress()

Overrides io.netty.channel.AbstractChannel.remoteAddress.

Implements io.netty.channel.unix.DomainDatagramChannel.remoteAddress, io.netty.channel.Channel.remoteAddress.

Doc from io.netty.channel.Channel.remoteAddress.

Returns the remote address where this channel is connected to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Returns:DomainSocketAddress

the remote address of this channel. null if this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g. DatagramChannel, use DatagramPacket#recipient() to determine the origination of the received message as this method will return null.

Annotations
@Override
remoteAddress0back to summary
protected DomainSocketAddress 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 EpollDomainDatagramChannel.EpollDomainDatagramChannelUnsafe

extends AbstractEpollUnsafe
Class Inheritance

Field Summary

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

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
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:
clearEpollIn0connectepollInBeforeepollInFinallyepollOutReadyepollRdHupReadyexecuteEpollInReadyRunnableflush0newEpollHandlerecvBufAllocHandleshutdownInput

Constructor Detail

EpollDomainDatagramChannelUnsafeback to summary
pack-priv EpollDomainDatagramChannelUnsafe()

Method Detail

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