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

      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

      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.