irext/iris-kit
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

force restart when MQTT could not be connected

Browse Source
This commit is contained in:
strawmanbobi
2025-01-19 20:47:00 +08:00
parent 496869f305
commit 65bd953cff
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
esp8285/src/emq_client.cpp
View File

@@ -75,11 +75,11 @@ int connectToEMQXBroker(PubSubClient &mqtt_client) {
}
if (emqx_client->connected()) {
INFOF("IoT connect done\n");
return 0;
} else {
ERRORF("IoT failed to connect\n");
return -1;
ESP.restart();
}
return 0;
}
void emqxClientKeepAlive(PubSubClient& mqtt_client) {

18
esp8285/src/serials.h
View File

@@ -31,24 +31,24 @@
// generic COM debug
#define DEBUGLN(...) \
{if (LOG_DEBUG) { Serial.printf("DEBUG: "); Serial.println(__VA_ARGS__);}}
{ if (LOG_DEBUG) { Serial.printf("DEBUG: "); Serial.println(__VA_ARGS__); } }
#define DEBUGF(...) \
{if (LOG_DEBUG) { Serial.printf("DEBUG: "); Serial.printf(__VA_ARGS__); Serial.println();}}
{ if (LOG_DEBUG) { Serial.printf("DEBUG: "); Serial.printf(__VA_ARGS__); } }
#define DEBUG(...) \
{if (LOG_DEBUG) { Serial.printf("DEBUG: "); Serial.print(__VA_ARGS__); Serial.println();}}
{ if (LOG_DEBUG) { Serial.printf("DEBUG: "); Serial.print(__VA_ARGS__); } }
#define INFOLN(...) \
{if (LOG_INFO) { Serial.printf("INFO: "); Serial.println(__VA_ARGS__);}}
{ if (LOG_INFO) { Serial.printf("INFO: "); Serial.println(__VA_ARGS__); } }
#define INFOF(...) \
{if (LOG_INFO) { Serial.printf("INFO: "); Serial.printf(__VA_ARGS__); Serial.println();}}
{ if (LOG_INFO) { Serial.printf("INFO: "); Serial.printf(__VA_ARGS__); } }
#define INFO(...) \
{if (LOG_INFO) { Serial.printf("INFO: "); Serial.print(__VA_ARGS__); Serial.println();}}
{ if (LOG_INFO) { Serial.printf("INFO: "); Serial.print(__VA_ARGS__); } }
#define ERRORLN(...) \
{if (LOG_ERROR) { Serial.printf("ERROR: "); Serial.println(__VA_ARGS__);}}
{ if (LOG_ERROR) { Serial.printf("ERROR: "); Serial.println(__VA_ARGS__); } }
#define ERRORF(...) \
{if (LOG_ERROR) { Serial.printf("ERROR: "); Serial.printf(__VA_ARGS__); Serial.println();}}
{ if (LOG_ERROR) { Serial.printf("ERROR: "); Serial.printf(__VA_ARGS__); } }
#define ERROR(...) \
{if (LOG_ERROR) { Serial.printf("ERROR: "); Serial.print(__VA_ARGS__); Serial.println();}}
{ if (LOG_ERROR) { Serial.printf("ERROR: "); Serial.print(__VA_ARGS__); } }
#endif // IRIS_KIT_SERIALS_H