From c60bde5a3516e773fbeaccdcb53bed5f59534740 Mon Sep 17 00:00:00 2001 From: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com> Date: Sat, 17 Aug 2024 09:00:40 +0900 Subject: [PATCH] enhance logs --- mixnet-rs/dissemination/src/main.rs | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/mixnet-rs/dissemination/src/main.rs b/mixnet-rs/dissemination/src/main.rs index fa150f7..77baee2 100644 --- a/mixnet-rs/dissemination/src/main.rs +++ b/mixnet-rs/dissemination/src/main.rs @@ -73,6 +73,9 @@ fn main() { let (sender, mut receiver) = tokio::sync::mpsc::unbounded_channel::<(u16, u16)>(); let mut waiting_iterations: HashMap = HashMap::new(); + let mut num_completed_paramsets = 0; + let num_paramsets = paramsets.len(); + for paramset in paramsets { let paramset_dir = format!("{outdir}/{subdir}/__WIP__paramset_{}", paramset.id); std::fs::create_dir_all(paramset_dir.as_str()).unwrap(); @@ -105,7 +108,14 @@ fn main() { let new_paramset_dir = paramset_dir.replace("__WIP__paramset_", "paramset_"); std::fs::rename(¶mset_dir, &new_paramset_dir) .expect("Failed to rename: {paramset_dir} -> {new_paramset_dir}: {e}"); - tracing::info!("ParamSet:{} completed.", paramset_id); + + num_completed_paramsets += 1; + tracing::info!( + "ParamSet:{} completed. {}/{} paramsets have been done so far.", + paramset_id, + num_completed_paramsets, + num_paramsets + ); } // Exit loop if no more iterations are waiting