Class IOUringDatagramChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.incubator.channel.uring.AbstractIOUringChannel

io.netty.incubator.channel.uring.IOUringDatagramChannel

All Implemented Interfaces:

io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.channel.socket.DatagramChannel, io.netty.channel.unix.UnixChannel, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>

public final class IOUringDatagramChannel
extends AbstractIOUringChannel
implements io.netty.channel.socket.DatagramChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	IOUringDatagramChannel.IOUringDatagramChannelUnsafe

Nested classes/interfaces inherited from class AbstractIOUringChannel

AbstractIOUringChannel.AbstractUringUnsafe

Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

io.netty.channel.AbstractChannel.AbstractUnsafe

Nested classes/interfaces inherited from interface io.netty.channel.Channel

io.netty.channel.Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field	Description
private final IOUringDatagramChannelConfig	config
private boolean	connected
private static final String	EXPECTED_TYPES
private static final io.netty.channel.ChannelMetadata	METADATA

Fields inherited from class AbstractIOUringChannel

active, socket

Constructor Summary

Constructors

Modifier	Constructor	Description
	IOUringDatagramChannel()	Create a new instance which selects the InternetProtocolFamily to use depending on the Operation Systems default which will be chosen.
	IOUringDatagramChannel(int fd)	Create a new instance which selects the InternetProtocolFamily to use depending on the Operation Systems default which will be chosen.
	IOUringDatagramChannel(io.netty.channel.socket.InternetProtocolFamily family)	Create a new instance using the given InternetProtocolFamily.
private	IOUringDatagramChannel(LinuxSocket fd, boolean active)

Method Summary

Modifier and Type	Method	Description
io.netty.channel.ChannelFuture	block(InetAddress multicastAddress, InetAddress sourceToBlock)
io.netty.channel.ChannelFuture	block(InetAddress multicastAddress, InetAddress sourceToBlock, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock)
io.netty.channel.ChannelFuture	block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock, io.netty.channel.ChannelPromise promise)
private static void	checkUnresolved(io.netty.channel.AddressedEnvelope<?,?> envelope)
IOUringDatagramChannelConfig	config()
protected void	doBind(SocketAddress localAddress)
protected void	doClose()
protected void	doDisconnect()
protected Object	filterOutboundMessage(Object msg)
boolean	isActive()
boolean	isConnected()
static boolean	isSegmentedDatagramPacketSupported()	Returns true if the usage of SegmentedDatagramPacket is supported.
io.netty.channel.ChannelFuture	joinGroup(InetAddress multicastAddress)
io.netty.channel.ChannelFuture	joinGroup(InetAddress multicastAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
io.netty.channel.ChannelFuture	joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
io.netty.channel.ChannelFuture	joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	leaveGroup(InetAddress multicastAddress)
io.netty.channel.ChannelFuture	leaveGroup(InetAddress multicastAddress, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source)
io.netty.channel.ChannelFuture	leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source, io.netty.channel.ChannelPromise promise)
io.netty.channel.ChannelFuture	leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface)
io.netty.channel.ChannelFuture	leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, io.netty.channel.ChannelPromise promise)
InetSocketAddress	localAddress()
io.netty.channel.ChannelMetadata	metadata()
protected AbstractIOUringChannel.AbstractUringUnsafe	newUnsafe()
InetSocketAddress	remoteAddress()
private static IOException	translateForConnected(io.netty.channel.unix.Errors.NativeIoException e)

Methods inherited from class AbstractIOUringChannel

checkResolvable, clearPollFlag, doBeginRead, doDeregister, doRegister, doWrite, fd, ioScheduled, ioUringUnsafe, isCompatible, isOpen, localAddress0, newDirectBuffer, newDirectBuffer, remoteAddress0, resetCachedAddresses, schedulePollRdHup, submissionQueue

Methods inherited from class io.netty.channel.AbstractChannel

alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from class io.netty.util.DefaultAttributeMap

attr, hasAttr

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.util.AttributeMap

attr, hasAttr

Methods inherited from interface io.netty.channel.Channel

alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isOpen, isRegistered, isWritable, parent, pipeline, read, unsafe

Methods inherited from interface io.netty.channel.ChannelOutboundInvoker

bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from interface Comparable

compareTo

Field Details

METADATA

private static final io.netty.channel.ChannelMetadata METADATA

EXPECTED_TYPES

private static final String EXPECTED_TYPES

config

private final IOUringDatagramChannelConfig config

connected

private volatile boolean connected

Constructor Details

IOUringDatagramChannel

public IOUringDatagramChannel()

Create a new instance which selects the InternetProtocolFamily to use depending on the Operation Systems default which will be chosen.

IOUringDatagramChannel

