pinned sync

Consensys · Feb 25, 2025 · 08aa980 · 08aa980
1 parent 17a68b3
commit 08aa980
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...n/sync/src/main/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/CommonAncestor.java b/...n/sync/src/main/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/CommonAncestor.java
@@ -57,7 +57,9 @@ public CommonAncestor(final RecentChainData recentChainData, final Optional<UInt
 
   public SafeFuture<UInt64> getCommonAncestor(
       final SyncSource peer, final UInt64 firstNonFinalSlot, final UInt64 peerHeadSlot) {
-    if (pinnedCommonAncestorSlot.isPresent()) {
+    if (pinnedCommonAncestorSlot
+        .map(slot -> slot.equals(recentChainData.getHeadSlot()))
+        .orElse(false)) {
       return getCommonAncestorFromPinned(peer);
     }