Skip to content

Commit

Permalink
Add retry logic
Browse files Browse the repository at this point in the history
  • Loading branch information
quentinlesceller committed Jan 25, 2023
1 parent 7ef56c6 commit 9e13376
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions eth/catalyst/api.go
Expand Up @@ -411,6 +411,13 @@ func (api *ConsensusAPI) NewPayloadV1(params beacon.ExecutableDataV1) (beacon.Pa
if err := api.eth.BlockChain().InsertBlockWithoutSetHead(block); err != nil {
log.Warn("NewPayloadV1: inserting block failed", "error", err)

if err.Error() == "Not locked" {
// we are stil working on the previous block
// we want to retry later
time.Sleep(5 * time.Second)
return api.NewPayloadV1(params)
}

api.invalidLock.Lock()
api.invalidBlocksHits[block.Hash()] = 1
api.invalidTipsets[block.Hash()] = block.Header()
Expand Down

0 comments on commit 9e13376

Please sign in to comment.