linkrs-storage 0.1.0

Storage engine with CSR and memory-mapped containers
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
29

//! Shared filesystem durability helpers: recursive tree and single
//! directory fsync. Used by the checkpoint writer and the snapshot manager.

use std::path::Path;

use linkrs_core::StorageResult;

/// Recursively fsync every file under `root`, then each directory bottom-up.
pub(crate) fn sync_tree(root: &Path) -> StorageResult<()> {
    fn visit(directory: &Path) -> StorageResult<()> {
        for item in std::fs::read_dir(directory)? {
            let path = item?.path();
            if path.is_dir() {
                visit(&path)?;
            } else if path.is_file() {
                std::fs::File::open(path)?.sync_all()?;
            }
        }
        sync_directory(directory)
    }

    visit(root)
}

/// fsync a single directory entry so rename/create operations are durable.
pub(crate) fn sync_directory(directory: &Path) -> StorageResult<()> {
    std::fs::File::open(directory)?.sync_all()?;
    Ok(())
}