Home
last modified time | relevance | path

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

123456

/hal_espressif-3.4.0/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 …]
/hal_espressif-3.4.0/components/bt/controller/esp32/
Dhli_api.c130 static inline char* IRAM_ATTR wrap_ptr(hli_queue_handle_t queue, char *ptr) in wrap_ptr() argument
132 return (ptr == queue->bufend) ? queue->buf : ptr; in wrap_ptr()
135 static inline bool IRAM_ATTR queue_empty(hli_queue_handle_t queue) in queue_empty() argument
137 return queue->begin == queue->end; in queue_empty()
140 static inline bool IRAM_ATTR queue_full(hli_queue_handle_t queue) in queue_full() argument
142 return wrap_ptr(queue, queue->end + queue->elem_size) == queue->begin; in queue_full()
149 hli_queue_handle_t queue; in queue_isr_handler() local
151 while (hli_queue_get(s_meta_queue_ptr, &queue)) { in queue_isr_handler()
153 while (hli_queue_get(queue, scratch)) { in queue_isr_handler()
155 if ((queue->flags & HLI_QUEUE_FLAG_CUSTOMER) != 0) { in queue_isr_handler()
[all …]
Dbt.c144 void (* _queue_delete)(void *queue);
145 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
146 int32_t (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
147 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
148 int32_t (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
269 static bool btdm_queue_generic_register(const btdm_queue_item_t *queue);
270 static bool btdm_queue_generic_deregister(btdm_queue_item_t *queue);
292 static void queue_delete_hlevel_wrapper(void *queue);
293 static int32_t IRAM_ATTR queue_send_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms);
294 static int32_t IRAM_ATTR queue_send_from_isr_hlevel_wrapper(void *queue, void *item, void *hptw);
[all …]
/hal_espressif-3.4.0/components/freertos/
Dlinker.lf93 queue: prvIsQueueFull (default)
94 queue: prvInitialiseNewQueue (default)
95 queue: prvInitialiseMutex (default)
96 queue: uxQueueSpacesAvailable (default)
97 queue: xQueueGenericReset (default)
98 queue: xQueueGenericCreate (default)
99 queue: xQueueGetMutexHolder (default)
100 queue: xQueueCreateCountingSemaphore (default)
101 queue: xQueueGenericSend (default)
102 queue: xQueueCreateMutex (default)
[all …]
/hal_espressif-3.4.0/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 …]
/hal_espressif-3.4.0/components/esp_wifi/esp32/
Desp_adapter.c118 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
120 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
121 if (!queue) { in wifi_create_queue()
127 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
128 if (!queue->storage) { in wifi_create_queue()
132 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
134 if (!queue->handle) { in wifi_create_queue()
138 return queue; in wifi_create_queue()
141 if (queue) { in wifi_create_queue()
142 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-3.4.0/components/esp_wifi/esp32s2/
Desp_adapter.c100 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
102 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
103 if (!queue) { in wifi_create_queue()
109 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
110 if (!queue->storage) { in wifi_create_queue()
114 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
116 if (!queue->handle) { in wifi_create_queue()
120 return queue; in wifi_create_queue()
123 if (queue) { in wifi_create_queue()
124 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-3.4.0/components/esp_wifi/esp32s3/
Desp_adapter.c108 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
110 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
111 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-3.4.0/components/freertos/test/
Dtest_preemption.c29 QueueHandle_t queue = (QueueHandle_t) param; in task_send_to_queue() local
36 xQueueSendToBack(queue, &ccount, 0); in task_send_to_queue()
51 QueueHandle_t queue = xQueueCreate(1, sizeof(uint32_t)); variable
56 …xTaskCreatePinnedToCore(task_send_to_queue, "YIELD", 2048, (void *)queue, UNITY_FREERTOS_PRIORITY …
62 TEST_ASSERT( xQueueReceive(queue, &yield_ccount, 100 / portTICK_PERIOD_MS) );
71 vQueueDelete(queue);
85 QueueHandle_t queue = xQueueCreate(1, sizeof(uint32_t)); variable
90 …xTaskCreatePinnedToCore(task_send_to_queue, "YIELD", 2048, (void *)queue, UNITY_FREERTOS_PRIORITY …
99 TEST_ASSERT( xQueueReceive(queue, &yield_ccount, 100 / portTICK_PERIOD_MS) );
107 vQueueDelete(queue);
/hal_espressif-3.4.0/zephyr/esp32c3/src/wifi/
Desp_wifi_adapter.c109 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
111 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
112 if (!queue) { in wifi_create_queue()
123 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
124 if (queue->handle == NULL) { in wifi_create_queue()
130 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
132 return queue; in wifi_create_queue()
135 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
137 if (queue) { in wifi_delete_queue()
138 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-3.4.0/zephyr/esp32/src/wifi/
Desp_wifi_adapter.c94 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
96 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
97 if (!queue) { in wifi_create_queue()
108 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
109 if (queue->handle == NULL) { in wifi_create_queue()
115 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
117 return queue; in wifi_create_queue()
120 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
122 if (queue) { in wifi_delete_queue()
123 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-3.4.0/zephyr/esp32s2/src/wifi/
Desp_wifi_adapter.c92 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
94 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
95 if (!queue) { in wifi_create_queue()
106 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
107 if (queue->handle == NULL) { in wifi_create_queue()
113 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
115 return queue; in wifi_create_queue()
118 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
120 if (queue) { in wifi_delete_queue()
121 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-3.4.0/zephyr/esp32s3/src/wifi/
Desp_wifi_adapter.c93 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
95 queue = (wifi_static_queue_t *) wifi_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
96 if (!queue) { in wifi_create_queue()
107 queue->handle = wifi_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
108 if (queue->handle == NULL) { in wifi_create_queue()
114 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
116 return queue; in wifi_create_queue()
119 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
121 if (queue) { in wifi_delete_queue()
122 esp_wifi_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-3.4.0/components/mdns/private_include/
Dmdns_private.h122 #define queueToEnd(type, queue, item) \ argument
123 if (!queue) { \
124 queue = item; \
126 type * _q = queue; \
131 #define queueDetach(type, queue, item) \ argument
132 if (queue) { \
133 if (queue == item) { \
134 queue = queue->next; \
136 type * _q = queue; \
147 #define queueFree(type, queue) while (queue) { type * _q = queue; queue = queue->next; free(_q); } argument
/hal_espressif-3.4.0/components/esp_wifi/esp32c3/
Desp_adapter.c76 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
78 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
79 if (!queue) { in wifi_create_queue()
83 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
84 return queue; in wifi_create_queue()
87 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
89 if (queue) { in wifi_delete_queue()
90 vQueueDelete(queue->handle); in wifi_delete_queue()
91 free(queue); in wifi_delete_queue()
100 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
[all …]
/hal_espressif-3.4.0/zephyr/esp32/src/bt/
Desp_bt_adapter.c83 struct k_msgq queue; member
107 void (*_queue_delete)(void *queue);
108 int32_t (*_queue_send)(void *queue, void *item, uint32_t block_time_ms);
109 int32_t (*_queue_send_from_isr)(void *queue, void *item, void *hptw);
110 int32_t (*_queue_recv)(void *queue, void *item, uint32_t block_time_ms);
111 int32_t (*_queue_recv_from_isr)(void *queue, void *item, void *hptw);
222 static void queue_delete_wrapper(void *queue);
223 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
224 static int32_t queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
225 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
[all …]
/hal_espressif-3.4.0/components/mdns/host_test/components/freertos_linux/
Dqueue_unique_ptr.cpp29 auto * queue = static_cast<QueueMock<std::vector<uint8_t>> *>(q); in destroy_q() local
30 delete(queue); in destroy_q()
37 auto queue = static_cast<QueueMock<std::vector<uint8_t>> *>(q); in send_q() local
38 queue->send(std::move(v)); in send_q()
44 auto queue = static_cast<QueueMock<std::vector<uint8_t>> *>(q); in recv_q() local
45 auto v = queue->receive(ms); in recv_q()
/hal_espressif-3.4.0/zephyr/esp32c3/src/bt/
Desp_bt_adapter.c109 struct k_msgq queue; member
135 void (* _queue_delete)(void *queue);
136 int (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
137 int (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
138 int (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
139 int (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
238 static void queue_delete_wrapper(void *queue);
239 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
240 static int queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
241 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
[all …]
/hal_espressif-3.4.0/zephyr/esp32s3/src/bt/
Desp_bt_adapter.c108 struct k_msgq queue; member
134 void (* _queue_delete)(void *queue);
135 int (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
136 int (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
137 int (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
138 int (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
237 static void queue_delete_wrapper(void *queue);
238 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
239 static int queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
240 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
[all …]
/hal_espressif-3.4.0/examples/system/sysview_tracing_heap_log/main/
Dsysview_heap_log.c23 QueueHandle_t queue = (QueueHandle_t)p; in free_task() local
26 if (xQueueReceive(queue, ( void * )&p, portMAX_DELAY) != pdPASS) { in free_task()
46 QueueHandle_t queue = xQueueCreate(10, sizeof(void *)); in alloc_task() local
47 if(queue == 0) { in alloc_task()
52 xTaskCreatePinnedToCore(free_task, task_name, 2500, queue, 5, NULL, portNUM_PROCESSORS-1); in alloc_task()
61 if (xQueueSend(queue, ( void * )&p, portMAX_DELAY) != pdPASS) { in alloc_task()
/hal_espressif-3.4.0/components/bt/host/bluedroid/stack/rfcomm/
Dport_utils.c131 p_port->tx.queue = fixed_queue_new(QUEUE_SIZE_MAX); in port_set_defaults()
132 p_port->rx.queue = fixed_queue_new(QUEUE_SIZE_MAX); in port_set_defaults()
213 if (p_port->rx.queue != NULL) { in port_release_port()
214 while ((p_buf = (BT_HDR *)fixed_queue_dequeue(p_port->rx.queue, 0)) != NULL) { in port_release_port()
220 if (p_port->tx.queue != NULL) { in port_release_port()
221 while ((p_buf = (BT_HDR *)fixed_queue_dequeue(p_port->tx.queue, 0)) != NULL) { in port_release_port()
240 fixed_queue_free(p_port->tx.queue, NULL); in port_release_port()
241 p_port->tx.queue = NULL; in port_release_port()
242 fixed_queue_free(p_port->rx.queue, NULL); in port_release_port()
243 p_port->rx.queue = NULL; in port_release_port()
[all …]
/hal_espressif-3.4.0/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-3.4.0/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);
/hal_espressif-3.4.0/components/esp_wifi/include/esp_private/
Dwifi_os_adapter.h50 void (* _queue_delete)(void *queue);
51 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_tick);
52 int32_t (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
53 int32_t (* _queue_send_to_back)(void *queue, void *item, uint32_t block_time_tick);
54 int32_t (* _queue_send_to_front)(void *queue, void *item, uint32_t block_time_tick);
55 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_tick);
56 uint32_t (* _queue_msg_waiting)(void *queue);
127 void (* _wifi_delete_queue)(void * queue);
/hal_espressif-3.4.0/components/bt/controller/esp32c3/
Dbt.c158 void (* _queue_delete)(void *queue);
159 int (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
160 int (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
161 int (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
162 int (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
288 static void queue_delete_wrapper(void *queue);
289 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
290 static int IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
291 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
292 static int IRAM_ATTR queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw);
[all …]

123456