Netty/Transport/Classes/KQueue 4.1.107.Final · io.netty.channel.kqueue.KQueueDatagramChannel

Modifier and Type	Class and Description
pack-priv class	KQueueDatagramChannel.KQueueDatagramChannelUnsafe

Modifier and Type	Field and Description
private final KQueueDatagramChannelConfig	config
private volatile boolean	connected
private static final String	EXPECTED_TYPES

Access	Constructor and Description
public	KQueueDatagramChannel()
public	KQueueDatagramChannel(InternetProtocolFamily protocol)
public	KQueueDatagramChannel(int fd)
pack-priv	KQueueDatagramChannel(BsdSocket socket, boolean active)

Method Summary

Modifier and Type	Method and Description
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)
public KQueueDatagramChannelConfig	config() Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.config. Implements io.netty.channel.socket.DatagramChannel.config, io.netty.channel.Channel.config. Returns the configuration of this channel.
protected void	doBind(SocketAddress localAddress) Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doBind. Bind the `Channel` to the `SocketAddress`
protected void	doClose() Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doClose. Close the `Channel`
protected boolean	doConnect(SocketAddress remoteAddress, SocketAddress localAddress) Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doConnect. Connect to the remote peer
protected void	doDisconnect() Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doDisconnect. Disconnect this `Channel` from its remote peer
protected boolean	doWriteMessage(Object msg) Implements abstract io.netty.channel.kqueue.AbstractKQueueDatagramChannel.doWriteMessage.
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.kqueue.AbstractKQueueChannel.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 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.
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.
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.
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`
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.

Inherited from io.netty.channel.kqueue.AbstractKQueueDatagramChannel:: doWrite metadata

config	back to summary
private final KQueueDatagramChannelConfig config

connected	back to summary
private volatile boolean connected

EXPECTED_TYPES	back to summary
private static final String EXPECTED_TYPES

KQueueDatagramChannel	back to summary
public KQueueDatagramChannel()

KQueueDatagramChannel	back to summary
public KQueueDatagramChannel(InternetProtocolFamily protocol)

KQueueDatagramChannel	back to summary
public KQueueDatagramChannel(int fd)

KQueueDatagramChannel	back to summary
pack-priv KQueueDatagramChannel(BsdSocket socket, boolean active)

Method Detail

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)

config	back to summary
public KQueueDatagramChannelConfig config() Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.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 KQueueDatagramChannelConfig config()

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

doBind back to summary

doBind	back to summary
protected void doBind(SocketAddress localAddress) throws Exception Overrides io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.doClose. Doc from io.netty.channel.AbstractChannel.doClose. Close the `Channel` Annotations @Override

protected void doClose() throws Exception

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.doConnect. Doc from io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.doConnect.

Doc from io.netty.channel.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.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.kqueue.AbstractKQueueChannel.doDisconnect.

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

Disconnect this Channel from its remote peer

Annotations

@Override

doWriteMessage	back to summary
protected boolean doWriteMessage(Object msg) throws Exception Implements abstract io.netty.channel.kqueue.AbstractKQueueDatagramChannel.doWriteMessage. Annotations @Override

doWriteMessage

back to summary

protected boolean doWriteMessage(Object msg) throws Exception

Implements abstract io.netty.channel.kqueue.AbstractKQueueDatagramChannel.doWriteMessage.

Annotations

@Override

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.kqueue.AbstractKQueueChannel.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 @SuppressWarnings:deprecation

public boolean isActive()

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.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
@SuppressWarnings:deprecation

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

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

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

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

newUnsafe back to summary

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

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

remoteAddress back to summary

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

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

public final Class KQueueDatagramChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class KQueueDatagramChannel.KQueueDatagramChannelUnsafe

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail