Приём данных через UDP полностью работает

KruFFT · KruFFT · Aug 18, 2022 · Jun 24, 2022 · Jun 24, 2022 · Jun 24, 2022
commit 5ec6e1b5dac74f2840650703d5d2bd7ad9e8bd56
diff --git a/.gitignore b/.gitignore
@@ -337,4 +337,5 @@ ASALocalRun/
 .localhistory/
 
 # BeatPulse healthcheck temp database
-healthchecksdb
+healthchecksdb
+/wxCAN Sniffer/CAN.csv
diff --git a/wxCAN Sniffer/FormMain.cpp b/wxCAN Sniffer/FormMain.cpp
@@ -411,17 +411,16 @@ FormMain::FormMain() : wxFrame(NULL, ID_MAIN_FORM, CAPTION, wxDefaultPosition, w
 	ipAddress.Service(UDP_PORT);
 	udpSocket = new wxDatagramSocket(ipAddress);
 
-	if (!udpSocket->IsOk())
+	if (udpSocket->IsOk())
 	{
-		if (udpSocket->Error())
-		{
-			std::cout << "Error %d at opening datagram socket" << udpSocket->LastError();
-		}
+		udpSocket->SetEventHandler(*this, ID_UDP_SOCKET);
+		udpSocket->SetNotify(wxSOCKET_INPUT_FLAG);
+		udpSocket->Notify(true);
+	}
+	else if (udpSocket->Error())
+	{
+		wxMessageBox(wxT("Ошибка открытия UDP-сокета: " + udpSocket->LastError()));
 	}
-
-	udpSocket->SetEventHandler(*this, ID_UDP_SOCKET);
-	udpSocket->SetNotify(wxSOCKET_INPUT_FLAG);
-	udpSocket->Notify(true);
 }
 
 // Нажатие кнопки закрытия окна
@@ -1180,13 +1179,11 @@ void FormMain::UDPSocket_OnEvent(wxSocketEvent& event)
 		size_t receivedDataLen = udpSocket->RecvFrom(espIpAddress, receivedData, sizeof(receivedData)).LastCount();
 		if (receivedDataLen)
 		{
-			uint32_t prefix = *(uint32_t*)receivedData;
 			// проверка на префикс
+			uint32_t prefix = *(uint32_t*)receivedData;
 			if (prefix == 0x55AA55AA)
 			{
-				//CANFrame frame;
-				//memcpy_s(&frame, 1024, receivedData + 4, receivedDataLen);
-				//ProcessCANFrame(&frame);
+				// обработать полученный пакет пропустив префикс
 				ProcessCANFrame((CANFrame*)&receivedData[4]);
 			}
 		}

diff --git a/wxCAN Sniffer/FormMain.h b/wxCAN Sniffer/FormMain.h
@@ -124,7 +124,7 @@ class FormMain : public wxFrame
 	double mul = 0.125;
 
 	vector<LogFile> logFiles;			// массив log-файлов
-	wxFFile* logFile = NULL;		// единый log-файл
+	wxFFile* logFile = NULL;			// единый log-файл
 
 	wxString decimalSeparator;			// выбранный символ разделитель для данных в log-файле
 

