| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | worker.rs | 206 while let Some(avail_desc) = lock_pop_unlock(&self.control_queue, &self.guest_memory) { in process_controlq_buffers()
207 let mut reader = Reader::new(self.guest_memory.clone(), avail_desc.clone()) in process_controlq_buffers()
217 avail_desc, in process_controlq_buffers()
258 self.send_info_reply(avail_desc, code, info_vec)?; in process_controlq_buffers()
281 let desc_index = avail_desc.index; in process_controlq_buffers()
282 let mut writer = Writer::new(self.guest_memory.clone(), avail_desc) in process_controlq_buffers()
324 self.send_info_reply(avail_desc, code, info_vec)?; in process_controlq_buffers()
351 self.send_info_reply(avail_desc, code, info_vec)?; in process_controlq_buffers()
353 VIRTIO_SND_R_PCM_SET_PARAMS => self.process_set_params(avail_desc, &read_buf)?, in process_controlq_buffers()
355 self.try_parse_pcm_hdr_and_send_msg(&read_buf, StreamMsg::Prepare(avail_desc))? in process_controlq_buffers()
[all …]
|
| /external/crosvm/devices/src/virtio/ |
| D | balloon.rs | 299 avail_desc: DescriptorChain, in handle_address_chain()
312 let mut reader = Reader::new(mem.clone(), avail_desc)?; in handle_address_chain()
357 let avail_desc = match queue.next_async(mem, &mut queue_event).await { in handle_queue() localVariable
364 let index = avail_desc.index; in handle_queue()
366 handle_address_chain(release_memory_tube, avail_desc, mem, &mut desc_handler) in handle_queue()
378 avail_desc: DescriptorChain, in handle_reported_buffer()
385 let regions = avail_desc.into_iter(); in handle_reported_buffer()
408 let avail_desc = match queue.next_async(mem, &mut queue_event).await { in handle_reporting_queue() localVariable
415 let index = avail_desc.index; in handle_reporting_queue()
416 if let Err(e) = handle_reported_buffer(release_memory_tube, avail_desc, &mut desc_handler) { in handle_reporting_queue()
[all …]
|
| D | pmem.rs | 130 avail_desc: DescriptorChain, in handle_request()
135 let mut reader = Reader::new(mem.clone(), avail_desc.clone()).map_err(Error::Descriptor)?; in handle_request()
136 let mut writer = Writer::new(mem.clone(), avail_desc).map_err(Error::Descriptor)?; in handle_request()
162 let avail_desc = match queue.next_async(mem, &mut queue_event).await { in handle_queue() localVariable
169 let index = avail_desc.index; in handle_queue()
172 avail_desc, in handle_queue()
|
| D | p9.rs | 89 while let Some(avail_desc) = self.queue.pop(&self.mem) { in process_queue()
90 let mut reader = Reader::new(self.mem.clone(), avail_desc.clone()) in process_queue()
92 let mut writer = Writer::new(self.mem.clone(), avail_desc.clone()) in process_queue()
100 .add_used(&self.mem, avail_desc.index, writer.bytes_written() as u32); in process_queue()
|
| D | rng.rs | 52 while let Some(avail_desc) = queue.pop(&self.mem) { in process_queue()
53 let index = avail_desc.index; in process_queue()
55 let writer_or_err = Writer::new(self.mem.clone(), avail_desc) in process_queue()
|
| D | tpm.rs | 94 while let Some(avail_desc) = self.queue.pop(&self.mem) { in process_queue()
95 let index = avail_desc.index; in process_queue()
97 let len = match self.perform_work(avail_desc) { in process_queue()
|
| D | iommu.rs | 552 avail_desc: &DescriptorChain, in execute_request()
555 Reader::new(self.mem.clone(), avail_desc.clone()).map_err(IommuError::CreateReader)?; in execute_request()
557 Writer::new(self.mem.clone(), avail_desc.clone()).map_err(IommuError::CreateWriter)?; in execute_request()
603 let avail_desc = queue in request_queue() localVariable
607 let desc_index = avail_desc.index; in request_queue()
609 let (len, fault_resolved_event) = match state.borrow_mut().execute_request(&avail_desc) { in request_queue()
|
| D | console.rs | 158 while let Some(avail_desc) = transmit_queue.pop(mem) { in process_transmit_queue()
159 let desc_index = avail_desc.index; in process_transmit_queue()
161 match Reader::new(mem.clone(), avail_desc) { in process_transmit_queue()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 357 avail_desc: DescriptorChain, in fill_event_virtqueue()
360 let mut writer = Writer::new(mem.clone(), avail_desc).map_err(InputError::Descriptor)?; in fill_event_virtqueue()
383 Some(avail_desc) => { in send_events()
384 let avail_desc_index = avail_desc.index; in send_events()
388 avail_desc, in send_events()
413 avail_desc: DescriptorChain, in read_event_virtqueue()
417 let mut reader = Reader::new(mem.clone(), avail_desc).map_err(InputError::Descriptor)?; in read_event_virtqueue()
428 while let Some(avail_desc) = self.status_queue.pop(&self.guest_memory) { in process_status_queue()
429 let avail_desc_index = avail_desc.index; in process_status_queue()
432 avail_desc, in process_status_queue()
|
| /external/crosvm/crosvm-fuzz/ |
| D | virtqueue_fuzzer.rs | 109 while let Some(avail_desc) = q.pop(mem) {
110 let idx = avail_desc.index;
111 let total = avail_desc
|
| /external/crosvm/devices/src/virtio/fs/ |
| D | worker.rs | 161 while let Some(avail_desc) = queue.pop(mem) { in process_fs_queue()
163 Reader::new(mem.clone(), avail_desc.clone()).map_err(Error::InvalidDescriptorChain)?; in process_fs_queue()
165 Writer::new(mem.clone(), avail_desc.clone()).map_err(Error::InvalidDescriptorChain)?; in process_fs_queue()
169 queue.add_used(mem, avail_desc.index, total as u32); in process_fs_queue()
|
| /external/crosvm/devices/src/virtio/block/ |
| D | asynchronous.rs | 237 avail_desc: DescriptorChain, in process_one_request()
244 Reader::new(mem.clone(), avail_desc.clone()).map_err(ExecuteError::Descriptor)?; in process_one_request()
245 let mut writer = Writer::new(mem.clone(), avail_desc).map_err(ExecuteError::Descriptor)?; in process_one_request()
283 avail_desc: DescriptorChain, in process_one_chain()
290 let descriptor_index = avail_desc.index; in process_one_chain()
292 match process_one_request(avail_desc, disk_state, flush_timer, flush_timer_armed, &mem) in process_one_chain()
1252 let avail_desc = create_descriptor_chain( in read_last_sector() localVariable
1284 let fut = process_one_request(avail_desc, disk_state, flush_timer, flush_timer_armed, &mem); in read_last_sector()
1313 let avail_desc = create_descriptor_chain( in read_beyond_last_sector() localVariable
1347 let fut = process_one_request(avail_desc, disk_state, flush_timer, flush_timer_armed, &mem); in read_beyond_last_sector()
[all …]
|
| /external/crosvm/devices/src/virtio/vsock/sys/windows/ |
| D | vsock.rs | 1121 let avail_desc = match queue.next_async(&self.mem, queue_evt).await { in get_next_writer() localVariable
1128 let index = avail_desc.index; in get_next_writer()
1129 Writer::new(self.mem.clone(), avail_desc) in get_next_writer()
1190 let avail_desc = match queue.next_async(&self.mem, queue_evt).await { in get_next() localVariable
1197 let index = avail_desc.index; in get_next()
1198 Reader::new(self.mem.clone(), avail_desc) in get_next()
|