Lines Matching refs:queue

83     wifi_static_queue_t *queue = NULL;  in wifi_create_queue()  local
85queue = (wifi_static_queue_t *)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL |… in wifi_create_queue()
86 if (!queue) { in wifi_create_queue()
90 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
91 return queue; in wifi_create_queue()
94 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
96 if (queue) { in wifi_delete_queue()
97 vQueueDelete(queue->handle); in wifi_delete_queue()
98 free(queue); in wifi_delete_queue()
107 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
109 wifi_delete_queue(queue); in wifi_delete_queue_wrapper()
209 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_wrapper() argument
212 return (int32_t)xQueueSend(queue, item, portMAX_DELAY); in queue_send_wrapper()
214 return (int32_t)xQueueSend(queue, item, block_time_tick); in queue_send_wrapper()
218 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_send_from_isr_wrapper() argument
220 return (int32_t)xQueueSendFromISR(queue, item, hptw); in queue_send_from_isr_wrapper()
223 static int32_t queue_send_to_back_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_to_back_wrapper() argument
225 return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_BACK); in queue_send_to_back_wrapper()
228 static int32_t queue_send_to_front_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_to_front_wrapper() argument
230 return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_FRONT); in queue_send_to_front_wrapper()
233 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_recv_wrapper() argument
236 return (int32_t)xQueueReceive(queue, item, portMAX_DELAY); in queue_recv_wrapper()
238 return (int32_t)xQueueReceive(queue, item, block_time_tick); in queue_recv_wrapper()