| /external/crosvm/cros_async/src/ |
| D | io_source.rs | 226 let source = ex.async_from(f).unwrap(); in readvec()
244 let source = ex.async_from(f.try_clone().unwrap()).unwrap(); in writevec()
278 let source = ex.async_from(f).unwrap(); in readmem()
304 let source = ex.async_from(f.try_clone().unwrap()).unwrap(); in writemem()
327 let source = ex.async_from(f).unwrap(); in fsync()
358 let source = ex.async_from(f).unwrap(); in readmulti()
381 let source = ex.async_from(f).unwrap(); in writemulti()
405 let source = ex.async_from(f).unwrap(); in read_current_file_position()
431 let source = ex.async_from(f.try_clone().unwrap()).unwrap(); in write_current_file_position()
|
| D | executor.rs | 215 fn async_from<'a, F: IntoAsync + 'a>(&self, f: F) -> AsyncResult<IoSource<F>>; in async_from() method
403 pub fn async_from<'a, F: IntoAsync + 'a>(&self, f: F) -> AsyncResult<IoSource<F>> { in async_from() method
406 Executor::Fd(ex) => ex.async_from(f), in async_from()
408 Executor::Uring(ex) => ex.async_from(f), in async_from()
410 Executor::Handle(ex) => ex.async_from(f), in async_from()
412 Executor::Overlapped(ex) => ex.async_from(f), in async_from()
414 Executor::Tokio(ex) => ex.async_from(f), in async_from()
428 _ => self.async_from(f), in async_overlapped_from()
|
| D | audio_streams_async.rs | 88 source: self.async_from(AsyncWrapper::new(stream))?, in async_unix_stream()
108 self.async_from(AsyncWrapper::new(Descriptor(fd)))? in wait_fd_readable()
|
| D | timer.rs | 24 ex.async_from(timer) in new()
|
| D | tokio_executor.rs | 82 fn async_from<'a, F: IntoAsync + 'a>(&self, f: F) -> AsyncResult<IoSource<F>> { in async_from() method
|
| D | common_executor.rs | 152 fn async_from<'a, F: IntoAsync + 'a>(&self, f: F) -> AsyncResult<IoSource<F>> { in async_from() method
|
| /external/crosvm/cros_async/src/sys/linux/ |
| D | event.rs | 14 ex.async_from(event) in new()
48 ex.async_from(event) in new_poll()
56 ex.async_from(event) in new_uring()
|
| D | timer.rs | 46 ex.async_from(timer) in new_poll()
54 ex.async_from(timer) in new_uring()
|
| D | async_types.rs | 22 inner: ex.async_from(tube)?, in new()
|
| D | uring_source.rs | 391 let source = uring_ex.async_from(f).unwrap(); in await_uring_from_poll()
426 let source = poll_ex.async_from(f).unwrap(); in await_poll_from_uring()
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | event.rs | 18 ex.async_from(event).map(|io_source| EventAsync { in new()
27 ex.async_from(event).map(|io_source| EventAsync { in new_without_reset()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/handler/sys/ |
| D | linux.rs | 24 .async_from(h) in run_handler()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/gpu/sys/ |
| D | linux.rs | 90 .async_from(bridge) in start_platform_workers()
106 .async_from(ctx) in start_platform_workers()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/connection/sys/linux/ |
| D | listener.rs | 63 .async_from(AsyncWrapper::new(listener)) in run_with_handler()
|
| /external/crosvm/disk/src/sys/ |
| D | linux.rs | 65 ex.async_from(disk) in new()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/net/sys/ |
| D | windows.rs | 198 .async_from(tap) in start_queue()
|
| D | linux.rs | 216 .async_from(tap) in start_queue()
|
| /external/crosvm/devices/src/virtio/video/ |
| D | worker.rs | 370 .async_from(AsyncWrapper::new( in run_async()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/ |
| D | wl.rs | 232 .async_from(ctx) in start_queue()
|
| /external/crosvm/disk/src/ |
| D | zstd.rs | 310 inner: ex.async_from(self.file).map_err(DiskError::ToAsync)?, in to_async_disk()
|
| D | android_sparse.rs | 327 inner: ex.async_from(self.file).map_err(DiskError::ToAsync)?, in to_async_disk()
|