default_event_loop.c 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. /*
  2. * SPDX-FileCopyrightText: 2018-2022 Espressif Systems (Shanghai) CO LTD
  3. *
  4. * SPDX-License-Identifier: Apache-2.0
  5. */
  6. #include "esp_event.h"
  7. #include "esp_event_internal.h"
  8. #include "esp_task.h"
  9. /* ------------------------- Static Variables ------------------------------- */
  10. static esp_event_loop_handle_t s_default_loop = NULL;
  11. /* ---------------------------- Public API ---------------------------------- */
  12. esp_err_t esp_event_handler_register(esp_event_base_t event_base, int32_t event_id,
  13. esp_event_handler_t event_handler, void* event_handler_arg)
  14. {
  15. if (s_default_loop == NULL) {
  16. return ESP_ERR_INVALID_STATE;
  17. }
  18. return esp_event_handler_register_with(s_default_loop, event_base, event_id,
  19. event_handler, event_handler_arg);
  20. }
  21. esp_err_t esp_event_handler_instance_register(esp_event_base_t event_base,
  22. int32_t event_id,
  23. esp_event_handler_t event_handler,
  24. void *event_handler_arg,
  25. esp_event_handler_instance_t *context)
  26. {
  27. if (s_default_loop == NULL) {
  28. return ESP_ERR_INVALID_STATE;
  29. }
  30. return esp_event_handler_instance_register_with(s_default_loop,
  31. event_base,
  32. event_id,
  33. event_handler,
  34. event_handler_arg,
  35. context);
  36. }
  37. esp_err_t esp_event_handler_unregister(esp_event_base_t event_base, int32_t event_id,
  38. esp_event_handler_t event_handler)
  39. {
  40. if (s_default_loop == NULL) {
  41. return ESP_ERR_INVALID_STATE;
  42. }
  43. return esp_event_handler_unregister_with(s_default_loop, event_base, event_id,
  44. event_handler);
  45. }
  46. esp_err_t esp_event_handler_instance_unregister(esp_event_base_t event_base,
  47. int32_t event_id,
  48. esp_event_handler_instance_t context)
  49. {
  50. if (s_default_loop == NULL) {
  51. return ESP_ERR_INVALID_STATE;
  52. }
  53. return esp_event_handler_instance_unregister_with(s_default_loop, event_base, event_id, context);
  54. }
  55. esp_err_t esp_event_post(esp_event_base_t event_base, int32_t event_id,
  56. const void* event_data, size_t event_data_size, TickType_t ticks_to_wait)
  57. {
  58. if (s_default_loop == NULL) {
  59. return ESP_ERR_INVALID_STATE;
  60. }
  61. return esp_event_post_to(s_default_loop, event_base, event_id,
  62. event_data, event_data_size, ticks_to_wait);
  63. }
  64. #if CONFIG_ESP_EVENT_POST_FROM_ISR
  65. esp_err_t esp_event_isr_post(esp_event_base_t event_base, int32_t event_id,
  66. const void* event_data, size_t event_data_size, BaseType_t* task_unblocked)
  67. {
  68. if (s_default_loop == NULL) {
  69. return ESP_ERR_INVALID_STATE;
  70. }
  71. return esp_event_isr_post_to(s_default_loop, event_base, event_id,
  72. event_data, event_data_size, task_unblocked);
  73. }
  74. #endif
  75. esp_err_t esp_event_loop_create_default(void)
  76. {
  77. if (s_default_loop) {
  78. return ESP_ERR_INVALID_STATE;
  79. }
  80. esp_event_loop_args_t loop_args = {
  81. .queue_size = CONFIG_ESP_SYSTEM_EVENT_QUEUE_SIZE,
  82. .task_name = "sys_evt",
  83. .task_stack_size = ESP_TASKD_EVENT_STACK,
  84. .task_priority = ESP_TASKD_EVENT_PRIO,
  85. .task_core_id = 0
  86. };
  87. esp_err_t err;
  88. err = esp_event_loop_create(&loop_args, &s_default_loop);
  89. if (err != ESP_OK) {
  90. return err;
  91. }
  92. return ESP_OK;
  93. }
  94. esp_err_t esp_event_loop_delete_default(void)
  95. {
  96. if (!s_default_loop) {
  97. return ESP_ERR_INVALID_STATE;
  98. }
  99. esp_err_t err;
  100. err = esp_event_loop_delete(s_default_loop);
  101. if (err != ESP_OK) {
  102. return err;
  103. }
  104. s_default_loop = NULL;
  105. return ESP_OK;
  106. }