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

Merge branch 'fix/account_for_failure_in_make_publish' into 'master'

Browse Source 
fix: Error on publish message creation was ignored.

See merge request espressif/esp-mqtt!185
This commit is contained in:
Rocha Euripedes
2023-06-30 20:42:28 +08:00
parent effd1e6705 585e3ba2e0
commit 8d98103013
1 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
mqtt_client.c
View File

@ -999,7 +999,7 @@ static esp_err_t esp_mqtt_dispatch_event(esp_mqtt_client_handle_t client)
client->event.protocol_ver = client->mqtt_state.connection.information.protocol_ver; client->event.protocol_ver = client->mqtt_state.connection.information.protocol_ver;
esp_err_t ret = ESP_FAIL; esp_err_t ret = ESP_FAIL;
#ifdef MQTT_SUPPORTED_FEATURE_EVENT_LOOP #ifdef MQTT_SUPPORTED_FEATURE_EVENT_LOOP
esp_event_post_to(client->config->event_loop_handle, MQTT_EVENTS, client->event.event_id, &client->event, sizeof(client->event), portMAX_DELAY); esp_event_post_to(client->config->event_loop_handle, MQTT_EVENTS, client->event.event_id, &client->event, sizeof(client->event), portMAX_DELAY);
ret = esp_event_loop_run(client->config->event_loop_handle, 0); ret = esp_event_loop_run(client->config->event_loop_handle, 0);
#else #else
@ -1976,6 +1976,9 @@ static inline int mqtt_client_enqueue_publish(esp_mqtt_client_handle_t client, c
int len, int qos, int retain, bool store) int len, int qos, int retain, bool store)
{ {
int pending_msg_id = make_publish(client, topic, data, len, qos, retain); int pending_msg_id = make_publish(client, topic, data, len, qos, retain);
if (pending_msg_id < 0) {
return -1;
}
/* We have to set as pending all the qos>0 messages */ /* We have to set as pending all the qos>0 messages */
//TODO: client->mqtt_state.outbound_message = publish_msg; //TODO: client->mqtt_state.outbound_message = publish_msg;
if (qos > 0 || store) { if (qos > 0 || store) {