Skip to content

Commit 549dc25

Browse files
noottimwu20
authored andcommitted
fix(lib/babe): call AddBlock in BABE synchronously (ChainSafe#1585)
1 parent 958a881 commit 549dc25

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

dot/core/service.go

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -284,12 +284,7 @@ func (s *Service) handleReceivedBlock(block *types.Block) (err error) {
284284
return ErrNilBlockState
285285
}
286286

287-
err = s.blockState.AddBlock(block)
288-
if err != nil {
289-
return err
290-
}
291-
292-
logger.Debug("added block from BABE", "header", block.Header, "body", block.Body)
287+
logger.Debug("got block from BABE", "header", block.Header, "body", block.Body)
293288

294289
msg := &network.BlockAnnounceMessage{
295290
ParentHash: block.Header.ParentHash,

lib/babe/babe.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -505,6 +505,11 @@ func (b *Service) handleSlot(slotNum uint64) error {
505505
logger.Info("built block", "hash", hash.String(), "number", block.Header.Number, "slot", slotNum)
506506
logger.Debug("built block", "header", block.Header, "body", block.Body, "parent", parent.Hash())
507507

508+
err = b.blockState.AddBlock(block)
509+
if err != nil {
510+
return err
511+
}
512+
508513
err = b.safeSend(*block)
509514
if err != nil {
510515
logger.Error("failed to send block to core", "error", err)

0 commit comments

Comments
 (0)