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),
}
}