Class AbstractIOUringChannel.AbstractUringUnsafe

    • Constructor Detail

      • AbstractUringUnsafe

        AbstractUringUnsafe()
    • Method Detail

      • scheduleWriteMultiple

        protected abstract int scheduleWriteMultiple​(io.netty.channel.ChannelOutboundBuffer in)
        Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write.
      • scheduleWriteSingle

        protected abstract int scheduleWriteSingle​(java.lang.Object msg)
        Schedule the write of a single message and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write
      • close

        public void close​(io.netty.channel.ChannelPromise promise)
        Specified by:
        close in interface io.netty.channel.Channel.Unsafe
      • forceClose

        private void forceClose​(io.netty.channel.ChannelPromise promise)
      • flush0

        protected final void flush0()
      • fulfillConnectPromise

        private void fulfillConnectPromise​(io.netty.channel.ChannelPromise promise,
                                           java.lang.Throwable cause)
      • fulfillConnectPromise

        private void fulfillConnectPromise​(io.netty.channel.ChannelPromise promise,
                                           boolean wasActive)
      • recvBufAllocHandle

        public final IOUringRecvByteAllocatorHandle recvBufAllocHandle()
        Specified by:
        recvBufAllocHandle in interface io.netty.channel.Channel.Unsafe
      • shutdownInput

        final void shutdownInput​(boolean rdHup)
      • fireEventAndClose

        private void fireEventAndClose​(java.lang.Object evt)
      • schedulePollIn

        final void schedulePollIn()
      • processDelayedClose

        final void processDelayedClose()
      • readComplete

        final void readComplete​(int res,
                                int data)
      • readComplete0

        protected abstract void readComplete0​(int res,
                                              int data,
                                              int outstandingCompletes)
        Called once a read was completed.
      • pollRdHup

        final void pollRdHup​(int res)
        Called once POLLRDHUP event is ready to be processed
      • pollIn

        final void pollIn​(int res)
        Called once POLLIN event is ready to be processed
      • scheduleFirstReadIfNeeded

        private void scheduleFirstReadIfNeeded()
      • scheduleFirstRead

        private void scheduleFirstRead()
      • scheduleRead

        protected final void scheduleRead()
      • scheduleRead0

        protected abstract int scheduleRead0()
        Schedule a read and returns the number of readComplete(int, int) calls that are expected because of the scheduled read.
      • pollOut

        final void pollOut​(int res)
        Called once POLLOUT event is ready to be processed
      • writeComplete

        final void writeComplete​(int res,
                                 int data)
        Called once a write was completed.
      • writeComplete0

        abstract boolean writeComplete0​(int res,
                                        int data,
                                        int outstanding)
        Called once a write was completed.
      • connectComplete

        void connectComplete​(int res)
        Connect was completed.
      • connect

        public void connect​(java.net.SocketAddress remoteAddress,
                            java.net.SocketAddress localAddress,
                            io.netty.channel.ChannelPromise promise)