Mercurial > mbsePi-apps / file comparison
comparison: thermferm/mqtt.c
thermferm/mqtt.c
- changeset 652
- 16d3d4b58b5b
- parent 632
- 9bd017df749b
- child 666
- 48cc8868f9f4
equal
deleted
inserted
replaced
| 651:da166cb8470f | 652:16d3d4b58b5b |
|---|---|
| 1 /***************************************************************************** | 1 /***************************************************************************** |
| 2 * Copyright (C) 2016-2023 | 2 * Copyright (C) 2016-2024 |
| 3 * | 3 * |
| 4 * Michiel Broek <mbroek at mbse dot eu> | 4 * Michiel Broek <mbroek at mbse dot eu> |
| 5 * | 5 * |
| 6 * This file is part of the mbsePi-apps | 6 * This file is part of the mbsePi-apps |
| 7 * | 7 * |
| 24 #include <sys/ioctl.h> | 24 #include <sys/ioctl.h> |
| 25 #include <linux/wireless.h> | 25 #include <linux/wireless.h> |
| 26 #include "rdconfig.h" | 26 #include "rdconfig.h" |
| 27 #include "devices.h" | 27 #include "devices.h" |
| 28 #include "xutil.h" | 28 #include "xutil.h" |
| 29 #include "delay.h" | |
| 29 #include "mqtt.h" | 30 #include "mqtt.h" |
| 30 | 31 |
| 31 extern sys_config Config; | 32 extern sys_config Config; |
| 32 extern int debug; | 33 extern int debug; |
| 33 extern int my_shutdown; | 34 extern int my_shutdown; |
| 1729 if (mqtt_status == STATUS_WAITING) { | 1730 if (mqtt_status == STATUS_WAITING) { |
| 1730 if (mqtt_last_mid_sent == mqtt_last_mid && mqtt_disconnect_sent == FALSE) { | 1731 if (mqtt_last_mid_sent == mqtt_last_mid && mqtt_disconnect_sent == FALSE) { |
| 1731 mosquitto_disconnect(mosq); | 1732 mosquitto_disconnect(mosq); |
| 1732 mqtt_disconnect_sent = TRUE; | 1733 mqtt_disconnect_sent = TRUE; |
| 1733 } | 1734 } |
| 1734 usleep(100000); | 1735 mDelay(100); |
| 1735 } | 1736 } |
| 1736 rc = MOSQ_ERR_SUCCESS; | 1737 rc = MOSQ_ERR_SUCCESS; |
| 1737 } while (rc == MOSQ_ERR_SUCCESS && mqtt_connected); | 1738 } while (rc == MOSQ_ERR_SUCCESS && mqtt_connected); |
| 1738 | 1739 |
| 1739 mosquitto_loop_stop(mosq, FALSE); | 1740 mosquitto_loop_stop(mosq, FALSE); |
