Данные UDP обрабатываются пакетно

KruFFT · KruFFT · Aug 18, 2022 · Jun 24, 2022 · Jun 24, 2022 · Jun 24, 2022
commit c55429cb15e381c8ba3b1f26a2f96f429c81f227
diff --git a/wxCAN Sniffer/CircularFrameBuffer.cpp b/wxCAN Sniffer/CircularFrameBuffer.cpp
@@ -9,6 +9,7 @@ CircularFrameBuffer::CircularFrameBuffer(size_t windowSize)
 	frameSize = windowSize;
 	frameBegin = 0;
 	frameEnd = frameSize;
+	frameSizeBytesCount = bufferSize * sizeof(uint32_t);
 }
 
 // Деструктор
@@ -24,8 +25,7 @@ CircularFrameBuffer::~CircularFrameBuffer()
 // Очистить буфер
 void CircularFrameBuffer::Clear()
 {
-	size_t count = bufferSize * sizeof(uint32_t);
-	memset(buffer, 0, count);
+	memset(buffer, 0, frameSizeBytesCount);
 	frameBegin = 0;
 	frameEnd = frameSize;
 }
@@ -36,8 +36,7 @@ void CircularFrameBuffer::Add(uint32_t value)
 	// если достигнут предел массива - надо сдвинуть данные
 	if (frameEnd >= bufferSize)
 	{
-		size_t count = frameSize * sizeof(uint32_t);
-		memcpy_s(buffer, count, &buffer[frameBegin], count);
+		memcpy_s(buffer, frameSizeBytesCount, &buffer[frameBegin], frameSizeBytesCount);
 		frameBegin = 0;
 		frameEnd = frameSize;
 	}

diff --git a/wxCAN Sniffer/CircularFrameBuffer.h b/wxCAN Sniffer/CircularFrameBuffer.h
@@ -19,4 +19,5 @@ class CircularFrameBuffer
 	size_t frameSize;				// размер окна данных
 	size_t frameBegin;				// начало окна данных
 	size_t frameEnd;				// конец окна данных
+	size_t frameSizeBytesCount;		// количество байтов в кадре
 };
diff --git a/wxCAN Sniffer/FormMain.cpp b/wxCAN Sniffer/FormMain.cpp
@@ -458,6 +458,10 @@ void FormMain::OnClose(wxCloseEvent& event)
 // Обработчик кнопки Подключить/отключить
 void FormMain::ButtonConDiscon_OnClick(wxCommandEvent& event)
 {
+	rowToView = -1;
+	colToView = -1;
+	drawData->Clear();
+
 	try
 	{
 		// если порт не открыт - открыть, иначе - закрыть
@@ -468,7 +472,6 @@ void FormMain::ButtonConDiscon_OnClick(wxCommandEvent& event)
 			{
 				frames.reserve(FRAMES_DATA_RESERV);
 				frames.clear();
-				drawData->Clear();
 
 				// удалить все строки таблицы
 				if (gridCANView->GetNumberRows() > 0)
@@ -478,8 +481,6 @@ void FormMain::ButtonConDiscon_OnClick(wxCommandEvent& event)
 
 				COM = new ThreadedSerialPort(textCOM->GetValue(), comSpeed, (wxFrame*)this);
 				buttonConnectDisconnect->SetLabelText(wxT("Отключить"));
-				rowToView = -1;
-				colToView = -1;
 			}
 		}
 		else
@@ -490,7 +491,6 @@ void FormMain::ButtonConDiscon_OnClick(wxCommandEvent& event)
 			}
 			delete COM;
 			COM = nullptr;
-			drawData->Clear();
 
 			buttonConnectDisconnect->SetLabelText(wxT("Подключить"));
 
@@ -1177,19 +1177,25 @@ void FormMain::TextCANAnswerID_OnEnter(wxCommandEvent& event)
 // событие UDP-сокета
 void FormMain::UDPSocket_OnEvent(wxSocketEvent& event)
 {
-	uint8_t receivedData[100];
+	uint8_t  receivedData[UDP_BUFFER_SIZE];
+	uint8_t* receivedDataPointer = receivedData;
 
 	if (event.GetSocketEvent() == wxSOCKET_INPUT)
 	{
-		size_t receivedDataLen = udpSocket->RecvFrom(espIpAddress, receivedData, sizeof(receivedData)).LastCount();
+		size_t receivedDataLen = udpSocket->RecvFrom(espIpAddress, receivedData, UDP_BUFFER_SIZE).LastCount();
 		if (receivedDataLen)
 		{
-			// проверка на префикс
-			uint32_t prefix = *(uint32_t*)receivedData;
-			if (prefix == 0x55AA55AA)
+			uint8_t* receivedDataTail = receivedDataPointer + receivedDataLen;
+			// поиск CAN-пакета и формирование данных
+			while (receivedDataPointer < receivedDataTail)
 			{
-				// обработать полученный пакет пропустив префикс
-				ProcessCANFrame((CANFrame&)receivedData[4]);
+				CANFrame frame;
+
+				// пакет собран - обработать пакет
+				if (CANParser::Parse(&receivedDataPointer, frame))
+				{
+					ProcessCANFrame(frame);
+				}
 			}
 		}
 	}

diff --git a/wxCAN Sniffer/FormMain.h b/wxCAN Sniffer/FormMain.h
@@ -4,17 +4,18 @@
 #include "ThreadedSerialPort.h"
 #include "CircularFrameBuffer.h"
 
-#define FRAMES_DATA_RESERV	100			// колчиество элементов для резерв в векторах
+#define FRAMES_DATA_RESERV	100			// количество элементов для резерва в векторе
 
 #define NEW_COLOR			0x00FF00	// green (BGR)
 #define MARKED_COLOR		0x0000FF	// red (BGR)
 #define DEFAULT_COLOR		0xFFFFFF	// white (BGR)
 #define DRAW_COLOR			0x0000FF	// red (BGR)
 
-#define TIMER_INTERVAL		10			// интервал срабатывания таймера (около 50 кадров/с)
+#define TIMER_INTERVAL		20			// интервал срабатывания таймера (около 50 кадров/с)
 
 #define COM_NAME			wxT("COM3")	// последовательный порт по умолчанию
 #define UDP_PORT			0xAA55		// UDP порт
+#define UDP_BUFFER_SIZE		1000		// размер буфера приёма пакетов
 
 // Идентификаторы необходимых объектов
 enum IDs
@@ -116,7 +117,7 @@ class FormMain : public wxFrame
 	vector<CANFrame> frames;			// список отображаемых на экране пакетов
 
 	vector<int32_t> logFilterIDs;		// список ID для записи в log-файл
-	size_t rowToLog = -1;				// выбранная в таблице строка для добавления в фильтр log-файла
+	int32_t rowToLog = -1;				// выбранная в таблице строка для добавления в фильтр log-файла
 	wxString logExt;					// расширение log-файла
 	wxString logSeparator;				// разделитель значений в log-файле
 	bool logDecimal = false;			// переключатель режима записи чисел в log-файле: десятичный или шестнадцатиричный