espressif/esp-mqtt
1
0
Fork 1
mirror of https://github.com/espressif/esp-mqtt.git synced 2025-07-29 18:28:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'Improve-handling-of-expired-messages' into 'master'

Browse Source 
feat: Moves deletion of expired messages to run at all states

Closes IDFGH-12831

See merge request espressif/esp-mqtt!213
This commit is contained in:
Rocha Euripedes
2024-06-03 20:48:47 +08:00
parent 60c76d5f17 32dada47ff
commit a0f4ce85de
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
mqtt_client.c
View File

@ -1574,6 +1574,8 @@ static void esp_mqtt_task(void *pv)
while (client->run) {
MQTT_API_LOCK(client);
run_event_loop(client);
// delete long pending messages
mqtt_delete_expired_messages(client);
mqtt_client_state_t state = client->state;
switch (state) {
case MQTT_STATE_DISCONNECTED:
@ -1653,8 +1655,6 @@ static void esp_mqtt_task(void *pv)
last_retransmit = platform_tick_get_ms();
}
// delete long pending messages
mqtt_delete_expired_messages(client);
// resend all non-transmitted messages first
outbox_item_handle_t item = outbox_dequeue(client->outbox, QUEUED, NULL);