process historical blocks async

ava-labs · Jan 16, 2024 · 1fad84b · 1fad84b
1 parent 37cd80f
commit 1fad84b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/relayer/relayer.go b/relayer/relayer.go
@@ -150,7 +150,10 @@ func NewRelayer(
 			)
 			return nil, nil, err
 		}
-		sub.ProcessFromHeight(big.NewInt(0).SetUint64(height), doneProcessingMissedBlocks)
+		// Process historical blocks asynchronously so that the main processing loop can
+		// start processing new blocks as soon as possible. Otherwise, it's possible for
+		// ProcessFromHeight to overload the message queue and cause a deadlock.
+		go sub.ProcessFromHeight(big.NewInt(0).SetUint64(height), doneProcessingMissedBlocks)
 	} else {
 		err = r.setProcessedBlockHeightToLatest()
 		if err != nil {