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

add QUEUE_DATA_MSG_COUNT_MEASUREMENT_INTERVAL

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

11
mixnet-rs/ordering/src/iteration.rs
View File

@ -15,6 +15,8 @@ use crate::{
};
use ordering::message::{DataMessage, DataMessageGenerator};
const QUEUE_DATA_MSG_COUNT_MEASUREMENT_INTERVAL: f32 = 100.0;
pub struct Iteration {
pub paramset: ParamSet,
pub iteration_idx: usize,
@ -79,6 +81,7 @@ impl Iteration {
// Virtual discrete time
let mut vtime: f32 = 0.0;
let mut recent_vtime_queue_data_msg_count_measured: f32 = 0.0;
// Transmission interval that each queue must release a message
let transmission_interval = 1.0 / paramset.transmission_rate as f32;
// Results
@ -174,7 +177,13 @@ impl Iteration {
);
// Record the number of data messages in each mix node's queues
outputs.add_queue_data_msg_counts(vtime, &mixnodes);
if vtime == 0.0
|| vtime - recent_vtime_queue_data_msg_count_measured
>= QUEUE_DATA_MSG_COUNT_MEASUREMENT_INTERVAL
{
outputs.add_queue_data_msg_counts(vtime, &mixnodes);
recent_vtime_queue_data_msg_count_measured = vtime;
}
// If all senders finally emitted all data+noise messages,
// and If all data messages have been received by the receiver,