Lines Matching refs:run_until
195 let handle = thread::spawn(move || uring_ex.run_until(quit)); in await_uring_from_poll()
198 poll_ex.run_until(go(source)).unwrap(); in await_uring_from_poll()
226 let handle = thread::spawn(move || poll_ex.run_until(quit)); in await_poll_from_uring()
229 uring_ex.run_until(go(source)).unwrap(); in await_poll_from_uring()
250 uring_ex.run_until(go(uring_source)).unwrap(); in readvec()
255 poll_ex.run_until(go(poll_source)).unwrap(); in readvec()
272 ex.run_until(go(uring_source)).unwrap(); in writevec()
277 poll_ex.run_until(go(poll_source)).unwrap(); in writevec()
312 ex.run_until(go(uring_source)).unwrap(); in readmem()
317 poll_ex.run_until(go(poll_source)).unwrap(); in readmem()
338 ex.run_until(go(uring_source)).unwrap(); in writemem()
343 poll_ex.run_until(go(poll_source)).unwrap(); in writemem()
355 let val = ex.run_until(go(f, ex.clone())).unwrap(); in read_u64s()
371 let val = ex.run_until(go(uring_source)).unwrap(); in read_eventfds()
378 let val = poll_ex.run_until(go(poll_source)).unwrap(); in read_eventfds()
398 ex.run_until(go(source)).unwrap(); in fsync()