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

Fix James' comment.

Browse Source
This commit is contained in:
Manu NALEPA
2025-08-12 22:35:48 +02:00
parent bd17dfefb9
commit 474f458834
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
beacon-chain/sync/pending_blocks_queue.go
View File

@@ -200,6 +200,18 @@ var errNoPeersForPending = errors.New("no suitable peers to process pending bloc
// processAndBroadcastBlock validates, processes, and broadcasts a block.
// Part of the function is to request missing sidecars from peers if the block contains kzg commitments.
func (s *Service) processAndBroadcastBlock(ctx context.Context, b interfaces.ReadOnlySignedBeaconBlock, blkRoot [fieldparams.RootLength]byte) error {
if err := s.processBlock(ctx, b, blkRoot); err != nil {
return errors.Wrap(err, "process block")
}
if err := s.receiveAndBroadCastBlock(ctx, b, blkRoot, b.Block().Slot()); err != nil {
return errors.Wrap(err, "receive and broadcast block")
}
return nil
}
func (s *Service) processBlock(ctx context.Context, b interfaces.ReadOnlySignedBeaconBlock, blkRoot [fieldparams.RootLength]byte) error {
blockSlot := b.Block().Slot()
if err := s.validateBeaconBlock(ctx, b, blkRoot); err != nil {
@@ -221,17 +233,13 @@ func (s *Service) processAndBroadcastBlock(ctx context.Context, b interfaces.Rea
return errors.Wrap(err, "request and save missing data column sidecars")
}
if err := s.receiveAndBroadCastBlock(ctx, b, blkRoot, blockSlot); err != nil {
return errors.Wrap(err, "receive and broadcast block")
}
return nil
}
if blockEpoch >= denebForkEpoch {
request, err := s.pendingBlobsRequestForBlock(blkRoot, b)
if err != nil {
return err
return errors.Wrap(err, "pending blobs request for block")
}
if len(request) > 0 {
@@ -243,21 +251,13 @@ func (s *Service) processAndBroadcastBlock(ctx context.Context, b interfaces.Rea
}
if err := s.sendAndSaveBlobSidecars(ctx, request, peers[rand.NewGenerator().Int()%peerCount], b); err != nil {
return err
return errors.Wrap(err, "send and save blob sidecars")
}
}
if err := s.receiveAndBroadCastBlock(ctx, b, blkRoot, blockSlot); err != nil {
return errors.Wrap(err, "receive and broadcast block")
}
return nil
}
if err := s.receiveAndBroadCastBlock(ctx, b, blkRoot, blockSlot); err != nil {
return errors.Wrap(err, "receive and broadcast block")
}
return nil
}