fmt

Author: patrick-ogrady

consensus/src/marshal/coding/marshaled.rs

@@ -795,8 +795,12 @@ where
         // Kick off deferred verification early to hide verification latency behind
         // shard validity checks and network latency for collecting votes.
         let round = consensus_context.round;
-        let task =
-            self.deferred_verify(consensus_context, payload, None, CodingPersistMode::Verified);
+        let task = self.deferred_verify(
+            consensus_context,
+            payload,
+            None,
+            CodingPersistMode::Verified,
+        );
         self.verification_tasks.insert(round, payload, task);
 
         match scheme.me() {

consensus/src/marshal/coding/mod.rs

@@ -283,17 +283,10 @@ mod tests {
                 participants,
                 schemes,
                 ..
-            } = bls12381_threshold_vrf::fixture::<V, _>(
-                &mut context,
-                NAMESPACE,
-                NUM_VALIDATORS,
-            );
-            let mut oracle = setup_network_with_participants(
-                context.clone(),
-                NZUsize!(1),
-                participants.clone(),
-            )
-            .await;
+            } = bls12381_threshold_vrf::fixture::<V, _>(&mut context, NAMESPACE, NUM_VALIDATORS);
+            let mut oracle =
+                setup_network_with_participants(context.clone(), NZUsize!(1), participants.clone())
+                    .await;
 
             let setup = CodingHarness::setup_validator(
                 context.with_label("validator_0"),
@@ -352,8 +345,7 @@ mod tests {
             };
             let descendant_finalization =
                 CodingHarness::make_finalization(descendant_proposal, &schemes, QUORUM);
-            CodingHarness::report_finalization(&mut handle.mailbox, descendant_finalization)
-                .await;
+            CodingHarness::report_finalization(&mut handle.mailbox, descendant_finalization).await;
 
             context.sleep(Duration::from_millis(200)).await;
 

consensus/src/marshal/core/actor.rs

@@ -1141,13 +1141,7 @@ where
                     debug!(?round, %height, "received finalization");
 
                     wrote |= self
-                        .store_finalization(
-                            height,
-                            digest,
-                            block,
-                            Some(finalization),
-                            application,
-                        )
+                        .store_finalization(height, digest, block, Some(finalization), application)
                         .await;
                 }
                 PendingVerification::Notarized {

consensus/src/marshal/standard/mod.rs

@@ -207,7 +207,6 @@ mod tests {
         harness::certify_persists_equivocated_block::<DeferredHarness>();
     }
 
-
     #[test_traced("WARN")]
     fn test_standard_delivery_visibility_implies_recoverable_after_restart() {
         harness::delivery_visibility_implies_recoverable_after_restart::<InlineHarness>(0..16);