1 Commits

Author SHA1 Message Date
Eric Fontana
90991a44d6 Removed some cleanup 2015-04-29 10:48:36 -04:00
2 changed files with 28 additions and 37 deletions

View File

@@ -30,18 +30,10 @@ namespace TimberWinR.Inputs
private static LogsFileDatabase instance;
private bool ExistingFile(string logName)
{
lock (_locker)
{
return ExistingFileTest(logName);
}
}
//
// Lookup the database entry for this log file, returns null if there isnt one.
//
private LogsFileDatabaseEntry FindFile(string logName)
private LogsFileDatabaseEntry FindFileWithLock(string logName)
{
lock (_locker)
{
@@ -69,7 +61,7 @@ namespace TimberWinR.Inputs
}
}
private LogsFileDatabaseEntry AddFileEntry(string logName)
private LogsFileDatabaseEntry AddFileEntryWithLock(string logName)
{
var de = new LogsFileDatabaseEntry();
lock (_locker)
@@ -92,9 +84,9 @@ namespace TimberWinR.Inputs
public static LogsFileDatabaseEntry LookupLogFile(string logName)
{
LogsFileDatabaseEntry dbe = Instance.FindFile(logName);
LogsFileDatabaseEntry dbe = Instance.FindFileWithLock(logName);
if (dbe == null)
dbe = Instance.AddFileEntry(logName);
dbe = Instance.AddFileEntryWithLock(logName);
FileInfo fi = new FileInfo(logName);
@@ -112,13 +104,13 @@ namespace TimberWinR.Inputs
}
// Find all the non-existent entries and remove them.
private void PruneFiles()
private void PruneFilesWithLock()
{
lock (_locker)
{
foreach(var entry in Entries.ToList())
foreach (var entry in Entries.ToList())
{
FileInfo fi = new FileInfo(entry.FileName);
var fi = new FileInfo(entry.FileName);
if (!fi.Exists)
Entries.Remove(entry);
}
@@ -130,7 +122,7 @@ namespace TimberWinR.Inputs
{
dbe.ProcessedFile = processedFile;
dbe.LogFileExists = File.Exists(dbe.FileName);
Instance.UpdateEntry(dbe, lastOffset);
Instance.UpdateEntryWithLock(dbe, lastOffset);
}
public static void Roll(LogsFileDatabaseEntry dbe)
@@ -138,11 +130,11 @@ namespace TimberWinR.Inputs
dbe.ProcessedFile = false;
dbe.LastPosition = 0;
dbe.Previous = "";
Instance.UpdateEntry(dbe, 0);
Instance.UpdateEntryWithLock(dbe, 0);
dbe.NewFile = true;
}
private void UpdateEntry(LogsFileDatabaseEntry dbe, long lastOffset)
private void UpdateEntryWithLock(LogsFileDatabaseEntry dbe, long lastOffset)
{
lock (_locker)
{
@@ -175,7 +167,7 @@ namespace TimberWinR.Inputs
if (instance.Entries == null)
instance.Entries = new List<LogsFileDatabaseEntry>();
instance.PruneFiles();
instance.PruneFilesWithLock();
}
}
return instance;
@@ -195,18 +187,17 @@ namespace TimberWinR.Inputs
}
catch (Exception ex)
{
LogManager.GetCurrentClassLogger()
.Error("Error reading database '{0}': {1}", DatabaseFileName, ex.ToString());
LogManager.GetCurrentClassLogger().Error("Error reading database '{0}': {1}", DatabaseFileName, ex.ToString());
try
{
if (File.Exists(DatabaseFileName))
File.Delete(DatabaseFileName);
LogManager.GetCurrentClassLogger().Info("Creating New Database '{0}'", DatabaseFileName);
LogManager.GetCurrentClassLogger().Error("Creating New Database '{0}'", DatabaseFileName);
WriteDatabaseLock();
}
catch (Exception ex2)
{
LogManager.GetCurrentClassLogger().Info("Error Creating New Database '{0}': {1}", DatabaseFileName, ex2.ToString());
LogManager.GetCurrentClassLogger().Error("Error Creating New Database '{0}': {1}", DatabaseFileName, ex2.ToString());
}
}
}

View File

@@ -110,7 +110,7 @@ namespace TimberWinR.Inputs
const int bufSize = 16535;
long prevLen = offset;
FileInfo fi = new FileInfo(fileName);
var fi = new FileInfo(fileName);
if (!fi.Exists)
return;
@@ -120,9 +120,9 @@ namespace TimberWinR.Inputs
{
stream.Seek(prevLen, SeekOrigin.Begin);
char[] buffer = new char[bufSize];
StringBuilder current = new StringBuilder();
using (StreamReader sr = new StreamReader(stream))
var buffer = new char[bufSize];
var current = new StringBuilder();
using (var sr = new StreamReader(stream))
{
int nRead;
do