Akatsuki-Misaki/ArchiSteamFarm
1
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm.git synced 2026-01-01 06:00:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Actually make ArchiCacheable catch cancellation

Browse Source 
We intend to give the caller best result, operation canceled has no value for him, he can check if cancellation token he provided himself got canceled or not
This commit is contained in:
Archi
2023-11-14 21:15:18 +01:00
parent adbf0748f8
commit ac9d4a7783
1 changed files with 26 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
ArchiSteamFarm/Helpers/ArchiCacheable.cs
View File

@@ -23,6 +23,7 @@ using System;
using System.ComponentModel;
using System.Threading;
using System.Threading.Tasks;
using ArchiSteamFarm.Core;
using JetBrains.Annotations;
namespace ArchiSteamFarm.Helpers;
@@ -58,7 +59,13 @@ public sealed class ArchiCacheable<T> : IDisposable {
return (true, InitializedValue);
}
await InitSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
try {
await InitSemaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
} catch (OperationCanceledException e) {
ASF.ArchiLogger.LogGenericDebuggingException(e);
return ReturnFailedValueFor(cacheFallback);
}
try {
if (IsInitialized && IsRecent) {
@@ -68,18 +75,17 @@ public sealed class ArchiCacheable<T> : IDisposable {
(bool success, T? result) = await ResolveFunction(cancellationToken).ConfigureAwait(false);
if (!success) {
return cacheFallback switch {
ECacheFallback.DefaultForType => (false, default(T?)),
ECacheFallback.FailedNow => (false, result),
ECacheFallback.SuccessPreviously => (false, InitializedValue),
_ => throw new InvalidOperationException(nameof(cacheFallback))
};
return ReturnFailedValueFor(cacheFallback, result);
}
InitializedValue = result;
InitializedAt = DateTime.UtcNow;
return (true, result);
} catch (OperationCanceledException e) {
ASF.ArchiLogger.LogGenericDebuggingException(e);
return ReturnFailedValueFor(cacheFallback);
} finally {
InitSemaphore.Release();
}
@@ -103,4 +109,17 @@ public sealed class ArchiCacheable<T> : IDisposable {
InitSemaphore.Release();
}
}
private (bool Success, T? Result) ReturnFailedValueFor(ECacheFallback cacheFallback, T? result = default) {
if (!Enum.IsDefined(typeof(ECacheFallback), cacheFallback)) {
throw new InvalidEnumArgumentException(nameof(cacheFallback), (int) cacheFallback, typeof(ECacheFallback));
}
return cacheFallback switch {
ECacheFallback.DefaultForType => (false, default(T?)),
ECacheFallback.FailedNow => (false, result),
ECacheFallback.SuccessPreviously => (false, InitializedValue),
_ => throw new InvalidOperationException(nameof(cacheFallback))
};
}
}