Filamentstr/05_wickler
Archived
1
0
Fork 0
Code Issues 3 Pull Requests Releases Wiki Activity

reenable error counter and indentation

Browse Source
This commit is contained in:
Eggert Jung
2022-04-06 00:03:48 +02:00
parent 76f3fd1d5a
commit b2721c0123
1 changed files with 27 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
mqtt.c
View File

@@ -35,32 +35,32 @@ void messageArrived(MessageData* md)
void mqtt_pub(Client* mqtt_client, char * mqtt_topic, char * mqtt_msg, int mqtt_msg_len)
{
//static uint32_t mqtt_pub_count = 0;
//static uint8_t mqtt_err_cnt = 0;
int32_t mqtt_rc;
//static uint32_t mqtt_pub_count = 0;
static uint8_t mqtt_err_cnt = 0;
int32_t mqtt_rc;
//printf(">>MQTT pub msg nr%lu ", ++mqtt_pub_count);
MQTTMessage pubMessage;
pubMessage.qos = QOS0;
pubMessage.id = mes_id++;
pubMessage.payloadlen = (size_t)mqtt_msg_len;
pubMessage.payload = mqtt_msg;
mqtt_rc = MQTTPublish(mqtt_client, mqtt_topic , &pubMessage);
//Analize MQTT publish result (for MQTT failover mode)
if (mqtt_rc == SUCCESSS)
{
//mqtt_err_cnt = 0;
//printf(" - OK\r\n");
}
else
{
printf("mqtt pub - ERROR\r\n");
printf("Connection with MQTT Broker was lost!!\r\nReboot the board..\r\n");
while(1);
//Reboot device after 20 continuous errors (~ 20sec)
//if(mqtt_err_cnt++ > 20)
//{
// while(1);
//}
}
//printf(">>MQTT pub msg nr%lu ", ++mqtt_pub_count);
MQTTMessage pubMessage;
pubMessage.qos = QOS0;
pubMessage.id = mes_id++;
pubMessage.payloadlen = (size_t)mqtt_msg_len;
pubMessage.payload = mqtt_msg;
mqtt_rc = MQTTPublish(mqtt_client, mqtt_topic , &pubMessage);
//Analize MQTT publish result (for MQTT failover mode)
if (mqtt_rc == SUCCESSS)
{
mqtt_err_cnt = 0;
//printf(" - OK\r\n");
}
else
{
//while(1);
//Reboot device after 20 continuous errors (~ 20sec)
if(mqtt_err_cnt++ > 10)
{
printf("mqtt pub - ERROR\r\n");
printf("Connection with MQTT Broker was lost!!\r\nReboot the board..\r\n");
while(1);
}
}
}