116     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()
142             free(queue->storage);  in wifi_create_queue()
145         free(queue);  in wifi_create_queue()
150     queue->handle = xQueueCreate( queue_len, item_size);  in wifi_create_queue()
151     return queue;  in wifi_create_queue()
155 void wifi_delete_queue(wifi_static_queue_t *queue)  in wifi_delete_queue()  argument
157     if (queue) {  in wifi_delete_queue()
158         vQueueDelete(queue->handle);  in wifi_delete_queue()
161         if (queue->storage) {  in wifi_delete_queue()
162             free(queue->storage);  in wifi_delete_queue()
166         free(queue);  in wifi_delete_queue()
175 static void wifi_delete_queue_wrapper(void *queue)  in wifi_delete_queue_wrapper()  argument
177     wifi_delete_queue(queue);  in wifi_delete_queue_wrapper()
278 static void queue_delete_wrapper(void *queue)  in queue_delete_wrapper()  argument
280     if (queue) {  in queue_delete_wrapper()
282         xQueueGetStaticBuffers(queue, NULL, &queue_buffer);  in queue_delete_wrapper()
283         vQueueDelete(queue);  in queue_delete_wrapper()
290 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_send_wrapper()  argument
293         return (int32_t)xQueueSend(queue, item, portMAX_DELAY);  in queue_send_wrapper()
295         return (int32_t)xQueueSend(queue, item, block_time_tick);  in queue_send_wrapper()
299 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw)  in queue_send_from_isr_wrapper()  argument
301     return (int32_t)xQueueSendFromISR(queue, item, hptw);  in queue_send_from_isr_wrapper()
304 static int32_t queue_send_to_back_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_send_to_back_wrapper()  argument
306     return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_BACK);  in queue_send_to_back_wrapper()
309 static int32_t queue_send_to_front_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_send_to_front_wrapper()  argument
311     return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_FRONT);  in queue_send_to_front_wrapper()
314 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_recv_wrapper()  argument
317         return (int32_t)xQueueReceive(queue, item, portMAX_DELAY);  in queue_recv_wrapper()
319         return (int32_t)xQueueReceive(queue, item, block_time_tick);  in queue_recv_wrapper()