Skip to content

Commit c96ba7e

Browse files
committed
update _io_uring_get_sqe to match upstream
1 parent 3c31342 commit c96ba7e

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

liburing-rs/src/lib.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1561,9 +1561,13 @@ unsafe fn _io_uring_get_sqe(ring: *mut io_uring) -> *mut io_uring_sqe
15611561
{
15621562
let sq = &raw mut (*ring).sq;
15631563

1564-
let head = io_uring_load_sq_head(ring);
1564+
let mut head = 0;
15651565
let tail = (*sq).sqe_tail;
15661566

1567+
if (*ring).flags & IORING_SETUP_SQ_REWIND == 0 {
1568+
head = io_uring_load_sq_head(ring);
1569+
}
1570+
15671571
if tail - head >= (*sq).ring_entries {
15681572
return ptr::null_mut();
15691573
}

0 commit comments

Comments
 (0)