add error log (#8135)

Consensys · Mar 25, 2024 · 1d8255a · 1d8255a
1 parent 6bad944
commit 1d8255a
Show file tree

Hide file tree

Showing 2 changed files with 33 additions and 0 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
@@ -272,6 +272,13 @@ public synchronized void onCompletedBlockAndBlobSidecars(
     totalBlobSidecars += (int) addedBlobs;
     sizeGauge.set(totalBlobSidecars, GAUGE_BLOB_SIDECARS_LABEL);
 
+    if (!blobSidecarsTracker.isCompleted()) {
+      LOG.error(
+          "Tracker for block {} is supposed to be completed but it is not. Missing blob sidecars: {}",
+          block.toLogString(),
+          blobSidecarsTracker.getMissingBlobSidecars().count());
+    }
+
     if (orderedBlobSidecarsTrackers.add(slotAndBlockRoot)) {
       sizeGauge.set(orderedBlobSidecarsTrackers.size(), GAUGE_BLOB_SIDECARS_TRACKERS_LABEL);
     }

diff --git a/...st/java/tech/pegasys/teku/statetransition/util/BlockBlobSidecarsTrackersPoolImplTest.java b/...st/java/tech/pegasys/teku/statetransition/util/BlockBlobSidecarsTrackersPoolImplTest.java
@@ -40,6 +40,7 @@
 import org.hyperledger.besu.metrics.prometheus.PrometheusMetricsSystem;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import tech.pegasys.infrastructure.logging.LogCaptor;
 import tech.pegasys.teku.infrastructure.async.StubAsyncRunner;
 import tech.pegasys.teku.infrastructure.metrics.TekuMetricCategory;
 import tech.pegasys.teku.infrastructure.time.StubTimeProvider;
@@ -227,6 +228,31 @@ public void onNewBlock_shouldIgnorePreDenebBlocks() {
     assertBlobSidecarsTrackersCount(0);
   }
 
+  @Test
+  public void onCompletedBlockAndBlobSidecars_shouldLogWarningWhenNotCompleted() {
+    try (final LogCaptor logCaptor = LogCaptor.forClass(BlockBlobSidecarsTrackersPoolImpl.class)) {
+      final SignedBeaconBlock block = dataStructureUtil.randomSignedBeaconBlock(currentSlot);
+      final int expectedBlobs =
+          block
+              .getMessage()
+              .getBody()
+              .toVersionDeneb()
+              .orElseThrow()
+              .getBlobKzgCommitments()
+              .size();
+
+      assertThat(expectedBlobs).isGreaterThan(0);
+
+      blockBlobSidecarsTrackersPool.onCompletedBlockAndBlobSidecars(block, List.of());
+
+      logCaptor.assertErrorLog(
+          "Tracker for block "
+              + block.toLogString()
+              + " is supposed to be completed but it is not. Missing blob sidecars: "
+              + expectedBlobs);
+    }
+  }
+
   @Test
   public void onNewBlobSidecarOnNewBlock_addTrackerWithBothBlockAndBlobSidecar() {
     final SignedBeaconBlock block = dataStructureUtil.randomSignedBeaconBlock(currentSlot);