Searched refs:control_queue (Results 1 – 8 of 8) sorted by relevance
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | worker.rs | 31 pub control_queue: Arc<Mutex<Queue>>, field
49 control_queue: Arc<Mutex<Queue>>, in try_new()
68 control_queue.clone(), in try_new()
92 control_queue, in try_new()
120 (self.control_queue.lock().event(), Token::ControlQAvailable), in control_loop()
137 self.control_queue in control_loop()
194 while let Some(mut avail_desc) = lock_pop_unlock(&self.control_queue) { in process_controlq_buffers()
205 &self.control_queue, in process_controlq_buffers()
276 let mut queue_lock = self.control_queue.lock(); in process_controlq_buffers()
363 &self.control_queue, in process_controlq_buffers()
[all …]
|
| D | streams.rs | 58 control_queue: Arc<Mutex<Queue>>, field
80 control_queue: Arc<Mutex<Queue>>, in try_new()
109 control_queue, in try_new()
248 reply_control_op_status(code, desc, &self.control_queue)?; in recv_msg()
|
| D | mod.rs | 135 let control_queue = queues.remove(&0).unwrap(); in activate() localVariable
152 Arc::new(Mutex::new(control_queue)), in activate()
200 let ctrl_queue = worker.control_queue.clone(); in virtio_sleep()
|
| /external/rust/pica/py/pica/pica/ |
| D | __init__.py | 14 self.control_queue = asyncio.Queue()
89 await self.control_queue.put(packet)
94 return await self.control_queue.get()
|
| /external/rust/android-crates-io/crates/virtio-drivers/src/device/ |
| D | gpu.rs | 31 control_queue: VirtQueue<H, { QUEUE_SIZE as usize }>, field
53 let control_queue = VirtQueue::new( in new() localVariable
76 control_queue, in new()
175 self.control_queue.add_notify_wait_pop( in request()
|
| D | sound.rs | 34 control_queue: VirtQueue<H, { QUEUE_SIZE as usize }>, field
73 let control_queue = VirtQueue::new( in new() localVariable
124 control_queue, in new()
166 self.control_queue.add_notify_wait_pop( in request()
|
| /external/rust/android-crates-io/crates/virtio-drivers-and-devices/src/device/ |
| D | gpu.rs | 31 control_queue: VirtQueue<H, { QUEUE_SIZE as usize }>, field
53 let control_queue = VirtQueue::new( in new() localVariable
76 control_queue, in new()
175 self.control_queue.add_notify_wait_pop( in request()
|
| D | sound.rs | 34 control_queue: VirtQueue<H, { QUEUE_SIZE as usize }>, field
73 let control_queue = VirtQueue::new( in new() localVariable
124 control_queue, in new()
166 self.control_queue.add_notify_wait_pop( in request()
|