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

Remove log of immediate forwardings

Browse Source
This commit is contained in:
Youngjoon Lee 2024-11-12 11:11:04 +09:00
parent 424585dd2a
commit 3e4bba0c83
No known key found for this signature in database
GPG Key ID: 167546E2D1712F8C
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
simlib/mixnet-sims/src/node/mix/mod.rs
View File

@ -210,7 +210,12 @@ impl MixNode {
}
}
fn forward(&mut self, message: MixMessage, exclude_node: Option<NodeId>, log: EmissionLog) {
fn forward(
&mut self,
message: MixMessage,
exclude_node: Option<NodeId>,
log: Option<EmissionLog>,
) {
for (i, node_id) in self
.settings
.connected_peers
@ -219,7 +224,9 @@ impl MixNode {
.enumerate()
{
if i == 0 {
Self::log_emission(&log);
if let Some(log) = &log {
Self::log_emission(log);
}
}
self.network_interface
.send_message(*node_id, message.clone())
@ -322,7 +329,7 @@ impl Node for MixNode {
self.forward(
network_message.payload().clone(),
Some(network_message.from),
self.new_emission_log("ImmediateForwarding"),
None,
);
self.blend_sender
.send(network_message.into_payload().0)
@ -362,7 +369,7 @@ impl Node for MixNode {
self.forward(
MixMessage(msg),
None,
self.new_emission_log("FromPersistent"),
Some(self.new_emission_log("FromPersistent")),
);
}