Skip to content

Commit 282a1b9

Browse files
Deomid Ryabkovcesantabot
authored andcommitted
Fix MQTT reconnect behavior
mgos_mqtt_global_connect() should kick off reconnect if needed, too. PUBLISHED_FROM=c8f4d07fb46fc2b4a7e39fcebf7cc0e9c2cc022a
1 parent 6ba7b2a commit 282a1b9

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/mgos_mqtt.c

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -384,16 +384,15 @@ bool mgos_mqtt_global_connect(void) {
384384
mg_set_protocol_mqtt(s_conn);
385385
s_conn->recv_mbuf_limit = s_cfg->recv_mbuf_limit;
386386
} else {
387+
mqtt_global_reconnect();
387388
ret = false;
388389
}
389390
return ret;
390391
}
391392

392393
static void reconnect_timer_cb(void *user_data) {
393394
s_reconnect_timer_id = MGOS_INVALID_TIMER_ID;
394-
if (!mgos_mqtt_global_connect()) {
395-
mqtt_global_reconnect();
396-
}
395+
mgos_mqtt_global_connect();
397396
(void) user_data;
398397
}
399398

0 commit comments

Comments
 (0)