Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-11-24 14:35:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't send notifications for header-only and invalid blocks

Browse Source
This commit is contained in:
Mike Zak 2022-05-23 17:35:56 +03:00
parent 3f959be0a3
commit 8ff78ecdb0
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
domain/consensus/consensus.go
View File

@ -4,6 +4,8 @@ import (
"math/big" "math/big"
"sync" "sync"
"github.com/kaspanet/kaspad/domain/consensus/utils/consensushashing"
"github.com/kaspanet/kaspad/util/mstime" "github.com/kaspanet/kaspad/util/mstime"
"github.com/kaspanet/kaspad/domain/consensus/database" "github.com/kaspanet/kaspad/domain/consensus/database"
@ -213,6 +215,14 @@ func (s *consensus) ValidateAndInsertBlock(block *externalapi.DomainBlock, shoul
func (s *consensus) sendBlockAddedEvent(block *externalapi.DomainBlock) error { func (s *consensus) sendBlockAddedEvent(block *externalapi.DomainBlock) error {
if s.consensusEventsChan != nil { if s.consensusEventsChan != nil {
blockStatus, err := s.blockStatusStore.Get(s.databaseContext, model.NewStagingArea(), consensushashing.BlockHash(block))
if err != nil {
return err
}
if blockStatus == externalapi.StatusHeaderOnly || blockStatus == externalapi.StatusInvalid {
return nil
}
if len(s.consensusEventsChan) == cap(s.consensusEventsChan) { if len(s.consensusEventsChan) == cap(s.consensusEventsChan) {
return errors.Errorf("consensusEventsChan is full") return errors.Errorf("consensusEventsChan is full")
} }