tmp

Consensys · Feb 24, 2025 · aa68a70 · aa68a70
1 parent f7b5dc7
commit aa68a70
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 10 deletions.
diff --git a/.../src/main/java/tech/pegasys/teku/validator/coordinator/BlockOperationSelectorFactory.java b/.../src/main/java/tech/pegasys/teku/validator/coordinator/BlockOperationSelectorFactory.java
@@ -131,9 +131,9 @@ public Function<BeaconBlockBodyBuilder, SafeFuture<Void>> createSelector(
       final Eth1Data eth1Data = eth1DataCache.getEth1Vote(blockSlotState);
 
       SafeFuture.of(
-                      SafeFuture.runAsync(
-                              () -> attestationPool.dumpAttestations(blockSlotState.getSlot())))
-              .finish(() -> LOG.info("Attestation pool dumped."), err -> LOG.error("Failed to dump.", err));
+              SafeFuture.runAsync(() -> attestationPool.dumpAttestations(blockSlotState.getSlot())))
+          .finish(
+              () -> LOG.info("Attestation pool dumped."), err -> LOG.error("Failed to dump.", err));
 
       final long start = System.currentTimeMillis();
       final SszList<Attestation> attestations =
@@ -156,7 +156,8 @@ public Function<BeaconBlockBodyBuilder, SafeFuture<Void>> createSelector(
                         throw new UncheckedIOException(e);
                       }
                     }))
-            .finish(() -> LOG.info("State dump completed."), err -> LOG.error("Failed to dump.", err));
+            .finish(
+                () -> LOG.info("State dump completed."), err -> LOG.error("Failed to dump.", err));
       }
 
       // Collect slashings to include

diff --git a/...c/main/java/tech/pegasys/teku/statetransition/attestation/AggregatingAttestationPool.java b/...c/main/java/tech/pegasys/teku/statetransition/attestation/AggregatingAttestationPool.java
@@ -336,8 +336,7 @@ public synchronized void onReorg(final UInt64 commonAncestorSlot) {
   }
 
   public synchronized void dumpAttestations(final UInt64 slot) {
-    try (FileWriter fos =
-        new FileWriter("/tmp/attestations_" + slot + ".multi_ssz", UTF_8)) {
+    try (FileWriter fos = new FileWriter("/tmp/attestations_" + slot + ".multi_ssz", UTF_8)) {
       dataHashBySlot.descendingMap().values().stream()
           .flatMap(Collection::stream)
           .map(attestationGroupByDataHash::get)
@@ -353,10 +352,7 @@ public synchronized void dumpAttestations(final UInt64 slot) {
                 }
               });
     } catch (final IOException e) {
-      LOG.error(
-          "An error occurred while dumping pool at slot {}: {}",
-              slot,
-          e.getMessage());
+      LOG.error("An error occurred while dumping pool at slot {}: {}", slot, e.getMessage());
     }
   }
 }