From 1a893547b680a13ccc5f56c3770aed10ef3fd1ab Mon Sep 17 00:00:00 2001 From: Erick Ahmed Date: Tue, 9 Dec 2025 23:50:26 +0100 Subject: [PATCH] Finalize event groups to improve performance --- firmware/esp32/main/mqtt.cpp | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/firmware/esp32/main/mqtt.cpp b/firmware/esp32/main/mqtt.cpp index 423dae7..6af5268 100644 --- a/firmware/esp32/main/mqtt.cpp +++ b/firmware/esp32/main/mqtt.cpp @@ -91,13 +91,15 @@ void mqttTask(void *pvParameters) { ESP_ERROR_CHECK(esp_task_wdt_add(NULL)); for(;;) { - ESP_LOGV(TAG, "Checking connection..."); - xEventGroupWaitBits(connectivity_event_group, WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT, pdFALSE, pdTRUE, portMAX_DELAY); - ESP_LOGV(TAG, "Connection present"); + ESP_LOGV(TAG, "Checking Wi-Fi connection..."); + EventBits_t bits = xEventGroupWaitBits(connectivity_event_group, WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT, pdFALSE, pdTRUE, pdMS_TO_TICKS(MQTT_TASK_TIMEOUT_MS)); - uint32_t task_notification = ulTaskNotifyTake(pdTRUE, pdMS_TO_TICKS(MQTT_TASK_TIMEOUT_MS)); + if ((bits & (WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT)) == (WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT)) { + ESP_LOGV(TAG, "Wi-Fi and MQTT up"); - if(task_notification) {} //{twi_do(global_rx_buffer)} + + + } else ESP_LOGV(TAG, "Wi-Fi or MQTT down"); ESP_ERROR_CHECK(esp_task_wdt_reset()); ESP_LOGV(TAG, "Task reset");