"gopkg.in/karalabe/cookiejar.v2/collections/prque"
"github.com/vapor/netsync/peers"
+ "github.com/vapor/p2p/security"
"github.com/vapor/protocol/bc"
)
func (f *blockFetcher) blockProcessor() {
for {
- height := f.chain.BestBlockHeight()
for !f.queue.Empty() {
msg := f.queue.PopItem().(*blockMsg)
- if msg.block.Height > height+1 {
+ if msg.block.Height > f.chain.BestBlockHeight()+1 {
f.queue.Push(msg, -float32(msg.block.Height))
break
}
return
}
- f.peers.AddBanScore(msg.peerID, 20, 0, err.Error())
+ f.peers.ProcessIllegal(msg.peerID, security.LevelMsgIllegal, err.Error())
return
}
return
}
- hash := msg.block.Hash()
- f.peers.SetStatus(msg.peerID, msg.block.Height, &hash)
proposeMsg, err := NewBlockProposeMsg(msg.block)
if err != nil {
logrus.WithFields(logrus.Fields{"module": logModule, "err": err}).Error("failed on create BlockProposeMsg")