diff --git a/wxCAN Sniffer/ThreadedSerialPort.cpp b/wxCAN Sniffer/ThreadedSerialPort.cpp
@@ -137,122 +137,122 @@ wxThread::ExitCode ThreadedSerialPort::Entry()
 				switch (step)
 				{
 					// искомая сигнатура в буфере 0xAA55AA55 - это начало пакета, байт 0 = 0xAA
-				case 0:
-					if (*bufferHead == SIG_BYTE_0)
-					{
-						step++;
-					}
-					else
-					{
-						step = 0;
-					}
-					bufferHead++;
-					break;
+					case 0:
+						if (*bufferHead == SIG_BYTE_0)
+						{
+							step++;
+						}
+						else
+						{
+							step = 0;
+						}
+						bufferHead++;
+						break;
 
 					// поиск сигнатуры, байт 1 = 0x55
-				case 1:
-					if (*bufferHead == SIG_BYTE_1)
-					{
-						step++;
-						bufferHead++;
-					}
-					else
-					{
-						step = 0;
-					}
-					break;
+					case 1:
+						if (*bufferHead == SIG_BYTE_1)
+						{
+							step++;
+							bufferHead++;
+						}
+						else
+						{
+							step = 0;
+						}
+						break;
 
 					// поиск сигнатуры, байт 2 = 0xAA
-				case 2:
-					if (*bufferHead == SIG_BYTE_2)
-					{
-						step++;
-						bufferHead++;
-					}
-					else
-					{
-						step = 0;
-					}
-					break;
+					case 2:
+						if (*bufferHead == SIG_BYTE_2)
+						{
+							step++;
+							bufferHead++;
+						}
+						else
+						{
+							step = 0;
+						}
+						break;
 
 					// поиск сигнатуры, байт 3 = 0x55
-				case 3:
-					if (*bufferHead == SIG_BYTE_3)
-					{
-						step++;
-						bufferHead++;
-					}
-					else
-					{
-						step = 0;
-					}
-					break;
+					case 3:
+						if (*bufferHead == SIG_BYTE_3)
+						{
+							step++;
+							bufferHead++;
+						}
+						else
+						{
+							step = 0;
+						}
+						break;
 
 					// ID пакета (байт 0)
-				case 4:
-					frame = { 0 };
-					frame.ID = *bufferHead;
-					bufferHead++;
-					step++;
-					break;
+					case 4:
+						frame = { 0 };
+						frame.ID = *bufferHead;
+						bufferHead++;
+						step++;
+						break;
 
 					// ID пакета (байт 1)
-				case 5:
-					frame.ID |= (*bufferHead) << 8;
-					bufferHead++;
-					step++;
-					break;
+					case 5:
+						frame.ID |= (*bufferHead) << 8;
+						bufferHead++;
+						step++;
+						break;
 
 					// ID пакета (байт 2)
-				case 6:
-					frame.ID |= (*bufferHead) << 16;
-					bufferHead++;
-					step++;
-					break;
+					case 6:
+						frame.ID |= (*bufferHead) << 16;
+						bufferHead++;
+						step++;
+						break;
 
 					// ID пакета (байт 3)
-				case 7:
-					frame.ID |= (*bufferHead) << 24;
-					bufferHead++;
-					step++;
-					break;
+					case 7:
+						frame.ID |= (*bufferHead) << 24;
+						bufferHead++;
+						step++;
+						break;
 
 					// длина пакета
-				case 8:
-					frame.Length = *bufferHead;
-					bufferHead++;
-					step++;
-					if (frame.Length > 8)
-					{
-						// данные некорректные - возврат к поиску заголовка
-						step = 0;
-					}
-					break;
-
-					// данные пакета
-				case 9: case 10: case 11: case 12: case 13: case 14: case 15: case 16:
-					if (step - 9 < frame.Length)
-					{
-						frame.Data[step - 9] = *bufferHead;
+					case 8:
+						frame.Length = *bufferHead;
 						bufferHead++;
 						step++;
-					}
-					else
-					{
-						step = 17;
-					}
-					break;
+						if (frame.Length > 8)
+						{
+							// данные некорректные - возврат к поиску заголовка
+							step = 0;
+						}
+						break;
+
+					// данные пакета
+					case 9: case 10: case 11: case 12: case 13: case 14: case 15: case 16:
+						if (step - 9 < frame.Length)
+						{
+							frame.Data[step - 9] = *bufferHead;
+							bufferHead++;
+							step++;
+						}
+						else
+						{
+							step = 17;
+						}
+						break;
 
 					// пакет собран - положить пакет в очередь
-				case 17:
-					syncCANBuffer.Lock();
-					canBuffer.push(frame);
-					syncCANBuffer.Unlock();
-					step = 0;
-
-					// сгенерировать событие
-					wxQueueEvent(handleFrame, new wxThreadEvent(wxEVT_THREAD));
-					break;
+					case 17:
+						syncCANBuffer.Lock();
+						canBuffer.push(frame);
+						syncCANBuffer.Unlock();
+						step = 0;
+
+						// сгенерировать событие
+						wxQueueEvent(handleFrame, new wxThreadEvent(wxEVT_THREAD));
+						break;
 				}
 			}