]> git.bitcoin.ninja Git - rust-lightning/commitdiff
Log enqueueing of gossip messages
authorArik Sosman <git@arik.io>
Fri, 25 Oct 2024 23:57:27 +0000 (16:57 -0700)
committerArik Sosman <git@arik.io>
Fri, 25 Oct 2024 23:57:27 +0000 (16:57 -0700)
lightning/src/ln/peer_handler.rs

index b5fc3443be5b16e7f898719c3650eb1c1ada02bb..2d4416e5aea9dbe3f759c6e2d93dc31b6d1bd65c 100644 (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);
                                                }
                                        }