CircuitBreakerEngine
class CircuitBreakerEngine
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
namespace Polly.CircuitBreaker
{
internal class CircuitBreakerEngine
{
internal static TResult Implementation<TResult>(Func<Context, CancellationToken, TResult> action, Context context, CancellationToken cancellationToken, IEnumerable<ExceptionPredicate> shouldHandleExceptionPredicates, IEnumerable<ResultPredicate<TResult>> shouldHandleResultPredicates, ICircuitController<TResult> breakerController)
{
cancellationToken.ThrowIfCancellationRequested();
breakerController.OnActionPreExecute();
try {
TResult result = (TResult)action(context, cancellationToken);
if (shouldHandleResultPredicates.Any((ResultPredicate<TResult> predicate) => predicate((TResult)result)))
breakerController.OnActionFailure(new DelegateResult<TResult>((TResult)result), context);
else
breakerController.OnActionSuccess(context);
return (TResult)result;
} catch (Exception ex2) {
Exception ex;
Exception ex3 = ex = ex2;
if (!shouldHandleExceptionPredicates.Any((ExceptionPredicate predicate) => predicate(ex)))
throw;
breakerController.OnActionFailure(new DelegateResult<TResult>(ex), context);
throw;
}
}
internal static async Task<TResult> ImplementationAsync<TResult>(Func<Context, CancellationToken, Task<TResult>> action, Context context, IEnumerable<ExceptionPredicate> shouldHandleExceptionPredicates, IEnumerable<ResultPredicate<TResult>> shouldHandleResultPredicates, ICircuitController<TResult> breakerController, CancellationToken cancellationToken, bool continueOnCapturedContext)
{
cancellationToken.ThrowIfCancellationRequested();
breakerController.OnActionPreExecute();
try {
<>c__DisplayClass1_0<TResult> <>c__DisplayClass1_;
TResult result2 = <>c__DisplayClass1_.result;
TResult result;
TResult val = (TResult)(result = (TResult)(await action(context, cancellationToken).ConfigureAwait(continueOnCapturedContext)));
if (Enumerable.Any<ResultPredicate<TResult>>(shouldHandleResultPredicates, (Func<ResultPredicate<TResult>, bool>)((ResultPredicate<TResult> predicate) => predicate((TResult)result))))
breakerController.OnActionFailure(new DelegateResult<TResult>((TResult)result), context);
else
breakerController.OnActionSuccess(context);
return (TResult)result;
} catch (Exception ex2) {
Exception ex = ex2;
if (!Enumerable.Any<ExceptionPredicate>(shouldHandleExceptionPredicates, (Func<ExceptionPredicate, bool>)((ExceptionPredicate predicate) => predicate(ex))))
throw;
breakerController.OnActionFailure(new DelegateResult<TResult>(ex), context);
throw;
}
}
}
}