From 98ec24b863dbf5d402aefb6648e3d1ece245b849 Mon Sep 17 00:00:00 2001 From: boqiu <82121246@qq.com> Date: Wed, 23 Oct 2024 19:08:48 +0800 Subject: [PATCH] use propagation source to handle NewFile message --- node/router/src/libp2p_event_handler.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/node/router/src/libp2p_event_handler.rs b/node/router/src/libp2p_event_handler.rs index 1ab2301..bccfb2b 100644 --- a/node/router/src/libp2p_event_handler.rs +++ b/node/router/src/libp2p_event_handler.rs @@ -319,7 +319,7 @@ impl Libp2pEventHandler { PubsubMessage::ExampleMessage(_) => MessageAcceptance::Ignore, PubsubMessage::NewFile(msg) => { metrics::LIBP2P_HANDLE_PUBSUB_NEW_FILE.mark(1); - self.on_new_file(source, msg).await + self.on_new_file(propagation_source, msg).await } PubsubMessage::FindFile(msg) => { metrics::LIBP2P_HANDLE_PUBSUB_FIND_FILE.mark(1);