diff --git a/node/router/src/libp2p_event_handler.rs b/node/router/src/libp2p_event_handler.rs index 7135a3a..23149cc 100644 --- a/node/router/src/libp2p_event_handler.rs +++ b/node/router/src/libp2p_event_handler.rs @@ -99,6 +99,8 @@ pub struct Libp2pEventHandler { file_batcher: RwLock>, /// Announcements to publish in batch announcement_batcher: RwLock>, + + since: Instant, } impl Libp2pEventHandler { @@ -138,6 +140,7 @@ impl Libp2pEventHandler { peers, file_batcher, announcement_batcher, + since: Instant::now(), } } @@ -325,14 +328,17 @@ impl Libp2pEventHandler { self.on_find_chunks(msg).await } PubsubMessage::AnnounceFile(msgs) => { - let txs = msgs - .iter() - .map(|file| file.tx_ids.iter().map(|x| x.seq).collect::>()) - .collect::>>(); - info!( - "qbit: received file announcement, propagation={}, source={}, txs={:?}", - propagation_source, source, txs - ); + let elapsed = self.since.elapsed().as_secs(); + if elapsed > 600 && elapsed < 1200 { + let txs = msgs + .iter() + .map(|file| file.tx_ids.iter().map(|x| x.seq).collect::>()) + .collect::>>(); + info!( + "qbit: received file announcement, propagation={}, source={}, txs={:?}", + propagation_source, source, txs + ); + } metrics::LIBP2P_HANDLE_PUBSUB_ANNOUNCE_FILE.mark(1);