Lines Matching refs:queue
80 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
82 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
83 if (!queue) { in wifi_create_queue()
87 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
88 return queue; in wifi_create_queue()
91 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
93 if (queue) { in wifi_delete_queue()
94 vQueueDelete(queue->handle); in wifi_delete_queue()
95 free(queue); in wifi_delete_queue()
104 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
106 wifi_delete_queue(queue); in wifi_delete_queue_wrapper()
206 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_wrapper() argument
209 return (int32_t)xQueueSend(queue, item, portMAX_DELAY); in queue_send_wrapper()
211 return (int32_t)xQueueSend(queue, item, block_time_tick); in queue_send_wrapper()
215 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_send_from_isr_wrapper() argument
217 return (int32_t)xQueueSendFromISR(queue, item, hptw); in queue_send_from_isr_wrapper()
220 static int32_t queue_send_to_back_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_to_back_wrapper() argument
222 return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_BACK); in queue_send_to_back_wrapper()
225 static int32_t queue_send_to_front_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_to_front_wrapper() argument
227 return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_FRONT); in queue_send_to_front_wrapper()
230 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_recv_wrapper() argument
233 return (int32_t)xQueueReceive(queue, item, portMAX_DELAY); in queue_recv_wrapper()
235 return (int32_t)xQueueReceive(queue, item, block_time_tick); in queue_recv_wrapper()