improvement

StefanBratanov · Dec 19, 2024 · 66c272a · 66c272a
1 parent b72e8ea
commit 66c272a
Showing 1 changed file with 10 additions and 5 deletions.
diff --git a/...c/main/java/tech/pegasys/teku/statetransition/util/BlockBlobSidecarsTrackersPoolImpl.java b/...c/main/java/tech/pegasys/teku/statetransition/util/BlockBlobSidecarsTrackersPoolImpl.java
@@ -505,15 +505,20 @@ private BlockBlobSidecarsTracker internalOnNewBlock(
 
               countBlock(remoteOrigin);
 
-              if (existingTracker.isRpcBlockFetchTriggered() && !existingTracker.isComplete()) {
-                // if we attempted to fetch this block via RPC, we missed the opportunity to
-                // complete the blob sidecars via local EL and RPC (since the block is required to
-                // be known) Let's try now
+              if (!existingTracker.isComplete()) {
+                // we missed the opportunity to complete the blob sidecars via local EL and RPC
+                // (since the block is required to be known) Let's try now
                 asyncRunner.runAsync(
                     () ->
                         fetchMissingBlobsFromLocalEL(slotAndBlockRoot)
                             .handleException(this::logLocalElBlobsLookupFailure)
-                            .thenRun(() -> fetchMissingBlockOrBlobsFromRPC(slotAndBlockRoot))
+                            .thenRun(
+                                () -> {
+                                  // respect the RPC fetch delay
+                                  if (existingTracker.isRpcBlockFetchTriggered()) {
+                                    fetchMissingBlockOrBlobsFromRPC(slotAndBlockRoot);
+                                  }
+                                })
                             .finish(this::logBlockOrBlobsRPCFailure));
               }
             });