small refactor

Consensys · Jan 12, 2023 · 0641b88 · 0641b88
1 parent 57f1ac9
commit 0641b88
Showing 1 changed file with 7 additions and 13 deletions.
diff --git a/beacon/sync/src/main/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/PeerSync.java b/beacon/sync/src/main/java/tech/pegasys/teku/beacon/sync/forward/singlepeer/PeerSync.java
@@ -19,7 +19,6 @@
 import com.google.common.base.Throwables;
 import java.time.Duration;
 import java.util.List;
-import java.util.Optional;
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -159,8 +158,6 @@ private SafeFuture<PeerSyncResult> executeSync(
     final UInt64 count = requestContext.getCount();
     final boolean blobsSidecarsRequired = requestContext.areBlobsSidecarsRequired();
 
-    readyForRequest.complete(null);
-
     return readyForRequest
         .thenCompose(
             __ -> {
@@ -185,18 +182,17 @@ private SafeFuture<PeerSyncResult> executeSync(
               final SafeFuture<Void> readyForNextRequest =
                   asyncRunner.getDelayedFuture(NEXT_REQUEST_TIMEOUT);
 
+              final BlockAndBlobsSidecarMatcher blockAndBlobsSidecarMatcher =
+                  new BlockAndBlobsSidecarMatcher(
+                      blobsSidecarManager,
+                      this::storeBlobsSidecarAndImportBlock,
+                      this::importBlock);
+
               final RpcResponseListener<SignedBeaconBlock> blockListener;
-              final Optional<BlockAndBlobsSidecarMatcher> maybeBlockAndBlobsSidecarMatcher;
               final SafeFuture<Void> blobsSidecarsRequest;
 
               if (blobsSidecarsRequired) {
-                final BlockAndBlobsSidecarMatcher blockAndBlobsSidecarMatcher =
-                    new BlockAndBlobsSidecarMatcher(
-                        blobsSidecarManager,
-                        this::storeBlobsSidecarAndImportBlock,
-                        this::importBlock);
                 blockListener = blockAndBlobsSidecarMatcher::recordBlock;
-                maybeBlockAndBlobsSidecarMatcher = Optional.of(blockAndBlobsSidecarMatcher);
                 LOG.debug(
                     "Request {} blobs sidecars starting at {} from peer {}",
                     count,
@@ -206,7 +202,6 @@ private SafeFuture<PeerSyncResult> executeSync(
                     peer.requestBlobsSidecarsByRange(
                         ancestorStartSlot, count, blockAndBlobsSidecarMatcher::recordBlobsSidecar);
               } else {
-                maybeBlockAndBlobsSidecarMatcher = Optional.empty();
                 blockListener = this::importBlock;
                 blobsSidecarsRequest = SafeFuture.COMPLETE;
               }
@@ -220,8 +215,7 @@ private SafeFuture<PeerSyncResult> executeSync(
                       blobsSidecarsRequest)
                   .thenApply(
                       __ -> {
-                        maybeBlockAndBlobsSidecarMatcher.ifPresent(
-                            BlockAndBlobsSidecarMatcher::clearCache);
+                        blockAndBlobsSidecarMatcher.clearCache();
                         return request;
                       });
             })