Searched refs:tx_queue_evt (Results 1 – 5 of 5) sorted by relevance
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | worker.rs | 47 tx_queue_evt: Event, in try_new()
87 tx_queue_evt, in try_new()
533 tx_queue_evt: Event, in io_loop()
546 (&tx_queue_evt, Token::TxQAvailable), in io_loop()
557 tx_queue_evt.read().map_err(SoundError::QueueEvt)?; in io_loop()
|
| D | mod.rs | 139 let tx_queue_evt = queue_evts.remove(0); in activate() localVariable
160 tx_queue_evt, in activate()
|
| /external/crosvm/devices/src/virtio/ |
| D | net.rs | 384 tx_queue_evt: Event, in run()
390 (&tx_queue_evt, Token::TxQueue), in run()
435 if let Err(e) = tx_queue_evt.read() { in run()
753 let tx_queue_evt = queue_evts.remove(0); in activate() localVariable
773 let result = worker.run(rx_queue_evt, tx_queue_evt, ctrl_queue_evt); in activate()
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | proxy.rs | 354 tx_queue_evt: Event, in run()
362 (&tx_queue_evt, Token::TxQueue), in run()
417 if let Err(e) = tx_queue_evt.read() { in run()
1196 let tx_queue_evt = activate_params.queue_evts.remove(0); in start_worker() localVariable
1197 if let Err(e) = worker.run(rx_queue_evt, tx_queue_evt, main_thread_tube, kill_evt) { in start_worker()
|
| /external/crosvm/devices/src/virtio/snd/cras_backend/ |
| D | mod.rs | 696 let tx_queue_evt = evts_async.remove(0); in run_worker() localVariable
726 let f_tx = handle_pcm_queue(&mem, &streams, tx_send2, &tx_queue, tx_queue_evt); in run_worker()
|