Class 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, java.lang.Comparable<io.netty.channel.Channel>
    Direct Known Subclasses:
    IOUringSocketChannel

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

      • logger

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

      • 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,
                                     java.net.SocketAddress remote)
    • Method Detail

      • 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 java.lang.Exception
        Overrides:
        doShutdownOutput in class io.netty.channel.AbstractChannel
        Throws:
        java.lang.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)