PublicArchive/uutils-coreutils
2
0
Fork 0
mirror of https://github.com/uutils/coreutils.git synced 2026-05-06 07:26:38 -04:00
Code Issues Packages Projects Releases Wiki Activity

refactor(sync): DRY do_sync_with function

Browse Source
This commit is contained in:
hlsxx
2026-04-27 15:38:51 +02:00
committed by Daniel Hofstetter
parent a8ca919dc4
commit 35d0a1eb5c
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/uu/sync/src/sync.rs
+11 -9
View File
@@ -80,25 +80,27 @@ mod platform {
}
#[cfg(any(target_os = "linux", target_os = "android"))]
pub fn do_syncfs(files: Vec<String>) -> UResult<()> {
pub fn do_sync_with<F>(files: Vec<String>, op: F) -> UResult<()>
where
F: Fn(File) -> Result<(), nix::Error>,
{
for path in files {
let f = open_and_reset_nonblock(&path)?;
syncfs(f).map_err_context(
op(f).map_err_context(
|| translate!("sync-error-syncing-file", "file" => path.quote()),
)?;
}
Ok(())
}
#[cfg(any(target_os = "linux", target_os = "android"))]
pub fn do_syncfs(files: Vec<String>) -> UResult<()> {
do_sync_with(files, syncfs)
}
#[cfg(any(target_os = "linux", target_os = "android"))]
pub fn do_fdatasync(files: Vec<String>) -> UResult<()> {
for path in files {
let f = open_and_reset_nonblock(&path)?;
fdatasync(f).map_err_context(
|| translate!("sync-error-syncing-file", "file" => path.quote()),
)?;
}
Ok(())
do_sync_with(files, fdatasync)
}
}