@@ -190,11 +190,6 @@ impl<E: EthSpec> CandidateBeaconNode<E> {
190190 spec : & ChainSpec ,
191191 log : & Logger ,
192192 ) -> Result < ( ) , CandidateError > {
193- debug ! (
194- log,
195- "Refresh started" ;
196- "endpoint" => %self . beacon_node,
197- ) ;
198193 let previous_status = self . status ( RequireSynced :: Yes ) . await ;
199194 let was_offline = matches ! ( previous_status, Err ( CandidateError :: Offline ) ) ;
200195
@@ -214,12 +209,6 @@ impl<E: EthSpec> CandidateBeaconNode<E> {
214209 // holding a write-lock whilst we check the online status of the node.
215210 * self . status . write ( ) . await = new_status;
216211
217- debug ! (
218- log,
219- "Refresh complete" ;
220- "endpoint" => %self . beacon_node,
221- ) ;
222-
223212 new_status
224213 }
225214
@@ -645,7 +634,6 @@ impl<T: SlotClock, E: EthSpec> BeaconNodeFallback<T, E> {
645634 // First pass: try `func` on all synced and ready candidates.
646635 //
647636 // This ensures that we always choose a synced node if it is available.
648- debug ! ( self . log, "Starting first batch of subscription requests" ) ;
649637 let mut first_batch_futures = vec ! [ ] ;
650638 for candidate in & self . candidates {
651639 match candidate. status ( RequireSynced :: Yes ) . await {
@@ -669,15 +657,13 @@ impl<T: SlotClock, E: EthSpec> BeaconNodeFallback<T, E> {
669657 //
670658 // Due to async race-conditions, it is possible that we will send a request to a candidate
671659 // that has been set to an offline/unready status. This is acceptable.
672- debug ! ( self . log, "Starting second batch of subscription requests" ) ;
673660 let second_batch_results = if require_synced == false {
674661 futures:: future:: join_all ( retry_unsynced. into_iter ( ) . map ( run_on_candidate) ) . await
675662 } else {
676663 vec ! [ ]
677664 } ;
678665
679666 // Third pass: try again, attempting to make non-ready clients become ready.
680- debug ! ( self . log, "Starting third batch of subscription requests" ) ;
681667 let mut third_batch_futures = vec ! [ ] ;
682668 let mut third_batch_results = vec ! [ ] ;
683669 for candidate in to_retry {
@@ -704,7 +690,6 @@ impl<T: SlotClock, E: EthSpec> BeaconNodeFallback<T, E> {
704690 }
705691 }
706692 third_batch_results. extend ( futures:: future:: join_all ( third_batch_futures) . await ) ;
707- debug ! ( self . log, "Completed all subscription requests" ) ;
708693
709694 let mut results = first_batch_results;
710695 results. extend ( second_batch_results) ;
0 commit comments