pinned on single peer

Consensys · Feb 25, 2025 · 6433def · 6433def
1 parent 5c3f3d8
commit 6433def
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 14 deletions.
diff --git a/beacon/sync/src/main/java/tech/pegasys/teku/beacon/sync/DefaultSyncServiceFactory.java b/beacon/sync/src/main/java/tech/pegasys/teku/beacon/sync/DefaultSyncServiceFactory.java
@@ -211,7 +211,7 @@ protected ForwardSyncService createForwardSyncService() {
               blobSidecarManager,
               blockBlobSidecarsTrackersPool,
               syncConfig.getForwardSyncBatchSize(),
-                  syncConfig.getPinnedSyncSlot(),
+              syncConfig.getPinnedSyncSlot(),
               spec);
     }
     return forwardSync;

diff --git a/...n/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/SinglePeerSyncServiceFactory.java b/...n/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/SinglePeerSyncServiceFactory.java
@@ -13,6 +13,7 @@
 
 package tech.pegasys.teku.beacon.sync.forward.singlepeer;
 
+import java.util.Optional;
 import org.hyperledger.besu.plugin.services.MetricsSystem;
 import tech.pegasys.teku.beacon.sync.forward.ForwardSyncService;
 import tech.pegasys.teku.infrastructure.async.AsyncRunner;
@@ -25,19 +26,17 @@
 import tech.pegasys.teku.statetransition.block.BlockImporter;
 import tech.pegasys.teku.storage.client.RecentChainData;
 
-import java.util.Optional;
-
 public class SinglePeerSyncServiceFactory {
   public static ForwardSyncService create(
-          final MetricsSystem metricsSystem,
-          final AsyncRunner asyncRunner,
-          final P2PNetwork<Eth2Peer> p2pNetwork,
-          final RecentChainData recentChainData,
-          final BlockImporter blockImporter,
-          final BlobSidecarManager blobSidecarManager,
-          final BlockBlobSidecarsTrackersPool blockBlobSidecarsTrackersPool,
-          final int batchSize,
-          final Optional<UInt64> pinnedSyncSlot,
+      final MetricsSystem metricsSystem,
+      final AsyncRunner asyncRunner,
+      final P2PNetwork<Eth2Peer> p2pNetwork,
+      final RecentChainData recentChainData,
+      final BlockImporter blockImporter,
+      final BlobSidecarManager blobSidecarManager,
+      final BlockBlobSidecarsTrackersPool blockBlobSidecarsTrackersPool,
+      final int batchSize,
+      final Optional<UInt64> pinnedSyncSlot,
       final Spec spec) {
     final SyncManager syncManager =
         SyncManager.create(
@@ -49,7 +48,7 @@ public static ForwardSyncService create(
             blockBlobSidecarsTrackersPool,
             metricsSystem,
             batchSize,
-                pinnedSyncSlot,
+            pinnedSyncSlot,
             spec);
     return new SinglePeerSyncService(syncManager, recentChainData);
   }

diff --git a/beacon/sync/src/main/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/SyncManager.java b/beacon/sync/src/main/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/SyncManager.java
@@ -104,7 +104,7 @@ public static SyncManager create(
             blobSidecarManager,
             blockBlobSidecarsTrackersPool,
             batchSize,
-                pinnedSyncSlot,
+            pinnedSyncSlot,
             metricsSystem);
     return new SyncManager(asyncRunner, network, recentChainData, peerSync, spec);
   }