@@ -1553,6 +1553,8 @@ impl<L: Deref> NetworkGraph<L> where L::Target: Logger {
1553
1553
let node_id_a = channel_info. node_one . clone ( ) ;
1554
1554
let node_id_b = channel_info. node_two . clone ( ) ;
1555
1555
1556
+ log_gossip ! ( self . logger, "Adding channel {} between nodes {} and {}" , short_channel_id, node_id_a, node_id_b) ;
1557
+
1556
1558
match channels. entry ( short_channel_id) {
1557
1559
IndexedMapEntry :: Occupied ( mut entry) => {
1558
1560
//TODO: because asking the blockchain if short_channel_id is valid is only optional
@@ -1805,6 +1807,7 @@ impl<L: Deref> NetworkGraph<L> where L::Target: Logger {
1805
1807
if !scids_to_remove. is_empty ( ) {
1806
1808
let mut nodes = self . nodes . write ( ) . unwrap ( ) ;
1807
1809
for scid in scids_to_remove {
1810
+ log_gossip ! ( self . logger, "Removing channel {}" , scid) ;
1808
1811
let info = channels. remove ( & scid) . expect ( "We just accessed this scid, it should be present" ) ;
1809
1812
Self :: remove_channel_in_nodes ( & mut nodes, & info, scid) ;
1810
1813
self . removed_channels . lock ( ) . unwrap ( ) . insert ( scid, Some ( current_time_unix) ) ;
@@ -1878,6 +1881,8 @@ impl<L: Deref> NetworkGraph<L> where L::Target: Logger {
1878
1881
}
1879
1882
}
1880
1883
1884
+ log_gossip ! ( self . logger, "Updating channel {} in direction {}" , msg. short_channel_id, msg. flags & 1 ) ;
1885
+
1881
1886
let mut channels = self . channels . write ( ) . unwrap ( ) ;
1882
1887
match channels. get_mut ( & msg. short_channel_id ) {
1883
1888
None => {
0 commit comments