granicus.if.org Git - esp-idf/blob - components/esp32/event_loop.c

   1 // Copyright 2015-2016 Espressif Systems (Shanghai) PTE LTD
   2 //
   3 // Licensed under the Apache License, Version 2.0 (the "License");
   4 // you may not use this file except in compliance with the License.
   5 // You may obtain a copy of the License at
   6
   7 //     http://www.apache.org/licenses/LICENSE-2.0
   8 //
   9 // Unless required by applicable law or agreed to in writing, software
  10 // distributed under the License is distributed on an "AS IS" BASIS,
  11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 // See the License for the specific language governing permissions and
  13 // limitations under the License.
  14
  15 #include <stddef.h>
  16 #include <stdlib.h>
  17 #include <string.h>
  18
  19 #include "esp_err.h"
  20 #include "esp_wifi.h"
  21 #include "esp_event.h"
  22 #include "esp_event_loop.h"
  23 #include "esp_task.h"
  24
  25 #include "freertos/FreeRTOS.h"
  26 #include "freertos/task.h"
  27 #include "freertos/queue.h"
  28 #include "freertos/semphr.h"
  29
  30 #include "esp_log.h"
  31 #include "sdkconfig.h"
  32
  33
  34 static const char* TAG = "event";
  35 static bool s_event_init_flag = false;
  36 static QueueHandle_t s_event_queue = NULL;
  37 static system_event_cb_t s_event_handler_cb = NULL;
  38 static void *s_event_ctx = NULL;
  39
  40 static esp_err_t esp_event_post_to_user(system_event_t *event)
  41 {
  42     if (s_event_handler_cb) {
  43         return (*s_event_handler_cb)(s_event_ctx, event);
  44     }
  45     return ESP_OK;
  46 }
  47
  48 static void esp_event_loop_task(void *pvParameters)
  49 {
  50     while (1) {
  51         system_event_t evt;
  52         if (xQueueReceive(s_event_queue, &evt, portMAX_DELAY) == pdPASS) {
  53             esp_err_t ret = esp_event_process_default(&evt);
  54             if (ret != ESP_OK) {
  55                 ESP_LOGE(TAG, "default event handler failed!");
  56             }
  57             ret = esp_event_post_to_user(&evt);
  58             if (ret != ESP_OK) {
  59                 ESP_LOGE(TAG, "post event to user fail!");
  60             }
  61         }
  62     }
  63 }
  64
  65 system_event_cb_t esp_event_loop_set_cb(system_event_cb_t cb, void *ctx)
  66 {
  67     system_event_cb_t old_cb = s_event_handler_cb;
  68     s_event_handler_cb = cb;
  69     s_event_ctx = ctx;
  70     return old_cb;
  71 }
  72
  73 esp_err_t esp_event_send(system_event_t *event)
  74 {
  75     portBASE_TYPE ret = xQueueSendToBack(s_event_queue, event, 0);
  76     if (ret != pdPASS) {
  77         if (event) {
  78             ESP_LOGE(TAG, "e=%d f", event->event_id);
  79         } else {
  80             ESP_LOGE(TAG, "e null");
  81         }
  82         return ESP_FAIL;
  83     }
  84     return ESP_OK;
  85 }
  86
  87 QueueHandle_t esp_event_loop_get_queue(void)
  88 {
  89     return s_event_queue;
  90 }
  91
  92 esp_err_t esp_event_loop_init(system_event_cb_t cb, void *ctx)
  93 {
  94     if (s_event_init_flag) {
  95         return ESP_FAIL;
  96     }
  97     s_event_handler_cb = cb;
  98     s_event_ctx = ctx;
  99     s_event_queue = xQueueCreate(CONFIG_SYSTEM_EVENT_QUEUE_SIZE, sizeof(system_event_t));
 100
 101     xTaskCreatePinnedToCore(esp_event_loop_task, "eventTask",
 102             ESP_TASKD_EVENT_STACK, NULL, ESP_TASKD_EVENT_PRIO, NULL, 0);
 103
 104     s_event_init_flag = true;
 105     return ESP_OK;
 106 }
 107