Lines Matching refs:queue

137     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);
278 static void queue_delete_wrapper(void *queue);
279 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
280 static int32_t queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
281 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
282 static int32_t queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw);
681 btdm_queue_item_t *queue = NULL; in queue_create_wrapper() local
683queue = (btdm_queue_item_t*)heap_caps_malloc(sizeof(btdm_queue_item_t), MALLOC_CAP_INTERNAL|MALLOC… in queue_create_wrapper()
684 assert(queue); in queue_create_wrapper()
687 queue->handle = xQueueCreate( queue_len, item_size); in queue_create_wrapper()
688 assert(queue->handle); in queue_create_wrapper()
690 return queue; in queue_create_wrapper()
693 static void queue_delete_wrapper(void *queue) in queue_delete_wrapper() argument
695 btdm_queue_item_t *queue_item = (btdm_queue_item_t *)queue; in queue_delete_wrapper()
711 hli_queue_handle_t queue = hli_queue_create(queue_len, item_size, downstream_queue); in queue_create_hlevel_wrapper() local
712 assert(queue); in queue_create_hlevel_wrapper()
713 queue_item->handle = queue; in queue_create_hlevel_wrapper()
723 hli_queue_handle_t queue = hli_customer_queue_create(queue_len, item_size, downstream_queue); in customer_queue_create_hlevel_wrapper() local
724 assert(queue); in customer_queue_create_hlevel_wrapper()
725 queue_item->handle = queue; in customer_queue_create_hlevel_wrapper()
729 static void queue_delete_hlevel_wrapper(void *queue) in queue_delete_hlevel_wrapper() argument
731 if (queue == NULL) { in queue_delete_hlevel_wrapper()
735 btdm_queue_item_t *queue_item = (btdm_queue_item_t *)queue; in queue_delete_hlevel_wrapper()
745 static int32_t queue_send_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_send_hlevel_wrapper() argument
747 void *handle = ((btdm_queue_item_t *)queue)->handle; in queue_send_hlevel_wrapper()
766 static int32_t IRAM_ATTR queue_send_from_isr_hlevel_wrapper(void *queue, void *item, void *hptw) in queue_send_from_isr_hlevel_wrapper() argument
770 void *handle = ((btdm_queue_item_t *)queue)->handle; in queue_send_from_isr_hlevel_wrapper()
774 static int32_t queue_recv_hlevel_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_recv_hlevel_wrapper() argument
777 void *handle = ((btdm_queue_item_t *)queue)->handle; in queue_recv_hlevel_wrapper()
787 static int32_t IRAM_ATTR queue_recv_from_isr_hlevel_wrapper(void *queue, void *item, void *hptw) in queue_recv_from_isr_hlevel_wrapper() argument
796 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_send_wrapper() argument
799 return (int32_t)xQueueSend(((btdm_queue_item_t*)queue)->handle, item, portMAX_DELAY); in queue_send_wrapper()
801 …return (int32_t)xQueueSend(((btdm_queue_item_t*)queue)->handle, item, block_time_ms / portTICK_PER… in queue_send_wrapper()
805 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_send_from_isr_wrapper() argument
807 return (int32_t)xQueueSendFromISR(((btdm_queue_item_t*)queue)->handle, item, hptw); in queue_send_from_isr_wrapper()
810 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_recv_wrapper() argument
814 ret = xQueueReceive(((btdm_queue_item_t*)queue)->handle, item, portMAX_DELAY); in queue_recv_wrapper()
816 …ret = xQueueReceive(((btdm_queue_item_t*)queue)->handle, item, block_time_ms / portTICK_PERIOD_MS); in queue_recv_wrapper()
822 static int32_t IRAM_ATTR queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_recv_from_isr_wrapper() argument
824 return (int32_t)xQueueReceiveFromISR(((btdm_queue_item_t*)queue)->handle, item, hptw); in queue_recv_from_isr_wrapper()