From 5a83e584287c17c901f1f6d3d31444ff5396ec3b Mon Sep 17 00:00:00 2001 From: Anton Kaliaev Date: Sun, 17 Dec 2017 20:16:02 -0600 Subject: [PATCH] stop eventBus --- consensus/wal_generator.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/consensus/wal_generator.go b/consensus/wal_generator.go index d7825c0a1..f477e5dc0 100644 --- a/consensus/wal_generator.go +++ b/consensus/wal_generator.go @@ -33,6 +33,7 @@ func WALWithNBlocks(numBlocks int) (data []byte, err error) { app := dummy.NewPersistentDummyApplication(filepath.Join(config.DBDir(), "wal_generator")) logger := log.TestingLogger().With("wal_generator", "wal_generator") + logger.Info("generating WAL (last height msg excluded)", "numBlocks", numBlocks) ///////////////////////////////////////////////////////////////////////////// // COPY PASTE FROM node.go WITH A FEW MODIFICATIONS @@ -63,6 +64,7 @@ func WALWithNBlocks(numBlocks int) (data []byte, err error) { if err := eventBus.Start(); err != nil { return nil, errors.Wrap(err, "failed to start event bus") } + defer eventBus.Stop() mempool := types.MockMempool{} consensusState := NewConsensusState(config.Consensus, state.Copy(), proxyApp.Consensus(), blockStore, mempool) consensusState.SetLogger(logger)