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

tape restore: add restore speed to logs

This commit is contained in:
Dietmar Maurer 2021-04-30 13:04:55 +02:00
parent 5400fe171c
commit 88aa3076f0
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/api2/tape/restore.rs
View File

@ -698,6 +698,9 @@ fn restore_chunk_archive<'a>(
let verify_and_write_channel = writer_pool.channel(); let verify_and_write_channel = writer_pool.channel();
let start_time = std::time::SystemTime::now();
let mut bytes = 0;
loop { loop {
let (digest, blob) = match decoder.next_chunk() { let (digest, blob) = match decoder.next_chunk() {
Ok(Some((digest, blob))) => (digest, blob), Ok(Some((digest, blob))) => (digest, blob),
@ -728,6 +731,7 @@ fn restore_chunk_archive<'a>(
if verbose { if verbose {
task_log!(worker, "Insert chunk: {}", proxmox::tools::digest_to_hex(&digest)); task_log!(worker, "Insert chunk: {}", proxmox::tools::digest_to_hex(&digest));
} }
bytes += blob.raw_size();
verify_and_write_channel.send((blob, digest.clone()))?; verify_and_write_channel.send((blob, digest.clone()))?;
} else if verbose { } else if verbose {
task_log!(worker, "Found existing chunk: {}", proxmox::tools::digest_to_hex(&digest)); task_log!(worker, "Found existing chunk: {}", proxmox::tools::digest_to_hex(&digest));
@ -740,6 +744,15 @@ fn restore_chunk_archive<'a>(
writer_pool.complete()?; writer_pool.complete()?;
let elapsed = start_time.elapsed()?.as_secs_f64();
task_log!(
worker,
"restored {} bytes ({:.2} MB/s)",
bytes,
(bytes as f64) / (1_000_000.0 * elapsed)
);
Ok(Some(chunks)) Ok(Some(chunks))
} }