Class AbstractIOUringChannel.AbstractUringUnsafe

java.lang.Object
io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
All Implemented Interfaces:
io.netty.channel.Channel.Unsafe
Direct Known Subclasses:
AbstractIOUringServerChannel.UringServerChannelUnsafe, AbstractIOUringStreamChannel.IOUringStreamUnsafe, IOUringDatagramChannel.IOUringDatagramChannelUnsafe
Enclosing class:
AbstractIOUringChannel

abstract class AbstractIOUringChannel.AbstractUringUnsafe extends Object
  • Field Details

  • Constructor Details

    • AbstractUringUnsafe

      AbstractUringUnsafe()
  • Method Details

    • 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(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, Throwable cause)
    • fulfillConnectPromise

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

      final IOUringRecvByteAllocatorHandle newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
    • 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(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(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise)