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

Send packet when notified from MQTT

Browse Source
This commit is contained in:
Erick
2025-12-13 12:41:38 +01:00
parent 68e5a67fb7
commit 26bbe5b518
1 changed files with 13 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
firmware/esp32/main/i2c.cpp
+13 -14
View File
@@ -7,17 +7,19 @@
#include "esp_task_wdt.h" #include "esp_task_wdt.h"
#include "driver/i2c_master.h" #include "driver/i2c_master.h"
#include "esp_log.h" #include "esp_log.h"
#include "config.h" #include "config-erick.h"
#define I2C_TASK_TIMEOUT_MS 4500 #define I2C_TASK_TIMEOUT_MS 4500
// ESP32-C3 Super Mini, change this ports for other versions // for ESP32-C3
#define I2C_MASTER_SCL_IO 9 #define I2C_MASTER_SCL_IO ((gpio_num_t)9)
#define I2C_MASTER_SDA_IO 8 #define I2C_MASTER_SDA_IO ((gpio_num_t)8)
#define DATA_LENGTH 100
static const char* TAG = "I2C"; static const char* TAG = "I2C";
TaskHandle_t i2c_task_handle = NULL; TaskHandle_t i2c_task = NULL;
i2c_master_bus_handle_t bus_handle; i2c_master_bus_handle_t bus_handle;
static i2c_master_dev_handle_t slave_handles[SLAVES_NUMBER]; static i2c_master_dev_handle_t slave_handles[SLAVES_NUMBER];
@@ -84,18 +86,15 @@ static void i2c_send(uint32_t packet) {
} }
void i2cTask(void *pvParameters) { void i2cTask(void *pvParameters) {
ESP_LOGV(TAG, "Task started");
i2c_init(); i2c_init();
ESP_ERROR_CHECK(esp_task_wdt_add(NULL));
uint32_t packet;
for(;;) { for(;;) {
ESP_LOGV(TAG, "Checking Wi-Fi & MQTT connection..."); if(xTaskNotifyWait(0, 0, &packet, pdMS_TO_TICKS(I2C_TASK_TIMEOUT_MS)) == pdPASS) {
i2c_send(packet);
//FIXME URGENT: instead of event group use event notification!! if notif then i2c_read (no notif=stopped) }
EventBits_t bits = xEventGroupWaitBits(connectivity_event_group, WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT, pdFALSE, pdTRUE, pdMS_TO_TICKS(I2C_TASK_TIMEOUT_MS));
if ((bits & (WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT)) == (WIFI_CONNECTED_BIT | MQTT_CONNECTED_BIT)) i2c_read();
ESP_ERROR_CHECK(esp_task_wdt_reset()); ESP_ERROR_CHECK(esp_task_wdt_reset());
ESP_LOGV(TAG, "Task reset"); vTaskDelay(pdMS_TO_TICKS(150));
vTaskDelay(pdMS_TO_TICKS(2000));
} }
} }