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

Add semaphore to active matching

Browse Source 
Very unlikely to be hit, but still
This commit is contained in:
JustArchi
2018-11-29 21:05:40 +01:00
parent 00f1ddfae3
commit ff2c0b3b79
1 changed files with 25 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
ArchiSteamFarm/Statistics.cs
View File

@@ -47,6 +47,7 @@ namespace ArchiSteamFarm {
};
private readonly Bot Bot;
private readonly SemaphoreSlim MatchActivelySemaphore = new SemaphoreSlim(1, 1);
private readonly Timer MatchActivelyTimer;
private readonly SemaphoreSlim RequestsSemaphore = new SemaphoreSlim(1, 1);
@@ -68,6 +69,7 @@ namespace ArchiSteamFarm {
}
public void Dispose() {
MatchActivelySemaphore.Dispose();
MatchActivelyTimer.Dispose();
RequestsSemaphore.Dispose();
}
@@ -206,23 +208,32 @@ namespace ArchiSteamFarm {
private async Task MatchActively() {
// TODO: This function has a lot of debug leftovers for logic testing, once that period is over, get rid of them
bool match = true;
Bot.ArchiLogger.LogGenericDebug("Matching started!");
for (byte i = 0; (i < MaxMatchingRounds) && match; i++) {
if (i > 0) {
// After each round we wait at least 5 minutes for all bots to react
Bot.ArchiLogger.LogGenericDebug("Cooldown...");
await Task.Delay(5 * 60 * 1000).ConfigureAwait(false);
}
Bot.ArchiLogger.LogGenericDebug("Now matching, round #" + i);
match = await MatchActivelyRound().ConfigureAwait(false);
Bot.ArchiLogger.LogGenericDebug("Matching ended, round #" + i);
if (!await MatchActivelySemaphore.WaitAsync(0).ConfigureAwait(false)) {
return;
}
Bot.ArchiLogger.LogGenericDebug("Matching finished!");
try {
bool match = true;
Bot.ArchiLogger.LogGenericDebug("Matching started!");
for (byte i = 0; (i < MaxMatchingRounds) && match; i++) {
if (i > 0) {
// After each round we wait at least 5 minutes for all bots to react
Bot.ArchiLogger.LogGenericDebug("Cooldown...");
await Task.Delay(5 * 60 * 1000).ConfigureAwait(false);
}
Bot.ArchiLogger.LogGenericDebug("Now matching, round #" + i);
match = await MatchActivelyRound().ConfigureAwait(false);
Bot.ArchiLogger.LogGenericDebug("Matching ended, round #" + i);
}
Bot.ArchiLogger.LogGenericDebug("Matching finished!");
} finally {
MatchActivelySemaphore.Release();
}
}
private async Task<bool> MatchActivelyRound() {