Class IoUringBufferRing.RingConsumer

  • All Implemented Interfaces:
    java.util.function.Consumer<ByteBuf>
    Enclosing class:
    IoUringBufferRing

    private final class IoUringBufferRing.RingConsumer
    extends java.lang.Object
    implements java.util.function.Consumer<ByteBuf>
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private short bid  
      private int expectedBuffers  
      private short num  
      private short oldTail  
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private RingConsumer()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void accept​(ByteBuf byteBuf)  
      private void add​(int tail, short bid, int offset, ByteBuf byteBuf)  
      (package private) void fill​(short bid)  
      (package private) short fill​(short startBid, int numBuffers)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface java.util.function.Consumer

        andThen
    • Field Detail

      • expectedBuffers

        private int expectedBuffers
      • num

        private short num
      • bid

        private short bid
      • oldTail

        private short oldTail
    • Constructor Detail

      • RingConsumer

        private RingConsumer()
    • Method Detail

      • fill

        short fill​(short startBid,
                   int numBuffers)
      • fill

        void fill​(short bid)
      • accept

        public void accept​(ByteBuf byteBuf)
        Specified by:
        accept in interface java.util.function.Consumer<ByteBuf>
      • add

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