tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

log rotate: factor out compression in private function

Browse Source 
Signed-off-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
This commit is contained in:
Thomas Lamprecht 2020-10-20 10:24:46 +02:00
parent e6ca9c3235
commit 7827e3b93e
1 changed files with 31 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
src/tools/logrotate.rs
View File

@ -46,6 +46,35 @@ impl LogRotate {
} }
} }
fn compress(file: &PathBuf, options: &CreateOptions) -> Result<(), Error> {
let mut source = File::open(file)?;
let (fd, tmp_path) = make_tmp_file(file, options.clone())?;
let target = unsafe { File::from_raw_fd(fd) };
let mut encoder = match zstd::stream::write::Encoder::new(target, 0) {
Ok(encoder) => encoder,
Err(err) => {
let _ = unistd::unlink(&tmp_path);
bail!("creating zstd encoder failed - {}", err);
}
};
if let Err(err) = std::io::copy(&mut source, &mut encoder) {
let _ = unistd::unlink(&tmp_path);
bail!("zstd encoding failed for file {:?} - {}", file, err);
}
if let Err(err) = encoder.finish() {
let _ = unistd::unlink(&tmp_path);
bail!("zstd finish failed for file {:?} - {}", file, err);
}
if let Err(err) = rename(&tmp_path, file) {
let _ = unistd::unlink(&tmp_path);
bail!("rename failed for file {:?} - {}", file, err);
}
Ok(())
}
/// Rotates the files up to 'max_files' /// Rotates the files up to 'max_files'
/// if the 'compress' option was given it will compress the newest file /// if the 'compress' option was given it will compress the newest file
/// ///
@ -77,38 +106,13 @@ impl LogRotate {
} }
if self.compress { if self.compress {
let mut source = File::open(&filenames[0])?; if filenames[0].extension().unwrap_or(std::ffi::OsStr::new("")) != "zst" {
let (fd, tmp_path) = make_tmp_file(&filenames[1], options.clone())?; Self::compress(&filenames[0], &options)?;
let target = unsafe { File::from_raw_fd(fd) };
let mut encoder = match zstd::stream::write::Encoder::new(target, 0) {
Ok(encoder) => encoder,
Err(err) => {
let _ = unistd::unlink(&tmp_path);
bail!("creating zstd encoder failed - {}", err);
}
};
if let Err(err) = std::io::copy(&mut source, &mut encoder) {
let _ = unistd::unlink(&tmp_path);
bail!("zstd encoding failed for file {:?} - {}", &filenames[1], err);
} }
if let Err(err) = encoder.finish() {
let _ = unistd::unlink(&tmp_path);
bail!("zstd finish failed for file {:?} - {}", &filenames[1], err);
}
if let Err(err) = rename(&tmp_path, &filenames[1]) {
let _ = unistd::unlink(&tmp_path);
bail!("rename failed for file {:?} - {}", &filenames[1], err);
}
unistd::unlink(&filenames[0])?;
} else { } else {
rename(&filenames[0], &filenames[1])?; rename(&filenames[0], &filenames[1])?;
} }
if let Some(max_files) = max_files { if let Some(max_files) = max_files {
// delete all files > max_files // delete all files > max_files
for file in filenames.iter().skip(max_files) { for file in filenames.iter().skip(max_files) {