AtHeartEngineer/prysm
1
0
Fork 0
mirror of https://github.com/OffchainLabs/prysm.git synced 2026-01-10 13:58:09 -05:00
Code Issues Packages Projects Releases Wiki Activity

lint: fmt and log capitalisation

Browse Source
This commit is contained in:
satushh
2025-07-23 10:54:49 +01:00
parent 77b3d23c86
commit 35f6d1277d
3 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
beacon-chain/execution/engine_client.go
View File

@@ -682,7 +682,7 @@ func (s *Service) ReconstructDataColumnSidecars(ctx context.Context, signedROBlo
// Create a result channel for this reconstruction call
resultChan := make(chan reconstructResult, 1)
// Try to claim this reconstruction call
if existingChanInterface, loaded := s.activeReconstructCalls.LoadOrStore(blockRoot, resultChan); loaded {
existingChan := existingChanInterface.(chan reconstructResult)
@@ -1105,14 +1105,14 @@ func (s *Service) retryReconstructDataColumnSidecars(ctx context.Context, signed
// Retry getBlobsV2
log.WithField("attempt", attemptCount).Debug("Retrying getBlobsV2")
if result, err := s.reconstructDataColumnSidecarsOnce(retryCtx, signedROBlock, blockRoot); err == nil && len(result) > 0 {
log.WithField("attempts", attemptCount).Debug("getBlobsV2 retry succeeded")
log.WithField("attempts", attemptCount).Debug("Retry of getBlobsV2 succeeded")
getBlobsRetryAttempts.WithLabelValues("success").Inc()
getBlobsRetryDuration.WithLabelValues("success").Observe(time.Since(startTime).Seconds())
return
}
case <-retryCtx.Done():
log.WithField("attempts", attemptCount).Debug("getBlobsV2 retry timeout")
log.WithField("attempts", attemptCount).Debug("Timeout of getBlobsV2 retry")
getBlobsRetryAttempts.WithLabelValues("timeout").Inc()
getBlobsRetryDuration.WithLabelValues("timeout").Observe(time.Since(startTime).Seconds())
return

1
beacon-chain/sync/BUILD.bazel
View File

@@ -194,6 +194,7 @@ go_test(
"slot_aware_cache_test.go",
"subscriber_beacon_aggregate_proof_test.go",
"subscriber_beacon_blocks_test.go",
"subscriber_data_column_sidecar_trigger_test.go",
"subscriber_test.go",
"subscription_topic_handler_test.go",
"sync_fuzz_test.go",

2
beacon-chain/sync/subscriber_data_column_sidecar.go
View File

@@ -97,7 +97,7 @@ func (s *Service) triggerGetBlobsV2ForDataColumnSidecar(ctx context.Context, blo
// Trigger the retry by calling the execution service's reconstruct method
go func() {
log.WithField("blockRoot", fmt.Sprintf("%#x", blockRoot)).Debug("Triggering getBlobsV2 retry for data column sidecar")
// This will trigger retry logic if needed
if s.cfg.executionReconstructor != nil {
_, err := s.cfg.executionReconstructor.ReconstructDataColumnSidecars(ctx, signedBlock, blockRoot)