Top Description Fields Constructors Methods

io.netty.incubator.channel.uring

pack-priv final Class IOUringCompletionQueue

Class Inheritance

extends Object

java.lang.Object
io.netty.incubator.channel.uring.IOUringCompletionQueue

Imports

io.netty.util.internal.PlatformDependent

Completion queue implementation for io_uring.

Field Summary

Modifier and Type	Field and 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
pack-priv final long	ringAddress
pack-priv final int	ringFd
private int	ringHead
private final int	ringMask
pack-priv final int	ringSize

Constructor Summary

Access	Constructor and Description
pack-priv	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 and Description
pack-priv boolean	hasCompletions() Returns `true` if any completion event is ready to be processed by `process(IOUringCompletionQueueCallback)`, `false` otherwise.
pack-priv void	ioUringWaitCqe() Block until there is at least one completion ready to be processed.
pack-priv int	process(IOUringCompletionQueueCallback callback) Process the completion events in the `IOUringCompletionQueue` and return the number of processed events.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

completionQueueArrayAddress	back to summary
private final long completionQueueArrayAddress

CQE_FLAGS_FIELD	back to summary
private static final int CQE_FLAGS_FIELD

CQE_RES_FIELD	back to summary
private static final int CQE_RES_FIELD

CQE_SIZE	back to summary
private static final int CQE_SIZE

CQE_USER_DATA_FIELD	back to summary
private static final int CQE_USER_DATA_FIELD

kHeadAddress	back to summary
private final long kHeadAddress

kTailAddress	back to summary
private final long kTailAddress

ringAddress	back to summary
pack-priv final long ringAddress

ringFd	back to summary
pack-priv final int ringFd

ringHead	back to summary
private int ringHead

ringMask	back to summary
private final int ringMask

ringSize	back to summary
pack-priv final int ringSize

Constructor Detail

IOUringCompletionQueue	back to summary
pack-priv IOUringCompletionQueue(long kHeadAddress, long kTailAddress, long kRingMaskAddress, long kRingEntriesAddress, long kOverflowAddress, long completionQueueArrayAddress, int ringSize, long ringAddress, int ringFd)

Method Detail

hasCompletions	back to summary
pack-priv boolean hasCompletions() Returns `true` if any completion event is ready to be processed by `process(IOUringCompletionQueueCallback)`, `false` otherwise.

ioUringWaitCqe	back to summary
pack-priv void ioUringWaitCqe() Block until there is at least one completion ready to be processed.

process	back to summary
pack-priv int process(IOUringCompletionQueueCallback callback) Process the completion events in the `IOUringCompletionQueue` and return the number of processed events.