node: Reduce log verbosity when receiving messages

This commit is contained in:
Alexis Sellier 2023-04-19 15:27:42 +02:00
parent 189eb3f201
commit 9120db4ddb
No known key found for this signature in database
2 changed files with 39 additions and 3 deletions

View File

@ -932,9 +932,12 @@ where
}
}
} else {
debug!(target: "service", "No sessions connected to {announcer}");
trace!(
target: "service",
"Skipping fetch of {}, no sessions connected to {announcer}",
message.rid
);
}
return Ok(relay);
} else {
debug!(
@ -1059,8 +1062,9 @@ where
return Ok(());
};
peer.last_active = self.clock;
message.log(log::Level::Debug, remote);
debug!(target: "service", "Received message {:?} from {}", &message, peer.id);
trace!(target: "service", "Received message {:?} from {}", &message, peer.id);
match (&mut peer.state, message) {
// Process a peer announcement.

View File

@ -407,6 +407,38 @@ impl Message {
until,
})
}
pub fn log(&self, level: log::Level, remote: &NodeId) {
if !log::log_enabled!(level) {
return;
}
let msg = match self {
Self::Announcement(Announcement { node, message, .. }) => match message {
AnnouncementMessage::Node(NodeAnnouncement { addresses, .. }) => format!(
"Node announced by {node} with {} addresses, relayed by {remote}",
addresses.len()
),
AnnouncementMessage::Refs(RefsAnnouncement { rid, refs, .. }) => {
format!(
"Refs announced by {node} for {rid} with {} remotes, relayed by {remote}",
refs.len()
)
}
AnnouncementMessage::Inventory(InventoryAnnouncement { inventory, .. }) => {
format!(
"Inventory announced by {node} with {} item(s), relayed by {remote}",
inventory.len()
)
}
},
Self::Ping { .. } => format!("Ping received from {remote}"),
Self::Pong { .. } => format!("Pong received from {remote}"),
Self::Subscribe(Subscribe { .. }) => {
format!("Subscription filter received from {remote}")
}
};
log::log!(target: "service", level, "{msg}");
}
}
/// A ping message.