main.c 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
  1. #include <stdio.h>
  2. #include "freertos/FreeRTOS.h"
  3. #include "freertos/task.h"
  4. #include "driver/gpio.h"
  5. #include "esp_rom_sys.h"
  6. #include "esp_log.h"
  7. #define DHT_PIN GPIO_NUM_4
  8. #define US_DELAY 3
  9. #define DHT_DATA_BITS 40
  10. static const char *TAG = "DHT22";
  11. static portMUX_TYPE mux = portMUX_INITIALIZER_UNLOCKED;
  12. // Macro to check the return value of a function and log an error if it is not ESP_OK
  13. // portEXIT_CRITICAL(&mux); despues del if
  14. #define CHECK_LOGE(x, msg, ...) do { \
  15. esp_err_t __; \
  16. if ((__ = x) != ESP_OK) { \
  17. ESP_LOGE(TAG, msg, ## __VA_ARGS__); \
  18. return __; \
  19. } \
  20. } while (0)
  21. gpio_num_t dht_pin = DHT_PIN;
  22. static esp_err_t dht_attach_pin(gpio_num_t pin){
  23. if (pin < GPIO_NUM_0 || pin >= GPIO_NUM_MAX) {
  24. ESP_LOGE(TAG, "Invalid GPIO pin number: %d", pin);
  25. return ESP_ERR_INVALID_ARG;
  26. }
  27. gpio_set_direction(pin, GPIO_MODE_INPUT_OUTPUT_OD);
  28. gpio_set_level(pin, 1); // Set the pin high by default
  29. return ESP_OK;
  30. }
  31. static esp_err_t get_change_time(gpio_num_t pin, uint8_t timeout_us, bool expected_level, uint32_t *time_us){
  32. *time_us = 0;
  33. while (*time_us < timeout_us){
  34. if (gpio_get_level(pin) == expected_level) {
  35. return ESP_OK;
  36. }
  37. *time_us += US_DELAY;
  38. esp_rom_delay_us(US_DELAY);
  39. }
  40. return ESP_ERR_TIMEOUT;
  41. }
  42. static inline esp_err_t dht_communication(gpio_num_t pin, uint8_t data[DHT_DATA_BITS/8]){
  43. uint32_t high_time;
  44. uint32_t low_time;
  45. // Send start signal
  46. gpio_set_direction(pin, GPIO_MODE_INPUT_OUTPUT_OD);
  47. gpio_set_level(pin, 0);
  48. esp_rom_delay_us(1500); // Pull low for at least 1ms
  49. gpio_set_level(pin, 1); // Release the line
  50. CHECK_LOGE(get_change_time(pin, 44, 0, &low_time), "Failed to get dht response"); // Wait for the sensor to pull low 20-40us
  51. CHECK_LOGE(get_change_time(pin, 88, 1, &high_time), "Failed to get dht response"); // Wait for the sensor to pull high 80us
  52. CHECK_LOGE(get_change_time(pin, 88, 0, &low_time), "Failed to get dht response"); // Wait for the sensor to pull low 80us
  53. for (uint8_t i = 0; i < DHT_DATA_BITS; i++){
  54. // Wait for the sensor to pull low 50us
  55. CHECK_LOGE(get_change_time(pin, 65, 1, &low_time), "Failed dht transmission %d h", i);
  56. // Wait for the sensor to pull high 26-28us for 0 or 70us for 1
  57. CHECK_LOGE(get_change_time(pin, 80, 0, &high_time), "Failed dht transmission %d l", i);
  58. uint8_t b = i / 8;
  59. uint8_t m = i % 8;
  60. if (!m) data[b] = 0; // Clear the byte at the start of each new byte
  61. data[b] |= (high_time > low_time) << (7 - m); // Set the bit if high_time is greater than low_time
  62. }
  63. return ESP_OK;
  64. }
  65. static inline int16_t data_to_int16(uint8_t MSB, uint8_t LSB){
  66. return (int16_t)((MSB << 8) | LSB);
  67. }
  68. esp_err_t dht_read(gpio_num_t pin, float *temperature, float *humidity){
  69. uint8_t data[DHT_DATA_BITS/8] = {0};
  70. gpio_set_direction(pin, GPIO_MODE_INPUT_OUTPUT_OD);
  71. gpio_set_level(pin, 1);
  72. //portENTER_CRITICAL(&mux);
  73. esp_err_t err = dht_communication(pin, data);
  74. if (err == ESP_OK) {
  75. // portEXIT_CRITICAL(&mux);
  76. }
  77. if (data[4] != ((data[0] + data[1] + data[2] + data[3]) & 0xFF)) {
  78. ESP_LOGE(TAG, "DHT22 checksum mismatch");
  79. return ESP_ERR_INVALID_CRC;
  80. }
  81. gpio_set_direction(pin, GPIO_MODE_INPUT_OUTPUT_OD);
  82. gpio_set_level(pin, 1);
  83. if (err != ESP_OK) return err;
  84. *humidity = data_to_int16(data[0], data[1]) / 10.0;
  85. *temperature = data_to_int16(data[2], data[3]) / 10.0;
  86. return ESP_OK;
  87. }
  88. void app_main(void)
  89. {
  90. float temperature;
  91. float humidity;
  92. esp_err_t err = dht_attach_pin(dht_pin);
  93. if (err != ESP_OK) {
  94. ESP_LOGE(TAG, "Failed to attach DHT pin: %s", esp_err_to_name(err));
  95. vTaskDelay(pdMS_TO_TICKS(5000)); // Wait for 5 seconds before retrying
  96. return;
  97. }
  98. vTaskDelay(pdMS_TO_TICKS(2000)); // Wait for 2 seconds before starting the main loop
  99. while (1) {
  100. if (dht_read(dht_pin, &temperature, &humidity) == ESP_OK) {
  101. ESP_LOGI(TAG, "Temperature: %.1f°C, Humidity: %.1f%%", temperature, humidity);
  102. } else {
  103. ESP_LOGE(TAG, "Failed to read from DHT22 sensor");
  104. }
  105. vTaskDelay(pdMS_TO_TICKS(5000)); // Wait for 5 seconds before the next reading
  106. }
  107. }