Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 70) sorted by relevance

123

/hal_espressif-latest/components/bt/common/osi/
Dfixed_queue.c71 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) in fixed_queue_free() argument
75 if (queue == NULL) { in fixed_queue_free()
79 fixed_queue_unregister_dequeue(queue); in fixed_queue_free()
82 … for (node = list_begin(queue->list); node != list_end(queue->list); node = list_next(node)) { in fixed_queue_free()
87 list_free(queue->list); in fixed_queue_free()
88 osi_sem_free(&queue->enqueue_sem); in fixed_queue_free()
89 osi_sem_free(&queue->dequeue_sem); in fixed_queue_free()
90 osi_mutex_free(&queue->lock); in fixed_queue_free()
91 osi_free(queue); in fixed_queue_free()
94 bool fixed_queue_is_empty(fixed_queue_t *queue) in fixed_queue_is_empty() argument
[all …]
Dpkt_queue.c22 struct pkt_queue *queue = calloc(1, sizeof(struct pkt_queue)); in pkt_queue_create() local
23 if (queue == NULL) { in pkt_queue_create()
26 if (osi_mutex_new(&queue->lock) != 0) { in pkt_queue_create()
27 osi_free(queue); in pkt_queue_create()
29 struct pkt_queue_header *p = &queue->header; in pkt_queue_create()
32 return queue; in pkt_queue_create()
35 static void pkt_queue_cleanup(struct pkt_queue *queue, pkt_queue_free_cb free_cb) in pkt_queue_cleanup() argument
37 if (queue == NULL) { in pkt_queue_cleanup()
41 struct pkt_queue_header *header = &queue->header; in pkt_queue_cleanup()
51 queue->length--; in pkt_queue_cleanup()
[all …]
Dfixed_pkt_queue.c51 void fixed_pkt_queue_free(fixed_pkt_queue_t *queue, fixed_pkt_queue_free_cb free_cb) in fixed_pkt_queue_free() argument
53 if (queue == NULL) { in fixed_pkt_queue_free()
57 fixed_pkt_queue_unregister_dequeue(queue); in fixed_pkt_queue_free()
59 pkt_queue_destroy(queue->pkt_list, (pkt_queue_free_cb)free_cb); in fixed_pkt_queue_free()
60 queue->pkt_list = NULL; in fixed_pkt_queue_free()
62 if (queue->enqueue_sem) { in fixed_pkt_queue_free()
63 osi_sem_free(&queue->enqueue_sem); in fixed_pkt_queue_free()
65 if (queue->dequeue_sem) { in fixed_pkt_queue_free()
66 osi_sem_free(&queue->dequeue_sem); in fixed_pkt_queue_free()
68 osi_free(queue); in fixed_pkt_queue_free()
[all …]
Dthread.c34 QueueHandle_t queue; member
72 wq->queue = xQueueCreate(capacity, sizeof(struct work_item)); in osi_work_queue_create()
73 if (wq->queue != 0) { in osi_work_queue_create()
87 if (wq->queue != 0) { in osi_work_queue_delete()
88 vQueueDelete(wq->queue); in osi_work_queue_delete()
90 wq->queue = 0; in osi_work_queue_delete()
100 assert (wq->queue != 0); in osi_thead_work_queue_get()
103 if (pdTRUE == xQueueReceive(wq->queue, item, 0)) { in osi_thead_work_queue_get()
113 assert (wq->queue != 0); in osi_thead_work_queue_put()
118 if (xQueueSend(wq->queue, item, portMAX_DELAY) != pdTRUE) { in osi_thead_work_queue_put()
[all …]
/hal_espressif-latest/components/bt/controller/esp32/
Dhli_api.c121 static inline char* IRAM_ATTR wrap_ptr(hli_queue_handle_t queue, char *ptr) in wrap_ptr() argument
123 return (ptr == queue->bufend) ? queue->buf : ptr; in wrap_ptr()
126 static inline bool IRAM_ATTR queue_empty(hli_queue_handle_t queue) in queue_empty() argument
128 return queue->begin == queue->end; in queue_empty()
131 static inline bool IRAM_ATTR queue_full(hli_queue_handle_t queue) in queue_full() argument
133 return wrap_ptr(queue, queue->end + queue->elem_size) == queue->begin; in queue_full()
140 hli_queue_handle_t queue; in queue_isr_handler() local
142 while (hli_queue_get(s_meta_queue_ptr, &queue)) { in queue_isr_handler()
144 while (hli_queue_get(queue, scratch)) { in queue_isr_handler()
146 if ((queue->flags & HLI_QUEUE_FLAG_CUSTOMER) != 0) { in queue_isr_handler()
[all …]
Dhli_api.h126 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);
Dbt.c137 void (* _queue_delete)(void *queue);
138 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
139 int32_t (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
140 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
141 int32_t (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
271 static void queue_delete_hlevel_wrapper(void *queue);
272 static int32_t queue_send_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms);
273 static int32_t queue_send_from_isr_hlevel_wrapper(void *queue, void *item, void *hptw);
274 static int32_t queue_recv_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms);
275 static int32_t queue_recv_from_isr_hlevel_wrapper(void *queue, void *item, void *hptw);
[all …]
/hal_espressif-latest/components/bt/common/osi/include/osi/
Dfixed_queue.h38 typedef void (*fixed_queue_cb)(fixed_queue_t *queue);
48 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb);
52 bool fixed_queue_is_empty(fixed_queue_t *queue);
56 size_t fixed_queue_length(fixed_queue_t *queue);
60 size_t fixed_queue_capacity(fixed_queue_t *queue);
64 bool fixed_queue_enqueue(fixed_queue_t *queue, void *data, uint32_t timeout);
69 void *fixed_queue_dequeue(fixed_queue_t *queue, uint32_t timeout);
74 void *fixed_queue_try_peek_first(fixed_queue_t *queue);
79 void *fixed_queue_try_peek_last(fixed_queue_t *queue);
86 void *fixed_queue_try_remove_from_queue(fixed_queue_t *queue, void *data);
[all …]
Dfixed_pkt_queue.h29 typedef void (*fixed_pkt_queue_cb)(fixed_pkt_queue_t *queue);
39 void fixed_pkt_queue_free(fixed_pkt_queue_t *queue, fixed_pkt_queue_free_cb free_cb);
43 bool fixed_pkt_queue_is_empty(fixed_pkt_queue_t *queue);
47 size_t fixed_pkt_queue_length(fixed_pkt_queue_t *queue);
51 size_t fixed_pkt_queue_capacity(fixed_pkt_queue_t *queue);
55 bool fixed_pkt_queue_enqueue(fixed_pkt_queue_t *queue, pkt_linked_item_t *linked_pkt, uint32_t time…
60 pkt_linked_item_t *fixed_pkt_queue_dequeue(fixed_pkt_queue_t *queue, uint32_t timeout);
65 pkt_linked_item_t *fixed_pkt_queue_try_peek_first(fixed_pkt_queue_t *queue);
71 void fixed_pkt_queue_register_dequeue(fixed_pkt_queue_t *queue, fixed_pkt_queue_cb ready_cb);
75 void fixed_pkt_queue_unregister_dequeue(fixed_pkt_queue_t *queue);
[all …]
Dpkt_queue.h42 bool pkt_queue_enqueue(struct pkt_queue *queue, pkt_linked_item_t *item);
49 pkt_linked_item_t *pkt_queue_dequeue(struct pkt_queue *queue);
56 pkt_linked_item_t *pkt_queue_try_peek_first(struct pkt_queue *queue);
63 size_t pkt_queue_length(const struct pkt_queue *queue);
70 bool pkt_queue_is_empty(const struct pkt_queue *queue);
76 void pkt_queue_flush(struct pkt_queue *queue, pkt_queue_free_cb free_cb);
82 void pkt_queue_destroy(struct pkt_queue *queue, pkt_queue_free_cb free_cb);
/hal_espressif-latest/components/esp_wifi/esp32s2/
Desp_adapter.c107 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
109 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
110 if (!queue) { in wifi_create_queue()
117 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
118 if (!queue->storage) { in wifi_create_queue()
122 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
124 if (!queue->handle) { in wifi_create_queue()
128 return queue; in wifi_create_queue()
131 if (queue) { in wifi_create_queue()
132 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-latest/components/esp_wifi/esp32/
Desp_adapter.c116 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
118 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
119 if (!queue) { in wifi_create_queue()
126 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
127 if (!queue->storage) { in wifi_create_queue()
131 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
133 if (!queue->handle) { in wifi_create_queue()
137 return queue; in wifi_create_queue()
140 if (queue) { in wifi_create_queue()
141 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-latest/components/esp_wifi/esp32s3/
Desp_adapter.c110 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
112 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
113 if (!queue) { in wifi_create_queue()
120 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
121 if (!queue->storage) { in wifi_create_queue()
125 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
127 if (!queue->handle) { in wifi_create_queue()
131 return queue; in wifi_create_queue()
134 if (queue) { in wifi_create_queue()
135 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-latest/zephyr/esp32c2/src/wifi/
Desp_wifi_adapter.c99 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
101 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
102 if (!queue) { in wifi_create_queue()
113 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
114 if (queue->handle == NULL) { in wifi_create_queue()
120 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
122 return queue; in wifi_create_queue()
125 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
127 if (queue) { in wifi_delete_queue()
128 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-latest/zephyr/esp32c3/src/wifi/
Desp_wifi_adapter.c99 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
101 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
102 if (!queue) { in wifi_create_queue()
113 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
114 if (queue->handle == NULL) { in wifi_create_queue()
120 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
122 return queue; in wifi_create_queue()
125 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
127 if (queue) { in wifi_delete_queue()
128 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-latest/zephyr/esp32c6/src/wifi/
Desp_wifi_adapter.c103 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
105 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
106 if (!queue) { in wifi_create_queue()
117 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
118 if (queue->handle == NULL) { in wifi_create_queue()
124 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
126 return queue; in wifi_create_queue()
129 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
131 if (queue) { in wifi_delete_queue()
132 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-latest/zephyr/esp32/src/wifi/
Desp_wifi_adapter.c97 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
99 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
100 if (!queue) { in wifi_create_queue()
111 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
112 if (queue->handle == NULL) { in wifi_create_queue()
118 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
120 return queue; in wifi_create_queue()
123 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
125 if (queue) { in wifi_delete_queue()
126 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-latest/zephyr/esp32s2/src/wifi/
Desp_wifi_adapter.c98 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
100 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
101 if (!queue) { in wifi_create_queue()
112 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
113 if (queue->handle == NULL) { in wifi_create_queue()
119 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
121 return queue; in wifi_create_queue()
124 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
126 if (queue) { in wifi_delete_queue()
127 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-latest/zephyr/esp32s3/src/wifi/
Desp_wifi_adapter.c100 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
102 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
103 if (!queue) { in wifi_create_queue()
114 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
115 if (queue->handle == NULL) { in wifi_create_queue()
121 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
123 return queue; in wifi_create_queue()
126 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
128 if (queue) { in wifi_delete_queue()
129 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-latest/components/esp_wifi/esp32c6/
Desp_adapter.c83 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
85 …queue = (wifi_static_queue_t *)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL |… in wifi_create_queue()
86 if (!queue) { in wifi_create_queue()
90 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
91 return queue; in wifi_create_queue()
94 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
96 if (queue) { in wifi_delete_queue()
97 vQueueDelete(queue->handle); in wifi_delete_queue()
98 free(queue); in wifi_delete_queue()
107 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
[all …]
/hal_espressif-latest/components/esp_wifi/esp32c2/
Desp_adapter.c77 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
79 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
80 if (!queue) { in wifi_create_queue()
84 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
85 return queue; in wifi_create_queue()
88 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
90 if (queue) { in wifi_delete_queue()
91 vQueueDelete(queue->handle); in wifi_delete_queue()
92 free(queue); in wifi_delete_queue()
101 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
[all …]
/hal_espressif-latest/components/esp_wifi/esp32c3/
Desp_adapter.c80 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
82 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
83 if (!queue) { in wifi_create_queue()
87 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
88 return queue; in wifi_create_queue()
91 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
93 if (queue) { in wifi_delete_queue()
94 vQueueDelete(queue->handle); in wifi_delete_queue()
95 free(queue); in wifi_delete_queue()
104 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
[all …]
/hal_espressif-latest/components/esp_event/host_test/
Dfixtures.hpp80 MockQueue (CreateAnd flags) : queue(reinterpret_cast<QueueHandle_t>(0xdeadbeef)) in MockQueue()
85 xQueueGenericCreate_IgnoreAndReturn(queue); in MockQueue()
88 xQueueGenericCreate_ExpectAnyArgsAndReturn(queue); in MockQueue()
89 vQueueDelete_Expect(queue); in MockQueue()
99 QueueHandle_t queue; member
/hal_espressif-latest/zephyr/esp32/src/bt/
Desp_bt_adapter.c89 struct k_msgq queue; member
113 void (*_queue_delete)(void *queue);
114 int32_t (*_queue_send)(void *queue, void *item, uint32_t block_time_ms);
115 int32_t (*_queue_send_from_isr)(void *queue, void *item, void *hptw);
116 int32_t (*_queue_recv)(void *queue, void *item, uint32_t block_time_ms);
117 int32_t (*_queue_recv_from_isr)(void *queue, void *item, void *hptw);
233 static void queue_delete_wrapper(void *queue);
234 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
235 static int32_t queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
236 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
[all …]
/hal_espressif-latest/components/esp_event/host_test/esp_event_unit_test/main/
Desp_event_test.cpp55 MockQueue queue(CreateAnd::IGNORE);
66 MockQueue queue(CreateAnd::FAIL);
78 MockQueue queue(CreateAnd::IGNORE);
90 MockQueue queue(CreateAnd::IGNORE);
102 MockQueue queue(CreateAnd::IGNORE);
124 MockQueue queue(CreateAnd::IGNORE);

123