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

Misc

Browse Source
This commit is contained in:
JustArchi
2018-04-29 23:58:18 +02:00
parent 6640f1212a
commit 49eeceeb2f
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
ArchiSteamFarm/ArchiWebHandler.cs
View File

@@ -1937,21 +1937,22 @@ namespace ArchiSteamFarm {
return await function().ConfigureAwait(false); return await function().ConfigureAwait(false);
} }
// Sending a request affects both - number of requests as well as open connections // Sending a request opens a new connection
await limiters.RateLimitingSemaphore.WaitAsync().ConfigureAwait(false);
await limiters.OpenConnectionsSemaphore.WaitAsync().ConfigureAwait(false); await limiters.OpenConnectionsSemaphore.WaitAsync().ConfigureAwait(false);
// We release rate-limiter semaphore regardless of our task completion, since we use that one only to guarantee rate-limiting of their creation
Utilities.InBackground(async () => {
await Task.Delay(Program.GlobalConfig.WebLimiterDelay).ConfigureAwait(false);
limiters.RateLimitingSemaphore.Release();
});
// However, we release open connections semaphore only once we're indeed done sending a particular request
try { try {
// It also increases number of requests
await limiters.RateLimitingSemaphore.WaitAsync().ConfigureAwait(false);
// We release rate-limiter semaphore regardless of our task completion, since we use that one only to guarantee rate-limiting of their creation
Utilities.InBackground(async () => {
await Task.Delay(Program.GlobalConfig.WebLimiterDelay).ConfigureAwait(false);
limiters.RateLimitingSemaphore.Release();
});
return await function().ConfigureAwait(false); return await function().ConfigureAwait(false);
} finally { } finally {
// We release open connections semaphore only once we're indeed done sending a particular request
limiters.OpenConnectionsSemaphore.Release(); limiters.OpenConnectionsSemaphore.Release();
} }
} }