1004e86ffSlogin use core::any::Any; 22dbef785SGnoCiYeH use core::intrinsics::unlikely; 3004e86ffSlogin 4004e86ffSlogin use alloc::{ 5004e86ffSlogin collections::BTreeMap, 6004e86ffSlogin string::String, 7004e86ffSlogin sync::{Arc, Weak}, 8004e86ffSlogin vec::Vec, 9004e86ffSlogin }; 10*91e9d4abSLoGin use system_error::SystemError; 11004e86ffSlogin 12004e86ffSlogin use crate::{ 13004e86ffSlogin filesystem::vfs::{core::generate_inode_id, FileType}, 142dbef785SGnoCiYeH ipc::pipe::LockedPipeInode, 15004e86ffSlogin libs::spinlock::{SpinLock, SpinLockGuard}, 1678bf93f0SYJwu2023 time::TimeSpec, 17004e86ffSlogin }; 18004e86ffSlogin 19004e86ffSlogin use super::vfs::{ 206b4e7a29SLoGin file::FilePrivateData, syscall::ModeType, FileSystem, FsInfo, IndexNode, InodeId, Metadata, 2140609970SGnoCiYeH SpecialNodeData, 22004e86ffSlogin }; 23004e86ffSlogin 24004e86ffSlogin /// RamFS的inode名称的最大长度 25004e86ffSlogin const RAMFS_MAX_NAMELEN: usize = 64; 26004e86ffSlogin 27004e86ffSlogin /// @brief 内存文件系统的Inode结构体 28004e86ffSlogin #[derive(Debug)] 29004e86ffSlogin struct LockedRamFSInode(SpinLock<RamFSInode>); 30004e86ffSlogin 31004e86ffSlogin /// @brief 内存文件系统结构体 32004e86ffSlogin #[derive(Debug)] 33004e86ffSlogin pub struct RamFS { 34004e86ffSlogin /// RamFS的root inode 35004e86ffSlogin root_inode: Arc<LockedRamFSInode>, 36004e86ffSlogin } 37004e86ffSlogin 38004e86ffSlogin /// @brief 内存文件系统的Inode结构体(不包含锁) 39004e86ffSlogin #[derive(Debug)] 40004e86ffSlogin pub struct RamFSInode { 41004e86ffSlogin // parent变量目前只在find函数中使用到 42004e86ffSlogin // 所以只有当inode是文件夹的时候,parent才会生效 43004e86ffSlogin // 对于文件来说,parent就没什么作用了 44004e86ffSlogin // 关于parent的说明: 目录不允许有硬链接 45004e86ffSlogin /// 指向父Inode的弱引用 46004e86ffSlogin parent: Weak<LockedRamFSInode>, 47004e86ffSlogin /// 指向自身的弱引用 48004e86ffSlogin self_ref: Weak<LockedRamFSInode>, 49004e86ffSlogin /// 子Inode的B树 50004e86ffSlogin children: BTreeMap<String, Arc<LockedRamFSInode>>, 51004e86ffSlogin /// 当前inode的数据部分 52004e86ffSlogin data: Vec<u8>, 53004e86ffSlogin /// 当前inode的元数据 54004e86ffSlogin metadata: Metadata, 55004e86ffSlogin /// 指向inode所在的文件系统对象的指针 56004e86ffSlogin fs: Weak<RamFS>, 572dbef785SGnoCiYeH /// 指向特殊节点 582dbef785SGnoCiYeH special_node: Option<SpecialNodeData>, 59004e86ffSlogin } 60004e86ffSlogin 61004e86ffSlogin impl FileSystem for RamFS { 62004e86ffSlogin fn root_inode(&self) -> Arc<dyn super::vfs::IndexNode> { 63004e86ffSlogin return self.root_inode.clone(); 64004e86ffSlogin } 65004e86ffSlogin 66004e86ffSlogin fn info(&self) -> FsInfo { 67004e86ffSlogin return FsInfo { 68004e86ffSlogin blk_dev_id: 0, 69004e86ffSlogin max_name_len: RAMFS_MAX_NAMELEN, 70004e86ffSlogin }; 71004e86ffSlogin } 72004e86ffSlogin 73004e86ffSlogin /// @brief 本函数用于实现动态转换。 74004e86ffSlogin /// 具体的文件系统在实现本函数时,最简单的方式就是:直接返回self 75004e86ffSlogin fn as_any_ref(&self) -> &dyn Any { 76004e86ffSlogin self 77004e86ffSlogin } 78004e86ffSlogin } 79004e86ffSlogin 80004e86ffSlogin impl RamFS { 81004e86ffSlogin pub fn new() -> Arc<Self> { 82004e86ffSlogin // 初始化root inode 83004e86ffSlogin let root: Arc<LockedRamFSInode> = Arc::new(LockedRamFSInode(SpinLock::new(RamFSInode { 84004e86ffSlogin parent: Weak::default(), 85004e86ffSlogin self_ref: Weak::default(), 86004e86ffSlogin children: BTreeMap::new(), 87004e86ffSlogin data: Vec::new(), 88004e86ffSlogin metadata: Metadata { 89004e86ffSlogin dev_id: 0, 90004e86ffSlogin inode_id: generate_inode_id(), 91004e86ffSlogin size: 0, 92004e86ffSlogin blk_size: 0, 93004e86ffSlogin blocks: 0, 94004e86ffSlogin atime: TimeSpec::default(), 95004e86ffSlogin mtime: TimeSpec::default(), 96004e86ffSlogin ctime: TimeSpec::default(), 97004e86ffSlogin file_type: FileType::Dir, 986b4e7a29SLoGin mode: ModeType::from_bits_truncate(0o777), 99004e86ffSlogin nlinks: 1, 100004e86ffSlogin uid: 0, 101004e86ffSlogin gid: 0, 102004e86ffSlogin raw_dev: 0, 103004e86ffSlogin }, 104004e86ffSlogin fs: Weak::default(), 1052dbef785SGnoCiYeH special_node: None, 106004e86ffSlogin }))); 107004e86ffSlogin 108004e86ffSlogin let result: Arc<RamFS> = Arc::new(RamFS { root_inode: root }); 109004e86ffSlogin 110004e86ffSlogin // 对root inode加锁,并继续完成初始化工作 111004e86ffSlogin let mut root_guard: SpinLockGuard<RamFSInode> = result.root_inode.0.lock(); 112004e86ffSlogin root_guard.parent = Arc::downgrade(&result.root_inode); 113004e86ffSlogin root_guard.self_ref = Arc::downgrade(&result.root_inode); 114004e86ffSlogin root_guard.fs = Arc::downgrade(&result); 115004e86ffSlogin // 释放锁 116004e86ffSlogin drop(root_guard); 117004e86ffSlogin 118004e86ffSlogin return result; 119004e86ffSlogin } 120004e86ffSlogin } 121004e86ffSlogin 122004e86ffSlogin impl IndexNode for LockedRamFSInode { 123a3ef8f8aSGnoCiYeH fn truncate(&self, len: usize) -> Result<(), SystemError> { 124a3ef8f8aSGnoCiYeH let mut inode = self.0.lock(); 125a3ef8f8aSGnoCiYeH 126a3ef8f8aSGnoCiYeH //如果是文件夹,则报错 127a3ef8f8aSGnoCiYeH if inode.metadata.file_type == FileType::Dir { 128a3ef8f8aSGnoCiYeH return Err(SystemError::EINVAL); 129a3ef8f8aSGnoCiYeH } 130a3ef8f8aSGnoCiYeH 131a3ef8f8aSGnoCiYeH //当前文件长度大于_len才进行截断,否则不操作 132a3ef8f8aSGnoCiYeH if inode.data.len() > len { 133a3ef8f8aSGnoCiYeH inode.data.resize(len, 0); 134a3ef8f8aSGnoCiYeH } 135a3ef8f8aSGnoCiYeH return Ok(()); 136a3ef8f8aSGnoCiYeH } 137a3ef8f8aSGnoCiYeH 138a3ef8f8aSGnoCiYeH fn close(&self, _data: &mut FilePrivateData) -> Result<(), SystemError> { 139a3ef8f8aSGnoCiYeH return Ok(()); 140a3ef8f8aSGnoCiYeH } 141a3ef8f8aSGnoCiYeH 142a3ef8f8aSGnoCiYeH fn open( 143a3ef8f8aSGnoCiYeH &self, 144a3ef8f8aSGnoCiYeH _data: &mut FilePrivateData, 145a3ef8f8aSGnoCiYeH _mode: &super::vfs::file::FileMode, 146a3ef8f8aSGnoCiYeH ) -> Result<(), SystemError> { 147a3ef8f8aSGnoCiYeH return Ok(()); 148a3ef8f8aSGnoCiYeH } 149a3ef8f8aSGnoCiYeH 150004e86ffSlogin fn read_at( 151004e86ffSlogin &self, 152004e86ffSlogin offset: usize, 153004e86ffSlogin len: usize, 154004e86ffSlogin buf: &mut [u8], 155004e86ffSlogin _data: &mut FilePrivateData, 156676b8ef6SMork ) -> Result<usize, SystemError> { 157004e86ffSlogin if buf.len() < len { 158676b8ef6SMork return Err(SystemError::EINVAL); 159004e86ffSlogin } 160004e86ffSlogin // 加锁 161004e86ffSlogin let inode: SpinLockGuard<RamFSInode> = self.0.lock(); 162004e86ffSlogin 163004e86ffSlogin // 检查当前inode是否为一个文件夹,如果是的话,就返回错误 164004e86ffSlogin if inode.metadata.file_type == FileType::Dir { 165676b8ef6SMork return Err(SystemError::EISDIR); 166004e86ffSlogin } 167004e86ffSlogin 168004e86ffSlogin let start = inode.data.len().min(offset); 169004e86ffSlogin let end = inode.data.len().min(offset + len); 170004e86ffSlogin 171004e86ffSlogin // buffer空间不足 172004e86ffSlogin if buf.len() < (end - start) { 173676b8ef6SMork return Err(SystemError::ENOBUFS); 174004e86ffSlogin } 175004e86ffSlogin 176004e86ffSlogin // 拷贝数据 177004e86ffSlogin let src = &inode.data[start..end]; 178004e86ffSlogin buf[0..src.len()].copy_from_slice(src); 179004e86ffSlogin return Ok(src.len()); 180004e86ffSlogin } 181004e86ffSlogin 182004e86ffSlogin fn write_at( 183004e86ffSlogin &self, 184004e86ffSlogin offset: usize, 185004e86ffSlogin len: usize, 186004e86ffSlogin buf: &[u8], 187004e86ffSlogin _data: &mut FilePrivateData, 188676b8ef6SMork ) -> Result<usize, SystemError> { 189004e86ffSlogin if buf.len() < len { 190676b8ef6SMork return Err(SystemError::EINVAL); 191004e86ffSlogin } 192004e86ffSlogin 193004e86ffSlogin // 加锁 194004e86ffSlogin let mut inode: SpinLockGuard<RamFSInode> = self.0.lock(); 195004e86ffSlogin 196004e86ffSlogin // 检查当前inode是否为一个文件夹,如果是的话,就返回错误 197004e86ffSlogin if inode.metadata.file_type == FileType::Dir { 198676b8ef6SMork return Err(SystemError::EISDIR); 199004e86ffSlogin } 200004e86ffSlogin 201004e86ffSlogin let data: &mut Vec<u8> = &mut inode.data; 202004e86ffSlogin 203004e86ffSlogin // 如果文件大小比原来的大,那就resize这个数组 204004e86ffSlogin if offset + len > data.len() { 205004e86ffSlogin data.resize(offset + len, 0); 206004e86ffSlogin } 207004e86ffSlogin 208004e86ffSlogin let target = &mut data[offset..offset + len]; 209004e86ffSlogin target.copy_from_slice(&buf[0..len]); 210004e86ffSlogin return Ok(len); 211004e86ffSlogin } 212004e86ffSlogin 213004e86ffSlogin fn fs(&self) -> Arc<dyn FileSystem> { 214004e86ffSlogin return self.0.lock().fs.upgrade().unwrap(); 215004e86ffSlogin } 216004e86ffSlogin 217004e86ffSlogin fn as_any_ref(&self) -> &dyn core::any::Any { 218004e86ffSlogin self 219004e86ffSlogin } 220004e86ffSlogin 221676b8ef6SMork fn metadata(&self) -> Result<Metadata, SystemError> { 222004e86ffSlogin let inode = self.0.lock(); 223004e86ffSlogin let mut metadata = inode.metadata.clone(); 224004e86ffSlogin metadata.size = inode.data.len() as i64; 225004e86ffSlogin 226004e86ffSlogin return Ok(metadata); 227004e86ffSlogin } 228004e86ffSlogin 229676b8ef6SMork fn set_metadata(&self, metadata: &Metadata) -> Result<(), SystemError> { 230004e86ffSlogin let mut inode = self.0.lock(); 231004e86ffSlogin inode.metadata.atime = metadata.atime; 232004e86ffSlogin inode.metadata.mtime = metadata.mtime; 233004e86ffSlogin inode.metadata.ctime = metadata.ctime; 234004e86ffSlogin inode.metadata.mode = metadata.mode; 235004e86ffSlogin inode.metadata.uid = metadata.uid; 236004e86ffSlogin inode.metadata.gid = metadata.gid; 237004e86ffSlogin 238004e86ffSlogin return Ok(()); 239004e86ffSlogin } 240004e86ffSlogin 241676b8ef6SMork fn resize(&self, len: usize) -> Result<(), SystemError> { 242004e86ffSlogin let mut inode = self.0.lock(); 243004e86ffSlogin if inode.metadata.file_type == FileType::File { 244004e86ffSlogin inode.data.resize(len, 0); 245004e86ffSlogin return Ok(()); 246004e86ffSlogin } else { 247676b8ef6SMork return Err(SystemError::EINVAL); 248004e86ffSlogin } 249004e86ffSlogin } 250004e86ffSlogin 251004e86ffSlogin fn create_with_data( 252004e86ffSlogin &self, 253004e86ffSlogin name: &str, 254004e86ffSlogin file_type: FileType, 2556b4e7a29SLoGin mode: ModeType, 256004e86ffSlogin data: usize, 257676b8ef6SMork ) -> Result<Arc<dyn IndexNode>, SystemError> { 258004e86ffSlogin // 获取当前inode 259004e86ffSlogin let mut inode = self.0.lock(); 260004e86ffSlogin // 如果当前inode不是文件夹,则返回 261004e86ffSlogin if inode.metadata.file_type != FileType::Dir { 262676b8ef6SMork return Err(SystemError::ENOTDIR); 263004e86ffSlogin } 264004e86ffSlogin // 如果有重名的,则返回 265004e86ffSlogin if inode.children.contains_key(name) { 266676b8ef6SMork return Err(SystemError::EEXIST); 267004e86ffSlogin } 268004e86ffSlogin 269004e86ffSlogin // 创建inode 270004e86ffSlogin let result: Arc<LockedRamFSInode> = Arc::new(LockedRamFSInode(SpinLock::new(RamFSInode { 271004e86ffSlogin parent: inode.self_ref.clone(), 272004e86ffSlogin self_ref: Weak::default(), 273004e86ffSlogin children: BTreeMap::new(), 274004e86ffSlogin data: Vec::new(), 275004e86ffSlogin metadata: Metadata { 276004e86ffSlogin dev_id: 0, 277004e86ffSlogin inode_id: generate_inode_id(), 278004e86ffSlogin size: 0, 279004e86ffSlogin blk_size: 0, 280004e86ffSlogin blocks: 0, 281004e86ffSlogin atime: TimeSpec::default(), 282004e86ffSlogin mtime: TimeSpec::default(), 283004e86ffSlogin ctime: TimeSpec::default(), 284004e86ffSlogin file_type: file_type, 285004e86ffSlogin mode: mode, 286004e86ffSlogin nlinks: 1, 287004e86ffSlogin uid: 0, 288004e86ffSlogin gid: 0, 289004e86ffSlogin raw_dev: data, 290004e86ffSlogin }, 291004e86ffSlogin fs: inode.fs.clone(), 2922dbef785SGnoCiYeH special_node: None, 293004e86ffSlogin }))); 294004e86ffSlogin 295004e86ffSlogin // 初始化inode的自引用的weak指针 296004e86ffSlogin result.0.lock().self_ref = Arc::downgrade(&result); 297004e86ffSlogin 298004e86ffSlogin // 将子inode插入父inode的B树中 299004e86ffSlogin inode.children.insert(String::from(name), result.clone()); 300004e86ffSlogin 301004e86ffSlogin return Ok(result); 302004e86ffSlogin } 303004e86ffSlogin 304676b8ef6SMork fn link(&self, name: &str, other: &Arc<dyn IndexNode>) -> Result<(), SystemError> { 305004e86ffSlogin let other: &LockedRamFSInode = other 306004e86ffSlogin .downcast_ref::<LockedRamFSInode>() 307676b8ef6SMork .ok_or(SystemError::EPERM)?; 308004e86ffSlogin let mut inode: SpinLockGuard<RamFSInode> = self.0.lock(); 309004e86ffSlogin let mut other_locked: SpinLockGuard<RamFSInode> = other.0.lock(); 310004e86ffSlogin 311004e86ffSlogin // 如果当前inode不是文件夹,那么报错 312004e86ffSlogin if inode.metadata.file_type != FileType::Dir { 313676b8ef6SMork return Err(SystemError::ENOTDIR); 314004e86ffSlogin } 315004e86ffSlogin 316004e86ffSlogin // 如果另一个inode是文件夹,那么也报错 317004e86ffSlogin if other_locked.metadata.file_type == FileType::Dir { 318676b8ef6SMork return Err(SystemError::EISDIR); 319004e86ffSlogin } 320004e86ffSlogin 321004e86ffSlogin // 如果当前文件夹下已经有同名文件,也报错。 322004e86ffSlogin if inode.children.contains_key(name) { 323676b8ef6SMork return Err(SystemError::EEXIST); 324004e86ffSlogin } 325004e86ffSlogin 326004e86ffSlogin inode 327004e86ffSlogin .children 328004e86ffSlogin .insert(String::from(name), other_locked.self_ref.upgrade().unwrap()); 329004e86ffSlogin 330004e86ffSlogin // 增加硬链接计数 331004e86ffSlogin other_locked.metadata.nlinks += 1; 332004e86ffSlogin return Ok(()); 333004e86ffSlogin } 334004e86ffSlogin 335676b8ef6SMork fn unlink(&self, name: &str) -> Result<(), SystemError> { 336004e86ffSlogin let mut inode: SpinLockGuard<RamFSInode> = self.0.lock(); 337004e86ffSlogin // 如果当前inode不是目录,那么也没有子目录/文件的概念了,因此要求当前inode的类型是目录 338004e86ffSlogin if inode.metadata.file_type != FileType::Dir { 339676b8ef6SMork return Err(SystemError::ENOTDIR); 340004e86ffSlogin } 341004e86ffSlogin // 不允许删除当前文件夹,也不允许删除上一个目录 342004e86ffSlogin if name == "." || name == ".." { 343676b8ef6SMork return Err(SystemError::ENOTEMPTY); 344004e86ffSlogin } 345004e86ffSlogin 346004e86ffSlogin // 获得要删除的文件的inode 347676b8ef6SMork let to_delete = inode.children.get(name).ok_or(SystemError::ENOENT)?; 348004e86ffSlogin if to_delete.0.lock().metadata.file_type == FileType::Dir { 349676b8ef6SMork return Err(SystemError::EPERM); 350004e86ffSlogin } 351004e86ffSlogin // 减少硬链接计数 352004e86ffSlogin to_delete.0.lock().metadata.nlinks -= 1; 353004e86ffSlogin // 在当前目录中删除这个子目录项 354004e86ffSlogin inode.children.remove(name); 355004e86ffSlogin return Ok(()); 356004e86ffSlogin } 357004e86ffSlogin 358676b8ef6SMork fn rmdir(&self, name: &str) -> Result<(), SystemError> { 359004e86ffSlogin let mut inode: SpinLockGuard<RamFSInode> = self.0.lock(); 360004e86ffSlogin // 如果当前inode不是目录,那么也没有子目录/文件的概念了,因此要求当前inode的类型是目录 361004e86ffSlogin if inode.metadata.file_type != FileType::Dir { 362676b8ef6SMork return Err(SystemError::ENOTDIR); 363004e86ffSlogin } 364004e86ffSlogin // 获得要删除的文件夹的inode 365676b8ef6SMork let to_delete = inode.children.get(name).ok_or(SystemError::ENOENT)?; 366004e86ffSlogin if to_delete.0.lock().metadata.file_type != FileType::Dir { 367676b8ef6SMork return Err(SystemError::ENOTDIR); 368004e86ffSlogin } 369004e86ffSlogin 370004e86ffSlogin to_delete.0.lock().metadata.nlinks -= 1; 371004e86ffSlogin // 在当前目录中删除这个子目录项 372004e86ffSlogin inode.children.remove(name); 373004e86ffSlogin return Ok(()); 374004e86ffSlogin } 375004e86ffSlogin 376004e86ffSlogin fn move_( 377004e86ffSlogin &self, 378004e86ffSlogin old_name: &str, 379004e86ffSlogin target: &Arc<dyn IndexNode>, 380004e86ffSlogin new_name: &str, 381676b8ef6SMork ) -> Result<(), SystemError> { 382004e86ffSlogin let old_inode: Arc<dyn IndexNode> = self.find(old_name)?; 383004e86ffSlogin 384004e86ffSlogin // 在新的目录下创建一个硬链接 385004e86ffSlogin target.link(new_name, &old_inode)?; 386004e86ffSlogin // 取消现有的目录下的这个硬链接 387004e86ffSlogin if let Err(err) = self.unlink(old_name) { 388004e86ffSlogin // 如果取消失败,那就取消新的目录下的硬链接 389004e86ffSlogin target.unlink(new_name)?; 390004e86ffSlogin return Err(err); 391004e86ffSlogin } 392004e86ffSlogin return Ok(()); 393004e86ffSlogin } 394004e86ffSlogin 395676b8ef6SMork fn find(&self, name: &str) -> Result<Arc<dyn IndexNode>, SystemError> { 396004e86ffSlogin let inode = self.0.lock(); 397004e86ffSlogin 398004e86ffSlogin if inode.metadata.file_type != FileType::Dir { 399676b8ef6SMork return Err(SystemError::ENOTDIR); 400004e86ffSlogin } 401004e86ffSlogin 402004e86ffSlogin match name { 403004e86ffSlogin "" | "." => { 404676b8ef6SMork return Ok(inode.self_ref.upgrade().ok_or(SystemError::ENOENT)?); 405004e86ffSlogin } 406004e86ffSlogin 407004e86ffSlogin ".." => { 408676b8ef6SMork return Ok(inode.parent.upgrade().ok_or(SystemError::ENOENT)?); 409004e86ffSlogin } 410004e86ffSlogin name => { 411004e86ffSlogin // 在子目录项中查找 412676b8ef6SMork return Ok(inode.children.get(name).ok_or(SystemError::ENOENT)?.clone()); 413004e86ffSlogin } 414004e86ffSlogin } 415004e86ffSlogin } 416004e86ffSlogin 417676b8ef6SMork fn get_entry_name(&self, ino: InodeId) -> Result<String, SystemError> { 418004e86ffSlogin let inode: SpinLockGuard<RamFSInode> = self.0.lock(); 419004e86ffSlogin if inode.metadata.file_type != FileType::Dir { 420676b8ef6SMork return Err(SystemError::ENOTDIR); 421004e86ffSlogin } 422004e86ffSlogin 4236b4e7a29SLoGin match ino.into() { 424004e86ffSlogin 0 => { 425004e86ffSlogin return Ok(String::from(".")); 426004e86ffSlogin } 427004e86ffSlogin 1 => { 428004e86ffSlogin return Ok(String::from("..")); 429004e86ffSlogin } 430004e86ffSlogin ino => { 431004e86ffSlogin // 暴力遍历所有的children,判断inode id是否相同 432004e86ffSlogin // TODO: 优化这里,这个地方性能很差! 433004e86ffSlogin let mut key: Vec<String> = inode 434004e86ffSlogin .children 435004e86ffSlogin .keys() 4366b4e7a29SLoGin .filter(|k| { 4376b4e7a29SLoGin inode 4386b4e7a29SLoGin .children 4396b4e7a29SLoGin .get(*k) 4406b4e7a29SLoGin .unwrap() 4416b4e7a29SLoGin .0 4426b4e7a29SLoGin .lock() 4436b4e7a29SLoGin .metadata 4446b4e7a29SLoGin .inode_id 4456b4e7a29SLoGin .into() 4466b4e7a29SLoGin == ino 4476b4e7a29SLoGin }) 448004e86ffSlogin .cloned() 449004e86ffSlogin .collect(); 450004e86ffSlogin 451004e86ffSlogin match key.len() { 452676b8ef6SMork 0=>{return Err(SystemError::ENOENT);} 453004e86ffSlogin 1=>{return Ok(key.remove(0));} 4546b4e7a29SLoGin _ => panic!("Ramfs get_entry_name: key.len()={key_len}>1, current inode_id={inode_id:?}, to find={to_find:?}", key_len=key.len(), inode_id = inode.metadata.inode_id, to_find=ino) 455004e86ffSlogin } 456004e86ffSlogin } 457004e86ffSlogin } 458004e86ffSlogin } 459004e86ffSlogin 460676b8ef6SMork fn list(&self) -> Result<Vec<String>, SystemError> { 461004e86ffSlogin let info = self.metadata()?; 462004e86ffSlogin if info.file_type != FileType::Dir { 463676b8ef6SMork return Err(SystemError::ENOTDIR); 464004e86ffSlogin } 465004e86ffSlogin 466004e86ffSlogin let mut keys: Vec<String> = Vec::new(); 467004e86ffSlogin keys.push(String::from(".")); 468004e86ffSlogin keys.push(String::from("..")); 469004e86ffSlogin keys.append(&mut self.0.lock().children.keys().cloned().collect()); 470004e86ffSlogin 471004e86ffSlogin return Ok(keys); 472004e86ffSlogin } 4732dbef785SGnoCiYeH 4742dbef785SGnoCiYeH fn mknod( 4752dbef785SGnoCiYeH &self, 4762dbef785SGnoCiYeH filename: &str, 4772dbef785SGnoCiYeH mode: ModeType, 4782dbef785SGnoCiYeH _dev_t: crate::driver::base::device::DeviceNumber, 4792dbef785SGnoCiYeH ) -> Result<Arc<dyn IndexNode>, SystemError> { 4802dbef785SGnoCiYeH let mut inode = self.0.lock(); 4812dbef785SGnoCiYeH if inode.metadata.file_type != FileType::Dir { 4822dbef785SGnoCiYeH return Err(SystemError::ENOTDIR); 4832dbef785SGnoCiYeH } 4842dbef785SGnoCiYeH 4852dbef785SGnoCiYeH // 判断需要创建的类型 4862dbef785SGnoCiYeH if unlikely(mode.contains(ModeType::S_IFREG)) { 4872dbef785SGnoCiYeH // 普通文件 4882dbef785SGnoCiYeH return Ok(self.create(filename, FileType::File, mode)?); 4892dbef785SGnoCiYeH } 4902dbef785SGnoCiYeH 4912dbef785SGnoCiYeH let nod = Arc::new(LockedRamFSInode(SpinLock::new(RamFSInode { 4922dbef785SGnoCiYeH parent: inode.self_ref.clone(), 4932dbef785SGnoCiYeH self_ref: Weak::default(), 4942dbef785SGnoCiYeH children: BTreeMap::new(), 4952dbef785SGnoCiYeH data: Vec::new(), 4962dbef785SGnoCiYeH metadata: Metadata { 4972dbef785SGnoCiYeH dev_id: 0, 4982dbef785SGnoCiYeH inode_id: generate_inode_id(), 4992dbef785SGnoCiYeH size: 0, 5002dbef785SGnoCiYeH blk_size: 0, 5012dbef785SGnoCiYeH blocks: 0, 5022dbef785SGnoCiYeH atime: TimeSpec::default(), 5032dbef785SGnoCiYeH mtime: TimeSpec::default(), 5042dbef785SGnoCiYeH ctime: TimeSpec::default(), 5052dbef785SGnoCiYeH file_type: FileType::Pipe, 5062dbef785SGnoCiYeH mode: mode, 5072dbef785SGnoCiYeH nlinks: 1, 5082dbef785SGnoCiYeH uid: 0, 5092dbef785SGnoCiYeH gid: 0, 5102dbef785SGnoCiYeH raw_dev: 0, 5112dbef785SGnoCiYeH }, 5122dbef785SGnoCiYeH fs: inode.fs.clone(), 5132dbef785SGnoCiYeH special_node: None, 5142dbef785SGnoCiYeH }))); 5152dbef785SGnoCiYeH 5162dbef785SGnoCiYeH nod.0.lock().self_ref = Arc::downgrade(&nod); 5172dbef785SGnoCiYeH 5182dbef785SGnoCiYeH if mode.contains(ModeType::S_IFIFO) { 5192dbef785SGnoCiYeH nod.0.lock().metadata.file_type = FileType::Pipe; 5202dbef785SGnoCiYeH // 创建pipe文件 5212dbef785SGnoCiYeH let pipe_inode = LockedPipeInode::new(); 5222dbef785SGnoCiYeH // 设置special_node 5232dbef785SGnoCiYeH nod.0.lock().special_node = Some(SpecialNodeData::Pipe(pipe_inode)); 5242dbef785SGnoCiYeH } else if mode.contains(ModeType::S_IFBLK) { 5252dbef785SGnoCiYeH nod.0.lock().metadata.file_type = FileType::BlockDevice; 5262dbef785SGnoCiYeH unimplemented!() 5272dbef785SGnoCiYeH } else if mode.contains(ModeType::S_IFCHR) { 5282dbef785SGnoCiYeH nod.0.lock().metadata.file_type = FileType::CharDevice; 5292dbef785SGnoCiYeH unimplemented!() 5302dbef785SGnoCiYeH } 5312dbef785SGnoCiYeH 5322dbef785SGnoCiYeH inode 5332dbef785SGnoCiYeH .children 5342dbef785SGnoCiYeH .insert(String::from(filename).to_uppercase(), nod.clone()); 5352dbef785SGnoCiYeH Ok(nod) 5362dbef785SGnoCiYeH } 5372dbef785SGnoCiYeH 5382dbef785SGnoCiYeH fn special_node(&self) -> Option<super::vfs::SpecialNodeData> { 5392dbef785SGnoCiYeH return self.0.lock().special_node.clone(); 5402dbef785SGnoCiYeH } 541004e86ffSlogin } 542