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

Remove invalid block and state

Browse Source
This commit is contained in:
terence tsao
2022-07-05 16:25:58 -07:00
parent 641b477e18
commit 9ca011b8ce
1 changed files with 21 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
beacon-chain/blockchain/execution_engine.go
View File

@@ -215,6 +215,13 @@ func (s *Service) notifyNewPayload(ctx context.Context, postStateVersion int,
return false, invalidBlock{ErrInvalidPayload}
case powchain.ErrInvalidBlockHashPayloadStatus:
newPayloadInvalidNodeCount.Inc()
root, err := blk.Block().HashTreeRoot()
if err != nil {
return false, err
}
if err := s.removeBlockAndState(ctx, root); err != nil {
return false, err
}
return false, invalidBlock{ErrInvalidBlockHashPayloadStatus}
default:
return false, errors.WithMessage(ErrUndefinedExecutionEngineError, err.Error())
@@ -307,16 +314,22 @@ func (s *Service) getPayloadAttribute(ctx context.Context, st state.BeaconState,
// removeInvalidBlockAndState removes the invalid block and its corresponding state from the cache and DB.
func (s *Service) removeInvalidBlockAndState(ctx context.Context, blkRoots [][32]byte) error {
for _, root := range blkRoots {
if err := s.cfg.StateGen.DeleteStateFromCaches(ctx, root); err != nil {
return err
}
// Delete block also deletes the state as well.
if err := s.cfg.BeaconDB.DeleteBlock(ctx, root); err != nil {
// TODO(10487): If a caller requests to delete a root that's justified and finalized. We should gracefully shutdown.
// This is an irreparable condition, it would me a justified or finalized block has become invalid.
if err := s.removeBlockAndState(ctx, root); err != nil {
return err
}
}
return nil
}
func (s *Service) removeBlockAndState(ctx context.Context, blkRoot [32]byte) error {
if err := s.cfg.StateGen.DeleteStateFromCaches(ctx, blkRoot); err != nil {
return err
}
// Delete block also deletes the state as well.
if err := s.cfg.BeaconDB.DeleteBlock(ctx, blkRoot); err != nil {
// TODO(10487): If a caller requests to delete a root that's justified and finalized. We should gracefully shutdown.
// This is an irreparable condition, it would me a justified or finalized block has become invalid.
return err
}
return nil
}