Skip to content

Commit cb360ab

Browse files
authored
fix(dot/sync): cleanup logs; don't log case where we fail to get parent while processing (#2188)
1 parent feeabff commit cb360ab

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

dot/sync/chain_processor.go

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -85,16 +85,18 @@ func (s *chainProcessor) processReadyBlocks() {
8585
}
8686

8787
if err := s.processBlockData(bd); err != nil {
88-
logger.Errorf("block data processing for block with hash %s failed: %s", bd.Hash, err)
89-
9088
// depending on the error, we might want to save this block for later
91-
if errors.Is(err, errFailedToGetParent) {
92-
if err := s.pendingBlocks.addBlock(&types.Block{
93-
Header: *bd.Header,
94-
Body: *bd.Body,
95-
}); err != nil {
96-
logger.Debugf("failed to re-add block to pending blocks: %s", err)
97-
}
89+
if !errors.Is(err, errFailedToGetParent) {
90+
logger.Errorf("block data processing for block with hash %s failed: %s", bd.Hash, err)
91+
continue
92+
}
93+
94+
logger.Tracef("block data processing for block with hash %s failed: %s", bd.Hash, err)
95+
if err := s.pendingBlocks.addBlock(&types.Block{
96+
Header: *bd.Header,
97+
Body: *bd.Body,
98+
}); err != nil {
99+
logger.Debugf("failed to re-add block to pending blocks: %s", err)
98100
}
99101
}
100102
}
@@ -169,7 +171,7 @@ func (s *chainProcessor) processBlockData(bd *types.BlockData) error {
169171
}
170172

171173
if err := s.handleBlock(block); err != nil {
172-
logger.Errorf("failed to handle block number %s: %s", block.Header.Number, err)
174+
logger.Debugf("failed to handle block number %s: %s", block.Header.Number, err)
173175
return err
174176
}
175177

0 commit comments

Comments
 (0)