Home
last modified time | relevance | path

Searched refs:hli_queue_handle_t (Results 1 – 3 of 3) sorted by relevance

/hal_espressif-latest/components/bt/controller/esp32/
Dhli_api.h66 typedef struct hli_queue_t* hli_queue_handle_t; typedef
91 hli_queue_handle_t hli_queue_create(size_t nelem, size_t elem_size, QueueHandle_t downstream);
106 hli_queue_handle_t hli_customer_queue_create(size_t nelem, size_t elem_size, QueueHandle_t downstre…
117 hli_queue_handle_t hli_semaphore_create(size_t max_count, SemaphoreHandle_t downstream);
126 void hli_queue_delete(hli_queue_handle_t queue);
138 bool hli_queue_get(hli_queue_handle_t queue, void* out);
153 bool hli_queue_put(hli_queue_handle_t queue, const void* data);
161 bool hli_semaphore_give(hli_queue_handle_t queue);
Dhli_api.c121 static inline char* IRAM_ATTR wrap_ptr(hli_queue_handle_t queue, char *ptr) in wrap_ptr()
126 static inline bool IRAM_ATTR queue_empty(hli_queue_handle_t queue) in queue_empty()
131 static inline bool IRAM_ATTR queue_full(hli_queue_handle_t queue) in queue_full()
140 hli_queue_handle_t queue; in queue_isr_handler()
168 static void IRAM_ATTR queue_signal(hli_queue_handle_t queue) in queue_signal()
172 const hli_queue_handle_t *end = (hli_queue_handle_t*) s_meta_queue_ptr->end; in queue_signal()
173 hli_queue_handle_t *item = (hli_queue_handle_t*) s_meta_queue_ptr->begin; in queue_signal()
174 … for (;item != end; item = (hli_queue_handle_t*) wrap_ptr(s_meta_queue_ptr, (char*) (item + 1))) { in queue_signal()
190 static void queue_init(hli_queue_handle_t queue, size_t buf_size, size_t elem_size, QueueHandle_t d… in queue_init()
219 hli_queue_handle_t hli_queue_create(size_t nelem, size_t elem_size, QueueHandle_t downstream) in hli_queue_create()
[all …]
Dbt.c571 hli_queue_handle_t s_semaphore = hli_semaphore_create(max, downstream_semaphore); in semphr_create_wrapper()
591 handle = ((hli_queue_handle_t)(semphr_item->handle))->downstream; in semphr_delete_wrapper()
592 hli_queue_delete((hli_queue_handle_t)(semphr_item->handle)); in semphr_delete_wrapper()
635 ret = xSemaphoreTake(((hli_queue_handle_t)handle)->downstream, portMAX_DELAY); in semphr_take_wrapper()
637 …ret = xSemaphoreTake(((hli_queue_handle_t)handle)->downstream, block_time_ms / portTICK_PERIOD_MS); in semphr_take_wrapper()
653 return (int32_t)xSemaphoreGive(((hli_queue_handle_t)handle)->downstream); in semphr_give_wrapper()
711 hli_queue_handle_t queue = hli_queue_create(queue_len, item_size, downstream_queue); in queue_create_hlevel_wrapper()
723 hli_queue_handle_t queue = hli_customer_queue_create(queue_len, item_size, downstream_queue); in customer_queue_create_hlevel_wrapper()
738 void *handle = ((hli_queue_handle_t)(queue_item->handle))->downstream; in queue_delete_hlevel_wrapper()
749 return (int32_t)xQueueSend(((hli_queue_handle_t)handle)->downstream, item, portMAX_DELAY); in queue_send_hlevel_wrapper()
[all …]