Adding file watcher instead for infinite loop

Author: sshishov

CSMDevHelper/LogReader.cs

@@ -47,23 +47,32 @@ abstract class LogReader
         protected static string logModelingPattern = @"^=+";
         protected bool m_isModeling;
         protected CSMEvent csmevent;
+        static int readPosition = 0;
 
         protected LogReader(string filename, bool fromBeginning)
         {
-            this.m_fileStream = new FileStream(filename, FileMode.Open, FileAccess.Read, FileShare.ReadWrite|FileShare.Delete|FileShare.Inheritable);
-            this.m_streamReader = new StreamReader(m_fileStream);
-            this.m_isModeling = false;
+            m_fileStream = new FileStream(filename, FileMode.Open, FileAccess.Read, FileShare.ReadWrite| FileShare.Delete);
+            m_streamReader = new StreamReader(m_fileStream);
+            m_isModeling = false;
             if (fromBeginning)
             {
-                this.m_fileStream.Seek(0, SeekOrigin.Begin);
+                //this.m_fileStream.Seek(0, SeekOrigin.Begin);
+                m_streamReader.BaseStream.Seek(0, SeekOrigin.Begin);
             }
             else
             {
-                this.m_fileStream.Seek(0, SeekOrigin.End);
+                //this.m_fileStream.Seek(0, SeekOrigin.End);
+                m_streamReader.BaseStream.Seek(0, SeekOrigin.End);
             }
         }
 
-        ~LogReader() { }
+        public void Close()
+        {
+            m_streamReader.Close();
+            //m_fileStream.Close();
+        }
+
+        ~LogReader() {}
 
 
         public virtual LogResult Process()

CSMDevHelper/frmCSMDH.cs

@@ -8,6 +8,7 @@
 using System.Windows.Forms;
 using System.Threading;
 using System.Reflection;
+using System.IO;
 
 namespace CSMDevHelper
 {
@@ -32,6 +33,8 @@ public partial class frmCSMDH : Form
         private EventWaitHandle waitHandle;
         private ThreadState threadState;
         private FormState formState;
+        private LogReader m_logReader;
+        private FileSystemWatcher m_watcher;
 
         public frmCSMDH()
         {
@@ -80,7 +83,6 @@ public frmCSMDH()
         private void btnLogStart_Click(object sender, EventArgs e)
         {
             this.threadState = ThreadState.RUN;
-            LogReader logReader;
             listNode.Clear();
             listFilterNode.Clear();
             tbEvent.Clear();
@@ -103,20 +105,27 @@ private void btnLogStart_Click(object sender, EventArgs e)
             btnLogStop.Enabled = true;
             btnLogPause.Enabled = true;
 
+            m_watcher = new FileSystemWatcher();
+            m_watcher.Path = Path.GetDirectoryName(log_filename);
+            m_watcher.Filter = Path.GetFileName(log_filename);
+            m_watcher.NotifyFilter = NotifyFilters.LastWrite;
+            m_watcher.Changed += new FileSystemEventHandler(watcher_OnChanged);
+            m_watcher.EnableRaisingEvents = true;
+
             try
             {
                 if ((rbtnAuto.Checked &&
                     registryHandler.DriverVersion == enumDriverVersion.CP5000) ||
                     rbtnCP.Checked)
                 {
-                    logReader = new LogCPReader(log_filename, !chkTailing.Checked);
+                    m_logReader = new LogCPReader(log_filename, !chkTailing.Checked);
                 }
                 else if ((rbtnAuto.Checked &&
                     (registryHandler.DriverVersion == enumDriverVersion.MCD4x ||
                     registryHandler.DriverVersion == enumDriverVersion.MCD5x)) ||
                     rbtnMCD.Checked)
                 {
-                    logReader = new LogMCDReader(log_filename, !chkTailing.Checked);
+                    m_logReader = new LogMCDReader(log_filename, !chkTailing.Checked);
                 }
                 else
                 {
@@ -137,11 +146,16 @@ private void btnLogStart_Click(object sender, EventArgs e)
             logThread.Name = "LogReaderThread";
             logThread.Priority = ThreadPriority.Lowest;
             logThread.IsBackground = true;
-            logThread.Start(logReader);
+            logThread.Start(m_logReader);
             while (!logThread.IsAlive);
             blockControls(sender, e);
         }
 
+        private void watcher_OnChanged(object sender, FileSystemEventArgs e)
+        {
+            Console.WriteLine("The file {0} has been changed, changed", e.Name);
+        }
+
         private void btnLogStop_Click(object sender, EventArgs e)
         {
             this.threadState = ThreadState.STOP;
@@ -153,6 +167,10 @@ private void btnLogStop_Click(object sender, EventArgs e)
             btnLogPause.Enabled = false;
             btnLogPause.Text = "Pause";
             unblockControls(sender, e);
+            if (m_logReader != null)
+            {
+                m_logReader.Close();
+            }
         }
 
         private void btnLogPause_Click(object sender, EventArgs e)
@@ -633,7 +651,7 @@ private void openLogFile(object sender, EventArgs e)
             if (dialog.ShowDialog() == DialogResult.OK)
             {
                 log_filename = dialog.FileName;
-                if (log_filename.Equals(default_log_filename,StringComparison.CurrentCultureIgnoreCase))
+                if (log_filename.Equals(default_log_filename, StringComparison.CurrentCultureIgnoreCase))
                 {
                     rbtnAuto.Visible = true;
                     rbtnMCD.Visible = false;