return
}
- logrus.WithFields(logrus.Fields{"module": logModule, "peer": peer.Addr(), "type": reflect.TypeOf(msg), "message": msg.String()}).Info("receive message from peer")
+ logrus.WithFields(logrus.Fields{"module": logModule, "peer": peer.Addr(), "type": reflect.TypeOf(msg), "message": msg.String()}).Debug("receive message from peer")
switch msg := msg.(type) {
case *BlockProposeMsg:
}
func (m *Manager) handleBlockSignatureMsg(peerID string, msg *BlockSignatureMsg) {
+ m.peers.MarkBlockSignature(peerID, msg.Signature)
blockHash := bc.NewHash(msg.BlockHash)
if err := m.chain.ProcessBlockSignature(msg.Signature, msg.PubKey, &blockHash); err != nil {
m.peers.ProcessIllegal(peerID, security.LevelMsgIllegal, err.Error())
return
}
- m.peers.MarkBlockSignature(peerID, msg.Signature)
}
func (m *Manager) blockProposeMsgBroadcastLoop() {