Function cleanup_stale_registrations

vmm/src/discovery.rs:113–144

Clean up stale discovery files from dead processes.

()

/// Clean up stale discovery files from dead processes.
pub fn cleanup_stale_registrations() {
    let dir = discovery_dir();
    let entries = match std::fs::read_dir(dir) {
        Ok(e) => e,
        Err(_) => return,
    };

    for entry in entries.flatten() {
        let path = entry.path();
        if path.extension().and_then(|e| e.to_str()) != Some("json") {
            continue;
        }
        let content = match std::fs::read_to_string(&path) {
            Ok(c) => c,
            Err(_) => continue,
        };
        let info: VmmInstanceInfo = match serde_json::from_str(&content) {
            Ok(i) => i,
            Err(_) => continue,
        };
        // Check if the process is still alive
        let alive = Path::new(&format!("/proc/{}", info.pid)).exists();
        if !alive {
            info!(
                "removing stale discovery file for pid {} at {}",
                info.pid,
                path.display()
            );
            let _ = std::fs::remove_file(&path);
        }
    }
}