1 use core::intrinsics::size_of; 2 3 use alloc::{ 4 borrow::ToOwned, 5 collections::BTreeMap, 6 format, 7 string::String, 8 sync::{Arc, Weak}, 9 vec::Vec, 10 }; 11 12 use crate::{ 13 arch::mm::LockedFrameAllocator, 14 filesystem::vfs::{ 15 core::{generate_inode_id, ROOT_INODE}, 16 FileType, 17 }, 18 kerror, kinfo, 19 libs::{ 20 once::Once, 21 spinlock::{SpinLock, SpinLockGuard}, 22 }, 23 mm::allocator::page_frame::FrameAllocator, 24 process::{Pid, ProcessManager}, 25 syscall::SystemError, 26 time::TimeSpec, 27 }; 28 29 use super::vfs::{ 30 file::{FileMode, FilePrivateData}, 31 syscall::ModeType, 32 FileSystem, FsInfo, IndexNode, InodeId, Metadata, PollStatus, 33 }; 34 35 /// @brief 进程文件类型 36 /// @usage 用于定义进程文件夹下的各类文件类型 37 #[derive(Debug)] 38 #[repr(u8)] 39 pub enum ProcFileType { 40 ///展示进程状态信息 41 ProcStatus = 0, 42 /// meminfo 43 ProcMeminfo = 1, 44 //todo: 其他文件类型 45 ///默认文件类型 46 Default, 47 } 48 49 impl From<u8> for ProcFileType { 50 fn from(value: u8) -> Self { 51 match value { 52 0 => ProcFileType::ProcStatus, 53 1 => ProcFileType::ProcMeminfo, 54 _ => ProcFileType::Default, 55 } 56 } 57 } 58 /// @brief 节点私有信息结构体 59 /// @usage 用于传入各类文件所需的信息 60 #[derive(Debug)] 61 pub struct InodeInfo { 62 ///进程的pid 63 pid: Pid, 64 ///文件类型 65 ftype: ProcFileType, 66 //其他需要传入的信息在此定义 67 } 68 69 /// @brief procfs的inode名称的最大长度 70 const PROCFS_MAX_NAMELEN: usize = 64; 71 72 /// @brief procfs文件系统的Inode结构体 73 #[derive(Debug)] 74 pub struct LockedProcFSInode(SpinLock<ProcFSInode>); 75 76 /// @brief procfs文件系统结构体 77 #[derive(Debug)] 78 pub struct ProcFS { 79 /// procfs的root inode 80 root_inode: Arc<LockedProcFSInode>, 81 } 82 83 #[derive(Debug, Clone)] 84 pub struct ProcfsFilePrivateData { 85 data: Vec<u8>, 86 } 87 88 impl ProcfsFilePrivateData { 89 pub fn new() -> Self { 90 return ProcfsFilePrivateData { data: Vec::new() }; 91 } 92 } 93 94 /// @brief procfs文件系统的Inode结构体(不包含锁) 95 #[derive(Debug)] 96 pub struct ProcFSInode { 97 /// 指向父Inode的弱引用 98 parent: Weak<LockedProcFSInode>, 99 /// 指向自身的弱引用 100 self_ref: Weak<LockedProcFSInode>, 101 /// 子Inode的B树 102 children: BTreeMap<String, Arc<LockedProcFSInode>>, 103 /// 当前inode的数据部分 104 data: Vec<u8>, 105 /// 当前inode的元数据 106 metadata: Metadata, 107 /// 指向inode所在的文件系统对象的指针 108 fs: Weak<ProcFS>, 109 /// 储存私有信息 110 fdata: InodeInfo, 111 } 112 113 /// 对ProcFSInode实现获取各类文件信息的函数 114 impl ProcFSInode { 115 /// @brief 去除Vec中所有的\0,并在结尾添加\0 116 #[inline] 117 fn trim_string(&self, data: &mut Vec<u8>) { 118 data.drain_filter(|x: &mut u8| *x == 0); 119 data.push(0); 120 } 121 // todo:其他数据获取函数实现 122 123 /// @brief 打开status文件 124 /// 125 fn open_status(&self, pdata: &mut ProcfsFilePrivateData) -> Result<i64, SystemError> { 126 // 获取该pid对应的pcb结构体 127 let pid = self.fdata.pid; 128 let pcb = ProcessManager::find(pid); 129 let pcb = if pcb.is_none() { 130 kerror!( 131 "ProcFS: Cannot find pcb for pid {:?} when opening its 'status' file.", 132 pid 133 ); 134 return Err(SystemError::ESRCH); 135 } else { 136 pcb.unwrap() 137 }; 138 // 传入数据 139 let pdata: &mut Vec<u8> = &mut pdata.data; 140 141 pdata.append( 142 &mut format!("Name:\t{}", pcb.basic().name()) 143 .as_bytes() 144 .to_owned(), 145 ); 146 147 let sched_info_guard = pcb.sched_info(); 148 let state = sched_info_guard.state(); 149 let cpu_id = sched_info_guard 150 .on_cpu() 151 .map(|cpu| cpu as i32) 152 .unwrap_or(-1); 153 154 let priority = sched_info_guard.priority(); 155 let vrtime = sched_info_guard.virtual_runtime(); 156 157 drop(sched_info_guard); 158 159 pdata.append(&mut format!("\nState:\t{:?}", state).as_bytes().to_owned()); 160 pdata.append( 161 &mut format!("\nPid:\t{}", pcb.pid().into()) 162 .as_bytes() 163 .to_owned(), 164 ); 165 pdata.append( 166 &mut format!("\nPpid:\t{}", pcb.basic().ppid().into()) 167 .as_bytes() 168 .to_owned(), 169 ); 170 pdata.append(&mut format!("\ncpu_id:\t{}", cpu_id).as_bytes().to_owned()); 171 pdata.append( 172 &mut format!("\npriority:\t{}", priority.data()) 173 .as_bytes() 174 .to_owned(), 175 ); 176 pdata.append( 177 &mut format!("\npreempt:\t{}", pcb.preempt_count()) 178 .as_bytes() 179 .to_owned(), 180 ); 181 pdata.append(&mut format!("\nvrtime:\t{}", vrtime).as_bytes().to_owned()); 182 183 if let Some(user_vm) = pcb.basic().user_vm() { 184 let address_space_guard = user_vm.read(); 185 // todo: 当前进程运行过程中占用内存的峰值 186 let hiwater_vm: u64 = 0; 187 // 进程代码段的大小 188 let text = (address_space_guard.end_code - address_space_guard.start_code) / 1024; 189 // 进程数据段的大小 190 let data = (address_space_guard.end_data - address_space_guard.start_data) / 1024; 191 drop(address_space_guard); 192 pdata.append( 193 &mut format!("\nVmPeak:\t{} kB", hiwater_vm) 194 .as_bytes() 195 .to_owned(), 196 ); 197 pdata.append(&mut format!("\nVmData:\t{} kB", data).as_bytes().to_owned()); 198 pdata.append(&mut format!("\nVmExe:\t{} kB", text).as_bytes().to_owned()); 199 } 200 201 pdata.append( 202 &mut format!("\nflags: {:?}\n", pcb.flags().clone()) 203 .as_bytes() 204 .to_owned(), 205 ); 206 207 // 去除多余的\0 208 self.trim_string(pdata); 209 210 return Ok((pdata.len() * size_of::<u8>()) as i64); 211 } 212 213 /// 打开 meminfo 文件 214 fn open_meminfo(&self, pdata: &mut ProcfsFilePrivateData) -> Result<i64, SystemError> { 215 // 获取内存信息 216 let usage = unsafe { LockedFrameAllocator.usage() }; 217 218 // 传入数据 219 let data: &mut Vec<u8> = &mut pdata.data; 220 221 data.append( 222 &mut format!("MemTotal:\t{} kB\n", usage.total().bytes() >> 10) 223 .as_bytes() 224 .to_owned(), 225 ); 226 227 data.append( 228 &mut format!("MemFree:\t{} kB\n", usage.free().bytes() >> 10) 229 .as_bytes() 230 .to_owned(), 231 ); 232 233 // 去除多余的\0 234 self.trim_string(data); 235 236 return Ok((data.len() * size_of::<u8>()) as i64); 237 } 238 239 /// proc文件系统读取函数 240 fn proc_read( 241 &self, 242 offset: usize, 243 len: usize, 244 buf: &mut [u8], 245 _pdata: &mut ProcfsFilePrivateData, 246 ) -> Result<usize, SystemError> { 247 let start = _pdata.data.len().min(offset); 248 let end = _pdata.data.len().min(offset + len); 249 250 // buffer空间不足 251 if buf.len() < (end - start) { 252 return Err(SystemError::ENOBUFS); 253 } 254 255 // 拷贝数据 256 let src = &_pdata.data[start..end]; 257 buf[0..src.len()].copy_from_slice(src); 258 return Ok(src.len()); 259 } 260 } 261 262 impl FileSystem for ProcFS { 263 fn root_inode(&self) -> Arc<dyn super::vfs::IndexNode> { 264 return self.root_inode.clone(); 265 } 266 267 fn info(&self) -> FsInfo { 268 return FsInfo { 269 blk_dev_id: 0, 270 max_name_len: PROCFS_MAX_NAMELEN, 271 }; 272 } 273 274 fn as_any_ref(&self) -> &dyn core::any::Any { 275 self 276 } 277 } 278 279 impl ProcFS { 280 pub fn new() -> Arc<Self> { 281 // 初始化root inode 282 let root: Arc<LockedProcFSInode> = 283 Arc::new(LockedProcFSInode(SpinLock::new(ProcFSInode { 284 parent: Weak::default(), 285 self_ref: Weak::default(), 286 children: BTreeMap::new(), 287 data: Vec::new(), 288 metadata: Metadata { 289 dev_id: 0, 290 inode_id: generate_inode_id(), 291 size: 0, 292 blk_size: 0, 293 blocks: 0, 294 atime: TimeSpec::default(), 295 mtime: TimeSpec::default(), 296 ctime: TimeSpec::default(), 297 file_type: FileType::Dir, 298 mode: ModeType::from_bits_truncate(0o555), 299 nlinks: 1, 300 uid: 0, 301 gid: 0, 302 raw_dev: 0, 303 }, 304 fs: Weak::default(), 305 fdata: InodeInfo { 306 pid: Pid::new(0), 307 ftype: ProcFileType::Default, 308 }, 309 }))); 310 311 let result: Arc<ProcFS> = Arc::new(ProcFS { root_inode: root }); 312 313 // 对root inode加锁,并继续完成初始化工作 314 let mut root_guard: SpinLockGuard<ProcFSInode> = result.root_inode.0.lock(); 315 root_guard.parent = Arc::downgrade(&result.root_inode); 316 root_guard.self_ref = Arc::downgrade(&result.root_inode); 317 root_guard.fs = Arc::downgrade(&result); 318 // 释放锁 319 drop(root_guard); 320 321 // 创建meminfo文件 322 let inode = result.root_inode(); 323 let binding = inode.create( 324 "meminfo", 325 FileType::File, 326 ModeType::from_bits_truncate(0o444), 327 ); 328 if let Ok(meminfo) = binding { 329 let meminfo_file = meminfo 330 .as_any_ref() 331 .downcast_ref::<LockedProcFSInode>() 332 .unwrap(); 333 meminfo_file.0.lock().fdata.pid = Pid::new(0); 334 meminfo_file.0.lock().fdata.ftype = ProcFileType::ProcMeminfo; 335 } else { 336 panic!("create meminfo error"); 337 } 338 339 return result; 340 } 341 342 /// @brief 进程注册函数 343 /// @usage 在进程中调用并创建进程对应文件 344 pub fn register_pid(&self, pid: Pid) -> Result<(), SystemError> { 345 // 获取当前inode 346 let inode: Arc<dyn IndexNode> = self.root_inode(); 347 // 创建对应进程文件夹 348 let pid_dir: Arc<dyn IndexNode> = inode.create( 349 &pid.to_string(), 350 FileType::Dir, 351 ModeType::from_bits_truncate(0o555), 352 )?; 353 // 创建相关文件 354 // status文件 355 let binding: Arc<dyn IndexNode> = pid_dir.create( 356 "status", 357 FileType::File, 358 ModeType::from_bits_truncate(0o444), 359 )?; 360 let status_file: &LockedProcFSInode = binding 361 .as_any_ref() 362 .downcast_ref::<LockedProcFSInode>() 363 .unwrap(); 364 status_file.0.lock().fdata.pid = pid; 365 status_file.0.lock().fdata.ftype = ProcFileType::ProcStatus; 366 367 //todo: 创建其他文件 368 369 return Ok(()); 370 } 371 372 /// @brief 解除进程注册 373 /// 374 pub fn unregister_pid(&self, pid: Pid) -> Result<(), SystemError> { 375 // 获取当前inode 376 let proc: Arc<dyn IndexNode> = self.root_inode(); 377 // 获取进程文件夹 378 let pid_dir: Arc<dyn IndexNode> = proc.find(&pid.to_string())?; 379 // 删除进程文件夹下文件 380 pid_dir.unlink("status")?; 381 382 // 查看进程文件是否还存在 383 // let pf= pid_dir.find("status").expect("Cannot find status"); 384 385 // 删除进程文件夹 386 proc.unlink(&pid.to_string())?; 387 388 return Ok(()); 389 } 390 } 391 392 impl IndexNode for LockedProcFSInode { 393 fn open(&self, data: &mut FilePrivateData, _mode: &FileMode) -> Result<(), SystemError> { 394 // 加锁 395 let mut inode: SpinLockGuard<ProcFSInode> = self.0.lock(); 396 397 // 如果inode类型为文件夹,则直接返回成功 398 if let FileType::Dir = inode.metadata.file_type { 399 return Ok(()); 400 } 401 let mut private_data = ProcfsFilePrivateData::new(); 402 // 根据文件类型获取相应数据 403 let file_size = match inode.fdata.ftype { 404 ProcFileType::ProcStatus => inode.open_status(&mut private_data)?, 405 ProcFileType::ProcMeminfo => inode.open_meminfo(&mut private_data)?, 406 _ => { 407 todo!() 408 } 409 }; 410 *data = FilePrivateData::Procfs(private_data); 411 // 更新metadata里面的文件大小数值 412 inode.metadata.size = file_size; 413 414 return Ok(()); 415 } 416 417 fn close(&self, data: &mut FilePrivateData) -> Result<(), SystemError> { 418 let guard: SpinLockGuard<ProcFSInode> = self.0.lock(); 419 // 如果inode类型为文件夹,则直接返回成功 420 if let FileType::Dir = guard.metadata.file_type { 421 return Ok(()); 422 } 423 // 获取数据信息 424 let private_data = match data { 425 FilePrivateData::Procfs(p) => p, 426 _ => { 427 panic!("ProcFS: FilePrivateData mismatch!"); 428 } 429 }; 430 // 释放资源 431 drop(private_data); 432 return Ok(()); 433 } 434 435 fn read_at( 436 &self, 437 offset: usize, 438 len: usize, 439 buf: &mut [u8], 440 data: &mut FilePrivateData, 441 ) -> Result<usize, SystemError> { 442 if buf.len() < len { 443 return Err(SystemError::EINVAL); 444 } 445 // 加锁 446 let inode: SpinLockGuard<ProcFSInode> = self.0.lock(); 447 448 // 检查当前inode是否为一个文件夹,如果是的话,就返回错误 449 if inode.metadata.file_type == FileType::Dir { 450 return Err(SystemError::EISDIR); 451 } 452 453 // 获取数据信息 454 let private_data = match data { 455 FilePrivateData::Procfs(p) => p, 456 _ => { 457 panic!("ProcFS: FilePrivateData mismatch!"); 458 } 459 }; 460 461 // 根据文件类型读取相应数据 462 match inode.fdata.ftype { 463 ProcFileType::ProcStatus => return inode.proc_read(offset, len, buf, private_data), 464 ProcFileType::ProcMeminfo => return inode.proc_read(offset, len, buf, private_data), 465 ProcFileType::Default => (), 466 }; 467 468 // 默认读取 469 let start = inode.data.len().min(offset); 470 let end = inode.data.len().min(offset + len); 471 472 // buffer空间不足 473 if buf.len() < (end - start) { 474 return Err(SystemError::ENOBUFS); 475 } 476 477 // 拷贝数据 478 let src = &inode.data[start..end]; 479 buf[0..src.len()].copy_from_slice(src); 480 return Ok(src.len()); 481 } 482 483 fn write_at( 484 &self, 485 _offset: usize, 486 _len: usize, 487 _buf: &[u8], 488 _data: &mut FilePrivateData, 489 ) -> Result<usize, SystemError> { 490 return Err(SystemError::EOPNOTSUPP_OR_ENOTSUP); 491 } 492 493 fn poll(&self) -> Result<PollStatus, SystemError> { 494 // 加锁 495 let inode: SpinLockGuard<ProcFSInode> = self.0.lock(); 496 497 // 检查当前inode是否为一个文件夹,如果是的话,就返回错误 498 if inode.metadata.file_type == FileType::Dir { 499 return Err(SystemError::EISDIR); 500 } 501 502 return Ok(PollStatus::READ); 503 } 504 505 fn fs(&self) -> Arc<dyn FileSystem> { 506 return self.0.lock().fs.upgrade().unwrap(); 507 } 508 509 fn as_any_ref(&self) -> &dyn core::any::Any { 510 self 511 } 512 513 fn metadata(&self) -> Result<Metadata, SystemError> { 514 let inode = self.0.lock(); 515 let metadata = inode.metadata.clone(); 516 517 return Ok(metadata); 518 } 519 520 fn set_metadata(&self, metadata: &Metadata) -> Result<(), SystemError> { 521 let mut inode = self.0.lock(); 522 inode.metadata.atime = metadata.atime; 523 inode.metadata.mtime = metadata.mtime; 524 inode.metadata.ctime = metadata.ctime; 525 inode.metadata.mode = metadata.mode; 526 inode.metadata.uid = metadata.uid; 527 inode.metadata.gid = metadata.gid; 528 529 return Ok(()); 530 } 531 532 fn resize(&self, len: usize) -> Result<(), SystemError> { 533 let mut inode = self.0.lock(); 534 if inode.metadata.file_type == FileType::File { 535 inode.data.resize(len, 0); 536 return Ok(()); 537 } else { 538 return Err(SystemError::EINVAL); 539 } 540 } 541 542 fn create_with_data( 543 &self, 544 name: &str, 545 file_type: FileType, 546 mode: ModeType, 547 data: usize, 548 ) -> Result<Arc<dyn IndexNode>, SystemError> { 549 // 获取当前inode 550 let mut inode = self.0.lock(); 551 // 如果当前inode不是文件夹,则返回 552 if inode.metadata.file_type != FileType::Dir { 553 return Err(SystemError::ENOTDIR); 554 } 555 // 如果有重名的,则返回 556 if inode.children.contains_key(name) { 557 return Err(SystemError::EEXIST); 558 } 559 560 // 创建inode 561 let result: Arc<LockedProcFSInode> = 562 Arc::new(LockedProcFSInode(SpinLock::new(ProcFSInode { 563 parent: inode.self_ref.clone(), 564 self_ref: Weak::default(), 565 children: BTreeMap::new(), 566 data: Vec::new(), 567 metadata: Metadata { 568 dev_id: 0, 569 inode_id: generate_inode_id(), 570 size: 0, 571 blk_size: 0, 572 blocks: 0, 573 atime: TimeSpec::default(), 574 mtime: TimeSpec::default(), 575 ctime: TimeSpec::default(), 576 file_type: file_type, 577 mode: mode, 578 nlinks: 1, 579 uid: 0, 580 gid: 0, 581 raw_dev: data, 582 }, 583 fs: inode.fs.clone(), 584 fdata: InodeInfo { 585 pid: Pid::new(0), 586 ftype: ProcFileType::Default, 587 }, 588 }))); 589 590 // 初始化inode的自引用的weak指针 591 result.0.lock().self_ref = Arc::downgrade(&result); 592 593 // 将子inode插入父inode的B树中 594 inode.children.insert(String::from(name), result.clone()); 595 596 return Ok(result); 597 } 598 599 fn link(&self, name: &str, other: &Arc<dyn IndexNode>) -> Result<(), SystemError> { 600 let other: &LockedProcFSInode = other 601 .downcast_ref::<LockedProcFSInode>() 602 .ok_or(SystemError::EPERM)?; 603 let mut inode: SpinLockGuard<ProcFSInode> = self.0.lock(); 604 let mut other_locked: SpinLockGuard<ProcFSInode> = other.0.lock(); 605 606 // 如果当前inode不是文件夹,那么报错 607 if inode.metadata.file_type != FileType::Dir { 608 return Err(SystemError::ENOTDIR); 609 } 610 611 // 如果另一个inode是文件夹,那么也报错 612 if other_locked.metadata.file_type == FileType::Dir { 613 return Err(SystemError::EISDIR); 614 } 615 616 // 如果当前文件夹下已经有同名文件,也报错。 617 if inode.children.contains_key(name) { 618 return Err(SystemError::EEXIST); 619 } 620 621 inode 622 .children 623 .insert(String::from(name), other_locked.self_ref.upgrade().unwrap()); 624 625 // 增加硬链接计数 626 other_locked.metadata.nlinks += 1; 627 return Ok(()); 628 } 629 630 fn unlink(&self, name: &str) -> Result<(), SystemError> { 631 let mut inode: SpinLockGuard<ProcFSInode> = self.0.lock(); 632 // 如果当前inode不是目录,那么也没有子目录/文件的概念了,因此要求当前inode的类型是目录 633 if inode.metadata.file_type != FileType::Dir { 634 return Err(SystemError::ENOTDIR); 635 } 636 // 不允许删除当前文件夹,也不允许删除上一个目录 637 if name == "." || name == ".." { 638 return Err(SystemError::ENOTEMPTY); 639 } 640 641 // 获得要删除的文件的inode 642 let to_delete = inode.children.get(name).ok_or(SystemError::ENOENT)?; 643 // 减少硬链接计数 644 to_delete.0.lock().metadata.nlinks -= 1; 645 // 在当前目录中删除这个子目录项 646 inode.children.remove(name); 647 return Ok(()); 648 } 649 650 fn move_( 651 &self, 652 _old_name: &str, 653 _target: &Arc<dyn IndexNode>, 654 _new_name: &str, 655 ) -> Result<(), SystemError> { 656 return Err(SystemError::EOPNOTSUPP_OR_ENOTSUP); 657 } 658 659 fn find(&self, name: &str) -> Result<Arc<dyn IndexNode>, SystemError> { 660 let inode = self.0.lock(); 661 662 if inode.metadata.file_type != FileType::Dir { 663 return Err(SystemError::ENOTDIR); 664 } 665 666 match name { 667 "" | "." => { 668 return Ok(inode.self_ref.upgrade().ok_or(SystemError::ENOENT)?); 669 } 670 671 ".." => { 672 return Ok(inode.parent.upgrade().ok_or(SystemError::ENOENT)?); 673 } 674 name => { 675 // 在子目录项中查找 676 return Ok(inode.children.get(name).ok_or(SystemError::ENOENT)?.clone()); 677 } 678 } 679 } 680 681 fn get_entry_name(&self, ino: InodeId) -> Result<String, SystemError> { 682 let inode: SpinLockGuard<ProcFSInode> = self.0.lock(); 683 if inode.metadata.file_type != FileType::Dir { 684 return Err(SystemError::ENOTDIR); 685 } 686 687 match ino.into() { 688 0 => { 689 return Ok(String::from(".")); 690 } 691 1 => { 692 return Ok(String::from("..")); 693 } 694 ino => { 695 // 暴力遍历所有的children,判断inode id是否相同 696 // TODO: 优化这里,这个地方性能很差! 697 let mut key: Vec<String> = inode 698 .children 699 .keys() 700 .filter(|k| { 701 inode 702 .children 703 .get(*k) 704 .unwrap() 705 .0 706 .lock() 707 .metadata 708 .inode_id 709 .into() 710 == ino 711 }) 712 .cloned() 713 .collect(); 714 715 match key.len() { 716 0=>{return Err(SystemError::ENOENT);} 717 1=>{return Ok(key.remove(0));} 718 _ => panic!("Procfs 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) 719 } 720 } 721 } 722 } 723 724 fn list(&self) -> Result<Vec<String>, SystemError> { 725 let info = self.metadata()?; 726 if info.file_type != FileType::Dir { 727 return Err(SystemError::ENOTDIR); 728 } 729 730 let mut keys: Vec<String> = Vec::new(); 731 keys.push(String::from(".")); 732 keys.push(String::from("..")); 733 keys.append(&mut self.0.lock().children.keys().cloned().collect()); 734 735 return Ok(keys); 736 } 737 } 738 739 /// @brief 向procfs注册进程 740 pub fn procfs_register_pid(pid: Pid) -> Result<(), SystemError> { 741 let procfs_inode = ROOT_INODE().find("proc")?; 742 743 let procfs_inode = procfs_inode 744 .downcast_ref::<LockedProcFSInode>() 745 .expect("Failed to find procfs' root inode"); 746 let fs = procfs_inode.fs(); 747 let procfs: &ProcFS = fs.as_any_ref().downcast_ref::<ProcFS>().unwrap(); 748 749 // 调用注册函数 750 procfs.register_pid(pid)?; 751 752 return Ok(()); 753 } 754 755 /// @brief 在ProcFS中,解除进程的注册 756 pub fn procfs_unregister_pid(pid: Pid) -> Result<(), SystemError> { 757 // 获取procfs实例 758 let procfs_inode: Arc<dyn IndexNode> = ROOT_INODE().find("proc")?; 759 760 let procfs_inode: &LockedProcFSInode = procfs_inode 761 .downcast_ref::<LockedProcFSInode>() 762 .expect("Failed to find procfs' root inode"); 763 let fs: Arc<dyn FileSystem> = procfs_inode.fs(); 764 let procfs: &ProcFS = fs.as_any_ref().downcast_ref::<ProcFS>().unwrap(); 765 766 // 调用解除注册函数 767 return procfs.unregister_pid(pid); 768 } 769 770 pub fn procfs_init() -> Result<(), SystemError> { 771 static INIT: Once = Once::new(); 772 let mut result = None; 773 INIT.call_once(|| { 774 kinfo!("Initializing ProcFS..."); 775 // 创建 procfs 实例 776 let procfs: Arc<ProcFS> = ProcFS::new(); 777 778 // procfs 挂载 779 let _t = ROOT_INODE() 780 .find("proc") 781 .expect("Cannot find /proc") 782 .mount(procfs) 783 .expect("Failed to mount proc"); 784 kinfo!("ProcFS mounted."); 785 result = Some(Ok(())); 786 }); 787 788 return result.unwrap(); 789 } 790