Package io.netty.incubator.channel.uring

Class IOUringDatagramChannel

java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
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 io.netty.channel.AbstractChannel implements io.netty.channel.socket.DatagramChannel

  • Nested Class Summary

    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
    protected boolean
    active
     

  • Constructor Summary

    Constructors
    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.

  • 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)
     
    protected static void
    checkResolvable(InetSocketAddress addr)
     
    void
    clearPollFlag(int pollMask)
     
    IOUringDatagramChannelConfig
    config()
     
    protected void
    doBeginRead()
     
    protected void
    doBind(SocketAddress localAddress)
     
    protected void
    doClose()
     
    protected final void
    doDeregister()
     
    protected void
    doDisconnect()
     
    protected void
    doRegister()
     
    protected void
    doWrite(io.netty.channel.ChannelOutboundBuffer in)
     
    io.netty.channel.unix.FileDescriptor
    fd()
     
    protected Object
    filterOutboundMessage(Object msg)
     
    boolean
    isActive()
     
    protected boolean
    isCompatible(io.netty.channel.EventLoop loop)
     
    boolean
    isConnected()
     
    boolean
    isOpen()
     
    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()
     
    protected SocketAddress
    localAddress0()
     
    io.netty.channel.ChannelMetadata
    metadata()
     
    protected final io.netty.buffer.ByteBuf
    newDirectBuffer(io.netty.buffer.ByteBuf buf)
     
    protected final io.netty.buffer.ByteBuf
    newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)
     
    protected io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
    newUnsafe()
     
    InetSocketAddress
    remoteAddress()
     
    protected SocketAddress
    remoteAddress0()
     

    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

    • active

      protected volatile boolean active

  • 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.

  • 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

    • isActive

      public boolean isActive()
      Specified by:
      isActive in interface io.netty.channel.Channel

    • 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 io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

    • doBind

      protected void doBind(SocketAddress localAddress) throws Exception
      Throws:
      Exception

    • filterOutboundMessage

      protected Object filterOutboundMessage(Object msg)

    • 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
      Throws:
      Exception

    • doClose

      protected void doClose() throws Exception
      Throws:
      Exception

    • isSegmentedDatagramPacketSupported

      public static boolean isSegmentedDatagramPacketSupported()
      Returns true if the usage of SegmentedDatagramPacket is supported.
      Returns:
      true if supported, false otherwise.

    • isOpen

      public boolean isOpen()
      Specified by:
      isOpen in interface io.netty.channel.Channel

    • fd

      public io.netty.channel.unix.FileDescriptor fd()
      Specified by:
      fd in interface io.netty.channel.unix.UnixChannel

    • isCompatible

      protected boolean isCompatible(io.netty.channel.EventLoop loop)
      Specified by:
      isCompatible in class io.netty.channel.AbstractChannel

    • newDirectBuffer

      protected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf)

    • newDirectBuffer

      protected final io.netty.buffer.ByteBuf newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)

    • doBeginRead

      protected void doBeginRead()
      Specified by:
      doBeginRead in class io.netty.channel.AbstractChannel

    • doWrite

      protected void doWrite(io.netty.channel.ChannelOutboundBuffer in)
      Specified by:
      doWrite in class io.netty.channel.AbstractChannel

    • doRegister

      protected void doRegister() throws Exception
      Overrides:
      doRegister in class io.netty.channel.AbstractChannel
      Throws:
      Exception

    • doDeregister

      protected final void doDeregister()
      Overrides:
      doDeregister in class io.netty.channel.AbstractChannel

    • checkResolvable

      protected static void checkResolvable(InetSocketAddress addr)

    • localAddress0

      protected SocketAddress localAddress0()
      Specified by:
      localAddress0 in class io.netty.channel.AbstractChannel

    • remoteAddress0

      protected SocketAddress remoteAddress0()
      Specified by:
      remoteAddress0 in class io.netty.channel.AbstractChannel

    • clearPollFlag

      public void clearPollFlag(int pollMask)