eeeck/the-waterinator
1
1
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Parametrize task delay values

Browse Source
This commit is contained in:
Erick
2025-11-30 23:35:23 +01:00
parent 2fcc3172aa
commit 5dd2c00ac0
3 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
firmware/esp32/main/mqtt.cpp
+13 -3
View File
@@ -5,6 +5,10 @@
#include "esp_log.h"
#include "mqtt_client.h"
#include "main.hpp"
#include "i2c.hpp"
#define MQTT_TASK_TIMEOUT_TICKS pdMS_TO_TICKS(3000)
#define MQTT_TIMEOUT_TICKS pdMS_TO_TICKS(MQTT_TASK_TIMEOUT/2)
static const char* TAG = "MQTT";
@@ -57,11 +61,17 @@ void mqttTask(void *pvParameters) {
for(;;) {
ESP_LOGI(TAG, "Checking broker connection...");
if(bits && MQTT_CONNECTED_BIT) mqtt_publish();
else ESP_LOGW(TAG, "Waiting for connection...");
if(bits && MQTT_CONNECTED_BIT) {
ESP_LOGI(TAG, "Connection estabilished");
uint32_t task_notification = ulTaskNotifyTake(pdTRUE, pdMS_TO_TICKS(MQTT_TASK_TIMEOUT_TICKS));
if (task_notification) twi_do(global_rx_buffer); //FIXME: develop i2c libs! (this func should then call mqtt_publish() if needed)
} else {
ESP_LOGW(TAG, "Waiting for connection...");
vTaskDelay(pdMS_TO_TICKS(MQTT_TIMEOUT_TICKS));
}
ESP_ERROR_CHECK(esp_task_wdt_reset());
ESP_LOGI(TAG, "Task reset");
vTaskDelay(pdMS_TO_TICKS(3000));
}
}