durable.rs 100.0%

26 of 26 lines run, 10 of 10 functions · run #33 on main · run missed

//! Writing files so a crash leaves the old content or the new, never half:
//! a temporary file in the same directory, flushed, then renamed over.

use std::io::Write;
use std::path::Path;

fn write(path: &Path, bytes: &[u8], private: bool) -> std::io::Result<()> {
    let dir = path.parent().filter(|d| !d.as_os_str().is_empty()).unwrap_or(Path::new("."));
    std::fs::create_dir_all(dir)?;
    let name = path.file_name().and_then(|n| n.to_str()).unwrap_or("file");
    let tmp = dir.join(format!(".{name}.{}.tmp", std::process::id()));
    let mut opts = std::fs::OpenOptions::new();
    opts.write(true).create(true).truncate(true);
    #[cfg(unix)]
    {
        use std::os::unix::fs::OpenOptionsExt;
        opts.mode(if private { 0o600 } else { 0o644 });
    }
    #[cfg(not(unix))]
    let _ = private;
    let mut f = opts.open(&tmp)?;
    f.write_all(bytes)?;
    f.sync_all()?;
    drop(f);
    std::fs::rename(&tmp, path)?;
    if let Ok(d) = std::fs::File::open(dir) {
        let _ = d.sync_all();
    }
    Ok(())
}

pub fn write_atomic(path: &Path, bytes: &[u8]) -> std::io::Result<()> {
    write(path, bytes, false)
}

/// As [`write_atomic`], readable by its owner only.
pub fn write_atomic_private(path: &Path, bytes: &[u8]) -> std::io::Result<()> {
    write(path, bytes, true)
}

1		//! Writing files so a crash leaves the old content or the new, never half:
2		//! a temporary file in the same directory, flushed, then renamed over.
3
4		use std::io::Write;
5		use std::path::Path;
6
7	666×	fn write(path: &Path, bytes: &[u8], private: bool) -> std::io::Result<()> {
8	666×	let dir = path.parent().filter(\|d\| !d.as_os_str().is_empty()).unwrap_or(Path::new("."));
9	666×	std::fs::create_dir_all(dir)?;
10	666×	let name = path.file_name().and_then(\|n\| n.to_str()).unwrap_or("file");
11	666×	let tmp = dir.join(format!(".{name}.{}.tmp", std::process::id()));
12	666×	let mut opts = std::fs::OpenOptions::new();
13	666×	opts.write(true).create(true).truncate(true);
14		#[cfg(unix)]
15		{
16		use std::os::unix::fs::OpenOptionsExt;
17	666×	opts.mode(if private { 0o600 } else { 0o644 });
18		}
19		#[cfg(not(unix))]
20		let _ = private;
21	666×	let mut f = opts.open(&tmp)?;
22	666×	f.write_all(bytes)?;
23	666×	f.sync_all()?;
24	666×	drop(f);
25	666×	std::fs::rename(&tmp, path)?;
26	666×	if let Ok(d) = std::fs::File::open(dir) {
27	666×	let _ = d.sync_all();
28	666×	}
29	666×	Ok(())
30	666×	}
31
32	458×	pub fn write_atomic(path: &Path, bytes: &[u8]) -> std::io::Result<()> {
33	458×	write(path, bytes, false)
34	458×	}
35
36		/// As [`write_atomic`], readable by its owner only.
37	208×	pub fn write_atomic_private(path: &Path, bytes: &[u8]) -> std::io::Result<()> {
38	208×	write(path, bytes, true)
39	208×	}

`/`	Search
`g` `c`	Code
`g` `h`	History
`g` `b`	Bookmarks
`g` `t`	Trust
`y`	Permalink to this state (files and trees)
`?`	This sheet

Coverage / crates/spectra-core/src/durable.rs 100.0%

Keyboard