tendermint#121 state sync mode

ackratos · Dec 13, 2018 · 878d9f1 · 878d9f1
1 parent a1ad253
commit 878d9f1
Show file tree

Hide file tree

Showing 9 changed files with 1,019 additions and 159 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{