WeebDataHoarder/Av1an
WeebDataHoarder/Av1an
1
0
Fork 0
Code Issues Pull requests Releases Activity

Added resume workers information

Browse source
This commit is contained in:
DataHoarder 2022-07-02 17:13:36 +02:00
parent a33040fd85
commit 25151d85f0
Signed by: DataHoarder
SSH key fingerprint: SHA256:OLTRf6Fl87G52SiR7sWLGNzlJt4WOX+tfI2yxo0z7xk
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
av1an-core/src/settings.rs
View file

@ -1,5 +1,5 @@
use std::borrow::{Borrow, Cow};
use std::cmp::{min, Ordering, Reverse};
use std::cmp::{max, min, Ordering, Reverse};
use std::collections::{BTreeSet, HashSet};
use std::convert::TryInto;
use std::ffi::OsString;
@ -1049,7 +1049,7 @@ properly into a mkv file. Specify mkvmerge as the concatenation method by settin
// only keep the chunks that are not done
chunks.retain(|chunk| !done.done.contains_key(&chunk.name()) && !done.locked.contains_key(&chunk.name()));
num_chunks = min(num_chunks, self.workers);
num_chunks = min(num_chunks, max(1, self.workers));
//only take as many chunks as workers
chunks = chunks[0..num_chunks].to_vec();
@ -1152,10 +1152,11 @@ properly into a mkv file. Specify mkvmerge as the concatenation method by settin
if self.resume {
let chunks_done = get_done().done.len();
info!(
"encoding resumed with {}/{} chunks completed ({} remaining)",
"encoding resumed with {}/{} chunks completed ({} remaining, {} workers)",
chunks_done,
chunk_queue.len() + chunks_done,
chunk_queue.len()
chunk_queue.len(),
self.workers
);
}