feat: added queue operations

This commit is contained in:
Alexey Zholtikov 2025-05-06 11:54:25 +03:00
parent 0f35e48fe5
commit 603c544e46
3 changed files with 39 additions and 2 deletions

View File

@ -187,6 +187,18 @@ extern "C"
*/
esp_err_t zh_espnow_get_mac(uint8_t *mac_addr);
/**
* @brief Get the number of available places in the queue.
*
* @return Number of available places.
*/
uint8_t zh_espnow_get_queue_space(void);
/**
* @brief Clean up the message queue.
*/
void zh_espnow_clear_queue(void);
#ifdef __cplusplus
}
#endif

View File

@ -1 +1 @@
1.7.0
1.8.0

View File

@ -272,7 +272,7 @@ static esp_err_t _zh_espnow_init_resources(const zh_espnow_init_config_t *config
_event_group_handle = xEventGroupCreate();
ZH_ESPNOW_CHECK(_event_group_handle != NULL, ESP_FAIL, "Event group creation failed.");
_queue_handle = xQueueCreate(config->queue_size, sizeof(_queue_t));
ZH_ESPNOW_CHECK(_queue_handle != 0, ESP_FAIL, "Queue creation failed.");
ZH_ESPNOW_CHECK(_queue_handle != NULL, ESP_FAIL, "Queue creation failed.");
return ESP_OK;
}
@ -597,4 +597,29 @@ esp_err_t zh_espnow_set_battery_mode(bool battery_mode)
esp_err_t zh_espnow_get_mac(uint8_t *mac_addr)
{
return esp_wifi_get_mac(_init_config.wifi_interface, mac_addr);
}
uint8_t zh_espnow_get_queue_space(void)
{
if (_queue_handle == NULL)
{
return 0;
}
return uxQueueSpacesAvailable(_queue_handle);
}
void zh_espnow_clear_queue(void)
{
if (_queue_handle != NULL)
{
_queue_t queue = {0};
while (xQueueReceive(_queue_handle, &queue, 0) == pdTRUE)
{
if (queue.data.payload != NULL)
{
heap_caps_free(queue.data.payload);
}
}
ZH_ESPNOW_LOGI("Queue clear completed successfully.");
}
}