tessarikv 0.1.0

A pure-Rust, lock-free-first LSM key-value storage engine
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

//! Durable flushes, per platform.

use std::fs::File;
use std::path::Path;

use crate::Result;

/// Flushes a file's data to stable storage.
///
/// Apple platforms need `F_FULLFSYNC`: a plain `fsync` there returns once the drive has the
/// data in its volatile cache.
#[cfg(target_vendor = "apple")]
pub(super) fn full_sync(file: &File) -> std::io::Result<()> {
    rustix::fs::fcntl_fullfsync(file).map_err(std::io::Error::from)
}

/// Flushes a file's data to stable storage: `fdatasync` on Linux, `FlushFileBuffers` on Windows.
#[cfg(not(target_vendor = "apple"))]
pub(super) fn full_sync(file: &File) -> std::io::Result<()> {
    file.sync_data()
}

/// Makes a directory's entries (creations, renames, removals) durable.
#[cfg(unix)]
pub(super) fn sync_directory(dir: &Path) -> Result<()> {
    File::open(dir)
        .and_then(|handle| handle.sync_all())
        .map_err(|error| crate::Error::io("sync directory", dir, error))
}

/// Windows has no directory handle to flush: NTFS journals metadata changes itself.
#[cfg(not(unix))]
pub(super) fn sync_directory(_dir: &Path) -> Result<()> {
    Ok(())
}