fixed and optimized port data processing
This commit is contained in:
51
Modbus.cs
51
Modbus.cs
@@ -276,41 +276,38 @@ namespace Gidrolock_Modbus_Scanner
|
|||||||
static int count = 0;
|
static int count = 0;
|
||||||
static void PortDataReceived(object sender, EventArgs e)
|
static void PortDataReceived(object sender, EventArgs e)
|
||||||
{
|
{
|
||||||
|
//reset values on every event call;
|
||||||
|
buffer = new byte[255];
|
||||||
|
offset = 0;
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
stopwatch.Restart();
|
//reset values on every event call;
|
||||||
while (stopwatch.ElapsedMilliseconds < 20)
|
buffer = new byte[255];
|
||||||
{
|
|
||||||
if (port.BytesToRead > 0)
|
|
||||||
{
|
|
||||||
stopwatch.Restart();
|
|
||||||
count = port.BytesToRead;
|
|
||||||
port.Read(buffer, offset, port.BytesToRead);
|
|
||||||
offset += count;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// assume that the message ended
|
|
||||||
offset = 0;
|
offset = 0;
|
||||||
List <byte> message = new List <byte>();
|
try
|
||||||
int endOfMessage = buffer.Length - 1;
|
|
||||||
for (int i = buffer.Length-1; i >= 0; i--)
|
|
||||||
{
|
{
|
||||||
if (buffer[i] != 0x00)
|
stopwatch.Restart();
|
||||||
|
while (stopwatch.ElapsedMilliseconds < 20)
|
||||||
{
|
{
|
||||||
endOfMessage = i;
|
if (port.BytesToRead > 0)
|
||||||
break;
|
{
|
||||||
|
stopwatch.Restart();
|
||||||
|
count = port.BytesToRead;
|
||||||
|
port.Read(buffer, offset, port.BytesToRead);
|
||||||
|
offset += count;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
// assume that the message ended
|
||||||
for (int i = 0; i < endOfMessage + 1; i++)
|
|
||||||
{
|
|
||||||
message.Add(buffer[i]);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (message.Count == 0)
|
List<byte> message = new List<byte>();
|
||||||
return;
|
for (int i = 0; i < offset; i++)
|
||||||
|
{
|
||||||
|
message.Add(buffer[i]);
|
||||||
|
}
|
||||||
|
if (message.Count == 0)
|
||||||
|
return;
|
||||||
|
|
||||||
Console.WriteLine("Incoming message: " + ByteArrayToString(message.ToArray(), false));
|
Console.WriteLine("Incoming message: " + ByteArrayToString(message.ToArray(), false));
|
||||||
/*
|
/*
|
||||||
if (!CheckResponse(message.ToArray()))
|
if (!CheckResponse(message.ToArray()))
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user