mirrors/rust-lightning
1
0
Fork 0
mirror of https://github.com/lightningdevkit/rust-lightning.git synced 2025-02-24 15:02:20 +01:00
Code Issues Projects Releases Packages Wiki Activity

Log enqueueing of gossip messages

Browse source
This commit is contained in:
Arik Sosman 2024-10-25 16:57:27 -07:00
parent 206ab82c02
commit 0a8c05f8ba
No known key found for this signature in database
GPG key ID: CFF795E7811C0093
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lightning/src/ln/peer_handler.rs
View file

@ -2403,9 +2403,16 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
}
},
MessageSendEvent::SendChannelRangeQuery { ref node_id, ref msg } => {
log_gossip!(WithContext::from(&self.logger, Some(*node_id), None, None), "Handling SendChannelRangeQuery event in peer_handler for node {} with first_blocknum={}, number_of_blocks={}",
log_pubkey!(node_id),
msg.first_blocknum,
msg.number_of_blocks);
self.enqueue_message(&mut *get_peer_for_forwarding!(node_id)?, msg);
},
MessageSendEvent::SendShortIdsQuery { ref node_id, ref msg } => {
log_gossip!(WithContext::from(&self.logger, Some(*node_id), None, None), "Handling SendShortIdsQuery event in peer_handler for node {} with num_scids={}",
log_pubkey!(node_id),
msg.short_channel_ids.len());
self.enqueue_message(&mut *get_peer_for_forwarding!(node_id)?, msg);
}
MessageSendEvent::SendReplyChannelRange { ref node_id, ref msg } => {
@ -2418,6 +2425,10 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
self.enqueue_message(&mut *get_peer_for_forwarding!(node_id)?, msg);
}
MessageSendEvent::SendGossipTimestampFilter { ref node_id, ref msg } => {
log_gossip!(WithContext::from(&self.logger, Some(*node_id), None, None), "Handling SendGossipTimestampFilter event in peer_handler for node {} with first_timestamp={}, timestamp_range={}",
log_pubkey!(node_id),
msg.first_timestamp,
msg.timestamp_range);
self.enqueue_message(&mut *get_peer_for_forwarding!(node_id)?, msg);
}
}