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

Allow CrossProcessFileBasedSemaphore to sleep asynchronously

Browse Source
This commit is contained in:
JustArchi
2020-05-21 23:08:02 +02:00
parent 0f1b3f05f9
commit a47b85ff85
1 changed files with 26 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
ArchiSteamFarm/Helpers/CrossProcessFileBasedSemaphore.cs
View File

@@ -71,22 +71,22 @@ namespace ArchiSteamFarm.Helpers {
bool success = false;
try {
lock (LocalSemaphore) {
if (FileLock != null) {
throw new ArgumentNullException(nameof(FileLock));
}
while (true) {
try {
lock (LocalSemaphore) {
if (FileLock != null) {
throw new ArgumentNullException(nameof(FileLock));
}
while (true) {
EnsureFileExists();
EnsureFileExists();
try {
FileLock = new FileStream(FilePath, FileMode.OpenOrCreate, FileAccess.Read, FileShare.None);
success = true;
return;
} catch (IOException) {
Thread.Sleep(SpinLockDelay);
}
} catch (IOException) {
await Task.Delay(SpinLockDelay).ConfigureAwait(false);
}
}
} finally {
@@ -116,28 +116,34 @@ namespace ArchiSteamFarm.Helpers {
return false;
}
lock (LocalSemaphore) {
if (FileLock != null) {
throw new ArgumentNullException(nameof(FileLock));
}
try {
while (true) {
EnsureFileExists();
try {
FileLock = new FileStream(FilePath, FileMode.OpenOrCreate, FileAccess.Read, FileShare.None);
success = true;
lock (LocalSemaphore) {
if (FileLock != null) {
throw new ArgumentNullException(nameof(FileLock));
}
return true;
EnsureFileExists();
FileLock = new FileStream(FilePath, FileMode.OpenOrCreate, FileAccess.Read, FileShare.None);
success = true;
return true;
}
} catch (IOException) {
if (millisecondsTimeout <= SpinLockDelay) {
return false;
}
Thread.Sleep(SpinLockDelay);
await Task.Delay(SpinLockDelay).ConfigureAwait(false);
millisecondsTimeout -= SpinLockDelay;
}
}
} finally {
if (!success) {
LocalSemaphore.Release();
}
}
} finally {
if (!success) {