quartznet/pulsar
2
0
Fork 0
mirror of https://github.com/9ParsonsB/Pulsar.git synced 2025-04-05 17:39:39 -04:00
Code Actions

LogMonitor fixes

Browse Source
This commit is contained in:
Xjph 2022-03-16 08:55:10 -02:30
parent 7d56a2b91b
commit ffd218a341
1 changed files with 3 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
ObservatoryCore/LogMonitor.cs
View File

@ -126,7 +126,7 @@ namespace Observatory
List<String> lastFileLines = new(); List<String> lastFileLines = new();
string lastLoadGame = String.Empty; string lastLoadGame = String.Empty;
bool sawFSDJump = false; bool sawFSDJump = false;
foreach (var file in files.Skip(Math.Max(files.Length - 2, 0))) foreach (var file in files.Skip(Math.Max(files.Count() - 2, 0)))
{ {
var lines = ReadAllLines(file.FullName); var lines = ReadAllLines(file.FullName);
foreach (var line in lines) foreach (var line in lines)
@ -191,7 +191,6 @@ namespace Observatory
private Dictionary<string, Type> journalTypes; private Dictionary<string, Type> journalTypes;
private Dictionary<string, int> currentLine; private Dictionary<string, int> currentLine;
private LogMonitorState currentState = LogMonitorState.Idle; // Change via #SetLogMonitorState private LogMonitorState currentState = LogMonitorState.Idle; // Change via #SetLogMonitorState
private bool monitoring = false;
private bool firstStartMonitor = true; private bool firstStartMonitor = true;
#endregion #endregion
@ -422,19 +421,9 @@ namespace Observatory
await System.Threading.Tasks.Task.Run(() => await System.Threading.Tasks.Task.Run(() =>
{ {
while (monitoring) while (IsMonitoring())
{ {
FileInfo fileToPoke = null; FileInfo fileToPoke = GetJournalFilesOrdered(journalFolder).Last();
// TODO: If we now have reliable file ordering guarantees, do we need this loop? Could we
// just poke file in the last slot of the array returned by GetJournalFilesOrdered?
foreach (var file in GetJournalFilesOrdered(journalFolder))
{
if (fileToPoke == null || string.Compare(file.Name, fileToPoke.Name) > 0)
{
fileToPoke = file;
}
}
using FileStream stream = fileToPoke.Open(FileMode.Open, FileAccess.Read, FileShare.ReadWrite); using FileStream stream = fileToPoke.Open(FileMode.Open, FileAccess.Read, FileShare.ReadWrite);
stream.Close(); stream.Close();