Searched refs:queue_evt (Results 1 – 5 of 5) sorted by relevance
| /external/crosvm/fuzz/fuzz_targets/ |
| D | block_fuzzer.rs | 96 let queue_evt = q.event().try_clone().unwrap(); localVariable
116 queue_evt.signal().unwrap(); // Rings the doorbell
|
| /external/crosvm/devices/src/virtio/ |
| D | pmem.rs | 309 let queue_evt = queue in run_worker() localVariable
313 let queue_evt = EventAsync::new(queue_evt, &ex).expect("failed to set up the queue event"); in run_worker() localVariable
318 queue_evt, in run_worker()
|
| D | virtio_mmio_device.rs | 153 let queue_evt = evt.try_clone().context("failed to clone queue_evt")?; in activate() localVariable
157 .activate(&mem, queue_evt, interrupt.clone()) in activate()
|
| D | virtio_pci_device.rs | 662 let queue_evt = evt.event.try_clone().context("failed to clone queue_evt")?; in activate() localVariable
666 .activate(&self.mem, queue_evt, interrupt.clone()) in activate()
1382 let queue_evt = self in restore() localVariable
1395 queue_evt, in restore()
|
| /external/crosvm/devices/src/virtio/vsock/sys/windows/ |
| D | vsock.rs | 669 mut queue_evt: EventAsync, in process_tx_queue()
676 .next_async_interruptable(&mut queue_evt, &mut stop_rx) in process_tx_queue()
1323 queue_evt: &mut EventAsync, in write_bytes_to_queue()
1326 let mut avail_desc = match queue.next_async(queue_evt).await { in write_bytes_to_queue()
1339 queue_evt: &mut EventAsync, in write_bytes_to_queue_interruptable()
1343 let mut avail_desc = match queue.next_async_interruptable(queue_evt, stop_rx).await { in write_bytes_to_queue_interruptable()
1391 mut queue_evt: EventAsync, in process_event_queue()
1410 &mut queue_evt, in process_event_queue()
|