Package io.netty.channel.uring

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 java.nio.ByteBuffer	completionQueueArray
private static int	CQE_FLAGS_FIELD
private static int	CQE_RES_FIELD
private static int	CQE_USER_DATA_FIELD
private int	cqeLength
private java.nio.ByteBuffer[]	extraCqeData
private static VarHandle	INT_HANDLE
private java.nio.ByteBuffer	kflags
private java.nio.ByteBuffer	khead
private java.nio.ByteBuffer	ktail
(package private) long	ringAddress
(package private) int	ringCapacity
(package private) int	ringEntries
(package private) int	ringFd
private int	ringHead
private int	ringMask
(package private) 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 Detail

INT_HANDLE

private static final VarHandle INT_HANDLE

CQE_USER_DATA_FIELD

private static final int CQE_USER_DATA_FIELD

See Also:

Constant Field Values

CQE_RES_FIELD

private static final int CQE_RES_FIELD

See Also:

Constant Field Values

CQE_FLAGS_FIELD

private static final int CQE_FLAGS_FIELD

See Also:

Constant Field Values

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 Detail

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 Detail

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)