file-engine 2.4.0

Async, cross-platform file operations engine for desktop apps and developer tools: copy, move, sync, watch, and compress files with progress reporting and cancellation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use std::io;

use crate::error::{classify_io_error, Error};

pub(crate) fn classify_jwalk_error(err: jwalk::Error) -> Error {
    let path = err.path().map(|p| p.to_path_buf());
    match err.into_io_error() {
        Some(io_err) => classify_io_error(io_err, path.unwrap_or_default(), 0),
        None => Error::Io {
            path: path.unwrap_or_default(),
            source: io::Error::other("directory walk error"),
        },
    }
}

/// Default worker pool size for both the parallel tree walk (`walk.rs`)
/// and concurrent hashing during duplicate detection (`hash.rs`).
/// Duplicated from `operations::default_concurrency` — that helper lives
/// behind `operations`, which `analyze` doesn't require. Unlike error
/// classification (consolidated into `crate::error::classify_io_error`,
/// which lives outside any feature gate), this one has no
/// feature-independent home to move to without restructuring where
/// `default_concurrency` itself is defined.
pub(crate) fn default_concurrency() -> usize {
    std::thread::available_parallelism()
        .map(|n| n.get())
        .unwrap_or(1)
}