closed chan is not an error

ava-labs · Apr 30, 2024 · 74c8526 · 74c8526
1 parent 3eb310f
commit 74c8526
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/relayer/listener.go b/relayer/listener.go
@@ -254,8 +254,9 @@ func (lstnr *Listener) NewWarpLogInfo(log types.Log) (*relayerTypes.WarpLogInfo,
 func (lstnr *Listener) ProcessLogs(ctx context.Context) error {
 	for {
 		select {
-		case catchUpResult := <-lstnr.catchUpResultChan:
-			if !catchUpResult {
+		case catchUpResult, ok := <-lstnr.catchUpResultChan:
+			// Mark the relayer as unhealthy if the catch-up process fails.
+			if ok && !catchUpResult {
 				lstnr.healthStatus.Store(false)
 				lstnr.logger.Error(
 					"Failed to catch up on historical blocks. Exiting listener goroutine.",