Searched refs:URingExecutor (Results 1 – 7 of 7) sorted by relevance
| /external/crosvm/cros_async/src/ |
| D | uring_source.rs | 14 use crate::uring_executor::{Error, RegisteredSource, Result, URingExecutor};
48 pub fn new(io_source: F, ex: &URingExecutor) -> Result<UringSource<F>> { in new()
249 let ex = URingExecutor::new().unwrap(); in read_to_mem()
278 async fn go(ex: &URingExecutor) { in readvec() argument
290 let ex = URingExecutor::new().unwrap(); in readvec()
296 async fn go(ex: &URingExecutor) { in readmulti() argument
308 let ex = URingExecutor::new().unwrap(); in readmulti()
325 let ex = URingExecutor::new().unwrap(); in u64_from_file()
335 async fn write_event(ev: EventFd, wait: EventFd, ex: &URingExecutor) { in event() argument
345 async fn read_events(ev: EventFd, signal: EventFd, ex: &URingExecutor) { in event() argument
[all …]
|
| D | executor.rs | 12 AsyncResult, FdExecutor, IntoAsync, IoSourceExt, PollSource, URingExecutor, UringSource,
17 ex: &URingExecutor, in async_uring_from() argument
121 Uring(URingExecutor),
129 Ok(URingExecutor::new().map(Executor::Uring)?) in new()
|
| D | timer.rs | 11 use crate::{FdExecutor, URingExecutor};
30 pub(crate) fn new_uring(timer: TimerFd, ex: &URingExecutor) -> AsyncResult<TimerAsync> { in new_uring()
56 async fn this_test(ex: &URingExecutor) -> () { in one_shot() argument
73 let ex = URingExecutor::new().unwrap(); in one_shot()
|
| D | io_ext.rs | 137 use crate::{Executor, FdExecutor, MemRegion, PollSource, URingExecutor, UringSource};
188 let uring_ex = URingExecutor::new().unwrap(); in await_uring_from_poll()
228 let uring_ex = URingExecutor::new().unwrap(); in await_poll_from_uring()
248 let uring_ex = URingExecutor::new().unwrap(); in readvec()
270 let ex = URingExecutor::new().unwrap(); in writevec()
310 let ex = URingExecutor::new().unwrap(); in readmem()
336 let ex = URingExecutor::new().unwrap(); in writemem()
348 async fn go(async_source: File, ex: URingExecutor) -> u64 { in read_u64s()
354 let ex = URingExecutor::new().unwrap(); in read_u64s()
369 let ex = URingExecutor::new().unwrap(); in read_eventfds()
|
| D | event.rs | 26 pub(crate) fn new_uring(event: EventFd, ex: &crate::URingExecutor) -> AsyncResult<EventAsync> { in new_uring()
43 use crate::{Executor, FdExecutor, URingExecutor};
67 let uring_ex = URingExecutor::new().unwrap(); in next_val_reads_value_poll_and_ring()
|
| D | lib.rs | 86 pub use uring_executor::URingExecutor;
103 URingExecutor(uring_executor::Error), enumerator
155 URingExecutor::new() in run_one_uring()
157 .map_err(Error::URingExecutor) in run_one_uring()
|
| D | uring_executor.rs | 711 pub struct URingExecutor { struct
715 impl URingExecutor { impl
716 pub fn new() -> Result<URingExecutor> { in new()
719 Ok(URingExecutor { raw }) in new()
848 ex: &'a URingExecutor,
874 let ex = URingExecutor::new().unwrap(); in dont_drop_backing_mem_read()
914 let ex = URingExecutor::new().unwrap(); in dont_drop_backing_mem_write()
960 let ex = URingExecutor::new().unwrap(); in canceled_before_completion()
996 let ex = URingExecutor::new().unwrap(); in drop_before_completion()
1029 let ex = URingExecutor::new().unwrap(); in drop_on_different_thread()
|