| /external/crosvm/devices/src/virtio/video/ |
| D | mod.rs | 162 mut queue_evts: Vec<Event>, in activate()
172 if queue_evts.len() != QUEUE_SIZES.len() { in activate()
175 queue_evts.len(), in activate()
190 let cmd_evt = queue_evts.remove(0); in activate()
192 let event_evt = queue_evts.remove(0); in activate()
|
| /external/crosvm/fuzz/ |
| D | block_fuzzer.rs | 78 let queue_evts: Vec<Event> = vec![Event::new().unwrap()]; localVariable
79 let queue_evt = queue_evts[0].try_clone().unwrap();
97 queue_evts,
|
| /external/crosvm/devices/src/virtio/ |
| D | virtio_pci_device.rs | 211 queue_evts: Vec<Event>, field
226 let mut queue_evts = Vec::new(); in new() localVariable
228 queue_evts.push(Event::new()?) in new()
276 queue_evts, in new()
387 self.queue_evts.iter().map(|e| e.try_clone()).collect() in clone_queue_evts()
531 self.queue_evts in ioevents()
701 Ok(queue_evts) => { in write_bar()
703 let (queues, queue_evts) = self in write_bar()
707 .zip(queue_evts.into_iter()) in write_bar()
711 self.device.activate(mem, interrupt, queues, queue_evts); in write_bar()
|
| D | console.rs | 208 fn run(&mut self, mut queues: Vec<Queue>, mut queue_evts: Vec<Event>, kill_evt: Event) { in run()
219 let (mut receive_queue, receive_evt) = (queues.remove(0), queue_evts.remove(0)); in run()
222 let (mut transmit_queue, transmit_evt) = (queues.remove(0), queue_evts.remove(0)); in run()
380 queue_evts: Vec<Event>, in activate()
382 if queues.len() < 2 || queue_evts.len() < 2 { in activate()
407 worker.run(queues, queue_evts, kill_evt); in activate()
|
| D | balloon.rs | 306 mut queue_evts: Vec<Event>, in run_worker()
323 let inflate_event = EventAsync::new(queue_evts.remove(0).0, &ex) in run_worker()
339 let deflate_event = EventAsync::new(queue_evts.remove(0).0, &ex) in run_worker()
353 EventAsync::new(queue_evts.remove(0).0, &ex).expect("failed to set up the stats event"); in run_worker()
474 queue_evts: Vec<Event>, in activate()
476 if queues.len() != QUEUE_SIZES.len() || queue_evts.len() != QUEUE_SIZES.len() { in activate()
495 queue_evts, in activate()
|
| D | rng.rs | 190 mut queue_evts: Vec<Event>, in activate()
192 if queues.len() != 1 || queue_evts.len() != 1 { in activate()
218 worker.run(queue_evts.remove(0), kill_evt); in activate()
|
| D | tpm.rs | 210 mut queue_evts: Vec<Event>, in activate()
212 if queues.len() != 1 || queue_evts.len() != 1 { in activate()
216 let queue_evt = queue_evts.remove(0); in activate()
|
| D | p9.rs | 224 mut queue_evts: Vec<Event>, in activate()
226 if queues.len() != 1 || queue_evts.len() != 1 { in activate()
251 worker.run(queue_evts.remove(0), kill_evt) in activate()
|
| D | net.rs | 647 mut queue_evts: Vec<Event>, in activate()
649 if queues.len() != self.queue_sizes.len() || queue_evts.len() != self.queue_sizes.len() { in activate()
687 let rx_queue_evt = queue_evts.remove(0); in activate()
688 let tx_queue_evt = queue_evts.remove(0); in activate()
690 Some(queue_evts.remove(queue_evts.len() - 1)) in activate()
|
| D | virtio_device.rs | 65 queue_evts: Vec<Event>, in activate()
|
| D | wl.rs | 1500 fn run(&mut self, mut queue_evts: Vec<Event>, kill_evt: Event) { in run()
1503 let in_queue_evt = queue_evts.remove(0); in run()
1504 let out_queue_evt = queue_evts.remove(0); in run()
1752 queue_evts: Vec<Event>, in activate()
1754 if queues.len() != QUEUE_SIZES.len() || queue_evts.len() != QUEUE_SIZES.len() { in activate()
1787 .run(queue_evts, kill_evt); in activate()
|
| D | block_async.rs | 483 queue_evts: Vec<Event>, in run_worker()
506 .zip(queue_evts.into_iter().map(|e| { in run_worker()
878 queue_evts: Vec<Event>, in activate()
920 queue_evts, in activate()
|
| D | block.rs | 791 mut queue_evts: Vec<Event>, in activate()
793 if queues.len() != 1 || queue_evts.len() != 1 { in activate()
827 worker.run(queue_evts.remove(0), kill_evt); in activate()
|
| /external/crosvm/devices/src/virtio/vhost/ |
| D | vsock.rs | 153 queue_evts: Vec<Event>, in activate()
155 if queues.len() != NUM_QUEUES || queue_evts.len() != NUM_QUEUES { in activate()
187 worker.run(queue_evts, QUEUE_SIZES, activate_vqs, cleanup_vqs); in activate()
|
| D | net.rs | 196 queue_evts: Vec<Event>, in activate()
198 if queues.len() != NUM_QUEUES || queue_evts.len() != NUM_QUEUES { in activate()
242 worker.run(queue_evts, QUEUE_SIZES, activate_vqs, cleanup_vqs); in activate()
|
| D | worker.rs | 49 queue_evts: Vec<Event>, in run()
94 .set_vring_kick(queue_index, &queue_evts[queue_index]) in run()
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | net.rs | 123 queue_evts: Vec<Event>, in activate()
136 .activate(&mem, &interrupt, &queues, &queue_evts) in activate()
|
| D | block.rs | 125 queue_evts: Vec<Event>, in activate()
130 .activate(&mem, &interrupt, &queues, &queue_evts) in activate()
|
| D | fs.rs | 124 queue_evts: Vec<Event>, in activate()
129 .activate(&mem, &interrupt, &queues, &queue_evts) in activate()
|
| D | handler.rs | 204 queue_evts: &[Event], in activate()
209 let queue_evt = &queue_evts[queue_index]; in activate()
|
| /external/crosvm/devices/src/virtio/fs/ |
| D | mod.rs | 243 queue_evts: Vec<Event>, in activate()
245 if queues.len() != self.queue_sizes.len() || queue_evts.len() != self.queue_sizes.len() { in activate()
278 for (idx, (queue, evt)) in queues.into_iter().zip(queue_evts.into_iter()).enumerate() { in activate()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 597 mut queue_evts: Vec<Event>, in activate()
599 if queues.len() != 2 || queue_evts.len() != 2 { in activate()
614 let status_queue_evt = queue_evts.remove(1); in activate()
617 let event_queue_evt = queue_evts.remove(0); in activate()
|
| /external/crosvm/devices/src/virtio/gpu/ |
| D | mod.rs | 1105 mut queue_evts: Vec<Event>, in activate()
1107 if queues.len() != QUEUE_SIZES.len() || queue_evts.len() != QUEUE_SIZES.len() { in activate()
1131 let ctrl_evt = queue_evts.remove(0); in activate()
1133 let cursor_evt = queue_evts.remove(0); in activate()
|