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

rollback mqtt reconnect time, added debug for receive mqtt data

Browse Source
This commit is contained in:
Bogdan Pilyugin 2024-04-04 14:48:20 +02:00
parent 2d8e4ee592
commit db5452fe8b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/MQTT.c
View File

@ -267,7 +267,9 @@ static void mqtt_system_event_handler(int idx, void *handler_args, esp_event_bas
case MQTT_EVENT_DATA: case MQTT_EVENT_DATA:
#if MQTT_DEBUG_MODE > 1 #if MQTT_DEBUG_MODE > 1
ESP_LOGI(TAG, "MQTT_EVENT_DATA, client %d", idx); ESP_LOGI(TAG, "MQTT_EVENT_DATA, client:%d, data-length:%d, offset:%d ", idx, event->data_len, event->current_data_offset);
ESP_LOGI(TAG, "MQTT client %d data received:%.*s", idx, event->data_len, event->data);
#endif #endif
if (event->data_len == 0 || event->current_data_offset > 0) //possible fragments of long data if (event->data_len == 0 || event->current_data_offset > 0) //possible fragments of long data
goto end_of_system_handler; goto end_of_system_handler;
@ -393,7 +395,7 @@ void MQTTTaskTransmit(void *pvParameter)
{ {
#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_LOGW(TAG, "MQTT client %d data send:%.*s", idx, DSS.data_length, DSS.raw_data_ptr);
#endif #endif
esp_mqtt_client_publish(mqtt[idx].mqtt, esp_mqtt_client_publish(mqtt[idx].mqtt,
(const char*) DSS.topic, (const char*) DSS.topic,
@ -441,7 +443,6 @@ static void start_mqtt()
#if ESP_IDF_VERSION_MAJOR >= 5 #if ESP_IDF_VERSION_MAJOR >= 5
mqtt_cfg.credentials.client_id = tmp; mqtt_cfg.credentials.client_id = tmp;
mqtt_cfg.network.reconnect_timeout_ms = MQTT_RECONNECT_TIMEOUT * 1000; mqtt_cfg.network.reconnect_timeout_ms = MQTT_RECONNECT_TIMEOUT * 1000;
mqtt_cfg.network.timeout_ms = 30000;
#else #else
mqtt_cfg.client_id = tmp; mqtt_cfg.client_id = tmp;
mqtt_cfg.reconnect_timeout_ms = MQTT_RECONNECT_TIMEOUT * 1000; mqtt_cfg.reconnect_timeout_ms = MQTT_RECONNECT_TIMEOUT * 1000;