Lines Matching refs:queue
165 void (* _queue_delete)(void *queue);
166 int (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
167 int (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
168 int (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
169 int (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
295 static void queue_delete_wrapper(void *queue);
296 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
297 static int IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
298 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
299 static int IRAM_ATTR queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw);
546 static void queue_delete_wrapper(void *queue) in queue_delete_wrapper() argument
548 vQueueDelete(queue); in queue_delete_wrapper()
551 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_send_wrapper() argument
554 return (int)xQueueSend(queue, item, portMAX_DELAY); in queue_send_wrapper()
556 return (int)xQueueSend(queue, item, block_time_ms / portTICK_PERIOD_MS); in queue_send_wrapper()
560 static int IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_send_from_isr_wrapper() argument
562 return (int)xQueueSendFromISR(queue, item, hptw); in queue_send_from_isr_wrapper()
565 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms) in queue_recv_wrapper() argument
568 return (int)xQueueReceive(queue, item, portMAX_DELAY); in queue_recv_wrapper()
570 return (int)xQueueReceive(queue, item, block_time_ms / portTICK_PERIOD_MS); in queue_recv_wrapper()
574 static int IRAM_ATTR queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw) in queue_recv_from_isr_wrapper() argument
576 return (int)xQueueReceiveFromISR(queue, item, hptw); in queue_recv_from_isr_wrapper()