fergalmoran/DnsServer
1
0
Fork 0
mirror of https://github.com/fergalmoran/DnsServer.git synced 2025-12-22 09:29:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improved async handlin when writing to files

Browse Source
This commit is contained in:
Zafer Balkan
2024-10-20 17:57:59 +03:00
parent 54952f1977
commit ebb5908dc4
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
Apps/LogExporterApp/Strategy/FileExportStrategy.cs
View File

@@ -60,22 +60,21 @@ namespace LogExporter.Strategy
{
jsonLogs.AppendLine(log.ToString());
}
Flush(jsonLogs.ToString());
return Task.CompletedTask;
return FlushAsync(jsonLogs.ToString());
}
private void Flush(string jsonLogs)
private async Task FlushAsync(string jsonLogs)
{
// Wait to enter the semaphore
_fileSemaphore.Wait();
await _fileSemaphore.WaitAsync();
try
{
// Use a FileStream with exclusive access
var fileStream = new FileStream(_filePath, FileMode.Append, FileAccess.Write, FileShare.Write);
var writer = new StreamWriter(fileStream);
writer.Write(jsonLogs);
writer.Close();
fileStream.Dispose();
using (var fileStream = new FileStream(_filePath, FileMode.Append, FileAccess.Write, FileShare.None))
using (var writer = new StreamWriter(fileStream))
{
await writer.WriteAsync(jsonLogs);
}
}
catch (Exception ex)
{
@@ -83,8 +82,11 @@ namespace LogExporter.Strategy
}
finally
{
// Release the semaphore
_ = _fileSemaphore.Release();
// Ensure semaphore is released only if it was successfully acquired
if (_fileSemaphore.CurrentCount == 0)
{
_fileSemaphore.Release();
}
}
}