Skip to content

Commit b692a4d

Browse files
authored
Merge pull request #179 from Berrysoft/fix/push-and-wait
fix(test): push_and_wait should poll in a loop
2 parents cba2bd2 + b160161 commit b692a4d

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

compio-driver/tests/file.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,9 @@ fn push_and_wait<O: OpCode + 'static>(driver: &mut Proactor, op: O) -> (usize, O
4646
PushEntry::Ready(res) => res.unwrap(),
4747
PushEntry::Pending(user_data) => {
4848
let mut entries = ArrayVec::<Entry, 1>::new();
49-
driver.poll(None, &mut entries).unwrap();
49+
while entries.is_empty() {
50+
driver.poll(None, &mut entries).unwrap();
51+
}
5052
let (n, op) = driver
5153
.pop(&mut entries.into_iter())
5254
.next()

compio/examples/driver.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,9 @@ fn push_and_wait<O: OpCode + 'static>(driver: &mut Proactor, op: O) -> (usize, O
4747
PushEntry::Ready(res) => res.unwrap(),
4848
PushEntry::Pending(user_data) => {
4949
let mut entries = ArrayVec::<Entry, 1>::new();
50-
driver.poll(None, &mut entries).unwrap();
50+
while entries.is_empty() {
51+
driver.poll(None, &mut entries).unwrap();
52+
}
5153
let (n, op) = driver
5254
.pop(&mut entries.into_iter())
5355
.next()

0 commit comments

Comments
 (0)