add debug info

diff --git a/netsync/consensusmgr/block_fetcher.go b/netsync/consensusmgr/block_fetcher.go
index 3c92b38..321daf8 100644 (file)
--- a/netsync/consensusmgr/block_fetcher.go
+++ b/netsync/consensusmgr/block_fetcher.go
@@ -4,6 +4,7 @@ import (
        "github.com/sirupsen/logrus"
        "gopkg.in/karalabe/cookiejar.v2/collections/prque"
 
+       "fmt"
        "github.com/vapor/netsync/peers"
        "github.com/vapor/p2p/security"
        "github.com/vapor/protocol/bc"
@@ -86,6 +87,7 @@ func (f *blockFetcher) insert(msg *blockMsg) {
        }
 
        if isOrphan {
+               fmt.Println("isOrphan block:", "height:",msg.block.Height, "hash:",msg.block.Hash())
                return
        }
 

diff --git a/netsync/consensusmgr/consensus_msg.go b/netsync/consensusmgr/consensus_msg.go
index 40f74c7..a6ed83b 100644 (file)
--- a/netsync/consensusmgr/consensus_msg.go
+++ b/netsync/consensusmgr/consensus_msg.go
@@ -109,9 +109,10 @@ func (bp *BlockProposeMsg) String() string {
 func (bp *BlockProposeMsg) BroadcastMarkSendRecord(ps *peers.PeerSet, peers []string) {
        block, err := bp.GetProposeBlock()
        if err != nil {
+               fmt.Println("GetProposeBlock error", err)
                return
        }
-
+       fmt.Println("mark send block record", peers)
        hash := block.Hash()
        height := block.Height
        for _, peer := range peers {
@@ -126,6 +127,6 @@ func (bp *BlockProposeMsg) BroadcastFilterTargetPeers(ps *peers.PeerSet) []strin
        if err != nil {
                return nil
        }
-
+       fmt.Println("peers without block.", "height:", block.Height, "hash:", block.Hash(), "peers:", ps.PeersWithoutBlock(block.Hash()))
        return ps.PeersWithoutBlock(block.Hash())
 }