TimeoutEngine
using Polly.Utilities;
using System;
using System.Diagnostics;
using System.Runtime.ExceptionServices;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.Timeout
{
internal static class TimeoutEngine
{
[System.Diagnostics.DebuggerDisableUserUnhandledExceptions]
internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> action, Context context, Func<Context, TimeSpan> timeoutProvider, TimeoutStrategy timeoutStrategy, Action<Context, TimeSpan, Task, Exception> onTimeout, CancellationToken cancellationToken)
{
cancellationToken.ThrowIfCancellationRequested();
TimeSpan timeSpan = timeoutProvider(context);
using (CancellationTokenSource cancellationTokenSource = new CancellationTokenSource())
using (CancellationTokenSource cancellationTokenSource2 = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, cancellationTokenSource.Token)) {
CancellationToken combinedToken = cancellationTokenSource2.Token;
Task<TResult> task = null;
try {
if (timeoutStrategy != 0) {
SystemClock.CancelTokenAfter(cancellationTokenSource, timeSpan);
task = Task.Run(() => action(context, combinedToken), combinedToken);
try {
task.Wait(cancellationTokenSource.Token);
} catch (AggregateException ex) when (ex.InnerExceptions.Count == 1) {
ExceptionDispatchInfo.Capture(ex.InnerException).Throw();
}
return task.Result;
}
SystemClock.CancelTokenAfter(cancellationTokenSource, timeSpan);
return action(context, combinedToken);
} catch (Exception ex2) {
if (ex2 is OperationCanceledException && cancellationTokenSource.IsCancellationRequested) {
onTimeout(context, timeSpan, task, ex2);
throw new TimeoutRejectedException("The delegate executed through TimeoutPolicy did not complete within the timeout.", timeSpan, ex2);
}
throw;
}
}
}
}
}