Skip to content

Commit ef7d824

Browse files
committed
Post entry directly to cqueue.
1 parent ffae164 commit ef7d824

File tree

1 file changed

+3
-12
lines changed

1 file changed

+3
-12
lines changed

src/driver/iour/mod.rs

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,8 @@
11
use crate::driver::{Entry, Poller};
22
use crossbeam_queue::SegQueue;
33
use io_uring::{
4-
cqueue,
5-
opcode::MsgRingData,
6-
squeue,
7-
types::{Fd, SubmitArgs, Timespec},
4+
cqueue, squeue,
5+
types::{SubmitArgs, Timespec},
86
IoUring,
97
};
108
use std::{cell::RefCell, io, marker::PhantomData, mem::MaybeUninit, time::Duration};
@@ -114,14 +112,7 @@ impl Poller for Driver {
114112
}
115113

116114
fn post(&self, user_data: usize, result: usize) -> io::Result<()> {
117-
let entry = MsgRingData::new(
118-
Fd(self.inner.as_raw_fd()),
119-
result as i32,
120-
user_data as _,
121-
None,
122-
)
123-
.build();
124-
self.squeue.push(entry);
115+
self.cqueue.push(Entry::new(user_data, Ok(result)));
125116
Ok(())
126117
}
127118

0 commit comments

Comments
 (0)