89 	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);
237 static int32_t queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw);
556 	struct bt_queue_t *queue = esp_bt_malloc_func(sizeof(struct bt_queue_t));  in queue_create_wrapper()  local
558 	if (queue == NULL) {  in queue_create_wrapper()
563 	queue->pool = (uint8_t *)esp_bt_malloc_func(queue_len * item_size * sizeof(uint8_t));  in queue_create_wrapper()
565 	if (queue->pool == NULL) {  in queue_create_wrapper()
567 		esp_bt_free(queue);  in queue_create_wrapper()
571 	k_msgq_init(&queue->queue, queue->pool, item_size, queue_len);  in queue_create_wrapper()
572 	return queue;  in queue_create_wrapper()
575 static void queue_delete_wrapper(void *queue)  in queue_delete_wrapper()  argument
577 	struct bt_queue_t *q = (struct bt_queue_t *) queue;  in queue_delete_wrapper()
585 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms)  in queue_send_wrapper()  argument
590 		res = k_msgq_put(queue, item, K_FOREVER);  in queue_send_wrapper()
592 		res = k_msgq_put(queue, item, K_MSEC(block_time_ms));  in queue_send_wrapper()
602 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw)  in queue_send_from_isr_wrapper()  argument
605 	int ret = k_msgq_put(queue, item, K_NO_WAIT);  in queue_send_from_isr_wrapper()
616 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms)  in queue_recv_wrapper()  argument
621 		ret = k_msgq_get(queue, item, K_FOREVER);  in queue_recv_wrapper()
623 		ret = k_msgq_get(queue, item, K_MSEC(block_time_ms));  in queue_recv_wrapper()
633 static int32_t IRAM_ATTR queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw)  in queue_recv_from_isr_wrapper()  argument
636 	int ret = k_msgq_get(queue, item, K_NO_WAIT);  in queue_recv_from_isr_wrapper()