diff --git a/src/Nethermind/Nethermind.Consensus/Processing/BlockCachePreWarmer.cs b/src/Nethermind/Nethermind.Consensus/Processing/BlockCachePreWarmer.cs index a309721c65a..7bd609daa97 100644 --- a/src/Nethermind/Nethermind.Consensus/Processing/BlockCachePreWarmer.cs +++ b/src/Nethermind/Nethermind.Consensus/Processing/BlockCachePreWarmer.cs @@ -99,6 +99,10 @@ private void WarmupWithdrawals(ParallelOptions parallelOptions, IReleaseSpec spe i = Interlocked.Increment(ref progress) - 1; scope.WorldState.WarmUp(block.Withdrawals[i].Address); } + catch (OperationCanceledException) + { + // Ignore + } catch (Exception ex) { if (_logger.IsDebug) _logger.Error($"Error pre-warming withdrawal {i}", ex); @@ -140,6 +144,10 @@ private void WarmupTransactions(ParallelOptions parallelOptions, IReleaseSpec sp TransactionResult result = scope.TransactionProcessor.Trace(systemTransaction, new BlockExecutionContext(block.Header.Clone()), NullTxTracer.Instance); if (_logger.IsTrace) _logger.Trace($"Finished pre-warming cache for tx[{i}] {tx.Hash} with {result}"); } + catch (OperationCanceledException) + { + // Ignore + } catch (Exception ex) { if (_logger.IsDebug) _logger.Error($"Error pre-warming cache {tx?.Hash}", ex); @@ -173,6 +181,10 @@ void IThreadPoolWorkItem.Execute() using IReadOnlyTxProcessingScope scope = env.Build(StateRoot); WarmupAddresses(parallelOptions, Block, scope); } + catch (OperationCanceledException) + { + // Ignore + } catch (Exception ex) { if (PreWarmer._logger.IsDebug) PreWarmer._logger.Error($"Error pre-warming addresses", ex); @@ -215,6 +227,10 @@ private void WarmupAddresses(ParallelOptions parallelOptions, Block block, IRead scope.WorldState.WarmUp(to); } } + catch (OperationCanceledException) + { + // Ignore + } catch (Exception ex) { if (PreWarmer._logger.IsDebug) PreWarmer._logger.Error($"Error pre-warming addresses {i}", ex);