Netty 4.1.107.Final · io.netty.channel.epoll.EpollDatagramChannel

Modifier and Type	Class and Description
pack-priv class	EpollDatagramChannel.EpollDatagramChannelUnsafe

Modifier and Type	Field and Description
private final EpollDatagramChannelConfig	config
private volatile boolean	connected
private static final String	EXPECTED_TYPES
private static final ChannelMetadata	METADATA Hides io.netty.channel.epoll.AbstractEpollChannel.METADATA.

Access	Constructor and Description
public	EpollDatagramChannel() Create a new instance which selects the `InternetProtocolFamily` to use depending on the Operation Systems default which will be chosen.
public	EpollDatagramChannel(InternetProtocolFamily family) Create a new instance using the given `InternetProtocolFamily`.
public	EpollDatagramChannel(int fd) Create a new instance which selects the `InternetProtocolFamily` to use depending on the Operation Systems default which will be chosen.
private	EpollDatagramChannel(LinuxSocket fd, boolean active)

Method Summary

Modifier and Type	Method and Description
private static void	addDatagramPacketToOut(DatagramPacket packet, RecyclableArrayList out)
public ChannelFuture	block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) Implements io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	block(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress sourceToBlock, final ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	block(InetAddress multicastAddress, InetAddress sourceToBlock) Implements io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress and notifies the `ChannelFuture` once the operation completes.
private static void	checkUnresolved(AddressedEnvelope<?, ?> envelope)
private NativeDatagramPacketArray	cleanDatagramPacketArray()
public EpollDatagramChannelConfig	config() Implements abstract io.netty.channel.epoll.AbstractEpollChannel.config. Implements io.netty.channel.socket.DatagramChannel.config, io.netty.channel.Channel.config. Returns the configuration of this channel.
private boolean	connectedRead(EpollRecvByteAllocatorHandle allocHandle, ByteBuf byteBuf, int maxDatagramPacketSize) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated.
protected void	doBind(SocketAddress localAddress) Overrides io.netty.channel.epoll.AbstractEpollChannel.doBind. Bind the `Channel` to the `SocketAddress`
protected void	doClose() Overrides io.netty.channel.epoll.AbstractEpollChannel.doClose. Close the `Channel`
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	doWriteMessage(Object msg)
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.socket.DatagramChannel.isConnected. Return `true` if the `DatagramChannel` is connected to the remote peer.
public static boolean	Returns: `true` if supported, `false` otherwise. isSegmentedDatagramPacketSupported() Returns `true` if `io.netty.channel.unix.SegmentedDatagramPacket` is supported natively.
public ChannelFuture	joinGroup(InetAddress multicastAddress) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Joins a multicast group and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	joinGroup(InetAddress multicastAddress, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Joins a multicast group and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	joinGroup(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes.
private void	joinGroup0(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise)
public ChannelFuture	leaveGroup(InetAddress multicastAddress) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	leaveGroup(InetAddress multicastAddress, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group on a specified local interface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group on a specified local interface and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Leave the specified multicast group at the specified interface using the specified source and notifies the `ChannelFuture` once the operation completes.
public ChannelFuture	leaveGroup(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Leave the specified multicast group at the specified interface using the specified source and notifies the `ChannelFuture` once the operation completes.
private void	leaveGroup0(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise)
public InetSocketAddress	localAddress() Overrides io.netty.channel.AbstractChannel.localAddress. Implements io.netty.channel.socket.DatagramChannel.localAddress, io.netty.channel.Channel.localAddress. Returns the local address where this channel is bound to.
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`
private static void	processPacket(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, DatagramPacket packet) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated.
private static void	processPacketList(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, RecyclableArrayList packetList) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated.
private boolean	recvmsg(EpollRecvByteAllocatorHandle allocHandle, NativeDatagramPacketArray array, ByteBuf byteBuf) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated.
private static void	releaseAndRecycle(ByteBuf byteBuf, RecyclableArrayList packetList)
public InetSocketAddress	remoteAddress() Overrides io.netty.channel.AbstractChannel.remoteAddress. Implements io.netty.channel.socket.DatagramChannel.remoteAddress, io.netty.channel.Channel.remoteAddress. Returns the remote address where this channel is connected to.
private boolean	scatteringRead(EpollRecvByteAllocatorHandle allocHandle, NativeDatagramPacketArray array, ByteBuf byteBuf, int datagramSize, int numDatagram) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated.
private IOException	translateForConnected(Errors.NativeIoException e)

config	back to summary
private final EpollDatagramChannelConfig config

connected	back to summary
private volatile boolean connected

EXPECTED_TYPES	back to summary
private static final String EXPECTED_TYPES

EpollDatagramChannel	back to summary
public EpollDatagramChannel() Create a new instance which selects the `InternetProtocolFamily` to use depending on the Operation Systems default which will be chosen.

EpollDatagramChannel	back to summary
public EpollDatagramChannel(InternetProtocolFamily family) Create a new instance using the given `InternetProtocolFamily`. If `null` is used it will depend on the Operation Systems default which will be chosen.

EpollDatagramChannel	back to summary
public EpollDatagramChannel(int fd) Create a new instance which selects the `InternetProtocolFamily` to use depending on the Operation Systems default which will be chosen.

EpollDatagramChannel	back to summary
private EpollDatagramChannel(LinuxSocket fd, boolean active)

Method Detail

addDatagramPacketToOut	back to summary
private static void addDatagramPacketToOut(DatagramPacket packet, RecyclableArrayList out)

block back to summary

block	back to summary
public ChannelFuture block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) Implements io.netty.channel.socket.DatagramChannel.block. Doc from io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)

Implements io.netty.channel.socket.DatagramChannel.block.

Doc from io.netty.channel.socket.DatagramChannel.block.

Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

block back to summary

block	back to summary
public ChannelFuture block(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress sourceToBlock, final ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.block. Doc from io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress on the given networkInterface and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture block(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress sourceToBlock, final ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.block.

Doc from io.netty.channel.socket.DatagramChannel.block.

Annotations

@Override

block back to summary

block	back to summary
public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock) Implements io.netty.channel.socket.DatagramChannel.block. Doc from io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock)

Implements io.netty.channel.socket.DatagramChannel.block.

Doc from io.netty.channel.socket.DatagramChannel.block.

Block the given sourceToBlock address for the given multicastAddress and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

block back to summary

block	back to summary
public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.block. Doc from io.netty.channel.socket.DatagramChannel.block. Block the given sourceToBlock address for the given multicastAddress and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock, ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.block.

Doc from io.netty.channel.socket.DatagramChannel.block.

Block the given sourceToBlock address for the given multicastAddress and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

checkUnresolved	back to summary
private static void checkUnresolved(AddressedEnvelope<?, ?> envelope)

cleanDatagramPacketArray	back to summary
private NativeDatagramPacketArray cleanDatagramPacketArray()

config	back to summary
public EpollDatagramChannelConfig config() Implements abstract io.netty.channel.epoll.AbstractEpollChannel.config. Implements io.netty.channel.socket.DatagramChannel.config, io.netty.channel.Channel.config. Doc from io.netty.channel.Channel.config. Returns the configuration of this channel. Annotations @Override

config

back to summary

public EpollDatagramChannelConfig config()

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

Implements io.netty.channel.socket.DatagramChannel.config, io.netty.channel.Channel.config.

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

Returns the configuration of this channel.

Annotations

@Override

connectedRead	back to summary
private boolean connectedRead(EpollRecvByteAllocatorHandle allocHandle, ByteBuf byteBuf, int maxDatagramPacketSize) throws Exception Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

doBind back to summary

doBind	back 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

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

doClose back to summary

doClose	back 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

protected void doClose() throws Exception

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

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

Close the Channel

Annotations

@Override

doConnect	back 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

doConnect

back 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

doDisconnect back to summary

doDisconnect	back 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

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

doWrite	back 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

doWrite

back 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

doWriteMessage	back to summary
private boolean doWriteMessage(Object msg) throws Exception

filterOutboundMessage back to summary

filterOutboundMessage	back 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

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

isActive back to summary

isActive	back 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

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

isConnected back to summary

isConnected	back to summary
public boolean isConnected() Implements io.netty.channel.socket.DatagramChannel.isConnected. Doc from io.netty.channel.socket.DatagramChannel.isConnected. Return `true` if the `DatagramChannel` is connected to the remote peer. Annotations @Override

public boolean isConnected()

Implements io.netty.channel.socket.DatagramChannel.isConnected.

Doc from io.netty.channel.socket.DatagramChannel.isConnected.

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

Annotations

@Override

isSegmentedDatagramPacketSupported back to summary

isSegmentedDatagramPacketSupported	back to summary
public static boolean isSegmentedDatagramPacketSupported() Returns `true` if `io.netty.channel.unix.SegmentedDatagramPacket` is supported natively. Returns:boolean `true` if supported, `false` otherwise.

public static boolean isSegmentedDatagramPacketSupported()

Returns true if io.netty.channel.unix.SegmentedDatagramPacket is supported natively.

Returns:boolean: true if supported, false otherwise.

joinGroup back to summary

joinGroup	back to summary
public ChannelFuture joinGroup(InetAddress multicastAddress) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Doc from io.netty.channel.socket.DatagramChannel.joinGroup. Joins a multicast group and notifies the `ChannelFuture` once the operation completes. Annotations @Override

public ChannelFuture joinGroup(InetAddress multicastAddress)

Implements io.netty.channel.socket.DatagramChannel.joinGroup.

Doc from io.netty.channel.socket.DatagramChannel.joinGroup.

Joins a multicast group and notifies the ChannelFuture once the operation completes.

Annotations

@Override

joinGroup back to summary

joinGroup	back to summary
public ChannelFuture joinGroup(InetAddress multicastAddress, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Doc from io.netty.channel.socket.DatagramChannel.joinGroup. Joins a multicast group and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture joinGroup(InetAddress multicastAddress, ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.joinGroup.

Doc from io.netty.channel.socket.DatagramChannel.joinGroup.

Joins a multicast group and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

joinGroup back to summary

joinGroup	back to summary
public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Doc from io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes. Annotations @Override

public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)

Implements io.netty.channel.socket.DatagramChannel.joinGroup.

Doc from io.netty.channel.socket.DatagramChannel.joinGroup.

Joins the specified multicast group at the specified interface and notifies the ChannelFuture once the operation completes.

Annotations

@Override

joinGroup back to summary

joinGroup	back to summary
public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Doc from io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.joinGroup.

Doc from io.netty.channel.socket.DatagramChannel.joinGroup.

Joins the specified multicast group at the specified interface and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

joinGroup back to summary

joinGroup	back to summary
public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Doc from io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes. Annotations @Override

public ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)

Implements io.netty.channel.socket.DatagramChannel.joinGroup.

Doc from io.netty.channel.socket.DatagramChannel.joinGroup.

Joins the specified multicast group at the specified interface and notifies the ChannelFuture once the operation completes.

Annotations

@Override

joinGroup back to summary

joinGroup	back to summary
public ChannelFuture joinGroup(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.joinGroup. Doc from io.netty.channel.socket.DatagramChannel.joinGroup. Joins the specified multicast group at the specified interface and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture joinGroup(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.joinGroup.

Doc from io.netty.channel.socket.DatagramChannel.joinGroup.

Joins the specified multicast group at the specified interface and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

joinGroup0	back to summary
private void joinGroup0(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise)

leaveGroup back to summary

leaveGroup	back to summary
public ChannelFuture leaveGroup(InetAddress multicastAddress) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Doc from io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group and notifies the `ChannelFuture` once the operation completes. Annotations @Override

public ChannelFuture leaveGroup(InetAddress multicastAddress)

Implements io.netty.channel.socket.DatagramChannel.leaveGroup.

Doc from io.netty.channel.socket.DatagramChannel.leaveGroup.

Leaves a multicast group and notifies the ChannelFuture once the operation completes.

Annotations

@Override

leaveGroup back to summary

leaveGroup	back to summary
public ChannelFuture leaveGroup(InetAddress multicastAddress, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Doc from io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture leaveGroup(InetAddress multicastAddress, ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.leaveGroup.

Doc from io.netty.channel.socket.DatagramChannel.leaveGroup.

Leaves a multicast group and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

leaveGroup back to summary

leaveGroup	back to summary
public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Doc from io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group on a specified local interface and notifies the `ChannelFuture` once the operation completes. Annotations @Override

public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)

Implements io.netty.channel.socket.DatagramChannel.leaveGroup.

Doc from io.netty.channel.socket.DatagramChannel.leaveGroup.

Leaves a multicast group on a specified local interface and notifies the ChannelFuture once the operation completes.

Annotations

@Override

leaveGroup back to summary

leaveGroup	back to summary
public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Doc from io.netty.channel.socket.DatagramChannel.leaveGroup. Leaves a multicast group on a specified local interface and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.leaveGroup.

Doc from io.netty.channel.socket.DatagramChannel.leaveGroup.

Leaves a multicast group on a specified local interface and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

leaveGroup back to summary

leaveGroup	back to summary
public ChannelFuture leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Doc from io.netty.channel.socket.DatagramChannel.leaveGroup. Leave the specified multicast group at the specified interface using the specified source and notifies the `ChannelFuture` once the operation completes. Annotations @Override

public ChannelFuture leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)

Implements io.netty.channel.socket.DatagramChannel.leaveGroup.

Doc from io.netty.channel.socket.DatagramChannel.leaveGroup.

Leave the specified multicast group at the specified interface using the specified source and notifies the ChannelFuture once the operation completes.

Annotations

@Override

leaveGroup back to summary

leaveGroup	back to summary
public ChannelFuture leaveGroup(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise) Implements io.netty.channel.socket.DatagramChannel.leaveGroup. Doc from io.netty.channel.socket.DatagramChannel.leaveGroup. Leave the specified multicast group at the specified interface using the specified source and notifies the `ChannelFuture` once the operation completes. The given `ChannelFuture` will be notified and also returned. Annotations @Override

public ChannelFuture leaveGroup(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise)

Implements io.netty.channel.socket.DatagramChannel.leaveGroup.

Doc from io.netty.channel.socket.DatagramChannel.leaveGroup.

Leave the specified multicast group at the specified interface using the specified source and notifies the ChannelFuture once the operation completes. The given ChannelFuture will be notified and also returned.

Annotations

@Override

leaveGroup0	back to summary
private void leaveGroup0(final InetAddress multicastAddress, final NetworkInterface networkInterface, final InetAddress source, final ChannelPromise promise)

localAddress back to summary

localAddress	back to summary
public InetSocketAddress localAddress() Overrides io.netty.channel.AbstractChannel.localAddress. Implements io.netty.channel.socket.DatagramChannel.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:InetSocketAddress the local address of this channel. `null` if this channel is not bound. Annotations @Override

public InetSocketAddress localAddress()

Overrides io.netty.channel.AbstractChannel.localAddress.

Implements io.netty.channel.socket.DatagramChannel.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:InetSocketAddress

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

Annotations

@Override

metadata back 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

newUnsafe back to summary

newUnsafe	back 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

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

processPacket	back to summary
private static void processPacket(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, DatagramPacket packet) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

processPacketList	back to summary
private static void processPacketList(ChannelPipeline pipeline, EpollRecvByteAllocatorHandle handle, int bytesRead, RecyclableArrayList packetList) Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

recvmsg	back to summary
private boolean recvmsg(EpollRecvByteAllocatorHandle allocHandle, NativeDatagramPacketArray array, ByteBuf byteBuf) throws IOException Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

releaseAndRecycle	back to summary
private static void releaseAndRecycle(ByteBuf byteBuf, RecyclableArrayList packetList)

remoteAddress back to summary

public InetSocketAddress remoteAddress()

Overrides io.netty.channel.AbstractChannel.remoteAddress.

Implements io.netty.channel.socket.DatagramChannel.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:InetSocketAddress

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

scatteringRead	back to summary
private boolean scatteringRead(EpollRecvByteAllocatorHandle allocHandle, NativeDatagramPacketArray array, ByteBuf byteBuf, int datagramSize, int numDatagram) throws IOException Deprecated as a consequence of `EpollRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

translateForConnected	back to summary
private IOException translateForConnected(Errors.NativeIoException e)

public final Class EpollDatagramChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class EpollDatagramChannel.EpollDatagramChannelUnsafe

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail