Proxmox/proxmox-backup
5
0
Fork 0
mirror of git://git.proxmox.com/git/proxmox-backup.git synced 2025-01-20 14:03:53 +03:00
Code Releases Activity

pxar: bin: support creation of split pxar archives via cli

Browse Source 
Add support to create split pxar archives by redirecting the payload
output to a dedicated file.

Signed-off-by: Christian Ebner <c.ebner@proxmox.com>
This commit is contained in:
Christian Ebner 2024-06-03 16:37:16 +02:00 committed by Fabian Grünbichler
parent f16c5de757
commit 108764f95b
1 changed files with 26 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
pxar-bin/src/main.rs
View File

@ -328,6 +328,10 @@ fn extract_archive(
minimum: 0, minimum: 0,
maximum: isize::MAX, maximum: isize::MAX,
}, },
"payload-output": {
description: "'ppxar' payload output data file to create split archive.",
optional: true,
},
}, },
}, },
)] )]
@ -345,6 +349,7 @@ async fn create_archive(
no_sockets: bool, no_sockets: bool,
exclude: Option<Vec<String>>, exclude: Option<Vec<String>>,
entries_max: isize, entries_max: isize,
payload_output: Option<String>,
) -> Result<(), Error> { ) -> Result<(), Error> {
let patterns = { let patterns = {
let input = exclude.unwrap_or_default(); let input = exclude.unwrap_or_default();
@ -387,6 +392,16 @@ async fn create_archive(
.mode(0o640) .mode(0o640)
.open(archive)?; .open(archive)?;
let payload_file = payload_output
.map(|payload_output| {
OpenOptions::new()
.create_new(true)
.write(true)
.mode(0o640)
.open(payload_output)
})
.transpose()?;
let writer = std::io::BufWriter::with_capacity(1024 * 1024, file); let writer = std::io::BufWriter::with_capacity(1024 * 1024, file);
let mut feature_flags = Flags::DEFAULT; let mut feature_flags = Flags::DEFAULT;
if no_xattrs { if no_xattrs {
@ -408,7 +423,15 @@ async fn create_archive(
feature_flags.remove(Flags::WITH_SOCKETS); feature_flags.remove(Flags::WITH_SOCKETS);
} }
let writer = pxar::PxarVariant::Unified(pxar::encoder::sync::StandardWriter::new(writer)); let writer = if let Some(payload_file) = payload_file {
let payload_writer = std::io::BufWriter::with_capacity(1024 * 1024, payload_file);
pxar::PxarVariant::Split(
pxar::encoder::sync::StandardWriter::new(writer),
pxar::encoder::sync::StandardWriter::new(payload_writer),
)
} else {
pxar::PxarVariant::Unified(pxar::encoder::sync::StandardWriter::new(writer))
};
pbs_client::pxar::create_archive( pbs_client::pxar::create_archive(
dir, dir,
PxarWriters::new(writer, None), PxarWriters::new(writer, None),
@ -535,7 +558,8 @@ fn main() {
CliCommand::new(&API_METHOD_CREATE_ARCHIVE) CliCommand::new(&API_METHOD_CREATE_ARCHIVE)
.arg_param(&["archive", "source"]) .arg_param(&["archive", "source"])
.completion_cb("archive", complete_file_name) .completion_cb("archive", complete_file_name)
.completion_cb("source", complete_file_name), .completion_cb("source", complete_file_name)
.completion_cb("payload-output", complete_file_name),
) )
.insert( .insert(
"extract", "extract",