pub fn cq_advance(self: *IoUring, count: u32) void self: *IoUringcount: u32335
336
337
338
339
340pub fn cq_advance(self: *IoUring, count: u32) void {
if (count > 0) {
// Ensure the kernel only sees the new head value after the CQEs have been read.
@atomicStore(u32, self.cq.head, self.cq.head.* +% count, .release);
}
}
For advanced use cases only that implement custom completion queue methods. Matches the implementation of cq_advance() in liburing.