"math/rand"
"net"
- wire "github.com/tendermint/go-wire"
+ "github.com/tendermint/go-wire"
"github.com/tendermint/tmlibs/flowrate"
"github.com/vapor/consensus"
return &PeerSet{}
}
-func (ps *PeerSet) AddBannedPeer(string) error { return nil }
-func (ps *PeerSet) StopPeerGracefully(string) {}
+func (ps *PeerSet) IsBanned(peerID string, level byte, reason string) bool {
+ return false
+}
+
+func (ps *PeerSet) StopPeerGracefully(string) {}
type NetWork struct {
nodes map[*Manager]P2PPeer
nodeA.AddPeer(&A2B)
nodeB.AddPeer(&B2A)
-
+ nodeA.SendStatus(B2A.srcPeer)
+ nodeB.SendStatus(A2B.srcPeer)
A2B.setAsync(true)
B2A.setAsync(true)
return &B2A, &A2B, nil
return blocks
}
-func mockSync(blocks []*types.Block) *Manager {
- chain := mock.NewChain()
+func mockSync(blocks []*types.Block, mempool *mock.Mempool) *Manager {
+ chain := mock.NewChain(mempool)
peers := peers.NewPeerSet(NewPeerSet())
chain.SetBestBlockHeader(&blocks[len(blocks)-1].BlockHeader)
for _, block := range blocks {
chain: chain,
blockKeeper: newBlockKeeper(chain, peers),
peers: peers,
+ mempool: mempool,
+ txSyncCh: make(chan *txSyncMsg),
}
}