logos-co/nomos-node
1
0
Fork 0
mirror of synced 2025-03-01 16:00:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

forward msgs immediately without any processing (#841)

Browse Source
This commit is contained in:
Youngjoon Lee 2024-10-24 11:44:35 +09:00 committed by GitHub
parent ca786fd264
commit 929fb1b7b1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nomos-mix/network/src/behaviour.rs
View File

@ -197,7 +197,14 @@ impl NetworkBehaviour for Behaviour {
return;
}
// Forward the message immediately to the rest of connected peers
// without any processing for the fast propagation.
if let Err(e) = self.forward_message(message.clone(), Some(peer_id)) {
tracing::error!("Failed to forward message: {e:?}");
}
// Try to unwrap the message.
// TODO: Abstract as Tier 2: Cryptographic Processor & Temporal Processor
match unwrap_message(&message) {
Ok((unwrapped_msg, fully_unwrapped)) => {
if fully_unwrapped {
@ -209,10 +216,7 @@ impl NetworkBehaviour for Behaviour {
}
}
Err(nomos_mix_message::Error::MsgUnwrapNotAllowed) => {
// Forward the received message as it is.
if let Err(e) = self.forward_message(message, Some(peer_id)) {
tracing::error!("Failed to forward message: {:?}", e);
}
tracing::debug!("Message cannot be unwrapped by this node");
}
Err(e) => {
tracing::error!("Failed to unwrap message: {:?}", e);