@@ -1553,6 +1553,8 @@ impl<L: Deref> NetworkGraph<L> where L::Target: Logger {
15531553 let node_id_a = channel_info. node_one . clone ( ) ;
15541554 let node_id_b = channel_info. node_two . clone ( ) ;
15551555
1556+ log_gossip ! ( self . logger, "Adding channel {} between nodes {} and {}" , short_channel_id, node_id_a, node_id_b) ;
1557+
15561558 match channels. entry ( short_channel_id) {
15571559 IndexedMapEntry :: Occupied ( mut entry) => {
15581560 //TODO: because asking the blockchain if short_channel_id is valid is only optional
@@ -1788,16 +1790,23 @@ impl<L: Deref> NetworkGraph<L> where L::Target: Logger {
17881790 let mut scids_to_remove = Vec :: new ( ) ;
17891791 for ( scid, info) in channels. unordered_iter_mut ( ) {
17901792 if info. one_to_two . is_some ( ) && info. one_to_two . as_ref ( ) . unwrap ( ) . last_update < min_time_unix {
1793+ log_gossip ! ( self . logger, "Removing directional update one_to_two (0) for channel {} due to its timestamp {} being below {}" ,
1794+ scid, info. one_to_two. as_ref( ) . unwrap( ) . last_update, min_time_unix) ;
17911795 info. one_to_two = None ;
17921796 }
17931797 if info. two_to_one . is_some ( ) && info. two_to_one . as_ref ( ) . unwrap ( ) . last_update < min_time_unix {
1798+ log_gossip ! ( self . logger, "Removing directional update two_to_one (1) for channel {} due to its timestamp {} being below {}" ,
1799+ scid, info. two_to_one. as_ref( ) . unwrap( ) . last_update, min_time_unix) ;
17941800 info. two_to_one = None ;
17951801 }
17961802 if info. one_to_two . is_none ( ) || info. two_to_one . is_none ( ) {
17971803 // We check the announcement_received_time here to ensure we don't drop
17981804 // announcements that we just received and are just waiting for our peer to send a
17991805 // channel_update for.
1800- if info. announcement_received_time < min_time_unix as u64 {
1806+ let announcement_received_timestamp = info. announcement_received_time ;
1807+ if announcement_received_timestamp < min_time_unix as u64 {
1808+ log_gossip ! ( self . logger, "Removing channel {} because both directional updates are missing and its announcement timestamp {} being below {}" ,
1809+ scid, announcement_received_timestamp, min_time_unix) ;
18011810 scids_to_remove. push ( * scid) ;
18021811 }
18031812 }
@@ -1878,6 +1887,8 @@ impl<L: Deref> NetworkGraph<L> where L::Target: Logger {
18781887 }
18791888 }
18801889
1890+ log_gossip ! ( self . logger, "Updating channel {} in direction {} with timestamp {}" , msg. short_channel_id, msg. flags & 1 , msg. timestamp) ;
1891+
18811892 let mut channels = self . channels . write ( ) . unwrap ( ) ;
18821893 match channels. get_mut ( & msg. short_channel_id ) {
18831894 None => {
0 commit comments