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

Modifier and Type	Class and Description
pack-priv class	KQueueDomainDatagramChannel.KQueueDomainDatagramChannelUnsafe

Modifier and Type	Field and Description
private final KQueueDomainDatagramChannelConfig	config
private volatile boolean	connected
private static final String	EXPECTED_TYPES
private volatile DomainSocketAddress	local Hides io.netty.channel.kqueue.AbstractKQueueChannel.local.
private volatile DomainSocketAddress	remote Hides io.netty.channel.kqueue.AbstractKQueueChannel.remote.

Constructor Summary

Access	Constructor and Description
public	KQueueDomainDatagramChannel()
public	KQueueDomainDatagramChannel(int fd)
private	KQueueDomainDatagramChannel(BsdSocket socket, boolean active)

Method Summary

Modifier and Type	Method and Description
public KQueueDomainDatagramChannelConfig	config() Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.config. Implements io.netty.channel.unix.DomainDatagramChannel.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.unix.DomainDatagramChannel.isConnected. Return `true` if the `DomainDatagramChannel` is connected to the remote peer.
public DomainSocketAddress	localAddress() Overrides io.netty.channel.AbstractChannel.localAddress. Implements io.netty.channel.unix.DomainDatagramChannel.localAddress, io.netty.channel.Channel.localAddress. Returns the local address where this channel is bound to.
protected DomainSocketAddress	localAddress0() Overrides io.netty.channel.kqueue.AbstractKQueueChannel.localAddress0. Returns the `SocketAddress` which is bound locally.
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 PeerCredentials	peerCredentials() Returns the unix credentials (uid, gid, pid) of the peer SO_PEERCRED
public DomainSocketAddress	remoteAddress() Overrides io.netty.channel.AbstractChannel.remoteAddress. Implements io.netty.channel.unix.DomainDatagramChannel.remoteAddress, io.netty.channel.Channel.remoteAddress. Returns the remote address where this channel is connected to.
protected DomainSocketAddress	remoteAddress0() Overrides io.netty.channel.kqueue.AbstractKQueueChannel.remoteAddress0. Return the `SocketAddress` which the `Channel` is connected to.

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

Field Detail

config	back to summary
private final KQueueDomainDatagramChannelConfig config

connected	back to summary
private volatile boolean connected

EXPECTED_TYPES	back to summary
private static final String EXPECTED_TYPES

local	back to summary
private volatile DomainSocketAddress local Hides io.netty.channel.kqueue.AbstractKQueueChannel.local.

remote	back to summary
private volatile DomainSocketAddress remote Hides io.netty.channel.kqueue.AbstractKQueueChannel.remote.

Constructor Detail

KQueueDomainDatagramChannel	back to summary
public KQueueDomainDatagramChannel()

KQueueDomainDatagramChannel	back to summary
public KQueueDomainDatagramChannel(int fd)

KQueueDomainDatagramChannel	back to summary
private KQueueDomainDatagramChannel(BsdSocket socket, boolean active)

Method Detail

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

config

back to summary

public KQueueDomainDatagramChannelConfig config()

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

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

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

isConnected back to summary

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

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

localAddress back to summary

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

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

localAddress0 back to summary

localAddress0	back to summary
protected DomainSocketAddress localAddress0() Overrides io.netty.channel.kqueue.AbstractKQueueChannel.localAddress0. Doc from io.netty.channel.AbstractChannel.localAddress0. Returns the `SocketAddress` which is bound locally. Annotations @Override

protected DomainSocketAddress localAddress0()

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.localAddress0.

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

Returns the SocketAddress which is bound locally.

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

peerCredentials	back to summary
public PeerCredentials peerCredentials() throws IOException Returns the unix credentials (uid, gid, pid) of the peer SO_PEERCRED

remoteAddress back to summary

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

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

remoteAddress0 back to summary

remoteAddress0	back to summary
protected DomainSocketAddress 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

protected DomainSocketAddress 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

Access	Constructor and Description
pack-priv	KQueueDomainDatagramChannelUnsafe()

Modifier and Type	Method 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.

Constructor Detail

KQueueDomainDatagramChannelUnsafe	back to summary
pack-priv KQueueDomainDatagramChannelUnsafe()

Method Detail

readReady back to summary

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

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

public final Class KQueueDomainDatagramChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class KQueueDomainDatagramChannel.KQueueDomainDatagramChannelUnsafe

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail