logos-co/nomos-node
1
0
Fork 0
mirror of synced 2025-02-08 05:45:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove prints

Browse Source
This commit is contained in:
Youngjoon Lee 2024-11-29 14:34:22 +09:00
parent ecfaa8fb8b
commit b362dc8b43
No known key found for this signature in database
GPG Key ID: 680B4E130CB5030E
3 changed files with 0 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nomos-mix/core/src/conn_maintenance.rs
View File

@ -55,7 +55,6 @@ where
let mut unhealthy_peers = HashSet::new();
self.meters.iter().for_each(|(peer, meter)| {
println!("Peer: {:?}, Meter: {:?}", peer, meter);
if meter.is_malicious(&self.settings) {
malicious_peers.insert(peer.clone());
} else if meter.is_unhealthy(&self.settings) {

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

@ -99,10 +99,8 @@ where
}
let msg_id = Self::message_id(&message);
println!("Publishing message with id: {:?}", msg_id);
// If the message was already seen, don't forward it again
if self.duplicate_cache.cache_get(&msg_id).is_some() {
println!("Skipping duplicate message: {:?}", msg_id);
return Ok(());
}

5
nomos-services/mix/src/lib.rs
View File

@ -158,20 +158,17 @@ where
loop {
tokio::select! {
Some(msg) = persistent_transmission_messages.next() => {
println!("A message from PTM to the mix network");
backend.publish(msg).await;
}
// Already processed blend messages
Some(msg) = blend_messages.next() => {
match msg {
MixOutgoingMessage::Outbound(msg) => {
println!("A outbound message from blend to PTM");
if let Err(e) = persistent_sender.send(msg) {
tracing::error!("Error sending message to persistent stream: {e}");
}
}
MixOutgoingMessage::FullyUnwrapped(msg) => {
println!("A fully unwrapped message from blend to the broadcast network");
tracing::debug!("Broadcasting fully unwrapped message");
match wire::deserialize::<NetworkMessage<Network::BroadcastSettings>>(&msg) {
Ok(msg) => {
@ -185,11 +182,9 @@ where
}
}
Some(msg) = cover_traffic.next() => {
println!("A cover traffic to PTM");
Self::wrap_and_send_to_persistent_transmission(msg, &mut cryptographic_processor, &persistent_sender);
}
Some(msg) = local_messages.next() => {
println!("A local traffic to PTM");
Self::wrap_and_send_to_persistent_transmission(msg, &mut cryptographic_processor, &persistent_sender);
}
Some(msg) = lifecycle_stream.next() => {