1f678331aShanjiezhou use crate::{ 2f678331aShanjiezhou arch::{sched::sched, CurrentIrqArch}, 3f678331aShanjiezhou exception::InterruptArch, 4f678331aShanjiezhou filesystem::vfs::{ 56b4e7a29SLoGin core::generate_inode_id, file::FileMode, syscall::ModeType, FilePrivateData, FileSystem, 640609970SGnoCiYeH FileType, IndexNode, Metadata, 7f678331aShanjiezhou }, 8*dfe53cf0SGnoCiYeH libs::{ 9*dfe53cf0SGnoCiYeH spinlock::{SpinLock, SpinLockGuard}, 10*dfe53cf0SGnoCiYeH wait_queue::WaitQueue, 11*dfe53cf0SGnoCiYeH }, 125e948c56SGnoCiYeH net::event_poll::{EPollEventType, EPollItem, EventPoll}, 131496ba7bSLoGin process::ProcessState, 14f678331aShanjiezhou time::TimeSpec, 15f678331aShanjiezhou }; 16f678331aShanjiezhou 175e948c56SGnoCiYeH use alloc::{ 185e948c56SGnoCiYeH collections::LinkedList, 195e948c56SGnoCiYeH sync::{Arc, Weak}, 205e948c56SGnoCiYeH }; 2191e9d4abSLoGin use system_error::SystemError; 22f678331aShanjiezhou 23f678331aShanjiezhou /// 我们设定pipe_buff的总大小为1024字节 24f678331aShanjiezhou const PIPE_BUFF_SIZE: usize = 1024; 25f678331aShanjiezhou 26876cb89eSGnoCiYeH #[derive(Debug, Clone)] 27876cb89eSGnoCiYeH pub struct PipeFsPrivateData { 28876cb89eSGnoCiYeH mode: FileMode, 29876cb89eSGnoCiYeH } 30876cb89eSGnoCiYeH 31876cb89eSGnoCiYeH impl PipeFsPrivateData { 32876cb89eSGnoCiYeH pub fn new(mode: FileMode) -> Self { 334ad52e57S裕依2439 return PipeFsPrivateData { mode }; 34876cb89eSGnoCiYeH } 355e948c56SGnoCiYeH 365e948c56SGnoCiYeH pub fn set_mode(&mut self, mode: FileMode) { 375e948c56SGnoCiYeH self.mode = mode; 385e948c56SGnoCiYeH } 39876cb89eSGnoCiYeH } 40876cb89eSGnoCiYeH 41f678331aShanjiezhou /// @brief 管道文件i节点(锁) 42f678331aShanjiezhou #[derive(Debug)] 43*dfe53cf0SGnoCiYeH pub struct LockedPipeInode { 44*dfe53cf0SGnoCiYeH inner: SpinLock<InnerPipeInode>, 45*dfe53cf0SGnoCiYeH read_wait_queue: WaitQueue, 46*dfe53cf0SGnoCiYeH write_wait_queue: WaitQueue, 47*dfe53cf0SGnoCiYeH } 48f678331aShanjiezhou 49f678331aShanjiezhou /// @brief 管道文件i节点(无锁) 50f678331aShanjiezhou #[derive(Debug)] 51f678331aShanjiezhou pub struct InnerPipeInode { 52f678331aShanjiezhou self_ref: Weak<LockedPipeInode>, 535e948c56SGnoCiYeH /// 管道内可读的数据数 54f678331aShanjiezhou valid_cnt: i32, 55f678331aShanjiezhou read_pos: i32, 56f678331aShanjiezhou write_pos: i32, 57f678331aShanjiezhou data: [u8; PIPE_BUFF_SIZE], 58f678331aShanjiezhou /// INode 元数据 59f678331aShanjiezhou metadata: Metadata, 60876cb89eSGnoCiYeH reader: u32, 61876cb89eSGnoCiYeH writer: u32, 625e948c56SGnoCiYeH epitems: SpinLock<LinkedList<Arc<EPollItem>>>, 635e948c56SGnoCiYeH } 645e948c56SGnoCiYeH 655e948c56SGnoCiYeH impl InnerPipeInode { 665e948c56SGnoCiYeH pub fn poll(&self, private_data: &FilePrivateData) -> Result<usize, SystemError> { 675e948c56SGnoCiYeH let mut events = EPollEventType::empty(); 685e948c56SGnoCiYeH 695e948c56SGnoCiYeH let mode = if let FilePrivateData::Pipefs(PipeFsPrivateData { mode }) = private_data { 705e948c56SGnoCiYeH mode 715e948c56SGnoCiYeH } else { 725e948c56SGnoCiYeH return Err(SystemError::EBADFD); 735e948c56SGnoCiYeH }; 745e948c56SGnoCiYeH 755e948c56SGnoCiYeH if mode.contains(FileMode::O_RDONLY) { 765e948c56SGnoCiYeH if self.valid_cnt != 0 { 775e948c56SGnoCiYeH // 有数据可读 785e948c56SGnoCiYeH events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLRDNORM); 795e948c56SGnoCiYeH } 805e948c56SGnoCiYeH 815e948c56SGnoCiYeH // 没有写者 825e948c56SGnoCiYeH if self.writer == 0 { 835e948c56SGnoCiYeH events.insert(EPollEventType::EPOLLHUP) 845e948c56SGnoCiYeH } 855e948c56SGnoCiYeH } 865e948c56SGnoCiYeH 875e948c56SGnoCiYeH if mode.contains(FileMode::O_WRONLY) { 885e948c56SGnoCiYeH // 管道内数据未满 895e948c56SGnoCiYeH if self.valid_cnt as usize != PIPE_BUFF_SIZE { 905e948c56SGnoCiYeH events.insert(EPollEventType::EPOLLIN & EPollEventType::EPOLLWRNORM); 915e948c56SGnoCiYeH } 925e948c56SGnoCiYeH 935e948c56SGnoCiYeH // 没有读者 945e948c56SGnoCiYeH if self.reader == 0 { 955e948c56SGnoCiYeH events.insert(EPollEventType::EPOLLERR); 965e948c56SGnoCiYeH } 975e948c56SGnoCiYeH } 985e948c56SGnoCiYeH 995e948c56SGnoCiYeH Ok(events.bits() as usize) 1005e948c56SGnoCiYeH } 1015e948c56SGnoCiYeH 1025e948c56SGnoCiYeH pub fn add_epoll(&mut self, epitem: Arc<EPollItem>) -> Result<(), SystemError> { 1035e948c56SGnoCiYeH self.epitems.lock().push_back(epitem); 1045e948c56SGnoCiYeH Ok(()) 1055e948c56SGnoCiYeH } 106f678331aShanjiezhou } 107f678331aShanjiezhou 108f678331aShanjiezhou impl LockedPipeInode { 109876cb89eSGnoCiYeH pub fn new() -> Arc<Self> { 110f678331aShanjiezhou let inner = InnerPipeInode { 111f678331aShanjiezhou self_ref: Weak::default(), 112f678331aShanjiezhou valid_cnt: 0, 113f678331aShanjiezhou read_pos: 0, 114f678331aShanjiezhou write_pos: 0, 115f678331aShanjiezhou data: [0; PIPE_BUFF_SIZE], 116f678331aShanjiezhou 117f678331aShanjiezhou metadata: Metadata { 118f678331aShanjiezhou dev_id: 0, 119f678331aShanjiezhou inode_id: generate_inode_id(), 12022c9db31Shanjiezhou size: PIPE_BUFF_SIZE as i64, 121f678331aShanjiezhou blk_size: 0, 122f678331aShanjiezhou blocks: 0, 123f678331aShanjiezhou atime: TimeSpec::default(), 124f678331aShanjiezhou mtime: TimeSpec::default(), 125f678331aShanjiezhou ctime: TimeSpec::default(), 126f678331aShanjiezhou file_type: FileType::Pipe, 1276b4e7a29SLoGin mode: ModeType::from_bits_truncate(0o666), 128f678331aShanjiezhou nlinks: 1, 129f678331aShanjiezhou uid: 0, 130f678331aShanjiezhou gid: 0, 13102343d0bSLoGin raw_dev: Default::default(), 132f678331aShanjiezhou }, 133876cb89eSGnoCiYeH reader: 0, 134876cb89eSGnoCiYeH writer: 0, 1355e948c56SGnoCiYeH epitems: SpinLock::new(LinkedList::new()), 136f678331aShanjiezhou }; 137*dfe53cf0SGnoCiYeH let result = Arc::new(Self { 138*dfe53cf0SGnoCiYeH inner: SpinLock::new(inner), 139*dfe53cf0SGnoCiYeH read_wait_queue: WaitQueue::default(), 140*dfe53cf0SGnoCiYeH write_wait_queue: WaitQueue::default(), 141*dfe53cf0SGnoCiYeH }); 142*dfe53cf0SGnoCiYeH let mut guard = result.inner.lock(); 143f678331aShanjiezhou guard.self_ref = Arc::downgrade(&result); 144f678331aShanjiezhou // 释放锁 145f678331aShanjiezhou drop(guard); //这一步其实不需要,只要离开作用域,guard生命周期结束,自会解锁 146f678331aShanjiezhou return result; 147f678331aShanjiezhou } 1485e948c56SGnoCiYeH 1495e948c56SGnoCiYeH pub fn inner(&self) -> &SpinLock<InnerPipeInode> { 150*dfe53cf0SGnoCiYeH &self.inner 1515e948c56SGnoCiYeH } 152f678331aShanjiezhou } 153f678331aShanjiezhou 154f678331aShanjiezhou impl IndexNode for LockedPipeInode { 155f678331aShanjiezhou fn read_at( 156f678331aShanjiezhou &self, 157f678331aShanjiezhou _offset: usize, 158f678331aShanjiezhou len: usize, 159f678331aShanjiezhou buf: &mut [u8], 160*dfe53cf0SGnoCiYeH data: SpinLockGuard<FilePrivateData>, 16191e9d4abSLoGin ) -> Result<usize, SystemError> { 162876cb89eSGnoCiYeH // 获取mode 163876cb89eSGnoCiYeH let mode: FileMode; 164*dfe53cf0SGnoCiYeH if let FilePrivateData::Pipefs(pdata) = &*data { 165876cb89eSGnoCiYeH mode = pdata.mode; 166876cb89eSGnoCiYeH } else { 167876cb89eSGnoCiYeH return Err(SystemError::EBADF); 168876cb89eSGnoCiYeH } 169876cb89eSGnoCiYeH 170f678331aShanjiezhou if buf.len() < len { 171f678331aShanjiezhou return Err(SystemError::EINVAL); 172f678331aShanjiezhou } 173f678331aShanjiezhou // 加锁 174*dfe53cf0SGnoCiYeH let mut inode = self.inner.lock(); 175f678331aShanjiezhou 176f678331aShanjiezhou // 如果管道里面没有数据,则唤醒写端, 177f678331aShanjiezhou while inode.valid_cnt == 0 { 178876cb89eSGnoCiYeH // 如果当前管道写者数为0,则返回EOF 179876cb89eSGnoCiYeH if inode.writer == 0 { 180876cb89eSGnoCiYeH return Ok(0); 181876cb89eSGnoCiYeH } 182876cb89eSGnoCiYeH 183*dfe53cf0SGnoCiYeH self.write_wait_queue 1841496ba7bSLoGin .wakeup(Some(ProcessState::Blocked(true))); 1851496ba7bSLoGin 18622c9db31Shanjiezhou // 如果为非阻塞管道,直接返回错误 187876cb89eSGnoCiYeH if mode.contains(FileMode::O_NONBLOCK) { 18822c9db31Shanjiezhou drop(inode); 18922c9db31Shanjiezhou return Err(SystemError::EAGAIN_OR_EWOULDBLOCK); 19022c9db31Shanjiezhou } 1911496ba7bSLoGin 19222c9db31Shanjiezhou // 否则在读等待队列中睡眠,并释放锁 193f678331aShanjiezhou unsafe { 194f678331aShanjiezhou let irq_guard = CurrentIrqArch::save_and_disable_irq(); 195bf4a4899SLoGin 196f678331aShanjiezhou drop(inode); 197*dfe53cf0SGnoCiYeH self.read_wait_queue.sleep_without_schedule(); 198f678331aShanjiezhou drop(irq_guard); 199f678331aShanjiezhou } 200f678331aShanjiezhou sched(); 201*dfe53cf0SGnoCiYeH inode = self.inner.lock(); 202f678331aShanjiezhou } 203f678331aShanjiezhou 204f678331aShanjiezhou let mut num = inode.valid_cnt as usize; 205f678331aShanjiezhou //决定要输出的字节 206f678331aShanjiezhou let start = inode.read_pos as usize; 207f678331aShanjiezhou //如果读端希望读取的字节数大于有效字节数,则输出有效字节 208f678331aShanjiezhou let mut end = (inode.valid_cnt as usize + inode.read_pos as usize) % PIPE_BUFF_SIZE; 209f678331aShanjiezhou //如果读端希望读取的字节数少于有效字节数,则输出希望读取的字节 210f678331aShanjiezhou if len < inode.valid_cnt as usize { 211f678331aShanjiezhou end = (len + inode.read_pos as usize) % PIPE_BUFF_SIZE; 212f678331aShanjiezhou num = len; 213f678331aShanjiezhou } 214f678331aShanjiezhou 215f678331aShanjiezhou // 从管道拷贝数据到用户的缓冲区 216f678331aShanjiezhou 217f678331aShanjiezhou if end < start { 218f678331aShanjiezhou buf[0..(PIPE_BUFF_SIZE - start)].copy_from_slice(&inode.data[start..PIPE_BUFF_SIZE]); 219f678331aShanjiezhou buf[(PIPE_BUFF_SIZE - start)..num].copy_from_slice(&inode.data[0..end]); 220f678331aShanjiezhou } else { 221f678331aShanjiezhou buf[0..num].copy_from_slice(&inode.data[start..end]); 222f678331aShanjiezhou } 223f678331aShanjiezhou 224f678331aShanjiezhou //更新读位置以及valid_cnt 225f678331aShanjiezhou inode.read_pos = (inode.read_pos + num as i32) % PIPE_BUFF_SIZE as i32; 226f678331aShanjiezhou inode.valid_cnt -= num as i32; 227f678331aShanjiezhou 2285e948c56SGnoCiYeH // 读完以后如果未读完,则唤醒下一个读者 2295e948c56SGnoCiYeH if inode.valid_cnt > 0 { 230*dfe53cf0SGnoCiYeH self.read_wait_queue 2315e948c56SGnoCiYeH .wakeup(Some(ProcessState::Blocked(true))); 2325e948c56SGnoCiYeH } 2335e948c56SGnoCiYeH 234f678331aShanjiezhou //读完后解锁并唤醒等待在写等待队列中的进程 235*dfe53cf0SGnoCiYeH self.write_wait_queue 2361496ba7bSLoGin .wakeup(Some(ProcessState::Blocked(true))); 2375e948c56SGnoCiYeH 238*dfe53cf0SGnoCiYeH let pollflag = EPollEventType::from_bits_truncate(inode.poll(&data)? as u32); 2395e948c56SGnoCiYeH // 唤醒epoll中等待的进程 240b5b571e0SLoGin EventPoll::wakeup_epoll(&inode.epitems, pollflag)?; 2415e948c56SGnoCiYeH 242f678331aShanjiezhou //返回读取的字节数 243f678331aShanjiezhou return Ok(num); 244f678331aShanjiezhou } 245f678331aShanjiezhou 246f678331aShanjiezhou fn open( 247f678331aShanjiezhou &self, 248*dfe53cf0SGnoCiYeH mut data: SpinLockGuard<FilePrivateData>, 249876cb89eSGnoCiYeH mode: &crate::filesystem::vfs::file::FileMode, 250f678331aShanjiezhou ) -> Result<(), SystemError> { 251*dfe53cf0SGnoCiYeH let mut guard = self.inner.lock(); 252876cb89eSGnoCiYeH // 不能以读写方式打开管道 253876cb89eSGnoCiYeH if mode.contains(FileMode::O_RDWR) { 254876cb89eSGnoCiYeH return Err(SystemError::EACCES); 255876cb89eSGnoCiYeH } 256876cb89eSGnoCiYeH if mode.contains(FileMode::O_RDONLY) { 257876cb89eSGnoCiYeH guard.reader += 1; 258876cb89eSGnoCiYeH } 259876cb89eSGnoCiYeH if mode.contains(FileMode::O_WRONLY) { 260876cb89eSGnoCiYeH guard.writer += 1; 261876cb89eSGnoCiYeH } 262876cb89eSGnoCiYeH 263876cb89eSGnoCiYeH // 设置mode 264876cb89eSGnoCiYeH *data = FilePrivateData::Pipefs(PipeFsPrivateData { mode: *mode }); 265876cb89eSGnoCiYeH 266f678331aShanjiezhou return Ok(()); 267f678331aShanjiezhou } 268f678331aShanjiezhou 269f678331aShanjiezhou fn metadata(&self) -> Result<crate::filesystem::vfs::Metadata, SystemError> { 270*dfe53cf0SGnoCiYeH let inode = self.inner.lock(); 271f678331aShanjiezhou let mut metadata = inode.metadata.clone(); 272f678331aShanjiezhou metadata.size = inode.data.len() as i64; 273f678331aShanjiezhou 274f678331aShanjiezhou return Ok(metadata); 275f678331aShanjiezhou } 276f678331aShanjiezhou 277*dfe53cf0SGnoCiYeH fn close(&self, data: SpinLockGuard<FilePrivateData>) -> Result<(), SystemError> { 278876cb89eSGnoCiYeH let mode: FileMode; 279*dfe53cf0SGnoCiYeH if let FilePrivateData::Pipefs(pipe_data) = &*data { 280876cb89eSGnoCiYeH mode = pipe_data.mode; 281876cb89eSGnoCiYeH } else { 282876cb89eSGnoCiYeH return Err(SystemError::EBADF); 283876cb89eSGnoCiYeH } 284*dfe53cf0SGnoCiYeH let mut guard = self.inner.lock(); 285876cb89eSGnoCiYeH 286876cb89eSGnoCiYeH // 写端关闭 287876cb89eSGnoCiYeH if mode.contains(FileMode::O_WRONLY) { 288876cb89eSGnoCiYeH assert!(guard.writer > 0); 289876cb89eSGnoCiYeH guard.writer -= 1; 290876cb89eSGnoCiYeH // 如果已经没有写端了,则唤醒读端 291876cb89eSGnoCiYeH if guard.writer == 0 { 292*dfe53cf0SGnoCiYeH self.read_wait_queue 293876cb89eSGnoCiYeH .wakeup_all(Some(ProcessState::Blocked(true))); 294876cb89eSGnoCiYeH } 295876cb89eSGnoCiYeH } 296876cb89eSGnoCiYeH 297876cb89eSGnoCiYeH // 读端关闭 298876cb89eSGnoCiYeH if mode.contains(FileMode::O_RDONLY) { 299876cb89eSGnoCiYeH assert!(guard.reader > 0); 300876cb89eSGnoCiYeH guard.reader -= 1; 301876cb89eSGnoCiYeH // 如果已经没有写端了,则唤醒读端 302876cb89eSGnoCiYeH if guard.reader == 0 { 303*dfe53cf0SGnoCiYeH self.write_wait_queue 304876cb89eSGnoCiYeH .wakeup_all(Some(ProcessState::Blocked(true))); 305876cb89eSGnoCiYeH } 306876cb89eSGnoCiYeH } 307876cb89eSGnoCiYeH 308f678331aShanjiezhou return Ok(()); 309f678331aShanjiezhou } 310f678331aShanjiezhou 311f678331aShanjiezhou fn write_at( 312f678331aShanjiezhou &self, 313f678331aShanjiezhou _offset: usize, 314f678331aShanjiezhou len: usize, 315f678331aShanjiezhou buf: &[u8], 316*dfe53cf0SGnoCiYeH data: SpinLockGuard<FilePrivateData>, 31791e9d4abSLoGin ) -> Result<usize, SystemError> { 318876cb89eSGnoCiYeH // 获取mode 319876cb89eSGnoCiYeH let mode: FileMode; 320*dfe53cf0SGnoCiYeH if let FilePrivateData::Pipefs(pdata) = &*data { 321876cb89eSGnoCiYeH mode = pdata.mode; 322876cb89eSGnoCiYeH } else { 323876cb89eSGnoCiYeH return Err(SystemError::EBADF); 324876cb89eSGnoCiYeH } 325876cb89eSGnoCiYeH 326f678331aShanjiezhou if buf.len() < len || len > PIPE_BUFF_SIZE { 327f678331aShanjiezhou return Err(SystemError::EINVAL); 328f678331aShanjiezhou } 329f678331aShanjiezhou // 加锁 330f678331aShanjiezhou 331*dfe53cf0SGnoCiYeH let mut inode = self.inner.lock(); 332f678331aShanjiezhou 333b5b571e0SLoGin if inode.reader == 0 { 334876cb89eSGnoCiYeH // TODO: 如果已经没有读端存在了,则向写端进程发送SIGPIPE信号 335b5b571e0SLoGin } 336876cb89eSGnoCiYeH 337f678331aShanjiezhou // 如果管道空间不够 338f678331aShanjiezhou 339f678331aShanjiezhou while len + inode.valid_cnt as usize > PIPE_BUFF_SIZE { 340f678331aShanjiezhou // 唤醒读端 341*dfe53cf0SGnoCiYeH self.read_wait_queue 3421496ba7bSLoGin .wakeup(Some(ProcessState::Blocked(true))); 3431496ba7bSLoGin 34422c9db31Shanjiezhou // 如果为非阻塞管道,直接返回错误 345876cb89eSGnoCiYeH if mode.contains(FileMode::O_NONBLOCK) { 34622c9db31Shanjiezhou drop(inode); 34722c9db31Shanjiezhou return Err(SystemError::ENOMEM); 34822c9db31Shanjiezhou } 3491496ba7bSLoGin 350f678331aShanjiezhou // 解锁并睡眠 351f678331aShanjiezhou unsafe { 352f678331aShanjiezhou let irq_guard = CurrentIrqArch::save_and_disable_irq(); 353f678331aShanjiezhou drop(inode); 354*dfe53cf0SGnoCiYeH self.write_wait_queue.sleep_without_schedule(); 355f678331aShanjiezhou drop(irq_guard); 356f678331aShanjiezhou } 357f678331aShanjiezhou sched(); 358*dfe53cf0SGnoCiYeH inode = self.inner.lock(); 359f678331aShanjiezhou } 360f678331aShanjiezhou 361f678331aShanjiezhou // 决定要输入的字节 362f678331aShanjiezhou let start = inode.write_pos as usize; 363f678331aShanjiezhou let end = (inode.write_pos as usize + len) % PIPE_BUFF_SIZE; 364f678331aShanjiezhou // 从用户的缓冲区拷贝数据到管道 365f678331aShanjiezhou 366f678331aShanjiezhou if end < start { 367f678331aShanjiezhou inode.data[start..PIPE_BUFF_SIZE].copy_from_slice(&buf[0..(PIPE_BUFF_SIZE - start)]); 368f678331aShanjiezhou inode.data[0..end].copy_from_slice(&buf[(PIPE_BUFF_SIZE - start)..len]); 369f678331aShanjiezhou } else { 370f678331aShanjiezhou inode.data[start..end].copy_from_slice(&buf[0..len]); 371f678331aShanjiezhou } 372f678331aShanjiezhou // 更新写位置以及valid_cnt 373f678331aShanjiezhou inode.write_pos = (inode.write_pos + len as i32) % PIPE_BUFF_SIZE as i32; 374f678331aShanjiezhou inode.valid_cnt += len as i32; 375f678331aShanjiezhou 3765e948c56SGnoCiYeH // 写完后还有位置,则唤醒下一个写者 3775e948c56SGnoCiYeH if (inode.valid_cnt as usize) < PIPE_BUFF_SIZE { 378*dfe53cf0SGnoCiYeH self.write_wait_queue 3795e948c56SGnoCiYeH .wakeup(Some(ProcessState::Blocked(true))); 3805e948c56SGnoCiYeH } 3815e948c56SGnoCiYeH 382f678331aShanjiezhou // 读完后解锁并唤醒等待在读等待队列中的进程 383*dfe53cf0SGnoCiYeH self.read_wait_queue 3841496ba7bSLoGin .wakeup(Some(ProcessState::Blocked(true))); 3855e948c56SGnoCiYeH 386*dfe53cf0SGnoCiYeH let pollflag = EPollEventType::from_bits_truncate(inode.poll(&data)? as u32); 3875e948c56SGnoCiYeH // 唤醒epoll中等待的进程 388b5b571e0SLoGin EventPoll::wakeup_epoll(&inode.epitems, pollflag)?; 3895e948c56SGnoCiYeH 390f678331aShanjiezhou // 返回写入的字节数 391f678331aShanjiezhou return Ok(len); 392f678331aShanjiezhou } 393f678331aShanjiezhou 394f678331aShanjiezhou fn as_any_ref(&self) -> &dyn core::any::Any { 395f678331aShanjiezhou self 396f678331aShanjiezhou } 397f678331aShanjiezhou 398f678331aShanjiezhou fn get_entry_name_and_metadata( 399f678331aShanjiezhou &self, 400f678331aShanjiezhou ino: crate::filesystem::vfs::InodeId, 401f678331aShanjiezhou ) -> Result<(alloc::string::String, crate::filesystem::vfs::Metadata), SystemError> { 402f678331aShanjiezhou // 如果有条件,请在文件系统中使用高效的方式实现本接口,而不是依赖这个低效率的默认实现。 403f678331aShanjiezhou let name = self.get_entry_name(ino)?; 404f678331aShanjiezhou let entry = self.find(&name)?; 405f678331aShanjiezhou return Ok((name, entry.metadata()?)); 406f678331aShanjiezhou } 407f678331aShanjiezhou 408f678331aShanjiezhou fn fs(&self) -> Arc<(dyn FileSystem)> { 409f678331aShanjiezhou todo!() 410f678331aShanjiezhou } 411f678331aShanjiezhou 412f678331aShanjiezhou fn list(&self) -> Result<alloc::vec::Vec<alloc::string::String>, SystemError> { 413f678331aShanjiezhou return Err(SystemError::EOPNOTSUPP_OR_ENOTSUP); 414f678331aShanjiezhou } 4155e948c56SGnoCiYeH 4165e948c56SGnoCiYeH fn poll(&self, private_data: &FilePrivateData) -> Result<usize, SystemError> { 417*dfe53cf0SGnoCiYeH return self.inner.lock().poll(private_data); 4185e948c56SGnoCiYeH } 419f678331aShanjiezhou } 420