Function read_dir_sync

nodedb/src/control/cold_tier.rs:207–221

Read a directory on a blocking thread, returning paths of all regular files.

(dir: &std::path::Path)

/// Read a directory on a blocking thread, returning paths of all regular files.
async fn read_dir_sync(dir: &std::path::Path) -> std::io::Result<Vec<PathBuf>> {
    let dir = dir.to_path_buf();
    tokio::task::spawn_blocking(move || {
        let mut result = Vec::new();
        for entry in std::fs::read_dir(&dir)? {
            let entry = entry?;
            if entry.metadata()?.is_file() {
                result.push(entry.path());
            }
        }
        Ok(result)
    })
    .await
    .map_err(|e| std::io::Error::other(format!("spawn_blocking join: {e}")))?
}

/// Return the elapsed time since a file was last modified, or `None` on any error.
fn file_age(path: &std::path::Path, now: SystemTime) -> Option<Duration> {