Prevent resending of received BlockSignatureMsg (#294)

diff --git a/netsync/consensusmgr/handle.go b/netsync/consensusmgr/handle.go
index 702df72..ffb5871 100644 (file)
--- a/netsync/consensusmgr/handle.go
+++ b/netsync/consensusmgr/handle.go
@@ -95,12 +95,12 @@ func (m *Manager) handleBlockProposeMsg(peerID string, msg *BlockProposeMsg) {
 }
 
 func (m *Manager) handleBlockSignatureMsg(peerID string, msg *BlockSignatureMsg) {
 }
 
 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
        }
        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() {
 }
 
 func (m *Manager) blockProposeMsgBroadcastLoop() {