Class IoUringBufferRing.RingConsumer

java.lang.Object
io.netty.channel.uring.IoUringBufferRing.RingConsumer
All Implemented Interfaces:
Consumer<ByteBuf>
Enclosing class:
IoUringBufferRing

private final class IoUringBufferRing.RingConsumer extends Object implements Consumer<ByteBuf>
  • Field Details

    • expectedBuffers

      private int expectedBuffers
    • num

      private short num
    • bid

      private short bid
    • oldTail

      private short oldTail
  • Constructor Details

    • RingConsumer

      private RingConsumer()
  • Method Details

    • fill

      short fill(short startBid, int numBuffers)
    • fill

      void fill(short bid)
    • accept

      public void accept(ByteBuf byteBuf)
      Specified by:
      accept in interface Consumer<ByteBuf>
    • add

      private void add(int tail, short bid, int offset, ByteBuf byteBuf)