Mirrors/ArchiSteamFarm
2
0
Fork 0
mirror of https://github.com/JustArchiNET/ArchiSteamFarm synced 2024-11-10 07:04:27 +00:00
Code Issues Projects Releases Packages Wiki Activity

Misc

Browse source
This commit is contained in:
JustArchi 2016-11-20 00:03:27 +01:00
parent 47b4912a9b
commit 1a49c80bc4
1 changed files with 13 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
ArchiSteamFarm/Trading.cs
View file

@ -62,7 +62,7 @@ namespace ArchiSteamFarm {
private readonly ConcurrentHashSet<ulong> IgnoredTrades = new ConcurrentHashSet<ulong>();
private readonly SemaphoreSlim TradesSemaphore = new SemaphoreSlim(1);
private byte ParsingTasks;
private bool ParsingScheduled;
internal static async Task LimitInventoryRequestsAsync() {
await InventorySemaphore.WaitAsync().ConfigureAwait(false);
@ -88,22 +88,27 @@ namespace ArchiSteamFarm {
internal void OnDisconnected() => IgnoredTrades.ClearAndTrim();
internal async Task CheckTrades() {
// We aim to have a maximum of 2 tasks, one already parsing, and one waiting in the queue
// This way we can call this function as many times as needed e.g. because of Steam events
lock (TradesSemaphore) {
if (ParsingTasks >= 2) {
if (ParsingScheduled) {
return;
}
ParsingTasks++;
ParsingScheduled = true;
}
await TradesSemaphore.WaitAsync().ConfigureAwait(false);
await ParseActiveTrades().ConfigureAwait(false);
lock (TradesSemaphore) {
ParsingTasks--;
}
try {
lock (TradesSemaphore) {
ParsingScheduled = false;
}
TradesSemaphore.Release();
await ParseActiveTrades().ConfigureAwait(false);
} finally {
TradesSemaphore.Release();
}
}
private async Task ParseActiveTrades() {