"github.com/tendermint/go-wire"
"github.com/tendermint/tmlibs/flowrate"
+ dbm "github.com/vapor/database/leveldb"
"github.com/vapor/consensus"
"github.com/vapor/netsync/peers"
return false
}
+func (p *P2PPeer) RemoteAddrHost() string {
+ return ""
+}
+
func (p *P2PPeer) ServiceFlag() consensus.ServiceFlag {
return p.flag
}
return &PeerSet{}
}
-func (ps *PeerSet) IsBanned(peerID string, level byte, reason string) bool {
+func (ps *PeerSet) IsBanned(ip string, level byte, reason string) bool {
return false
}
return blocks
}
-func mockSync(blocks []*types.Block, mempool *mock.Mempool) *Manager {
+func mockSync(blocks []*types.Block, mempool *mock.Mempool, fastSyncDB dbm.DB) *Manager {
chain := mock.NewChain(mempool)
peers := peers.NewPeerSet(NewPeerSet())
chain.SetBestBlockHeader(&blocks[len(blocks)-1].BlockHeader)
return &Manager{
chain: chain,
- blockKeeper: newBlockKeeper(chain, peers),
+ blockKeeper: newBlockKeeper(chain, peers, fastSyncDB),
peers: peers,
mempool: mempool,
txSyncCh: make(chan *txSyncMsg),