logos-co
/
nomos-simulations
mirror of https://github.com/logos-co/nomos-simulations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Count # of messages broadcasted by each node (#21)

This commit is contained in:
Youngjoon Lee 2024-11-07 11:55:02 +09:00 committed by GitHub
parent 9d997e2b54
commit fbd114f724
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
network-runner/src/node/mix/mod.rs
View File

@ -143,6 +143,7 @@ impl MixNode {
node_id: id, node_id: id,
mock_counter: 0, mock_counter: 0,
step_id: 0, step_id: 0,
num_messages_broadcasted: 0,
}, },
msg_gen_rng: ChaCha12Rng::from_rng(&mut rng_generator).unwrap(), msg_gen_rng: ChaCha12Rng::from_rng(&mut rng_generator).unwrap(),
persistent_sender, persistent_sender,
@ -217,7 +218,8 @@ impl Node for MixNode {
persistent_sender.send(msg).unwrap(); persistent_sender.send(msg).unwrap();
} }
MixOutgoingMessage::FullyUnwrapped(_) => { MixOutgoingMessage::FullyUnwrapped(_) => {
//TODO: increase counter and create a tracing event self.state.num_messages_broadcasted += 1;
//TODO: create a tracing event
} }
} }
} }

1
network-runner/src/node/mix/state.rs
View File

@ -14,6 +14,7 @@ pub struct MixnodeState {
pub node_id: NodeId, pub node_id: NodeId,
pub mock_counter: usize, pub mock_counter: usize,
pub step_id: usize, pub step_id: usize,
pub num_messages_broadcasted: usize,
} }
#[derive(Serialize)] #[derive(Serialize)]