consistency

Author: julienrbrt

block/internal/executing/executor.go

@@ -593,15 +593,15 @@ func (e *Executor) signHeader(header types.Header) (types.Signature, error) {
 }
 
 // executeTxsWithRetry executes transactions with retry logic
-func (s *Executor) executeTxsWithRetry(ctx context.Context, rawTxs [][]byte, header types.Header, currentState types.State) ([]byte, error) {
+func (e *Executor) executeTxsWithRetry(ctx context.Context, rawTxs [][]byte, header types.Header, currentState types.State) ([]byte, error) {
 	for attempt := 1; attempt <= common.MaxRetriesBeforeHalt; attempt++ {
-		newAppHash, _, err := s.exec.ExecuteTxs(ctx, rawTxs, header.Height(), header.Time(), currentState.AppHash)
+		newAppHash, _, err := e.exec.ExecuteTxs(ctx, rawTxs, header.Height(), header.Time(), currentState.AppHash)
 		if err != nil {
 			if attempt == common.MaxRetriesBeforeHalt {
 				return nil, fmt.Errorf("failed to execute transactions: %w", err)
 			}
 
-			s.logger.Error().Err(err).
+			e.logger.Error().Err(err).
 				Int("attempt", attempt).
 				Int("max_attempts", common.MaxRetriesBeforeHalt).
 				Uint64("height", header.Height()).
@@ -610,8 +610,8 @@ func (s *Executor) executeTxsWithRetry(ctx context.Context, rawTxs [][]byte, hea
 			select {
 			case <-time.After(common.MaxRetriesTimeout):
 				continue
-			case <-s.ctx.Done():
-				return nil, fmt.Errorf("context cancelled during retry: %w", s.ctx.Err())
+			case <-e.ctx.Done():
+				return nil, fmt.Errorf("context cancelled during retry: %w", e.ctx.Err())
 			}
 		}