Lines Matching refs:poll_ex
197 let poll_ex = FdExecutor::new().unwrap(); in await_uring_from_poll() localVariable
198 poll_ex.run_until(go(source)).unwrap(); in await_uring_from_poll()
219 let poll_ex = FdExecutor::new().unwrap(); in await_poll_from_uring() localVariable
221 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() localVariable
254 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() localVariable
276 let poll_source = async_poll_from(f, &poll_ex).unwrap(); in writevec()
277 poll_ex.run_until(go(poll_source)).unwrap(); in writevec()
315 let poll_ex = FdExecutor::new().unwrap(); in readmem() localVariable
316 let poll_source = async_poll_from(f, &poll_ex).unwrap(); in readmem()
317 poll_ex.run_until(go(poll_source)).unwrap(); in readmem()
341 let poll_ex = FdExecutor::new().unwrap(); in writemem() localVariable
342 let poll_source = async_poll_from(f, &poll_ex).unwrap(); in writemem()
343 poll_ex.run_until(go(poll_source)).unwrap(); in writemem()
376 let poll_ex = FdExecutor::new().unwrap(); in read_eventfds() localVariable
377 let poll_source = async_poll_from(eventfd, &poll_ex).unwrap(); in read_eventfds()
378 let val = poll_ex.run_until(go(poll_source)).unwrap(); in read_eventfds()