@@ -311,7 +311,6 @@ fn get_dummy_channel_update(short_chan_id: u64) -> msgs::ChannelUpdate {
311
311
pub struct TestRoutingMessageHandler {
312
312
pub chan_upds_recvd : AtomicUsize ,
313
313
pub chan_anns_recvd : AtomicUsize ,
314
- pub chan_anns_sent : AtomicUsize ,
315
314
pub request_full_sync : AtomicBool ,
316
315
}
317
316
@@ -320,7 +319,6 @@ impl TestRoutingMessageHandler {
320
319
TestRoutingMessageHandler {
321
320
chan_upds_recvd : AtomicUsize :: new ( 0 ) ,
322
321
chan_anns_recvd : AtomicUsize :: new ( 0 ) ,
323
- chan_anns_sent : AtomicUsize :: new ( 0 ) ,
324
322
request_full_sync : AtomicBool :: new ( false ) ,
325
323
}
326
324
}
@@ -339,8 +337,8 @@ impl msgs::RoutingMessageHandler for TestRoutingMessageHandler {
339
337
}
340
338
fn get_next_channel_announcements ( & self , starting_point : u64 , batch_amount : u8 ) -> Vec < ( msgs:: ChannelAnnouncement , Option < msgs:: ChannelUpdate > , Option < msgs:: ChannelUpdate > ) > {
341
339
let mut chan_anns = Vec :: new ( ) ;
342
- const TOTAL_UPDS : u64 = 100 ;
343
- let end: u64 = cmp:: min ( starting_point + batch_amount as u64 , TOTAL_UPDS - self . chan_anns_sent . load ( Ordering :: Acquire ) as u64 ) ;
340
+ const TOTAL_UPDS : u64 = 50 ;
341
+ let end: u64 = cmp:: min ( starting_point + batch_amount as u64 , TOTAL_UPDS ) ;
344
342
for i in starting_point..end {
345
343
let chan_upd_1 = get_dummy_channel_update ( i) ;
346
344
let chan_upd_2 = get_dummy_channel_update ( i) ;
@@ -349,7 +347,6 @@ impl msgs::RoutingMessageHandler for TestRoutingMessageHandler {
349
347
chan_anns. push ( ( chan_ann, Some ( chan_upd_1) , Some ( chan_upd_2) ) ) ;
350
348
}
351
349
352
- self . chan_anns_sent . fetch_add ( chan_anns. len ( ) , Ordering :: AcqRel ) ;
353
350
chan_anns
354
351
}
355
352
0 commit comments