| /external/crosvm/cros_async/src/ |
| D | event.rs | 11 pub struct EventAsync { struct
17 impl EventAsync { argument
26 unsafe impl Send for EventAsync {} implementation
|
| D | io_ext.rs | 23 EventAsync(base::Error), enumerator
37 EventAsync(base::Error), enumerator
|
| D | audio_streams_async.rs | 77 impl EventAsyncWrapper for EventAsync { implementation
|
| D | lib.rs | 116 EventAsync(base::Error), enumerator
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | event.rs | 16 impl EventAsync { implementation
17 pub fn new(event: Event, ex: &Executor) -> AsyncResult<EventAsync> { in new()
26 pub fn new_without_reset(event: Event, ex: &Executor) -> AsyncResult<EventAsync> { in new_without_reset()
38 ) -> AsyncResult<EventAsync> { in clone_raw_without_reset()
|
| D | wait_for_handle.rs | 266 async fn wait_on_unsignaled_event(evt: EventAsync) { in test_unsignaled_event()
291 async fn wait_on_signaled_event(evt: EventAsync) { in test_signaled_event()
|
| /external/crosvm/cros_async/src/sys/unix/ |
| D | event.rs | 15 impl EventAsync { implementation
16 pub fn new(event: Event, ex: &Executor) -> AsyncResult<EventAsync> { in new()
27 pub(crate) fn new_poll(event: Event, ex: &FdExecutor) -> AsyncResult<EventAsync> { in new_poll()
32 pub(crate) fn new_uring(event: Event, ex: &URingExecutor) -> AsyncResult<EventAsync> { in new_uring()
|
| /external/crosvm/devices/src/virtio/vsock/sys/windows/ |
| D | vsock.rs | 329 mut rx_queue_evt: EventAsync, in process_rx_queue()
516 mut queue_evt: EventAsync, in process_tx_queue()
847 mut rx_queue_evt: EventAsync, in process_tx_packets_for_port()
872 rx_queue_evt: &mut EventAsync, in handle_tx_packet()
1039 rx_queue_evt: &mut EventAsync, in send_vsock_credit_update()
1081 rx_queue_evt: &mut EventAsync, in send_vsock_reset()
1119 queue_evt: &mut EventAsync, in get_next_writer()
1140 queue_evt: &mut EventAsync, in write_bytes_to_queue()
1188 queue_evt: &mut EventAsync, in get_next()
1276 async fn wait_event_and_return_port_pair(evt: EventAsync, pair: PortPair) -> PortPair { in wait_event_and_return_port_pair()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/net/sys/ |
| D | windows.rs | 88 kick_evt: EventAsync, in run_rx_queue()
89 read_notifier: EventAsync, in run_rx_queue()
|
| D | unix.rs | 142 kick_evt: EventAsync, in run_rx_queue()
|
| /external/crosvm/devices/src/virtio/ |
| D | iommu.rs | 211 ) -> (bool, Option<EventAsync>) { in detach_endpoint()
259 ) -> Result<(usize, Option<EventAsync>)> { in process_attach_request()
341 ) -> Result<(usize, Option<EventAsync>)> { in process_detach_request()
456 ) -> Result<(usize, Option<EventAsync>)> { in process_dma_unmap_request()
553 ) -> Result<(usize, Option<EventAsync>)> { in execute_request()
598 mut queue_event: EventAsync, in request_queue()
|
| D | balloon.rs | 349 mut queue_event: EventAsync, in handle_queue()
400 mut queue_event: EventAsync, in handle_reporting_queue()
445 mut queue_event: EventAsync, in handle_stats_queue()
559 mut queue_event: EventAsync, in handle_events_queue()
585 mut queue_event: EventAsync, in handle_wss_queue()
674 mut queue_event: EventAsync, in handle_wss_data_queue()
759 queue_event: &mut EventAsync, in send_initial_wss_config()
856 pending_adjusted_response_event: EventAsync, in handle_pending_adjusted_responses()
|
| D | pmem.rs | 155 mut queue_event: EventAsync, in handle_queue()
|
| D | queue.rs | 711 eventfd: &mut EventAsync, in next_async()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/ |
| D | net.rs | 45 kick_evt: EventAsync, in run_tx_queue()
62 kick_evt: EventAsync, in run_ctrl_queue()
|
| D | wl.rs | 59 kick_evt: EventAsync, in run_out_queue()
76 kick_evt: EventAsync, in run_in_queue()
|
| D | fs.rs | 50 kick_evt: EventAsync, in handle_fs_queue()
|
| D | gpu.rs | 66 kick_evt: EventAsync, in run_ctrl_queue()
|
| /external/crosvm/devices/src/virtio/iommu/ |
| D | memory_mapper.rs | 99 fn on_fault(&mut self) -> Option<EventAsync> { in on_fault()
192 fn reset_domain(&mut self) -> Option<EventAsync> { in reset_domain()
328 fn reset_domain(&mut self) -> Option<EventAsync> { in reset_domain()
|
| /external/crosvm/devices/src/virtio/console/ |
| D | asynchronous.rs | 63 kick_evt: EventAsync, in run_tx_queue()
79 kick_evt: EventAsync, in run_rx_queue()
|
| /external/crosvm/devices/src/virtio/snd/common_backend/ |
| D | async_funcs.rs | 588 queue_event: &EventAsync, in handle_pcm_queue()
676 queue_event: &mut EventAsync, in handle_ctrl_queue()
932 mut queue_event: EventAsync, in handle_event_queue()
|
| D | mod.rs | 600 ctrl_queue_evt: &mut EventAsync, in run_worker_once()
602 tx_queue_evt: &EventAsync, in run_worker_once()
606 rx_queue_evt: &EventAsync, in run_worker_once()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/gpu/sys/ |
| D | windows.rs | 54 display: EventAsync, in run_display()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/vvu/ |
| D | device.rs | 237 evt: EventAsync, in process_rxq()
282 async fn process_txq(evt: EventAsync, txq: Arc<Mutex<Queue>>) -> Result<()> { in process_txq()
|
| /external/crosvm/devices/src/virtio/block/ |
| D | asynchronous.rs | 314 evt: EventAsync, in handle_queue()
|