public IOUringDatagramChannel(io.netty.channel.socket.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.

IOUringDatagramChannel

public IOUringDatagramChannel(int fd)

Create a new instance which selects the InternetProtocolFamily to use depending on the Operation Systems default which will be chosen.

IOUringDatagramChannel

private IOUringDatagramChannel(LinuxSocket fd,
 boolean active)

Method Details

remoteAddress

public InetSocketAddress remoteAddress()

Specified by:

remoteAddress in interface io.netty.channel.Channel

Specified by:

remoteAddress in interface io.netty.channel.socket.DatagramChannel

Overrides:

remoteAddress in class io.netty.channel.AbstractChannel

localAddress

public InetSocketAddress localAddress()

Specified by:

localAddress in interface io.netty.channel.Channel

Specified by:

localAddress in interface io.netty.channel.socket.DatagramChannel

Overrides:

localAddress in class io.netty.channel.AbstractChannel

metadata

public io.netty.channel.ChannelMetadata metadata()

Specified by:

metadata in interface io.netty.channel.Channel

Overrides:

metadata in class AbstractIOUringChannel

isActive

public boolean isActive()

Specified by:

isActive in interface io.netty.channel.Channel

Overrides:

isActive in class AbstractIOUringChannel

isConnected

public boolean isConnected()

Specified by:

isConnected in interface io.netty.channel.socket.DatagramChannel

joinGroup

public io.netty.channel.ChannelFuture joinGroup(InetAddress multicastAddress)

Specified by:

joinGroup in interface io.netty.channel.socket.DatagramChannel

joinGroup

public io.netty.channel.ChannelFuture joinGroup(InetAddress multicastAddress,
 io.netty.channel.ChannelPromise promise)

Specified by:

joinGroup in interface io.netty.channel.socket.DatagramChannel

joinGroup

public io.netty.channel.ChannelFuture joinGroup(InetSocketAddress multicastAddress,
 NetworkInterface networkInterface)

Specified by:

joinGroup in interface io.netty.channel.socket.DatagramChannel

joinGroup

public io.netty.channel.ChannelFuture joinGroup(InetSocketAddress multicastAddress,
 NetworkInterface networkInterface,
 io.netty.channel.ChannelPromise promise)

Specified by:

joinGroup in interface io.netty.channel.socket.DatagramChannel

joinGroup

public io.netty.channel.ChannelFuture joinGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source)

Specified by:

joinGroup in interface io.netty.channel.socket.DatagramChannel

joinGroup

public io.netty.channel.ChannelFuture joinGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source,
 io.netty.channel.ChannelPromise promise)

Specified by:

joinGroup in interface io.netty.channel.socket.DatagramChannel

leaveGroup

public io.netty.channel.ChannelFuture leaveGroup(InetAddress multicastAddress)

Specified by:

leaveGroup in interface io.netty.channel.socket.DatagramChannel

leaveGroup

public io.netty.channel.ChannelFuture leaveGroup(InetAddress multicastAddress,
 io.netty.channel.ChannelPromise promise)

Specified by:

leaveGroup in interface io.netty.channel.socket.DatagramChannel

leaveGroup

public io.netty.channel.ChannelFuture leaveGroup(InetSocketAddress multicastAddress,
 NetworkInterface networkInterface)

Specified by:

leaveGroup in interface io.netty.channel.socket.DatagramChannel

leaveGroup

public io.netty.channel.ChannelFuture leaveGroup(InetSocketAddress multicastAddress,
 NetworkInterface networkInterface,
 io.netty.channel.ChannelPromise promise)

Specified by:

leaveGroup in interface io.netty.channel.socket.DatagramChannel

leaveGroup

public io.netty.channel.ChannelFuture leaveGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source)

Specified by:

leaveGroup in interface io.netty.channel.socket.DatagramChannel

leaveGroup

public io.netty.channel.ChannelFuture leaveGroup(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress source,
 io.netty.channel.ChannelPromise promise)

Specified by:

leaveGroup in interface io.netty.channel.socket.DatagramChannel

block

public io.netty.channel.ChannelFuture block(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress sourceToBlock)

Specified by:

block in interface io.netty.channel.socket.DatagramChannel

block

public io.netty.channel.ChannelFuture block(InetAddress multicastAddress,
 NetworkInterface networkInterface,
 InetAddress sourceToBlock,
 io.netty.channel.ChannelPromise promise)

Specified by:

block in interface io.netty.channel.socket.DatagramChannel

block

public io.netty.channel.ChannelFuture block(InetAddress multicastAddress,
 InetAddress sourceToBlock)

Specified by:

block in interface io.netty.channel.socket.DatagramChannel

block

public io.netty.channel.ChannelFuture block(InetAddress multicastAddress,
 InetAddress sourceToBlock,
 io.netty.channel.ChannelPromise promise)

Specified by:

block in interface io.netty.channel.socket.DatagramChannel

newUnsafe

protected AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

Specified by:

newUnsafe in class AbstractIOUringChannel

doBind

protected void doBind(SocketAddress localAddress)
               throws Exception

Overrides:

doBind in class AbstractIOUringChannel

Throws:

Exception

checkUnresolved

private static void checkUnresolved(io.netty.channel.AddressedEnvelope<?,?> envelope)

filterOutboundMessage

protected Object filterOutboundMessage(Object msg)

Overrides:

filterOutboundMessage in class AbstractIOUringChannel

config

public IOUringDatagramChannelConfig config()

Specified by:

config in interface io.netty.channel.Channel

Specified by:

config in interface io.netty.channel.socket.DatagramChannel

doDisconnect

protected void doDisconnect()
                     throws Exception

Overrides:

doDisconnect in class AbstractIOUringChannel

Throws:

Exception

doClose

protected void doClose()
                throws Exception

Overrides:

doClose in class AbstractIOUringChannel

Throws:

Exception

translateForConnected

private static IOException translateForConnected(io.netty.channel.unix.Errors.NativeIoException e)

isSegmentedDatagramPacketSupported

public static boolean isSegmentedDatagramPacketSupported()

Returns true if the usage of SegmentedDatagramPacket is supported.

Returns:

true if supported, false otherwise.