CacheEngine
using System;
using System.Threading;
namespace Polly.Caching
{
internal static class CacheEngine
{
internal static TResult Implementation<TResult>(ISyncCacheProvider<TResult> cacheProvider, ITtlStrategy<TResult> ttlStrategy, Func<Context, string> cacheKeyStrategy, Func<Context, CancellationToken, TResult> action, Context context, CancellationToken cancellationToken, Action<Context, string> onCacheGet, Action<Context, string> onCacheMiss, Action<Context, string> onCachePut, Action<Context, string, Exception> onCacheGetError, Action<Context, string, Exception> onCachePutError)
{
cancellationToken.ThrowIfCancellationRequested();
string text = cacheKeyStrategy(context);
if (text == null)
return action(context, cancellationToken);
bool flag;
TResult result;
try {
(bool, TResult) valueTuple = cacheProvider.TryGet(text);
flag = valueTuple.Item1;
result = valueTuple.Item2;
} catch (Exception arg) {
flag = false;
result = default(TResult);
onCacheGetError(context, text, arg);
}
if (flag) {
onCacheGet(context, text);
return result;
}
onCacheMiss(context, text);
TResult val = action(context, cancellationToken);
Ttl ttl = ttlStrategy.GetTtl(context, val);
if (ttl.Timespan > TimeSpan.Zero)
try {
cacheProvider.Put(text, val, ttl);
onCachePut(context, text);
return val;
} catch (Exception arg2) {
onCachePutError(context, text, arg2);
return val;
}
return val;
}
}
}