1 use crate::arch::kvm::vmx::vcpu::VcpuContextFrame; 2 use crate::arch::KVMArch; 3 use crate::filesystem::devfs::DevFS; 4 use crate::filesystem::vfs::{ 5 core::generate_inode_id, file::FileMode, make_rawdev, FilePrivateData, FileSystem, FileType, 6 IndexNode, Metadata, 7 }; 8 use crate::mm::VirtAddr; 9 use crate::syscall::user_access::copy_from_user; 10 use crate::virt::kvm::vcpu::Vcpu; 11 use crate::virt::kvm::vm; 12 use crate::{filesystem, kdebug}; 13 use crate::{libs::spinlock::SpinLock, syscall::SystemError, time::TimeSpec}; 14 use alloc::{ 15 string::String, 16 sync::{Arc, Weak}, 17 vec::Vec, 18 }; 19 20 // pub const KVM_API_VERSION:u32 = 12; 21 pub const KVM_RUN: u32 = 0x00; 22 // pub const KVM_GET_REGS: u32 = 0x01; 23 pub const KVM_SET_REGS: u32 = 0x02; 24 25 // pub const GUEST_STACK_SIZE:usize = 1024; 26 // pub const HOST_STACK_SIZE:usize = 0x1000 * 6; 27 28 /* 29 * ioctls for /dev/vm fds: 30 */ 31 // pub const KVM_CREATE_VCPU: u32 = 0x00; 32 // pub const KVM_SET_USER_MEMORY_REGION: u32 = 0x01; 33 // pub const KVM_GET_DIRTY_LOG: u32 = 0x02; 34 // pub const KVM_IRQFD: u32 = 0x03; 35 // pub const KVM_IOEVENTFD: u32 = 0x04; 36 // pub const KVM_IRQ_LINE_STATUS: u32 = 0x05; 37 38 // #[derive(Debug)] 39 // pub struct InodeInfo { 40 // kvm: Arc<Hypervisor>, 41 // } 42 43 #[derive(Debug)] 44 pub struct VcpuInode { 45 /// uuid 暂时不知道有什么用（x 46 // uuid: Uuid, 47 /// 指向自身的弱引用 48 self_ref: Weak<LockedVcpuInode>, 49 /// 指向inode所在的文件系统对象的指针 50 fs: Weak<DevFS>, 51 /// INode 元数据 52 metadata: Metadata, 53 // fdata: InodeInfo, 54 } 55 56 #[derive(Debug)] 57 pub struct LockedVcpuInode(SpinLock<VcpuInode>); 58 59 impl LockedVcpuInode { 60 pub fn new() -> Arc<Self> { 61 let inode = VcpuInode { 62 self_ref: Weak::default(), 63 fs: Weak::default(), 64 metadata: Metadata { 65 dev_id: 1, 66 inode_id: generate_inode_id(), 67 size: 0, 68 blk_size: 0, 69 blocks: 0, 70 atime: TimeSpec::default(), 71 mtime: TimeSpec::default(), 72 ctime: TimeSpec::default(), 73 file_type: FileType::KvmDevice, // 文件夹，block设备，char设备 74 mode: filesystem::vfs::syscall::ModeType::S_IALLUGO, 75 nlinks: 1, 76 uid: 0, 77 gid: 0, 78 raw_dev: make_rawdev(1, 4), // 这里用来作为device number 79 }, 80 // fdata: InodeInfo { 81 // kvm: kvm, 82 // }, 83 }; 84 85 let result = Arc::new(LockedVcpuInode(SpinLock::new(inode))); 86 result.0.lock().self_ref = Arc::downgrade(&result); 87 88 return result; 89 } 90 } 91 92 impl IndexNode for LockedVcpuInode { 93 fn as_any_ref(&self) -> &dyn core::any::Any { 94 self 95 } 96 97 fn open(&self, _data: &mut FilePrivateData, _mode: &FileMode) -> Result<(), SystemError> { 98 kdebug!("file private data:{:?}", _data); 99 return Ok(()); 100 } 101 102 fn close(&self, _data: &mut FilePrivateData) -> Result<(), SystemError> { 103 return Ok(()); 104 } 105 106 fn metadata(&self) -> Result<Metadata, SystemError> { 107 return Ok(self.0.lock().metadata.clone()); 108 } 109 110 fn fs(&self) -> Arc<dyn FileSystem> { 111 return self.0.lock().fs.upgrade().unwrap(); 112 } 113 114 fn list(&self) -> Result<Vec<String>, SystemError> { 115 Err(SystemError::EOPNOTSUPP_OR_ENOTSUP) 116 } 117 118 fn set_metadata(&self, metadata: &Metadata) -> Result<(), SystemError> { 119 let mut inode = self.0.lock(); 120 inode.metadata.atime = metadata.atime; 121 inode.metadata.mtime = metadata.mtime; 122 inode.metadata.ctime = metadata.ctime; 123 inode.metadata.mode = metadata.mode; 124 inode.metadata.uid = metadata.uid; 125 inode.metadata.gid = metadata.gid; 126 127 return Ok(()); 128 } 129 130 /// @brief io control接口 131 /// 132 /// @param cmd 命令 133 /// @param data 数据 134 /// 135 /// @return 成功：Ok() 136 /// 失败：Err(错误码) 137 fn ioctl(&self, cmd: u32, data: usize) -> Result<usize, SystemError> { 138 match cmd { 139 0xdeadbeef => { 140 kdebug!("kvm_cpu ioctl"); 141 Ok(0) 142 } 143 KVM_RUN => { 144 kdebug!("kvm_cpu ioctl"); 145 // let guest_stack = vec![0xCC; GUEST_STACK_SIZE]; 146 // let host_stack = vec![0xCC; HOST_STACK_SIZE]; 147 // let guest_rsp = guest_stack.as_ptr() as u64 + GUEST_STACK_SIZE as u64; 148 // let host_rsp = (host_stack.as_ptr() as u64) + HOST_STACK_SIZE as u64; 149 // let hypervisor = Hypervisor::new(1, host_rsp, 0).expect("Cannot create hypervisor"); 150 // let vcpu = VmxVcpu::new(1, Arc::new(Mutex::new(hypervisor)), host_rsp, guest_rsp, guest_code as *const () as u64).expect("Cannot create VcpuData"); 151 // vcpu.virtualize_cpu().expect("Cannot virtualize cpu"); 152 let vcpu = vm(0).unwrap().vcpu[0].clone(); 153 vcpu.lock().virtualize_cpu()?; 154 KVMArch::kvm_arch_vcpu_ioctl_run(vcpu.as_ref())?; 155 Ok(0) 156 } 157 KVM_SET_REGS => { 158 let mut kvm_regs = VcpuContextFrame::default(); 159 unsafe { 160 copy_from_user( 161 core::slice::from_raw_parts_mut( 162 (&mut kvm_regs as *mut _) as *mut u8, 163 core::mem::size_of::<VcpuContextFrame>(), 164 ), 165 VirtAddr::new(data), 166 )?; 167 } 168 kdebug!( 169 "rip={:x}, rflags={:x}, rsp={:x}, rax={:x}", 170 kvm_regs.rip, 171 kvm_regs.rflags, 172 kvm_regs.regs[6], 173 kvm_regs.regs[0], 174 ); 175 176 let vcpu = vm(0).unwrap().vcpu[0].clone(); 177 vcpu.lock().set_regs(kvm_regs)?; 178 179 Ok(0) 180 } 181 _ => { 182 kdebug!("kvm_cpu ioctl"); 183 Ok(usize::MAX) 184 } 185 } 186 } 187 /// 读设备 - 应该调用设备的函数读写，而不是通过文件系统读写 188 fn read_at( 189 &self, 190 _offset: usize, 191 _len: usize, 192 _buf: &mut [u8], 193 _data: &mut FilePrivateData, 194 ) -> Result<usize, SystemError> { 195 Err(SystemError::EOPNOTSUPP_OR_ENOTSUP) 196 } 197 198 /// 写设备 - 应该调用设备的函数读写，而不是通过文件系统读写 199 fn write_at( 200 &self, 201 _offset: usize, 202 _len: usize, 203 _buf: &[u8], 204 _data: &mut FilePrivateData, 205 ) -> Result<usize, SystemError> { 206 Err(SystemError::EOPNOTSUPP_OR_ENOTSUP) 207 } 208 } 209