Package io.netty.incubator.channel.uring
Class IOUringCompletionQueue
java.lang.Object
io.netty.incubator.channel.uring.IOUringCompletionQueue
Completion queue implementation for io_uring.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final long
private static final int
private static final int
private static final int
private static final int
private final long
private final long
(package private) final long
(package private) final int
private int
private final int
(package private) final int
-
Constructor Summary
ConstructorsConstructorDescriptionIOUringCompletionQueue
(long kHeadAddress, long kTailAddress, long kRingMaskAddress, long kRingEntriesAddress, long kOverflowAddress, long completionQueueArrayAddress, int ringSize, long ringAddress, int ringFd) -
Method Summary
Modifier and TypeMethodDescription(package private) boolean
Returnstrue
if any completion event is ready to be processed byprocess(IOUringCompletionQueueCallback)
,false
otherwise.(package private) void
Block until there is at least one completion ready to be processed.(package private) int
process
(IOUringCompletionQueueCallback callback) Process the completion events in theIOUringCompletionQueue
and return the number of processed events.
-
Field Details
-
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:
-
CQE_SIZE
private static final int CQE_SIZE- See Also:
-
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()Returnstrue
if any completion event is ready to be processed byprocess(IOUringCompletionQueueCallback)
,false
otherwise. -
process
Process the completion events in theIOUringCompletionQueue
and return the number of processed events. -
ioUringWaitCqe
void ioUringWaitCqe()Block until there is at least one completion ready to be processed.
-