Searched refs:FdExecutor (Results 1 – 7 of 7) sorted by relevance
| /external/crosvm/cros_async/src/ |
| D | poll_source.rs | 15 use crate::fd_executor::{self, FdExecutor, RegisteredSource};
53 pub fn new(f: F, ex: &FdExecutor) -> Result<Self> { in new()
311 async fn go(ex: &FdExecutor) { in readvec() argument
323 let ex = FdExecutor::new().unwrap(); in readvec()
329 async fn go(ex: &FdExecutor) { in writevec() argument
340 let ex = FdExecutor::new().unwrap(); in writevec()
346 async fn go(ex: &FdExecutor) { in fallocate() argument
363 let ex = FdExecutor::new().unwrap(); in fallocate()
376 let ex = FdExecutor::new().unwrap(); in memory_leak()
|
| D | timer.rs | 11 use crate::{FdExecutor, URingExecutor};
25 pub(crate) fn new_poll(timer: TimerFd, ex: &FdExecutor) -> AsyncResult<TimerAsync> { in new_poll()
79 async fn this_test(ex: &FdExecutor) -> () { in one_shot_fd() argument
96 let ex = FdExecutor::new().unwrap(); in one_shot_fd()
|
| D | executor.rs | 12 AsyncResult, FdExecutor, IntoAsync, IoSourceExt, PollSource, URingExecutor, UringSource,
25 ex: &FdExecutor, in async_poll_from() argument
122 Fd(FdExecutor),
131 Ok(FdExecutor::new() in new()
|
| D | io_ext.rs | 137 use crate::{Executor, FdExecutor, MemRegion, PollSource, URingExecutor, UringSource};
197 let poll_ex = FdExecutor::new().unwrap(); in await_uring_from_poll()
219 let poll_ex = FdExecutor::new().unwrap(); in await_poll_from_uring()
253 let poll_ex = FdExecutor::new().unwrap(); in readvec()
275 let poll_ex = FdExecutor::new().unwrap(); in writevec()
315 let poll_ex = FdExecutor::new().unwrap(); in readmem()
341 let poll_ex = FdExecutor::new().unwrap(); in writemem()
376 let poll_ex = FdExecutor::new().unwrap(); in read_eventfds()
|
| D | event.rs | 21 pub(crate) fn new_poll(event: EventFd, ex: &crate::FdExecutor) -> AsyncResult<EventAsync> { in new_poll()
43 use crate::{Executor, FdExecutor, URingExecutor};
75 let poll_ex = FdExecutor::new().unwrap(); in next_val_reads_value_poll_and_ring()
|
| D | fd_executor.rs | 447 pub struct FdExecutor { struct
451 impl FdExecutor { argument
452 pub fn new() -> Result<FdExecutor> { in new()
463 Ok(FdExecutor { raw }) in new()
528 async fn do_test(ex: &FdExecutor) { in test_it() argument
539 let ex = FdExecutor::new().unwrap(); in test_it()
571 let ex = FdExecutor::new().unwrap(); in drop_before_completion()
|
| D | lib.rs | 78 pub use fd_executor::FdExecutor;
100 FdExecutor(fd_executor::Error), enumerator
171 FdExecutor::new() in run_one_poll()
173 .map_err(Error::FdExecutor) in run_one_poll()
|