Fix cache

This commit is contained in:
Daniel Sanchez Quiros 2024-11-08 18:10:47 +07:00
parent 8147b7d718
commit ec9f79c763

View File

@ -211,13 +211,6 @@ impl MixNode {
}
fn forward(&mut self, message: MixMessage, exclude_node: Option<NodeId>) {
if self
.message_cache
.cache_set(Self::sha256(&message.0), ())
.is_some()
{
return;
}
for node_id in self
.settings
.connected_peers
@ -227,6 +220,7 @@ impl MixNode {
self.network_interface
.send_message(*node_id, message.clone())
}
self.message_cache.cache_set(Self::sha256(&message.0), ());
}
fn receive(&mut self) -> Vec<NetworkMessage<MixMessage>> {