Week 8

// ==================== 1. 触发点安全过滤与前置校验 ====================
// api/src/kmod/ondemand_builtin.rs 
// 优先比对 filesystem name 和 devfs 内存特征，杜绝误触底层 Ext4 磁盘的 Cache，进而引发 ext4_bcache_free 崩溃。
#[inline]
fn is_fuse_node(loc: &axfs_ng_vfs::Location) -> bool {
    if loc.filesystem().name() == "fuse" {
        return true;
    }
    if let Ok(metadata) = loc.metadata() {
        if metadata.node_type == axfs_ng_vfs::NodeType::CharacterDevice {
            if metadata.rdev == axfs_ng_vfs::DeviceId::new(10, 229) {
                return true;
            }
        }
    }
    false
}

impl UsageChecker for FuseUsageChecker {
    fn is_in_use(&self) -> bool {
        let mut process_data_list = alloc::vec::Vec::new();
        // 收集任务信息，避免在获取 VFS 锁时长时间把持自旋锁
        for task in tasks() {
            process_data_list.push(task.as_thread().proc_data.clone());
        }

        for proc_data in process_data_list {
            let scope_guard = proc_data.scope.read();

            // 前置调用 is_fuse_node() 过滤，取代原版的 .path().contains()
            if is_fuse_node(FS_CONTEXT.scope(&scope_guard).lock().current_dir()) {
                return true;
            }

            // 同样安全地遍历用户进程持有的全量 FD
            let fd_table_scope = FD_TABLE.scope(&scope_guard);
            let fd_table = fd_table_scope.read();
            for fd in fd_table.ids() {
                if let Some(fd_obj) = fd_table.get(fd) {
                    let any = fd_obj.inner.clone().into_any();
                    if let Some(file) = any.downcast_ref::<crate::file::File>() {
                        if is_fuse_node(file.inner().location()) {
                            return true;
                        }
                    }
                }
            }
        }
        false
    }
}

// ==================== 2. 文件系统动态挂载表，抹除硬编码 ====================
// api/src/syscall/fs/mount.rs
// 系统解除针对特定文件系统（如 ext4, procfs）的内部探测 if-else 判断。
// 不受 FS_CONTEXT.lock() 牵制的专属 registry 匹配机制，令 FUSE 模块加载后能够动态挂载自身。
pub fn sys_mount(
    source: *const c_char,
    target: *const c_char,
    fs_type: *const c_char,
    _flags: i32,
    _data: *const c_void,
) -> AxResult<isize> {
    let source = vm_load_string(source)?;
    let target = vm_load_string(target)?;
    let fs_type = vm_load_string(fs_type)?;
    
    let fs = if fs_type == "tmpfs" {
        MemoryFs::new()
    } else if let Some(creator) = crate::vfs::get_filesystem_creator(&fs_type) {
        // 如果系统内部无法处理，下行给全局注册表闭包 (Creator) 支持 On-Demand
        creator()?
    } else {
        return Err(AxError::NoSuchDevice);
    };

    let target = FS_CONTEXT.lock().resolve(target)?;
    target.mount(&fs)?;

    Ok(0)
}


// ==================== 3. 用户态服务多路复用，规避进程僵死挂起 ====================
// Starryfuse/tests/fuse_test/src/main.rs
// 舍弃死板的阻塞 read。利用 libc::poll 获取超时控制，以便在空闲时主导生命周期控制并平滑退出。
loop {
    let mut pfd = libc::pollfd {
        fd: fuse_fd,
        events: libc::POLLIN,
        revents: 0,
    };
    
    // Poll 超时设为 20ms，若队列全空则短暂挂起后苏醒
    let poll_ret = unsafe { libc::poll(&mut pfd as *mut libc::pollfd, 1, 20) };
    if poll_ret < 0 {
        let err = std::io::Error::last_os_error();
        if err.kind() == std::io::ErrorKind::Interrupted {
            continue;
        }
        break;
    }

    // 识别到已无后续指令，主动读取停止标志位退出循环，从根源解决 daemon hang
    if poll_ret == 0 || (pfd.revents & libc::POLLIN) == 0 {
        if child_done.load(std::sync::atomic::Ordering::SeqCst)
            && child_done_since
                .map(|t| t.elapsed() >= Duration::from_millis(500))
                .unwrap_or(false)
        {
            println!("Test complete, daemon exiting.");
            break;
        }
        continue;
    }

    let n = match fuse_dev.read(&mut buf) {
        Ok(n) => n,
        Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => continue,
        Err(e) => break,
    };
    
    // ... [处理具体的 FUSE opcode 逻辑]
}