diff --git a/src/apps/mqtt/mqtt.c b/src/apps/mqtt/mqtt.c index 096215e2..76c6bbc7 100644 --- a/src/apps/mqtt/mqtt.c +++ b/src/apps/mqtt/mqtt.c @@ -603,14 +603,13 @@ mqtt_cyclic_timer(void *arg) } /* If time for a keep alive message to be sent, transmission has been idle for keep_alive time */ + client->cyclic_tick++; if ((client->cyclic_tick * MQTT_CYCLIC_TIMER_INTERVAL) >= client->keep_alive) { LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_cyclic_timer: Sending keep-alive message to server\n")); if (mqtt_output_check_space(&client->output, 0) != 0) { mqtt_output_append_fixed_header(&client->output, MQTT_MSG_TYPE_PINGREQ, 0, 0, 0, 0); client->cyclic_tick = 0; } - } else { - client->cyclic_tick++; } } } else {