Lines Matching refs:vfd
593 let mut vfd = WlVfd::default(); in connect() localVariable
594 vfd.socket = Some(socket); in connect()
595 Ok(vfd) in connect()
607 let mut vfd = WlVfd::default(); in allocate() localVariable
612 vfd.guest_shared_memory = Some(vfd_shm); in allocate()
613 vfd.slot = Some((slot, pfn, vm)); in allocate()
614 Ok(vfd) in allocate()
640 let mut vfd = WlVfd::default(); in dmabuf() localVariable
643 vfd.guest_shared_memory = Some(vfd_shm); in dmabuf()
644 vfd.slot = Some((slot, pfn, vm)); in dmabuf()
645 vfd.is_dmabuf = true; in dmabuf()
646 Ok((vfd, desc)) in dmabuf()
676 let mut vfd = WlVfd::default(); in pipe_remote_read_local_write() localVariable
677 vfd.remote_pipe = Some(read_pipe); in pipe_remote_read_local_write()
678 vfd.local_pipe = Some((VIRTIO_WL_VFD_WRITE, write_pipe)); in pipe_remote_read_local_write()
679 Ok(vfd) in pipe_remote_read_local_write()
684 let mut vfd = WlVfd::default(); in pipe_remote_write_local_read() localVariable
685 vfd.remote_pipe = Some(write_pipe); in pipe_remote_write_local_read()
686 vfd.local_pipe = Some((VIRTIO_WL_VFD_READ, read_pipe)); in pipe_remote_write_local_read()
687 Ok(vfd) in pipe_remote_write_local_read()
703 let mut vfd = WlVfd::default(); in from_file() localVariable
704 vfd.guest_shared_memory = Some(shm); in from_file()
705 vfd.slot = Some((slot, pfn, vm)); in from_file()
706 Ok(vfd) in from_file()
718 let mut vfd = WlVfd::default(); in from_file() localVariable
719 vfd.local_pipe = Some((flags, descriptor)); in from_file()
720 Ok(vfd) in from_file()
926 let vfd = if flags & VIRTIO_WL_VFD_WRITE != 0 { in new_pipe() localVariable
934 .add(vfd.wait_descriptor().unwrap(), id) in new_pipe()
943 entry.insert(vfd); in new_pipe()
965 let vfd = WlVfd::allocate(self.vm.clone(), size as u64)?; in new_alloc() localVariable
969 pfn: vfd.pfn().unwrap_or_default(), in new_alloc()
970 size: vfd.size().unwrap_or_default() as u32, in new_alloc()
973 entry.insert(vfd); in new_alloc()
988 let (vfd, desc) = WlVfd::dmabuf(self.vm.clone(), width, height, format)?; in new_dmabuf()
992 pfn: vfd.pfn().unwrap_or_default(), in new_dmabuf()
993 size: vfd.size().unwrap_or_default() as u32, in new_dmabuf()
996 entry.insert(vfd); in new_dmabuf()
1010 Some(vfd) => { in dmabuf_sync()
1011 vfd.dmabuf_sync(flags)?; in dmabuf_sync()
1031 let vfd = entry.insert(WlVfd::connect( in new_context() localVariable
1038 .add(vfd.wait_descriptor().unwrap(), id) in new_context()
1071 self.vfds.get(&vfd_id).and_then(|vfd| vfd.wait_descriptor()) in process_wait_context()
1096 Some(mut vfd) => { in close()
1098 vfd.close()?; in close()
1142 let vfd: CtrlVfdSendVfd = reader.read_obj().map_err(WlError::ParseDesc)?; in send() localVariable
1144 kind: vfd.kind, in send()
1145 payload: CtrlVfdSendVfdV2Payload { id: vfd.id }, in send()
1166 Some(vfd) => match vfd.send_descriptor() { in send()
1246 Some(vfd) => match vfd.send(&rds[..vfd_count], reader)? { in send()
1256 if let Some(vfd) = self.vfds.get_mut(&send_vfd_id.id().into()) { in send()
1257 vfd.close_remote(); in send()
1266 Some(vfd) => vfd.recv(&mut self.in_file_queue)?, in recv()
1274 let vfd = WlVfd::from_file(self.vm.clone(), file)?; in recv() localVariable
1275 if let Some(wait_descriptor) = vfd.wait_descriptor() { in recv()
1280 self.vfds.insert(self.next_vfd_id, vfd); in recv()
1390 Some(vfd) => Some(WlResp::VfdNew { in next_recv()
1392 flags: vfd.flags(self.use_transition_flags), in next_recv()
1393 pfn: vfd.pfn().unwrap_or_default(), in next_recv()
1394 size: vfd.size().unwrap_or_default() as u32, in next_recv()