Add log for file announcement

This commit is contained in:
boqiu 2024-09-26 13:50:41 +08:00
parent 69b71fc0b2
commit 15aca2d386

View File

@ -325,6 +325,15 @@ 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::<Vec<u64>>())
.collect::<Vec<Vec<u64>>>();
info!(
"qbit: received file announcement, propagation={}, source={}, txs={:?}",
propagation_source, source, txs
);
metrics::LIBP2P_HANDLE_PUBSUB_ANNOUNCE_FILE.mark(1);
for msg in msgs {