fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-04-26 15:22:15 +00:00
Code Issues Projects Releases Wiki Activity

fix mempool test

Browse Source
This commit is contained in:
Jae Kwon 2015-09-29 09:29:15 -07:00 committed by Ethan Buchman
parent ceed000c58
commit 2f60b5b674
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
mempool/mempool_test.go
View File

@ -100,9 +100,7 @@ func TestResetInfo(t *testing.T) {
// but all we care about is how the mempool responds after // but all we care about is how the mempool responds after
block := makeBlock(mempool) block := makeBlock(mempool)
mempool.ResetForBlockAndState(block, state) ri := mempool.ResetForBlockAndState(block, state)
ri := mempool.resetInfo
if len(ri.Included) != len(TestResetInfoData.Included) { if len(ri.Included) != len(TestResetInfoData.Included) {
t.Fatalf("invalid number of included ranges. Got %d, expected %d\n", len(ri.Included), len(TestResetInfoData.Included)) t.Fatalf("invalid number of included ranges. Got %d, expected %d\n", len(ri.Included), len(TestResetInfoData.Included))
@ -209,9 +207,9 @@ func TestBroadcast(t *testing.T) {
fmt.Println("dont broadcast any") fmt.Println("dont broadcast any")
addTxs(t, mempool, lastAcc, privAccs) addTxs(t, mempool, lastAcc, privAccs)
block := makeBlock(mempool) block := makeBlock(mempool)
mempool.ResetForBlockAndState(block, state) ri := mempool.ResetForBlockAndState(block, state)
newBlockChan <- mempool.resetInfo newBlockChan <- ri
peer.height = mempool.resetInfo.Height peer.height = ri.Height
tickerChan <- time.Now() tickerChan <- time.Now()
pullTxs(t, peer, len(mempool.txs)) // should have sent whatever txs are left (3) pullTxs(t, peer, len(mempool.txs)) // should have sent whatever txs are left (3)
@ -226,9 +224,9 @@ func TestBroadcast(t *testing.T) {
tickerChan <- time.Now() tickerChan <- time.Now()
pullTxs(t, peer, txsToSendPerCheck) // should have sent N txs pullTxs(t, peer, txsToSendPerCheck) // should have sent N txs
block = makeBlock(mempool) block = makeBlock(mempool)
mempool.ResetForBlockAndState(block, state) ri := mempool.ResetForBlockAndState(block, state)
newBlockChan <- mempool.resetInfo newBlockChan <- ri
peer.height = mempool.resetInfo.Height peer.height = ri.Height
txsToSendPerCheck = 100 txsToSendPerCheck = 100
tickerChan <- time.Now() tickerChan <- time.Now()
left := len(mempool.txs) left := len(mempool.txs)