fsys 1.1.0

Filesystem IO for Rust storage engines: journal substrate, io_uring, NVMe passthrough, atomic writes, cross-platform durability.
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

//! 0.4.0 integration: strict input-order semantics (decision #3).
//!
//! Within a single batch, ops execute in submission order. The
//! dispatcher does not reorder, coalesce, or deduplicate. This file
//! exercises ordering through the public API across mixed op types.

use std::path::PathBuf;
use std::sync::atomic::{AtomicU64, Ordering};

static C: AtomicU64 = AtomicU64::new(0);

fn tmp(suffix: &str) -> PathBuf {
    let n = C.fetch_add(1, Ordering::Relaxed);
    std::env::temp_dir().join(format!(
        "fsys_batch_order_{}_{}_{}",
        std::process::id(),
        n,
        suffix
    ))
}

struct FileGuard(PathBuf);
impl Drop for FileGuard {
    fn drop(&mut self) {
        let _ = std::fs::remove_file(&self.0);
    }
}

#[test]
fn write_batch_repeats_to_same_file_last_one_wins() {
    let h = fsys::new().expect("handle");
    let p = tmp("repeat");
    let _g = FileGuard(p.clone());

    h.write_batch(&[
        (p.as_path(), b"v1".as_slice()),
        (p.as_path(), b"v2".as_slice()),
        (p.as_path(), b"v3".as_slice()),
        (p.as_path(), b"final".as_slice()),
    ])
    .expect("batch");

    assert_eq!(std::fs::read(&p).unwrap(), b"final");
}

#[test]
fn write_then_delete_then_write_in_same_batch_executes_in_order() {
    let h = fsys::new().expect("handle");
    let p = tmp("write_delete_write");
    let _g = FileGuard(p.clone());

    let mut b = h.batch();
    let _ = b
        .write(&p, b"initial")
        .delete(&p)
        .write(&p, b"after-delete");
    b.commit().expect("commit");

    // Final state: file exists with the post-delete payload, because
    // the delete happened before the second write within the batch.
    assert_eq!(std::fs::read(&p).unwrap(), b"after-delete");
}

#[test]
fn delete_after_write_in_same_batch_leaves_file_gone() {
    let h = fsys::new().expect("handle");
    let p = tmp("write_then_delete");
    let _g = FileGuard(p.clone());

    let mut b = h.batch();
    let _ = b.write(&p, b"created").delete(&p);
    b.commit().expect("commit");

    assert!(!p.exists(), "delete after write must remove the file");
}

#[test]
fn copy_observes_post_write_state_within_same_batch() {
    let h = fsys::new().expect("handle");
    let src = tmp("ord_src");
    let dst = tmp("ord_dst");
    let _g1 = FileGuard(src.clone());
    let _g2 = FileGuard(dst.clone());

    let mut b = h.batch();
    let _ = b.write(&src, b"new-content").copy(&src, &dst);
    b.commit().expect("commit");

    // Strict order: write happened before copy, so the copy must see
    // the new content.
    assert_eq!(std::fs::read(&dst).unwrap(), b"new-content");
}

#[test]
fn ten_distinct_writes_in_one_batch_all_persist_in_order() {
    let h = fsys::new().expect("handle");
    let dir = tmp("ten_root");
    std::fs::create_dir_all(&dir).unwrap();
    struct DirGuard(PathBuf);
    impl Drop for DirGuard {
        fn drop(&mut self) {
            let _ = std::fs::remove_dir_all(&self.0);
        }
    }
    let _g = DirGuard(dir.clone());

    // Build a batch of 10 writes to distinct files, each carrying its
    // index. After commit, every file must reflect its index.
    let mut b = h.batch();
    let paths: Vec<PathBuf> = (0..10).map(|i| dir.join(format!("ord_{i}"))).collect();
    for (i, p) in paths.iter().enumerate() {
        let _ = b.write(p, format!("v{i}").as_bytes());
    }
    b.commit().expect("commit");

    for (i, p) in paths.iter().enumerate() {
        assert_eq!(std::fs::read_to_string(p).unwrap(), format!("v{i}"));
    }
}