We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d75b76e commit 4b5795bCopy full SHA for 4b5795b
compio-driver/src/iour/mod.rs
@@ -20,6 +20,7 @@ cfg_if::cfg_if! {
20
}
21
22
use io_uring::{
23
+ cqueue::more,
24
opcode::{AsyncCancel, PollAdd},
25
types::{Fd, SubmitArgs, Timespec},
26
IoUring,
@@ -152,9 +153,8 @@ impl Driver {
152
153
let completed_entries = cqueue.filter_map(|entry| match entry.user_data() {
154
Self::CANCEL => None,
155
Self::NOTIFY => {
- const IORING_CQE_F_MORE: u32 = 1 << 1;
156
let flags = entry.flags();
157
- debug_assert!(flags & IORING_CQE_F_MORE == IORING_CQE_F_MORE);
+ debug_assert!(more(flags));
158
self.notifier.clear().expect("cannot clear notifier");
159
None
160
0 commit comments