mirror of
https://github.com/tendermint/tendermint.git
synced 2025-12-23 14:25:19 +00:00
@@ -92,11 +92,10 @@ func WALWithNBlocks(numBlocks int) (data []byte, err error) {
|
|||||||
|
|
||||||
select {
|
select {
|
||||||
case <-numBlocksWritten:
|
case <-numBlocksWritten:
|
||||||
consensusState.Stop()
|
|
||||||
wr.Flush()
|
wr.Flush()
|
||||||
return b.Bytes(), nil
|
return b.Bytes(), nil
|
||||||
case <-time.After(1 * time.Minute):
|
case <-time.After(1 * time.Minute):
|
||||||
consensusState.Stop()
|
wr.Flush()
|
||||||
return []byte{}, fmt.Errorf("waited too long for tendermint to produce %d blocks (grep logs for `wal_generator`)", numBlocks)
|
return []byte{}, fmt.Errorf("waited too long for tendermint to produce %d blocks (grep logs for `wal_generator`)", numBlocks)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user