From e15d3e6fd20b3f87abaad7ddec1c88b0e66419f9 Mon Sep 17 00:00:00 2001 From: hozan23 Date: Mon, 15 Jul 2024 13:16:01 +0200 Subject: p2p: Major refactoring of the handshake protocol Introduce a new protocol InitProtocol which can be used as the core protocol for initializing a connection with a peer. Move the handshake logic from the PeerPool module to the protocols directory and build a handshake protocol that implements InitProtocol trait. --- p2p/src/monitor/mod.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'p2p/src/monitor') diff --git a/p2p/src/monitor/mod.rs b/p2p/src/monitor/mod.rs index 4ecb431..86db23e 100644 --- a/p2p/src/monitor/mod.rs +++ b/p2p/src/monitor/mod.rs @@ -2,6 +2,8 @@ mod event; use std::sync::Arc; +use log::error; + use karyon_core::event::{EventListener, EventSys, EventValue, EventValueTopic}; use karyon_net::Endpoint; @@ -62,7 +64,9 @@ impl Monitor { pub(crate) async fn notify(&self, event: E) { if self.config.enable_monitor { let event = event.to_struct(); - self.event_sys.emit(&event).await + if let Err(err) = self.event_sys.emit(&event).await { + error!("Failed to notify monitor event {:?}: {err}", event); + } } } -- cgit v1.2.3