Function cq_advance [src]

For advanced use cases only that implement custom completion queue methods. Matches the implementation of cq_advance() in liburing.

Prototype

pub fn cq_advance(self: *IoUring, count: u32) void

Parameters

self: *IoUringcount: u32

Source

  pub 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);
    }
}  