Отказался от очередей, переписал парсе CAN-пакетов

KruFFT · KruFFT · Aug 18, 2022 · Jun 24, 2022 · Jun 24, 2022 · Jun 24, 2022
commit ccfb80890b919ba507f7583249fd608ee19cdacf
diff --git a/wxCAN Sniffer/CANParser.cpp b/wxCAN Sniffer/CANParser.cpp
@@ -1,61 +1,31 @@
 #include "CANParser.h"
 
-// Деструктор очищает очередь
-CANParser::~CANParser()
+// Собрать CAN-пакет из входящего потока байтов (контроль границ вне этого кода, должно быть не менее 17 байт данных)
+CANFrame CANParser::Parse(uint8_t** bufferHead, bool* ok)
 {
-	wxMutexLocker lock(syncCanQueue);
-	while (!frames.empty())
-	{
-		frames.pop();
-	}
-}
-
-void CANParser::ParseAll(FIFOBuffer& buffer)
-{
-    bool ok;
-    CANFrame frame;
+    CANFrame frame = { 0 };
+    *ok = false;
 
-	while (buffer.Count() > 17)
-	{
-        if (buffer.Next(ok) == SIG_BYTE_0 &&
-            buffer.Next(ok) == SIG_BYTE_1 &&
-            buffer.Next(ok) == SIG_BYTE_2 &&
-            buffer.Next(ok) == SIG_BYTE_3)
+    // ниже "магия" указателей на указатели :)
+    // поиск сигнатуры в потоке байтов
+    if (*(uint32_t*)*bufferHead == SIG_DWORD)
+    {
+        *bufferHead += 4;
+        // сборка пакета
+        frame.ID = *(uint32_t*)*bufferHead;
+        *bufferHead += 4;
+        frame.Length = *(*bufferHead)++;
+        if (frame.Length <= 8)
         {
-            // сборка ID пакета
-            uint8_t id0 = buffer.Next(ok);
-            uint8_t id1 = buffer.Next(ok);
-            uint8_t id2 = buffer.Next(ok);
-            uint8_t id3 = buffer.Next(ok);
-            frame.ID = id3 << 24 | id2 << 16 | id1 << 8 | id0;
-            frame.Length = buffer.Next(ok);
-            if (frame.Length <= 8)
-            {
-                for (size_t iData = 0; iData < frame.Length; iData++)
-                    frame.Data[iData] = buffer.Next(ok);
+            for (size_t iData = 0; iData < frame.Length; iData++)
+                frame.Data[iData] = *(*bufferHead)++;
 
-                syncCanQueue.Lock();
-                frames.push(frame);
-                syncCanQueue.Unlock();
-            }
+            *ok = true;
         }
-	}
-}
-
-CANFrame CANParser::Next(bool& ok)
-{
-    CANFrame value;
-    syncCanQueue.Lock();
-    if (ok = !frames.empty())
-    {
-        value = frames.front();
-        frames.pop();
     }
     else
     {
-        value.ID = 0;
+        (*bufferHead)++;
     }
-    syncCanQueue.Unlock();
-
-    return value;
-}
+    return frame;
+}
diff --git a/wxCAN Sniffer/CANParser.h b/wxCAN Sniffer/CANParser.h
@@ -1,21 +1,10 @@
 #pragma once
 
 #include "Common.h"
-#include "FIFOBuffer.h"
-#include <queue>
-
-static wxMutex syncCanQueue;
 
 class CANParser
 {
 public:
 	CANParser() = default;
-	~CANParser();
-
-	void ParseAll(FIFOBuffer& buffer);
-	CANFrame Next(bool& ok);
-
-private:
-	std::queue<CANFrame> frames;	// очередь с полученными пакетами
+	static CANFrame Parse(uint8_t** bufferHead, bool* ok);
 };
-
diff --git a/wxCAN Sniffer/Common.h b/wxCAN Sniffer/Common.h
@@ -17,14 +17,12 @@
 using namespace std;
 
 #define CAPTION		wxT("CAN Sniffer 2.0.0")
-#define COM_NAME	wxT("COM3")
 
-#define SIG_BYTE_0 0xAA
-#define SIG_BYTE_1 0x55
-#define SIG_BYTE_2 0xAA
-#define SIG_BYTE_3 0x55
-
-#define UDP_PORT 0xAA55
+#define SIG_DWORD	0x55AA55AA
+#define SIG_BYTE_0	0xAA
+#define SIG_BYTE_1	0x55
+#define SIG_BYTE_2	0xAA
+#define SIG_BYTE_3	0x55
 
 // CAN-пакет данных
 struct CANFrame
@@ -61,3 +59,11 @@ struct LogFile
 	uint32_t ID;		// идентификатор пакета
 	wxFFile* File;		// хэндл ассоциированного файла
 };
+
+// Описание одного байтового буфера
+struct Buffer
+{
+public:
+	uint8_t* Pointer;
+	size_t   Size;
+};
diff --git a/wxCAN Sniffer/FIFOBuffer.cpp b/wxCAN Sniffer/FIFOBuffer.cpp
diff --git a/wxCAN Sniffer/FIFOBuffer.h b/wxCAN Sniffer/FIFOBuffer.h