UPD(block): add height to fetch isSynced condition

ouyun · Nov 1, 2018 · 3a8000e · 3a8000e
1 parent d51aa54
commit 3a8000e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/stream/block/fetch.go b/internal/stream/block/fetch.go
@@ -206,7 +206,7 @@ func (b *BlockFetcher) handle(blocks []*lws.Block) error {
 		if err != nil {
 			log.Printf("handle sync block error [%s]", err)
 		}
-		if bytes.Compare(block.Hash, b.TriggerBlock.Hash) == 0 {
+		if bytes.Compare(block.Hash, b.TriggerBlock.Hash) == 0 || block.NHeight > b.TriggerBlock.NHeight {
 			b.isTriggerBlockSynced = true
 		}
 	}