| ... | @@ -241,7 +241,7 @@ pub const IO_Uring = struct { | ... | @@ -241,7 +241,7 @@ pub const IO_Uring = struct { |
| 241 | pub fn sq_ring_needs_enter(self: *IO_Uring, submitted: u32, flags: *u32) bool { | 241 | pub fn sq_ring_needs_enter(self: *IO_Uring, submitted: u32, flags: *u32) bool { |
| 242 | assert(flags.* == 0); | 242 | assert(flags.* == 0); |
| 243 | if ((self.flags & linux.IORING_SETUP_SQPOLL) == 0 and submitted > 0) return true; | 243 | if ((self.flags & linux.IORING_SETUP_SQPOLL) == 0 and submitted > 0) return true; |
| 244 | if ((@atomicLoad(u32, self.sq.flags, .Acquire) & linux.IORING_SQ_NEED_WAKEUP) != 0) { | 244 | if ((@atomicLoad(u32, self.sq.flags, .Unordered) & linux.IORING_SQ_NEED_WAKEUP) != 0) { |
| 245 | flags.* |= linux.IORING_ENTER_SQ_WAKEUP; | 245 | flags.* |= linux.IORING_ENTER_SQ_WAKEUP; |
| 246 | return true; | 246 | return true; |
| 247 | } | 247 | } |