core: Lock entire lattice.ProcessBlock (#259)

* Lock entire ProcessBlock

* Lock Consensus.processBlock

1 files changed, 4 insertions, 0 deletions

diff --git a/core/consensus.go b/core/consensus.go
index ab59a67..05f93e1 100644
--- a/core/consensus.go
+++ b/core/consensus.go
@@ -830,6 +830,10 @@ func (con *Consensus) processBlock(block *types.Block) (err error) {
 	if err = con.db.Put(*block); err != nil && err != blockdb.ErrBlockExists {
 		return
 	}
+	con.lock.Lock()
+	defer con.lock.Unlock()
+	// Block processed by lattice can be out-of-order. But the output of lattice
+	// (deliveredBlocks) cannot.
 	deliveredBlocks, err := con.lattice.ProcessBlock(block)
 	if err != nil {
 		return