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

remove warnings

Browse Source
master
Eggert Jung 4 years ago
parent b842604f98
commit 56ff8260a1
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File

10
mqtt.c
Unescape Escape View File

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