Class CompletionQueue

java.lang.Object
io.netty.channel.uring.CompletionQueue
final class CompletionQueue extends java.lang.Object
Completion queue implementation for io_uring.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private boolean
    closed
     
    private final java.nio.ByteBuffer
    completionQueueArray
     
    private static final int
    CQE_FLAGS_FIELD
     
    private static final int
    CQE_RES_FIELD
     
    private static final int
    CQE_USER_DATA_FIELD
     
    private final int
    cqeLength
     
    private final java.nio.ByteBuffer[]
    extraCqeData
     
    private static final VarHandle
    INT_HANDLE
     
    private final java.nio.ByteBuffer
    kflags
     
    private final java.nio.ByteBuffer
    khead
     
    private final java.nio.ByteBuffer
    ktail
     
    (package private) final long
    ringAddress
     
    (package private) final int
    ringCapacity
     
    (package private) final int
    ringEntries
     
    (package private) final int
    ringFd
     
    private int
    ringHead
     
    private final int
    ringMask
     
    (package private) final int
    ringSize
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    CompletionQueue(java.nio.ByteBuffer kHead, java.nio.ByteBuffer kTail, int ringMask, int ringEntries, java.nio.ByteBuffer kflags, java.nio.ByteBuffer completionQueueArray, int ringSize, long ringAddress, int ringFd, int ringCapacity, int cqeLength, boolean extraCqeDataNeeded)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) void
    close()
     
    (package private) int
    count()
     
    private static int
    cqeIdx(int ringHead, int ringMask)
     
    private java.nio.ByteBuffer
    extraCqeData(int cqeIdx)
     
    (package private) int
    flags()
     
    (package private) boolean
    hasCompletions()
    Returns true if any completion event is ready to be processed by process(CompletionCallback), false otherwise.
    (package private) long
    process(CompletionCallback callback)
    Process the completion events in the CompletionQueue and return the number of processed events.
    java.lang.String
    toString()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Field Details

    • INT_HANDLE

      private static final VarHandle INT_HANDLE

    • CQE_USER_DATA_FIELD

      private static final int CQE_USER_DATA_FIELD
      See Also:

    • CQE_RES_FIELD

      private static final int CQE_RES_FIELD
      See Also:

    • CQE_FLAGS_FIELD

      private static final int CQE_FLAGS_FIELD
      See Also:

    • khead

      private final java.nio.ByteBuffer khead

    • ktail

      private final java.nio.ByteBuffer ktail

    • kflags

      private final java.nio.ByteBuffer kflags

    • completionQueueArray

      private final java.nio.ByteBuffer completionQueueArray

    • extraCqeData

      private final java.nio.ByteBuffer[] extraCqeData

    • ringSize

      final int ringSize

    • ringAddress

      final long ringAddress

    • ringFd

      final int ringFd

    • ringEntries

      final int ringEntries

    • ringCapacity

      final int ringCapacity

    • cqeLength

      private final int cqeLength

    • ringMask

      private final int ringMask

    • ringHead

      private int ringHead

    • closed

      private boolean closed

  • Constructor Details

    • CompletionQueue

      CompletionQueue(java.nio.ByteBuffer kHead, java.nio.ByteBuffer kTail, int ringMask, int ringEntries, java.nio.ByteBuffer kflags, java.nio.ByteBuffer completionQueueArray, int ringSize, long ringAddress, int ringFd, int ringCapacity, int cqeLength, boolean extraCqeDataNeeded)

  • Method Details

    • close

      void close()

    • flags

      int flags()

    • hasCompletions

      boolean hasCompletions()
      Returns true if any completion event is ready to be processed by process(CompletionCallback), false otherwise.

    • count

      int count()

    • process

      long process(CompletionCallback callback)
      Process the completion events in the CompletionQueue and return the number of processed events.

    • extraCqeData

      private java.nio.ByteBuffer extraCqeData(int cqeIdx)

    • toString

      public java.lang.String toString()
      Overrides:
      toString in class java.lang.Object

    • cqeIdx

      private static int cqeIdx(int ringHead, int ringMask)