Searched refs:queue_evt (Results 1 – 8 of 8) sorted by relevance
| /external/crosvm/devices/src/virtio/ |
| D | tpm.rs | 36 queue_evt: Event, field
115 (&self.queue_evt, Token::QueueAvailable), in run()
144 if let Err(e) = self.queue_evt.read() { in run()
216 let queue_evt = queue_evts.remove(0); in activate() localVariable
241 queue_evt, in activate()
|
| D | rng.rs | 68 fn run(&mut self, queue_evt: Event, kill_evt: Event) { in run()
77 (&queue_evt, Token::QueueAvailable), in run()
109 if let Err(e) = queue_evt.read() { in run()
|
| D | p9.rs | 108 fn run(&mut self, queue_evt: Event, kill_evt: Event) -> P9Result<()> { in run()
120 WaitContext::build_with(&[(&queue_evt, Token::QueueReady), (&kill_evt, Token::Kill)]) in run()
133 queue_evt.read().map_err(P9Error::ReadQueueEvent)?; in run()
|
| D | pmem.rs | 166 fn run(&mut self, queue_evt: Event, kill_evt: Event) { in run()
175 (&queue_evt, Token::QueueAvailable), in run()
207 if let Err(e) = queue_evt.read() { in run()
|
| D | block.rs | 378 fn run(&mut self, queue_evt: Event, kill_evt: Event) { in run()
399 (&queue_evt, Token::QueueAvailable), in run()
444 if let Err(e) = queue_evt.read() { in run()
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | handler.rs | 146 queue_evt: &Event, in activate_vring()
189 .set_vring_kick(queue_index, &queue_evt.0) in activate_vring()
209 let queue_evt = &queue_evts[queue_index]; in activate() localVariable
210 self.activate_vring(&mem, queue_index, queue, queue_evt, &interrupt)?; in activate()
|
| /external/crosvm/fuzz/ |
| D | block_fuzzer.rs | 79 let queue_evt = queue_evts[0].try_clone().unwrap(); localVariable
100 queue_evt.write(77).unwrap(); // Rings the doorbell, any byte will do.
|
| /external/crosvm/devices/src/virtio/fs/ |
| D | worker.rs | 182 queue_evt: Event, in run()
216 WaitContext::build_with(&[(&queue_evt, Token::QueueReady), (&kill_evt, Token::Kill)]) in run()
232 queue_evt.read().map_err(Error::ReadQueueEvent)?; in run()
|