C#

<br />
using ( FileStream fileStream<br />
  = new FileStream(e.FullPath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite ) )<br />
{<br />
  fileStream.Seek(_logFileLastReadPosition, SeekOrigin.Begin);<br />
  TextReader reader = new StreamReader(fileStream);<br />
<br />
  string line;<br />
  while ( (line = reader.ReadLine()) != null )<br />
  {<br />
    PerformOutputAppended(this, new OutputEventArgs(line));<br />
    _logFileLastReadPosition += line.Length;<br />
  }<br />
          <br />
  reader.Close();<br />
  fileStream.Close();<br />
}<br />

private void output(string s) {
	try {
		StreamWriter sw=new StreamWriter(fileSpec, true); // append !
		sw.WriteLine(s);
		sw.Close();
	} catch (Exception exc) {
		timelog(exc.Message);
	}
}

private void input() {
	try {
		StreamReader sr=new StreamReader(fileSpec);
		sr.BaseStream.Position=seek;
		if (delay) Thread.Sleep(1000);	// try to block producer !
		while((string s=sr.ReadLine())!=null) {
			log("line "+line+": "+s); // process the input data
			seek=sr.BaseStream.Position;
		}
		sr.Close();
	} catch (Exception exc) {
		timelog(exc.Message);
	}
}

<br />
using ( FileStream fileStream<br />
  = new FileStream(e.FullPath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite) )  // setting the FileShare to ReadWrite allows the logger to keep on writing to the text file while this reads the current output.<br />
{<br />
  fileStream.Seek(_logFileLastReadPosition, SeekOrigin.Begin);<br />
<br />
  TextReader reader = new StreamReader(fileStream);<br />
<br />
  string line;<br />
  while ( (line = reader.ReadLine()) != null )<br />
  {<br />
    PerformOutputAppended(this, new OutputEventArgs(line));<br />
  }<br />
<br />
  _logFileLastReadPosition = fileStream.Seek(0, SeekOrigin.End);<br />
          <br />
  reader.Close();<br />
  fileStream.Close();<br />
}<br />

wrote:

None