Searched refs:uring_ex (Results 1 – 2 of 2) sorted by relevance
67 let uring_ex = URingExecutor::new().unwrap(); in next_val_reads_value_poll_and_ring() localVariable68 let val = uring_ex in next_val_reads_value_poll_and_ring()69 .run_until(go(EventAsync::new_uring(eventfd, &uring_ex).unwrap())) in next_val_reads_value_poll_and_ring()
188 let uring_ex = URingExecutor::new().unwrap(); in await_uring_from_poll() localVariable190 let source = UringSource::new(f, &uring_ex).unwrap(); in await_uring_from_poll()195 let handle = thread::spawn(move || uring_ex.run_until(quit)); in await_uring_from_poll()228 let uring_ex = URingExecutor::new().unwrap(); in await_poll_from_uring() localVariable229 uring_ex.run_until(go(source)).unwrap(); in await_poll_from_uring()248 let uring_ex = URingExecutor::new().unwrap(); in readvec() localVariable249 let uring_source = async_uring_from(f, &uring_ex).unwrap(); in readvec()250 uring_ex.run_until(go(uring_source)).unwrap(); in readvec()