Searched refs:poll_ex (Results 1 – 2 of 2) sorted by relevance
197 let poll_ex = FdExecutor::new().unwrap(); in await_uring_from_poll() localVariable198 poll_ex.run_until(go(source)).unwrap(); in await_uring_from_poll()219 let poll_ex = FdExecutor::new().unwrap(); in await_poll_from_uring() localVariable221 let source = PollSource::new(f, &poll_ex).unwrap(); in await_poll_from_uring()226 let handle = thread::spawn(move || poll_ex.run_until(quit)); in await_poll_from_uring()253 let poll_ex = FdExecutor::new().unwrap(); in readvec() localVariable254 let poll_source = async_poll_from(f, &poll_ex).unwrap(); in readvec()255 poll_ex.run_until(go(poll_source)).unwrap(); in readvec()275 let poll_ex = FdExecutor::new().unwrap(); in writevec() localVariable276 let poll_source = async_poll_from(f, &poll_ex).unwrap(); in writevec()[all …]
75 let poll_ex = FdExecutor::new().unwrap(); in next_val_reads_value_poll_and_ring() localVariable76 let val = poll_ex in next_val_reads_value_poll_and_ring()77 .run_until(go(EventAsync::new_poll(eventfd, &poll_ex).unwrap())) in next_val_reads_value_poll_and_ring()