File tree Expand file tree Collapse file tree 1 file changed +8
-0
lines changed
beacon_node/beacon_chain/src/data_availability_checker Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -576,8 +576,11 @@ impl<T: BeaconChainTypes> DataAvailabilityCheckerInner<T> {
576
576
577
577
pending_components. reconstruction_started = true ;
578
578
579
+ debug ! ( received_column_count, "Starting wait for more cols..." ) ;
580
+
579
581
// Instead of starting to reconstruct immediately, wait for more columns to arrive
580
582
drop ( write_lock) ;
583
+ let mut iter = 1 ;
581
584
loop {
582
585
sleep ( Duration :: from_millis ( 25 ) ) ;
583
586
let mut write_lock = self . critical . write ( ) ;
@@ -589,16 +592,21 @@ impl<T: BeaconChainTypes> DataAvailabilityCheckerInner<T> {
589
592
590
593
// Check if there is still a need to reconstruct.
591
594
if new_received_column_count >= total_column_count {
595
+ debug ! ( iter, new_received_column_count, "Got all!" ) ;
592
596
return ReconstructColumnsDecision :: No ( "all columns received" ) ;
593
597
}
594
598
595
599
// Check if no new column arrived.
596
600
if new_received_column_count == received_column_count {
601
+ debug ! ( iter, new_received_column_count, "No new cols :/" ) ;
597
602
return ReconstructColumnsDecision :: Yes ( pending_components. verified_data_columns . clone ( ) ) ;
598
603
}
599
604
605
+ debug ! ( iter, new_received_column_count, "Waiting for more cols..." ) ;
606
+
600
607
// Update count for next check.
601
608
received_column_count = new_received_column_count;
609
+ iter += 1 ;
602
610
}
603
611
}
604
612
You can’t perform that action at this time.
0 commit comments