Class IOUringCompletionQueue

java.lang.Object

io.netty.incubator.channel.uring.IOUringCompletionQueue

final class IOUringCompletionQueue
extends Object

Completion queue implementation for io_uring.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	completionQueueArrayAddress
private static final int	CQE_FLAGS_FIELD
private static final int	CQE_RES_FIELD
private static final int	CQE_SIZE
private static final int	CQE_USER_DATA_FIELD
private final long	kHeadAddress
private final long	kTailAddress
(package private) final long	ringAddress
(package private) final int	ringFd
private int	ringHead
private final int	ringMask
(package private) final int	ringSize

Constructor Summary

Constructors

Constructor	Description
IOUringCompletionQueue(long kHeadAddress, long kTailAddress, long kRingMaskAddress, long kRingEntriesAddress, long kOverflowAddress, long completionQueueArrayAddress, int ringSize, long ringAddress, int ringFd)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	hasCompletions()	Returns true if any completion event is ready to be processed by process(IOUringCompletionQueueCallback), false otherwise.
(package private) void	ioUringWaitCqe()	Block until there is at least one completion ready to be processed.
(package private) int	process(IOUringCompletionQueueCallback callback)	Process the completion events in the IOUringCompletionQueue and return the number of processed events.

Methods inherited from class Object

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

Field Details

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

CQE_SIZE

private static final int CQE_SIZE

See Also:

• Constant Field Values

kHeadAddress

private final long kHeadAddress

kTailAddress

private final long kTailAddress

completionQueueArrayAddress

private final long completionQueueArrayAddress

ringSize

final int ringSize

ringAddress

final long ringAddress

ringFd

final int ringFd

ringMask

private final int ringMask

ringHead

private int ringHead

Constructor Details

IOUringCompletionQueue

IOUringCompletionQueue(long kHeadAddress,
 long kTailAddress,
 long kRingMaskAddress,
 long kRingEntriesAddress,
 long kOverflowAddress,
 long completionQueueArrayAddress,
 int ringSize,
 long ringAddress,
 int ringFd)

Method Details

hasCompletions

boolean hasCompletions()

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

process

int process(IOUringCompletionQueueCallback callback)

Process the completion events in the IOUringCompletionQueue and return the number of processed events.

ioUringWaitCqe

void ioUringWaitCqe()

Block until there is at least one completion ready to be processed.