logos-blockchain/logos-blockchain-simulations
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-simulations.git synced 2026-01-21 22:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

coeff: handle only completed paramsets

Browse Source
This commit is contained in:
Youngjoon Lee 2024-09-26 11:09:27 +09:00
parent b495b6852a
commit b1b5d87528
No known key found for this signature in database
GPG Key ID: 167546E2D1712F8C
1 changed files with 36 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
mixnet/ordering/src/bin/coeff.rs
View File

@ -240,32 +240,45 @@ fn calculate_coeffs(args: &Args) {
.filter(|e| e.file_type().is_dir())
{
let dir_name = entry.path().file_name().unwrap().to_string_lossy();
if dir_name.starts_with("iteration_") {
for sent_seq_file in glob(&format!("{}/sent_seq_*.csv", entry.path().display()))
.unwrap()
.filter_map(Result::ok)
if dir_name.starts_with("paramset_") {
for inner_entry in WalkDir::new(entry.path())
.into_iter()
.filter_map(|e| e.ok())
.filter(|e| e.file_type().is_dir())
{
let sender =
extract_id(&sent_seq_file.file_name().unwrap().to_string_lossy()).unwrap();
let dir_name = inner_entry.path().file_name().unwrap().to_string_lossy();
if dir_name.starts_with("iteration_") {
for sent_seq_file in
glob(&format!("{}/sent_seq_*.csv", inner_entry.path().display()))
.unwrap()
.filter_map(Result::ok)
{
let sender =
extract_id(&sent_seq_file.file_name().unwrap().to_string_lossy())
.unwrap();
for recv_seq_file in glob(&format!("{}/recv_seq_*.csv", entry.path().display()))
.unwrap()
.filter_map(Result::ok)
{
let receiver =
extract_id(&recv_seq_file.file_name().unwrap().to_string_lossy()).unwrap();
for recv_seq_file in
glob(&format!("{}/recv_seq_*.csv", inner_entry.path().display()))
.unwrap()
.filter_map(Result::ok)
{
let receiver =
extract_id(&recv_seq_file.file_name().unwrap().to_string_lossy())
.unwrap();
let task = Task {
sent_seq_file: sent_seq_file.clone(),
recv_seq_file: recv_seq_file.clone(),
sender,
receiver,
outpath: entry
.path()
.join(format!("coeffs_{}_{}.csv", sender, receiver)),
sent_seq_limit: args.sent_seq_limit,
};
tasks.push(task);
let task = Task {
sent_seq_file: sent_seq_file.clone(),
recv_seq_file: recv_seq_file.clone(),
sender,
receiver,
outpath: inner_entry
.path()
.join(format!("coeffs_{}_{}.csv", sender, receiver)),
sent_seq_limit: args.sent_seq_limit,
};
tasks.push(task);
}
}
}
}
}