Skip to content
This repository has been archived by the owner on Oct 31, 2024. It is now read-only.

Commit

Permalink
fix: fixing review comments
Browse files Browse the repository at this point in the history
Signed-off-by: Simon Paitrault <[email protected]>
  • Loading branch information
Freyskeyd committed Mar 18, 2024
1 parent c291014 commit 81ffe69
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
4 changes: 2 additions & 2 deletions crates/topos-p2p/src/behaviour/gossip.rs
Original file line number Diff line number Diff line change
Expand Up @@ -255,7 +255,7 @@ impl NetworkBehaviour for Behaviour {
_ => {}
},
gossipsub::Event::Subscribed { peer_id, topic } => {
debug!("Subscribed to {:?} with {peer_id}", topic);
debug!("{peer_id} subscribed to {:?}", topic);

// If the behaviour isn't already healthy we check if this event
// triggers a switch to healthy
Expand All @@ -268,7 +268,7 @@ impl NetworkBehaviour for Behaviour {
}
}
gossipsub::Event::Unsubscribed { peer_id, topic } => {
debug!("Unsubscribed from {:?} with {peer_id}", topic);
debug!("{peer_id} unsubscribed from {:?}", topic);
}
gossipsub::Event::GossipsubNotSupported { peer_id } => {
debug!("Gossipsub not supported by {:?}", peer_id);
Expand Down
1 change: 1 addition & 0 deletions crates/topos-p2p/src/runtime/handle_event.rs
Original file line number Diff line number Diff line change
Expand Up @@ -193,6 +193,7 @@ impl EventHandler<SwarmEvent<ComposedEvent>> for Runtime {
let behaviour = self.swarm.behaviour();

if let Some(event) = self.healthy_status_changed() {
debug!("Healthy status changed: {:?}", event);
_ = self.event_sender.send(event).await;
}

Expand Down

0 comments on commit 81ffe69

Please sign in to comment.