feedback

julienrbrt · julienrbrt · commit 7e8e835b4310 · 2025-10-01T12:21:53.000+02:00
diff --git a/block/internal/syncing/syncer.go b/block/internal/syncing/syncer.go
@@ -498,7 +498,12 @@ func (s *Syncer) applyBlock(header types.Header, data *types.Data, currentState
 			return types.State{}, fmt.Errorf("failed to execute transactions: %w", err)
 		}
 
-		time.Sleep(maxRetriesTimeout)
+		select {
+		case <-time.After(maxRetriesTimeout):
+		case <-s.ctx.Done():
+			return types.State{}, s.ctx.Err()
+		}
+
 		return types.State{}, fmt.Errorf("failed to execute transactions (retry %d / %d): %w", s.retriesBeforeHalt[header.Height()], maxRetriesBeforeHalt, err)
 	}
 	delete(s.retriesBeforeHalt, header.Height())

Original file line number	Diff line number	Diff line change
`@@ -498,7 +498,12 @@ func (s Syncer) applyBlock(header types.Header, data types.Data, currentState`
`498`	`498`	`return types.State{}, fmt.Errorf("failed to execute transactions: %w", err)`
`499`	`499`	`}`
`500`	`500`
`501`		`- time.Sleep(maxRetriesTimeout)`
	`501`	`+ select {`
	`502`	`+ case <-time.After(maxRetriesTimeout):`
	`503`	`+ case <-s.ctx.Done():`
	`504`	`+ return types.State{}, s.ctx.Err()`
	`505`	`+ }`
	`506`	`+`
`502`	`507`	`return types.State{}, fmt.Errorf("failed to execute transactions (retry %d / %d): %w", s.retriesBeforeHalt[header.Height()], maxRetriesBeforeHalt, err)`
`503`	`508`	`}`
`504`	`509`	`delete(s.retriesBeforeHalt, header.Height())`