mirror/SimplySerial
1
0
Fork 0
mirror of https://github.com/fasteddy516/SimplySerial.git synced 2024-11-24 10:04:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added timeouts to force-flush the log buffer

Browse Source
This commit is contained in:
Edward Wright 2021-05-10 21:22:02 -04:00
parent 32902034ed
commit 36e4916280
1 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
SimplySerial/SimplySerial.cs
View File

@ -32,6 +32,7 @@ namespace SimplySerial
static string logFile = string.Empty; static string logFile = string.Empty;
static string logData = string.Empty; static string logData = string.Empty;
static int bufferSize = 4096; static int bufferSize = 4096;
static DateTime lastFlush = DateTime.Now;
static void Main(string[] args) static void Main(string[] args)
@ -184,6 +185,12 @@ namespace SimplySerial
(logging == true) ? ($"Logfile : {logFile} (Mode = " + ((logMode == FileMode.Create) ? "OVERWRITE" : "APPEND") + ")\n" ) : "" (logging == true) ? ($"Logfile : {logFile} (Mode = " + ((logMode == FileMode.Create) ? "OVERWRITE" : "APPEND") + ")\n" ) : ""
), flush: true); ), flush: true);
lastFlush = DateTime.Now;
DateTime start = DateTime.Now;
TimeSpan timeSinceRX = new TimeSpan();
TimeSpan timeSinceFlush = new TimeSpan();
// this is the core functionality - loop while the serial port is open // this is the core functionality - loop while the serial port is open
while (serialPort.IsOpen) while (serialPort.IsOpen)
{ {
@ -226,6 +233,22 @@ namespace SimplySerial
// write what was received to console // write what was received to console
Output(received, force: true, newline: false); Output(received, force: true, newline: false);
start = DateTime.Now;
}
else
{
Thread.Sleep(1);
if (logging)
{
timeSinceRX = DateTime.Now - start;
timeSinceFlush = DateTime.Now - lastFlush;
if ((timeSinceRX.TotalSeconds >= 2) || (timeSinceFlush.TotalSeconds >= 10))
{
if (logData.Length > 0)
Output("", force: true, newline: false, flush: true);
start = DateTime.Now;
}
}
} }
} }
catch (Exception e) catch (Exception e)
@ -490,7 +513,8 @@ namespace SimplySerial
if (newline) if (newline)
message += "\n"; message += "\n";
Console.Write(message); if (message.Length > 0)
Console.Write(message);
if (logging) if (logging)
{ {
@ -504,6 +528,7 @@ namespace SimplySerial
{ {
writer.Write(logData); writer.Write(logData);
} }
lastFlush = DateTime.Now;
} }
catch catch
{ {