| /external/crosvm/devices/src/virtio/ |
| D | pmem.rs | 127 fn handle_request(&self, avail_desc: DescriptorChain) -> Result<usize> { in handle_request()
129 Reader::new(self.memory.clone(), avail_desc.clone()).map_err(Error::Descriptor)?; in handle_request()
130 let mut writer = Writer::new(self.memory.clone(), avail_desc).map_err(Error::Descriptor)?; in handle_request()
148 while let Some(avail_desc) = self.queue.pop(&self.memory) { in process_queue()
149 let avail_desc_index = avail_desc.index; in process_queue()
151 let bytes_written = match self.handle_request(avail_desc) { in process_queue()
|
| D | tpm.rs | 84 let avail_desc = match self.queue.pop(&self.mem) { in process_queue() localVariable
85 Some(avail_desc) => avail_desc, in process_queue()
89 let index = avail_desc.index; in process_queue()
91 let len = match self.device.perform_work(&self.mem, avail_desc) { in process_queue()
|
| D | block.rs | 265 avail_desc: DescriptorChain, in process_one_request()
276 Reader::new(mem.clone(), avail_desc.clone()).map_err(ExecuteError::Descriptor)?; in process_one_request()
277 let mut writer = Writer::new(mem.clone(), avail_desc).map_err(ExecuteError::Descriptor)?; in process_one_request()
322 while let Some(avail_desc) = queue.pop(&self.mem) { in process_queue()
324 let desc_index = avail_desc.index; in process_queue()
327 avail_desc, in process_queue()
962 let avail_desc = create_descriptor_chain( in read_last_sector() localVariable
982 avail_desc, in read_last_sector()
1016 let avail_desc = create_descriptor_chain( in read_beyond_last_sector() localVariable
1036 avail_desc, in read_beyond_last_sector()
[all …]
|
| 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 | 47 while let Some(avail_desc) = queue.pop(&self.mem) { in process_queue()
48 let index = avail_desc.index; in process_queue()
50 let written = match Writer::new(self.mem.clone(), avail_desc) in process_queue()
|
| D | block_async.rs | 245 avail_desc: DescriptorChain, in process_one_request()
252 Reader::new(mem.clone(), avail_desc.clone()).map_err(ExecuteError::Descriptor)?; in process_one_request()
253 let mut writer = Writer::new(mem.clone(), avail_desc).map_err(ExecuteError::Descriptor)?; in process_one_request()
288 avail_desc: DescriptorChain, in process_one_request_task()
295 let descriptor_index = avail_desc.index; in process_one_request_task()
297 match process_one_request(avail_desc, disk_state, flush_timer, flush_timer_armed, &mem) in process_one_request_task()
1095 let avail_desc = create_descriptor_chain( in read_last_sector() localVariable
1125 let fut = process_one_request(avail_desc, disk_state, flush_timer, flush_timer_armed, &mem); in read_last_sector()
1162 let avail_desc = create_descriptor_chain( in read_beyond_last_sector() localVariable
1194 let fut = process_one_request(avail_desc, disk_state, flush_timer, flush_timer_armed, &mem); in read_beyond_last_sector()
[all …]
|
| D | balloon.rs | 114 avail_desc: DescriptorChain, in handle_address_chain()
127 let mut reader = Reader::new(mem.clone(), avail_desc)?; in handle_address_chain()
169 let avail_desc = match queue.next_async(mem, &mut queue_event).await { in handle_queue() localVariable
176 let index = avail_desc.index; in handle_queue()
177 if let Err(e) = handle_address_chain(avail_desc, mem, &mut desc_handler) { in handle_queue()
|
| D | console.rs | 67 while let Some(avail_desc) = transmit_queue.pop(&self.mem) { in process_transmit_queue()
68 let desc_index = avail_desc.index; in process_transmit_queue()
70 let reader = match Reader::new(self.mem.clone(), avail_desc) { in process_transmit_queue()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 354 avail_desc: DescriptorChain, in fill_event_virtqueue()
357 let mut writer = Writer::new(mem.clone(), avail_desc).map_err(InputError::Descriptor)?; in fill_event_virtqueue()
380 Some(avail_desc) => { in send_events()
381 let avail_desc_index = avail_desc.index; in send_events()
385 avail_desc, in send_events()
410 avail_desc: DescriptorChain, in read_event_virtqueue()
414 let mut reader = Reader::new(mem.clone(), avail_desc).map_err(InputError::Descriptor)?; in read_event_virtqueue()
425 while let Some(avail_desc) = self.status_queue.pop(&self.guest_memory) { in process_status_queue()
426 let avail_desc_index = avail_desc.index; in process_status_queue()
429 avail_desc, in process_status_queue()
|
| /external/crosvm/fuzz/ |
| D | virtqueue_fuzzer.rs | 99 while let Some(avail_desc) = q.pop(mem) {
100 let idx = avail_desc.index;
101 let total = avail_desc
|
| /external/crosvm/devices/src/virtio/fs/ |
| D | worker.rs | 159 while let Some(avail_desc) = self.queue.pop(&self.mem) { in process_queue()
160 let reader = Reader::new(self.mem.clone(), avail_desc.clone()) in process_queue()
162 let writer = Writer::new(self.mem.clone(), avail_desc.clone()) in process_queue()
168 .add_used(&self.mem, avail_desc.index, total as u32); in process_queue()
|