485 통신 오류 검출 루틴

- 10초 동안 UDP를 받지 못하면 통신 오류 시그널 출력 - 통신 오류 시그널 출력 후 UDP를 받으면 통신 복구 시그널 출력

485 통신 오류 검출 루틴
- 10초 동안 UDP를 받지 못하면 통신 오류 시그널 출력 - 통신 오류 시그널 출력 후 UDP를 받으면 통신 복구 시그널 출력
김태훈
1 parent 81b55e0463
Showing 2 changed files with 27 additions and 0 deletions Show diff stats
app/gui/oven_control/udphandler.cpp
app/gui/oven_control/udphandler.h
@@ -17,6 +17,13 @@ UdpHandler::UdpHandler(QObject *parent) : QObject(parent)
 {
     bzero(&control, sizeof(control));
     bzero(&state, sizeof(state));
+
+    emitted = false;
+    emitTimeoutTimer.setSingleShot(true);
+    emitTimeoutTimer.setInterval(10 * 1000);
+    connect(&emitTimeoutTimer, SIGNAL(timeout()), SLOT(emitTimeout()));
+
+    emitTimeoutTimer.start();
 }
 bool UdpHandler::init()
@@ -48,6 +55,12 @@ void UdpHandler::processDatagram(QByteArray &amp;datagram)
 {
     sock->writeDatagram(datagram, QHostAddress("localhost"), 40001);
+    if (emitted)
+    {
+        emitted = false;
+        emit recovered();
+    }
+
     packet_t *packet = (packet_t *) datagram.data();
     switch (packet->header)
     {
@@ -63,6 +76,8 @@ void UdpHandler::processDatagram(QByteArray &amp;datagram)
         qDebug() << "Received Error";
         break;
     }
+
+    emitTimeoutTimer.start();
 }
 void UdpHandler::processControl(oven_control_t *control)
@@ -105,6 +120,12 @@ void UdpHandler::sendCommand(int cmd, int target, int value)
     sock->writeDatagram((const char *) &command, sizeof(command), QHostAddress(IPC_UDP_SYS_HOST), IPC_UDP_SYS_PORT);
 }
+void UdpHandler::emitTimeout()
+{
+    emitted = true;
+    emit timeout();
+}
+
 void UdpHandler::fillControl(oven_control_t &container)
 {
     memcpy(&container, &control, sizeof(control));
@@ -4,6 +4,7 @@
 #include <QObject>
 #include <QUdpSocket>
 #include <QByteArray>
+#include <QTimer>
 #include "../../app-prime-modbus/include/all_share.h"
@@ -55,6 +56,8 @@ public:
 signals:
     void changed();
+    void timeout();
+    void recovered();
 public slots:
     void turnOn(int target);
@@ -71,11 +74,14 @@ private:
     void processState(oven_state_t *state);
     QUdpSocket *sock;
+    QTimer emitTimeoutTimer;
+    bool emitted;
 private slots:
     void readPendingDatagrams();
     void sendCommand(int cmd, int target, int value);
+    void emitTimeout();
 };
 #endif // UDPHANDLER_H
	@@ -17,6 +17,13 @@ UdpHandler::UdpHandler(QObject *parent) : QObject(parent)		@@ -17,6 +17,13 @@ UdpHandler::UdpHandler(QObject *parent) : QObject(parent)
17	{	17	{
18	bzero(&control, sizeof(control));	18	bzero(&control, sizeof(control));
19	bzero(&state, sizeof(state));	19	bzero(&state, sizeof(state));
		20	+
		21	+ emitted = false;
		22	+ emitTimeoutTimer.setSingleShot(true);
		23	+ emitTimeoutTimer.setInterval(10 * 1000);
		24	+ connect(&emitTimeoutTimer, SIGNAL(timeout()), SLOT(emitTimeout()));
		25	+
		26	+ emitTimeoutTimer.start();
20	}	27	}
21		28
22	bool UdpHandler::init()	29	bool UdpHandler::init()
	@@ -48,6 +55,12 @@ void UdpHandler::processDatagram(QByteArray &datagram)		@@ -48,6 +55,12 @@ void UdpHandler::processDatagram(QByteArray &datagram)
48	{	55	{
49	sock->writeDatagram(datagram, QHostAddress("localhost"), 40001);	56	sock->writeDatagram(datagram, QHostAddress("localhost"), 40001);
50		57
		58	+ if (emitted)
		59	+ {
		60	+ emitted = false;
		61	+ emit recovered();
		62	+ }
		63	+
51	packet_t packet = (packet_t ) datagram.data();	64	packet_t packet = (packet_t ) datagram.data();
52	switch (packet->header)	65	switch (packet->header)
53	{	66	{
	@@ -63,6 +76,8 @@ void UdpHandler::processDatagram(QByteArray &datagram)		@@ -63,6 +76,8 @@ void UdpHandler::processDatagram(QByteArray &datagram)
63	qDebug() << "Received Error";	76	qDebug() << "Received Error";
64	break;	77	break;
65	}	78	}
		79	+
		80	+ emitTimeoutTimer.start();
66	}	81	}
67		82
68	void UdpHandler::processControl(oven_control_t *control)	83	void UdpHandler::processControl(oven_control_t *control)
	@@ -105,6 +120,12 @@ void UdpHandler::sendCommand(int cmd, int target, int value)		@@ -105,6 +120,12 @@ void UdpHandler::sendCommand(int cmd, int target, int value)
105	sock->writeDatagram((const char *) &command, sizeof(command), QHostAddress(IPC_UDP_SYS_HOST), IPC_UDP_SYS_PORT);	120	sock->writeDatagram((const char *) &command, sizeof(command), QHostAddress(IPC_UDP_SYS_HOST), IPC_UDP_SYS_PORT);
106	}	121	}
107		122
		123	+void UdpHandler::emitTimeout()
		124	+{
		125	+ emitted = true;
		126	+ emit timeout();
		127	+}
		128	+
108	void UdpHandler::fillControl(oven_control_t &container)	129	void UdpHandler::fillControl(oven_control_t &container)
109	{	130	{
110	memcpy(&container, &control, sizeof(control));	131	memcpy(&container, &control, sizeof(control));