Merge pull request #129 from binance-chain/indexlag

[R4R] fix tx indexer lag behind block

CHANGELOG_PENDING.md

@@ -19,3 +19,5 @@
 ### IMPROVEMENTS:
 
 ### BUG FIXES:
+- [index] [\#129](https://github.com/binance-chain/bnc-tendermint/pull/129) fix tx indexer lag behind block
+

state/blockindex/kv/kv.go

@@ -54,6 +54,6 @@ func (bki *BlockIndex) Index(header *types.Header) error {
 	if err != nil {
 		return err
 	}
-	bki.store.Set(hash, rawBytes)
+	bki.store.SetSync(hash, rawBytes)
 	return nil
 }

state/index.go

@@ -152,7 +152,7 @@ func (ih *IndexHub) SetIndexedHeight(h int64) {
 	if err != nil {
 		ih.Logger.Error("failed to MarshalBinaryBare for indexed height", "error", err, "height", h)
 	} else {
-		ih.stateDB.Set(IndexHeightKey, rawHeight)
+		ih.stateDB.SetSync(IndexHeightKey, rawHeight)
 	}
 }
 

state/txindex/kv/kv.go

@@ -111,7 +111,7 @@ func (txi *TxIndex) AddBatch(b *txindex.Batch) error {
 		storeBatch.Set(hash, rawBytes)
 	}
 
-	storeBatch.Write()
+	storeBatch.WriteSync()
 	return nil
 }
 
@@ -141,7 +141,7 @@ func (txi *TxIndex) Index(result *types.TxResult) error {
 	}
 	b.Set(hash, rawBytes)
 
-	b.Write()
+	b.WriteSync()
 	return nil
 }