userbogd/webguiapp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed MQTT send stack overflow on disconnected socket, no keep messages

Browse Source
This commit is contained in:
Bogdan Pilyugin 2023-11-24 12:27:58 +02:00
parent 5151cfc0f6
commit 0f371b6abc
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/MQTT.c
View File

@ -380,10 +380,8 @@ void MQTTTaskTransmit(void *pvParameter)
vTaskDelay(pdMS_TO_TICKS(300)); //wait for MQTT queue ready vTaskDelay(pdMS_TO_TICKS(300)); //wait for MQTT queue ready
while (1) while (1)
{ {
while (!mqtt[idx].is_connected)
vTaskDelay(pdMS_TO_TICKS(1000));
xQueueReceive(mqtt[idx].mqtt_queue, &DSS, portMAX_DELAY); xQueueReceive(mqtt[idx].mqtt_queue, &DSS, portMAX_DELAY);
if (mqtt[idx].mqtt) if (mqtt[idx].mqtt && mqtt[idx].is_connected)
{ {
#if MQTT_DEBUG_MODE > 1 #if MQTT_DEBUG_MODE > 1
ESP_LOGI(TAG, "MQTT client %d data send:%.*s", idx, DSS.data_length, DSS.raw_data_ptr); ESP_LOGI(TAG, "MQTT client %d data send:%.*s", idx, DSS.data_length, DSS.raw_data_ptr);
@ -394,8 +392,8 @@ void MQTTTaskTransmit(void *pvParameter)
DSS.data_length, DSS.data_length,
0, 0); 0, 0);
} }
else //else
ESP_LOGE(TAG, "MQTT client not initialized"); // ESP_LOGW(TAG, "MQTT client not initialized or disconnected");
free(DSS.raw_data_ptr); free(DSS.raw_data_ptr);
} }
} }