Lines Matching refs:queue

77     wifi_static_queue_t *queue = NULL;  in wifi_create_queue()  local
79queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
80 if (!queue) { in wifi_create_queue()
84 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
85 return queue; in wifi_create_queue()
88 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
90 if (queue) { in wifi_delete_queue()
91 vQueueDelete(queue->handle); in wifi_delete_queue()
92 free(queue); in wifi_delete_queue()
101 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
103 wifi_delete_queue(queue); in wifi_delete_queue_wrapper()
203 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_wrapper() argument
206 return (int32_t)xQueueSend(queue, item, portMAX_DELAY); in queue_send_wrapper()
208 return (int32_t)xQueueSend(queue, item, block_time_tick); in queue_send_wrapper()
212 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_send_from_isr_wrapper() argument
214 return (int32_t)xQueueSendFromISR(queue, item, hptw); in queue_send_from_isr_wrapper()
217 static int32_t queue_send_to_back_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_to_back_wrapper() argument
219 return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_BACK); in queue_send_to_back_wrapper()
222 static int32_t queue_send_to_front_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_send_to_front_wrapper() argument
224 return (int32_t)xQueueGenericSend(queue, item, block_time_tick, queueSEND_TO_FRONT); in queue_send_to_front_wrapper()
227 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_tick) in queue_recv_wrapper() argument
230 return (int32_t)xQueueReceive(queue, item, portMAX_DELAY); in queue_recv_wrapper()
232 return (int32_t)xQueueReceive(queue, item, block_time_tick); in queue_recv_wrapper()