@@ -40,6 +40,8 @@ pub(super) struct DirectedUpdateDelta {
40
40
pub ( super ) struct ChannelDelta {
41
41
pub ( super ) announcement : Option < AnnouncementDelta > ,
42
42
pub ( super ) updates : ( Option < DirectedUpdateDelta > , Option < DirectedUpdateDelta > ) ,
43
+ /// This value is only set if the first update to achieve bidirectionality was seen after
44
+ /// the last sync.
43
45
pub ( super ) first_bidirectional_updates_seen : Option < u32 > ,
44
46
/// The seen timestamp of the older of the two latest directional updates
45
47
pub ( super ) requires_reminder : bool ,
@@ -164,7 +166,7 @@ pub(super) async fn fetch_channel_announcements<L: Deref>(delta_set: &mut DeltaS
164
166
let scid: i64 = current_row. get ( "short_channel_id" ) ;
165
167
let current_seen_timestamp = current_row. get :: < _ , i64 > ( "seen" ) as u32 ;
166
168
167
- log_trace ! ( logger, "Channel {} first update to complete bidirectional data seen at: {}" , scid, current_seen_timestamp) ;
169
+ log_trace ! ( logger, "Channel {} with first update to complete bidirectional data since last sync seen at: {}" , scid, current_seen_timestamp) ;
168
170
169
171
// the newer of the two oldest seen directional updates came after last sync timestamp
170
172
let current_channel_delta = delta_set. entry ( scid as u64 ) . or_insert ( ChannelDelta :: default ( ) ) ;
@@ -173,7 +175,7 @@ pub(super) async fn fetch_channel_announcements<L: Deref>(delta_set: &mut DeltaS
173
175
174
176
newer_oldest_directional_update_count += 1 ;
175
177
}
176
- log_info ! ( logger, "Fetched {} update rows of the first update in a new direction" , newer_oldest_directional_update_count) ;
178
+ log_info ! ( logger, "Fetched {} update rows of the first update in a new direction having occurred since the last sync " , newer_oldest_directional_update_count) ;
177
179
}
178
180
179
181
{
@@ -388,7 +390,7 @@ pub(super) async fn fetch_channel_updates<L: Deref>(delta_set: &mut DeltaSet, cl
388
390
}
389
391
}
390
392
}
391
- log_info ! ( logger, "Processed intermediate rows ({}) (delta size: {}): {:?}" , intermediate_update_count, delta_set. len( ) , start. elapsed( ) ) ;
393
+ log_info ! ( logger, "Processed {} intermediate rows (delta size: {}): {:?}" , intermediate_update_count, delta_set. len( ) , start. elapsed( ) ) ;
392
394
}
393
395
394
396
pub ( super ) fn filter_delta_set < L : Deref > ( delta_set : & mut DeltaSet , logger : L ) where L :: Target : Logger {
0 commit comments