Package io.netty.incubator.channel.uring
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 ClassesModifier and TypeClassDescription(package private) final class
Nested classes/interfaces inherited from class io.netty.incubator.channel.uring.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
FieldsModifier and TypeFieldDescriptionprivate final IOUringDatagramChannelConfig
private boolean
private static final String
private static final io.netty.channel.ChannelMetadata
Fields inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel
active, socket
-
Constructor Summary
ConstructorsModifierConstructorDescriptionCreate a new instance which selects theInternetProtocolFamily
to use depending on the Operation Systems default which will be chosen.IOUringDatagramChannel
(int fd) Create a new instance which selects theInternetProtocolFamily
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 givenInternetProtocolFamily
.private
IOUringDatagramChannel
(LinuxSocket fd, boolean active) -
Method Summary
Modifier and TypeMethodDescriptionio.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) config()
protected void
doBind
(SocketAddress localAddress) protected void
doClose()
protected void
protected Object
boolean
isActive()
boolean
static boolean
Returnstrue
if the usage ofSegmentedDatagramPacket
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) io.netty.channel.ChannelMetadata
metadata()
private static IOException
translateForConnected
(io.netty.channel.unix.Errors.NativeIoException e) Methods inherited from class io.netty.incubator.channel.uring.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 java.lang.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 java.lang.Comparable
compareTo
-
Field Details
-
METADATA
private static final io.netty.channel.ChannelMetadata METADATA -
EXPECTED_TYPES
-
config
-
connected
private volatile boolean connected
-
-
Constructor Details
-
IOUringDatagramChannel
public IOUringDatagramChannel()Create a new instance which selects theInternetProtocolFamily
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 givenInternetProtocolFamily
. Ifnull
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 theInternetProtocolFamily
to use depending on the Operation Systems default which will be chosen. -
IOUringDatagramChannel
-
-
Method Details
-
remoteAddress
- Specified by:
remoteAddress
in interfaceio.netty.channel.Channel
- Specified by:
remoteAddress
in interfaceio.netty.channel.socket.DatagramChannel
- Overrides:
remoteAddress
in classio.netty.channel.AbstractChannel
-
localAddress
- Specified by:
localAddress
in interfaceio.netty.channel.Channel
- Specified by:
localAddress
in interfaceio.netty.channel.socket.DatagramChannel
- Overrides:
localAddress
in classio.netty.channel.AbstractChannel
-
metadata
public io.netty.channel.ChannelMetadata metadata()- Specified by:
metadata
in interfaceio.netty.channel.Channel
- Overrides:
metadata
in classAbstractIOUringChannel
-
isActive
public boolean isActive()- Specified by:
isActive
in interfaceio.netty.channel.Channel
- Overrides:
isActive
in classAbstractIOUringChannel
-
isConnected
public boolean isConnected()- Specified by:
isConnected
in interfaceio.netty.channel.socket.DatagramChannel
-
joinGroup
- Specified by:
joinGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
joinGroup
public io.netty.channel.ChannelFuture joinGroup(InetAddress multicastAddress, io.netty.channel.ChannelPromise promise) - Specified by:
joinGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
joinGroup
public io.netty.channel.ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) - Specified by:
joinGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
joinGroup
public io.netty.channel.ChannelFuture joinGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, io.netty.channel.ChannelPromise promise) - Specified by:
joinGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
joinGroup
public io.netty.channel.ChannelFuture joinGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) - Specified by:
joinGroup
in interfaceio.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 interfaceio.netty.channel.socket.DatagramChannel
-
leaveGroup
- Specified by:
leaveGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
leaveGroup
public io.netty.channel.ChannelFuture leaveGroup(InetAddress multicastAddress, io.netty.channel.ChannelPromise promise) - Specified by:
leaveGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
leaveGroup
public io.netty.channel.ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface) - Specified by:
leaveGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
leaveGroup
public io.netty.channel.ChannelFuture leaveGroup(InetSocketAddress multicastAddress, NetworkInterface networkInterface, io.netty.channel.ChannelPromise promise) - Specified by:
leaveGroup
in interfaceio.netty.channel.socket.DatagramChannel
-
leaveGroup
public io.netty.channel.ChannelFuture leaveGroup(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress source) - Specified by:
leaveGroup
in interfaceio.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 interfaceio.netty.channel.socket.DatagramChannel
-
block
public io.netty.channel.ChannelFuture block(InetAddress multicastAddress, NetworkInterface networkInterface, InetAddress sourceToBlock) - Specified by:
block
in interfaceio.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 interfaceio.netty.channel.socket.DatagramChannel
-
block
public io.netty.channel.ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock) - Specified by:
block
in interfaceio.netty.channel.socket.DatagramChannel
-
block
public io.netty.channel.ChannelFuture block(InetAddress multicastAddress, InetAddress sourceToBlock, io.netty.channel.ChannelPromise promise) - Specified by:
block
in interfaceio.netty.channel.socket.DatagramChannel
-
newUnsafe
- Specified by:
newUnsafe
in classAbstractIOUringChannel
-
doBind
- Overrides:
doBind
in classAbstractIOUringChannel
- Throws:
Exception
-
checkUnresolved
private static void checkUnresolved(io.netty.channel.AddressedEnvelope<?, ?> envelope) -
filterOutboundMessage
- Overrides:
filterOutboundMessage
in classAbstractIOUringChannel
-
config
- Specified by:
config
in interfaceio.netty.channel.Channel
- Specified by:
config
in interfaceio.netty.channel.socket.DatagramChannel
-
doDisconnect
- Overrides:
doDisconnect
in classAbstractIOUringChannel
- Throws:
Exception
-
doClose
- Overrides:
doClose
in classAbstractIOUringChannel
- Throws:
Exception
-
translateForConnected
-
isSegmentedDatagramPacketSupported
public static boolean isSegmentedDatagramPacketSupported()Returnstrue
if the usage ofSegmentedDatagramPacket
is supported.- Returns:
true
if supported,false
otherwise.
-