fast sync status

blockchain/reactor.go

@@ -267,11 +267,6 @@ func (bcR *BlockchainReactor) SetEventSwitch(evsw types.EventSwitch) {
 	bcR.evsw = evsw
 }
 
-// FastSync returns whether the blockchain reactor is currently fast syncing
-func (bcR *BlockchainReactor) FastSync() bool {
-	return bcR.fastSync
-}
-
 //-----------------------------------------------------------------------------
 // Messages
 

consensus/reactor.go

@@ -290,6 +290,11 @@ func (conR *ConsensusReactor) SetEventSwitch(evsw types.EventSwitch) {
 	conR.conS.SetEventSwitch(evsw)
 }
 
+// FastSync returns whether the consensus reactor is currently fast syncing
+func (conR *ConsensusReactor) FastSync() bool {
+	return conR.fastSync
+}
+
 //--------------------------------------
 
 // Listens for new steps and votes,

node/node.go

@@ -315,7 +315,7 @@ func (n *Node) ConfigureRPC() {
 	rpccore.SetAddrBook(n.addrBook)
 	rpccore.SetProxyAppQuery(n.proxyApp.Query())
 	rpccore.SetTxIndexer(n.txIndexer)
-	rpccore.SetBlockchainReactor(n.bcReactor)
+	rpccore.SetConsensusReactor(n.consensusReactor)
 	rpccore.SetLogger(n.Logger.With("module", "rpc"))
 }
 

rpc/core/pipe.go

@@ -2,7 +2,6 @@ package core
 
 import (
 	crypto "github.com/tendermint/go-crypto"
-	"github.com/tendermint/tendermint/blockchain"
 	"github.com/tendermint/tendermint/consensus"
 	p2p "github.com/tendermint/tendermint/p2p"
 	"github.com/tendermint/tendermint/proxy"
@@ -42,11 +41,11 @@ var (
 	p2pSwitch      P2P
 
 	// objects
-	pubKey    crypto.PubKey
-	genDoc    *types.GenesisDoc // cache the genesis structure
-	addrBook  *p2p.AddrBook
-	txIndexer txindex.TxIndexer
-	bcReactor *blockchain.BlockchainReactor
+	pubKey           crypto.PubKey
+	genDoc           *types.GenesisDoc // cache the genesis structure
+	addrBook         *p2p.AddrBook
+	txIndexer        txindex.TxIndexer
+	consensusReactor *consensus.ConsensusReactor
 
 	logger log.Logger
 )
@@ -91,8 +90,8 @@ func SetTxIndexer(indexer txindex.TxIndexer) {
 	txIndexer = indexer
 }
 
-func SetBlockchainReactor(bc *blockchain.BlockchainReactor) {
-	bcReactor = bc
+func SetConsensusReactor(conR *consensus.ConsensusReactor) {
+	consensusReactor = conR
 }
 
 func SetLogger(l log.Logger) {

rpc/core/status.go

@@ -28,5 +28,5 @@ func Status() (*ctypes.ResultStatus, error) {
 		LatestAppHash:     latestAppHash,
 		LatestBlockHeight: latestHeight,
 		LatestBlockTime:   latestBlockTime,
-		Syncing:           bcReactor.FastSync()}, nil
+		Syncing:           consensusReactor.FastSync()}, nil
 }