#include #include #include "freertos/FreeRTOS.h" #include "freertos/event_groups.h" #include "freertos/task.h" #include "freertos/queue.h" #include "esp_task_wdt.h" #include "driver/i2c_master.h" #include "esp_log.h" #include "config.h" #define I2C_TASK_TIMEOUT_MS 4500 // ESP32-C3 Super Mini, change this ports for other versions #define I2C_MASTER_SCL_IO 9 #define I2C_MASTER_SDA_IO 8 static const char* TAG = "I2C"; TaskHandle_t i2c_task_handle = NULL; i2c_master_bus_handle_t bus_handle; static i2c_master_dev_handle_t slave_handles[SLAVES_NUMBER]; uint8_t slave_count = 0; uint8_t slave_addrs[SLAVES_NUMBER]; uint8_t data_rd[DATA_LENGTH]; static void register_slave(uint8_t addr) { i2c_device_config_t slave_dev_cfg = {}; slave_dev_cfg.dev_addr_length = I2C_ADDR_BIT_LEN_7; slave_dev_cfg.device_address = addr; slave_dev_cfg.scl_speed_hz = 100000; ESP_ERROR_CHECK(i2c_master_bus_add_device(bus_handle, &slave_dev_cfg, &slave_handles[slave_count])); slave_addrs[slave_count++] = addr; } static void i2c_init(void) { i2c_master_bus_config_t i2c_mst_config = {}; i2c_mst_config.i2c_port = I2C_NUM_0; i2c_mst_config.scl_io_num = I2C_MASTER_SCL_IO; i2c_mst_config.sda_io_num = I2C_MASTER_SDA_IO; i2c_mst_config.clk_source = I2C_CLK_SRC_DEFAULT; i2c_mst_config.glitch_ignore_cnt = 7; i2c_mst_config.intr_priority = 1; i2c_mst_config.trans_queue_depth = 4; ESP_ERROR_CHECK(i2c_new_master_bus(&i2c_mst_config, &bus_handle)); register_slave(0x30); register_slave(0x31); } static void i2c_read() {} //should read from i2c and if necessary call i2c_write static void i2c_write() {} void i2cTask(void *pvParameters) { ESP_LOGV(TAG, "Task started"); i2c_init(); for(;;) { ESP_LOGV(TAG, "Checking Wi-Fi & MQTT connection..."); //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_LOGV(TAG, "Task reset"); vTaskDelay(pdMS_TO_TICKS(2000)); } }