Class AbstractIOUringStreamChannel

java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.incubator.channel.uring.AbstractIOUringChannel
io.netty.incubator.channel.uring.AbstractIOUringStreamChannel
All Implemented Interfaces:
io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.channel.socket.DuplexChannel, io.netty.channel.unix.UnixChannel, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>
Direct Known Subclasses:
IOUringSocketChannel

abstract class AbstractIOUringStreamChannel extends AbstractIOUringChannel implements io.netty.channel.socket.DuplexChannel
  • Field Details

    • logger

      private static final io.netty.util.internal.logging.InternalLogger logger
  • Constructor Details

    • AbstractIOUringStreamChannel

      AbstractIOUringStreamChannel(io.netty.channel.Channel parent, LinuxSocket socket)
    • AbstractIOUringStreamChannel

      protected AbstractIOUringStreamChannel(io.netty.channel.Channel parent, LinuxSocket socket, boolean active)
    • AbstractIOUringStreamChannel

      AbstractIOUringStreamChannel(io.netty.channel.Channel parent, LinuxSocket fd, SocketAddress remote)
  • Method Details

    • newUnsafe

      Specified by:
      newUnsafe in class AbstractIOUringChannel
    • shutdown

      public io.netty.channel.ChannelFuture shutdown()
      Specified by:
      shutdown in interface io.netty.channel.socket.DuplexChannel
    • shutdown

      public io.netty.channel.ChannelFuture shutdown(io.netty.channel.ChannelPromise promise)
      Specified by:
      shutdown in interface io.netty.channel.socket.DuplexChannel
    • doShutdownOutput

      @UnstableApi protected final void doShutdownOutput() throws Exception
      Overrides:
      doShutdownOutput in class io.netty.channel.AbstractChannel
      Throws:
      Exception
    • shutdownInput0

      private void shutdownInput0(io.netty.channel.ChannelPromise promise)
    • isOutputShutdown

      public boolean isOutputShutdown()
      Specified by:
      isOutputShutdown in interface io.netty.channel.socket.DuplexChannel
    • isInputShutdown

      public boolean isInputShutdown()
      Specified by:
      isInputShutdown in interface io.netty.channel.socket.DuplexChannel
    • isShutdown

      public boolean isShutdown()
      Specified by:
      isShutdown in interface io.netty.channel.socket.DuplexChannel
    • shutdownOutput

      public io.netty.channel.ChannelFuture shutdownOutput()
      Specified by:
      shutdownOutput in interface io.netty.channel.socket.DuplexChannel
    • shutdownOutput

      public io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise promise)
      Specified by:
      shutdownOutput in interface io.netty.channel.socket.DuplexChannel
    • shutdownInput

      public io.netty.channel.ChannelFuture shutdownInput()
      Specified by:
      shutdownInput in interface io.netty.channel.socket.DuplexChannel
    • shutdownInput

      public io.netty.channel.ChannelFuture shutdownInput(io.netty.channel.ChannelPromise promise)
      Specified by:
      shutdownInput in interface io.netty.channel.socket.DuplexChannel
    • shutdownOutputDone

      private void shutdownOutputDone(io.netty.channel.ChannelFuture shutdownOutputFuture, io.netty.channel.ChannelPromise promise)
    • shutdownDone

      private static void shutdownDone(io.netty.channel.ChannelFuture shutdownOutputFuture, io.netty.channel.ChannelFuture shutdownInputFuture, io.netty.channel.ChannelPromise promise)
    • doRegister

      protected void doRegister() throws Exception
      Overrides:
      doRegister in class AbstractIOUringChannel
      Throws:
      Exception