fmt

dknopik · dknopik · commit f8137674e1f3 · 2025-06-11T14:42:00.000+02:00
diff --git a/beacon_node/beacon_chain/src/data_availability_checker/overflow_lru_cache.rs b/beacon_node/beacon_chain/src/data_availability_checker/overflow_lru_cache.rs
@@ -595,14 +595,14 @@ impl<T: BeaconChainTypes> DataAvailabilityCheckerInner<T> {
         match descision {
             ReconstructColumnsDecision::Yes(_) => {
                 pending_components.reconstruction_state = ReconstructionState::Started;
-                debug!(block_root, received_column_count, "Starting reconstruction");
+                debug!(%block_root, received_column_count, "Starting reconstruction");
             }
             ReconstructColumnsDecision::Wait => {
                 pending_components.reconstruction_state = ReconstructionState::WaitingForColumns {
                     num_last: received_column_count,
                 };
                 debug!(
-                    block_root,
+                    %block_root,
                     received_column_count,
                     "Waiting for more columns to arrive before reconstruction"
                 );
diff --git a/beacon_node/beacon_processor/src/work_reprocessing_queue.rs b/beacon_node/beacon_processor/src/work_reprocessing_queue.rs
@@ -357,7 +357,9 @@ impl<S: SlotClock> Stream for ReprocessQueue<S> {
 
         match self.column_reconstructions_delay_queue.poll_expired(cx) {
             Poll::Ready(Some(reconstruction)) => {
-                return Poll::Ready(Some(InboundEvent::ReadyColumnReconstruction(reconstruction.into_inner())));
+                return Poll::Ready(Some(InboundEvent::ReadyColumnReconstruction(
+                    reconstruction.into_inner(),
+                )));
             }
             Poll::Ready(None) | Poll::Pending => (),
         }
@@ -967,7 +969,8 @@ impl<S: SlotClock> ReprocessQueue<S> {
             InboundEvent::ReadyColumnReconstruction(column_reconstruction) => {
                 if self
                     .ready_work_tx
-                    .try_send(ReadyWork::ColumnReconstruction(column_reconstruction)).is_err()
+                    .try_send(ReadyWork::ColumnReconstruction(column_reconstruction))
+                    .is_err()
                 {
                     error!(
                         hint = "system may be overloaded",
diff --git a/beacon_node/network/src/network_beacon_processor/gossip_methods.rs b/beacon_node/network/src/network_beacon_processor/gossip_methods.rs
@@ -1173,7 +1173,8 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
                         "Processed data column, waiting for other components"
                     );
 
-                    Arc::clone(self).attempt_data_column_reconstruction(block_root, true)
+                    Arc::clone(self)
+                        .attempt_data_column_reconstruction(block_root, true)
                         .await;
                 }
             },
diff --git a/beacon_node/network/src/network_beacon_processor/mod.rs b/beacon_node/network/src/network_beacon_processor/mod.rs
@@ -970,7 +970,8 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {
                 }
                 Ok(ReconstructionOutcome::Delay) => {
                     let cloned_self = Arc::clone(&self);
-                    let send_result = self.reprocess_tx
+                    let send_result = self
+                        .reprocess_tx
                         .send(ReprocessQueueMessage::DelayColumnReconstruction(
                             QueuedColumnReconstruction(Box::pin(async move {
                                 cloned_self

Original file line number	Diff line number	Diff line change
`@@ -357,7 +357,9 @@ impl<S: SlotClock> Stream for ReprocessQueue<S> {`
`357`	`357`
`358`	`358`	`match self.column_reconstructions_delay_queue.poll_expired(cx) {`
`359`	`359`	`Poll::Ready(Some(reconstruction)) => {`
`360`		`- return Poll::Ready(Some(InboundEvent::ReadyColumnReconstruction(reconstruction.into_inner())));`
	`360`	`+ return Poll::Ready(Some(InboundEvent::ReadyColumnReconstruction(`
	`361`	`+ reconstruction.into_inner(),`
	`362`	`+ )));`
`361`	`363`	`}`
`362`	`364`	`Poll::Ready(None) \| Poll::Pending => (),`
`363`	`365`	`}`
`@@ -967,7 +969,8 @@ impl<S: SlotClock> ReprocessQueue<S> {`
`967`	`969`	`InboundEvent::ReadyColumnReconstruction(column_reconstruction) => {`
`968`	`970`	`if self`
`969`	`971`	`.ready_work_tx`
`970`		`- .try_send(ReadyWork::ColumnReconstruction(column_reconstruction)).is_err()`
	`972`	`+ .try_send(ReadyWork::ColumnReconstruction(column_reconstruction))`
	`973`	`+ .is_err()`
`971`	`974`	`{`
`972`	`975`	`error!(`
`973`	`976`	`hint = "system may be overloaded",`
Original file line number	Diff line number	Diff line change
`@@ -1173,7 +1173,8 @@ impl<T: BeaconChainTypes> NetworkBeaconProcessor<T> {`
`1173`	`1173`	`"Processed data column, waiting for other components"`
`1174`	`1174`	`);`
`1175`	`1175`
`1176`		`- Arc::clone(self).attempt_data_column_reconstruction(block_root, true)`
	`1176`	`+ Arc::clone(self)`
	`1177`	`+ .attempt_data_column_reconstruction(block_root, true)`
`1177`	`1178`	`.await;`
`1178`	`1179`	`}`
`1179`	`1180`	`},`