tendermint#121 state sync mode

ackratos · Dec 27, 2018 · 30cfecf · 30cfecf
1 parent 53e8710
commit 30cfecf
Show file tree

Hide file tree

Showing 10 changed files with 1,022 additions and 160 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/blockchain/reactor.go b/blockchain/reactor.go
@@ -124,6 +124,21 @@ func (bcR *BlockchainReactor) OnStop() {
 	bcR.pool.Stop()
 }
 
+// SwitchToBlockchain switches from fastest_sync mode to blockchain mode.
+// It resets the state, turns off fastest_sync, and starts the blockchain state-machine
+func (bcR *BlockchainReactor) SwitchToBlockchain(state sm.State, blocksSynced int) {
+	bcR.Logger.Info("SwitchToConsensus")
+	bcR.initialState = state
+
+	bcR.fastSync = true
+
+	err := bcR.pool.Start()
+	if err != nil {
+		bcR.Logger.Error("Error starting blockchainReactor", "err", err)
+		return
+	}
+}
+
 // GetChannels implements Reactor
 func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor {
 	return []*p2p.ChannelDescriptor{