103 	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()
133 		esp_wifi_free(queue);  in wifi_delete_queue()
142 static void wifi_delete_queue_wrapper(void *queue)  in wifi_delete_queue_wrapper()  argument
144 	wifi_delete_queue(queue);  in wifi_delete_queue_wrapper()
214 	struct k_queue *queue = (struct k_queue *) wifi_malloc(sizeof(struct k_queue));  in queue_create_wrapper()  local
216 	if (queue == NULL) {  in queue_create_wrapper()
221 	k_msgq_init((struct k_msgq *)queue, wifi_msgq_buffer, item_size, queue_len);  in queue_create_wrapper()
223 	return (void *)queue;  in queue_create_wrapper()
242 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_send_wrapper()  argument
245 		k_msgq_put((struct k_msgq *)queue, item, K_FOREVER);  in queue_send_wrapper()
247 		k_msgq_put((struct k_msgq *)queue, item, K_TICKS(block_time_tick));  in queue_send_wrapper()
252 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw)  in queue_send_from_isr_wrapper()  argument
256 	k_msgq_put((struct k_msgq *)queue, item, K_NO_WAIT);  in queue_send_from_isr_wrapper()
261 int32_t queue_send_to_back_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_send_to_back_wrapper()  argument
263 	ARG_UNUSED(queue);  in queue_send_to_back_wrapper()
270 int32_t queue_send_to_front_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_send_to_front_wrapper()  argument
272 	ARG_UNUSED(queue);  in queue_send_to_front_wrapper()
279 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_tick)  in queue_recv_wrapper()  argument
282 		k_msgq_get((struct k_msgq *)queue, item, K_FOREVER);  in queue_recv_wrapper()
284 		k_msgq_get((struct k_msgq *)queue, item, K_MSEC(block_time_tick));  in queue_recv_wrapper()
389 uint32_t uxQueueMessagesWaiting(void *queue)  in uxQueueMessagesWaiting()  argument
391 	ARG_UNUSED(queue);  in uxQueueMessagesWaiting()