759 cy_rslt_t cy_rtos_queue_init(cy_queue_t* queue, size_t length, size_t itemsize)  in cy_rtos_queue_init()  argument
764     if ((queue == NULL) || (itemsize == 0) ||  in cy_rtos_queue_init()
777     queue->itemsize = itemsize;  in cy_rtos_queue_init()
779     queue->mem = malloc(queue_size);  in cy_rtos_queue_init()
780     if (queue->mem == NULL)  in cy_rtos_queue_init()
785     cy_rtos_error_t tx_rslt = tx_queue_create(&(queue->tx_queue), TX_NULL, message_words,  in cy_rtos_queue_init()
786                                               queue->mem, queue_size);  in cy_rtos_queue_init()
790         free(queue->mem);  in cy_rtos_queue_init()
801 cy_rslt_t cy_rtos_queue_put(cy_queue_t* queue, const void* item_ptr, cy_time_t timeout_ms)  in cy_rtos_queue_put()  argument
803     if ((queue == NULL) || (item_ptr == NULL) || (is_in_isr() && (timeout_ms != 0)))  in cy_rtos_queue_put()
808 …  cy_rtos_error_t tx_rslt = tx_queue_send(&(queue->tx_queue), (void*)item_ptr, convert_ms_to_ticks(  in cy_rtos_queue_put()
824 cy_rslt_t cy_rtos_queue_get(cy_queue_t* queue, void* item_ptr, cy_time_t timeout_ms)  in cy_rtos_queue_get()  argument
827     if ((queue == NULL) || (item_ptr == NULL) || (is_in_isr() && (timeout_ms != 0)))  in cy_rtos_queue_get()
833         tx_queue_receive(&(queue->tx_queue), buffer, convert_ms_to_ticks(timeout_ms));  in cy_rtos_queue_get()
840         memcpy(item_ptr, (void*)buffer, queue->itemsize);  in cy_rtos_queue_get()
854 cy_rslt_t cy_rtos_queue_count(cy_queue_t* queue, size_t* num_waiting)  in cy_rtos_queue_count()  argument
856     if ((queue == NULL) || (num_waiting == NULL))  in cy_rtos_queue_count()
860     return convert_error(tx_queue_info_get(&(queue->tx_queue), TX_NULL, (ULONG*)num_waiting,  in cy_rtos_queue_count()
868 cy_rslt_t cy_rtos_queue_space(cy_queue_t* queue, size_t* num_spaces)  in cy_rtos_queue_space()  argument
870     if ((queue == NULL) || (num_spaces == NULL))  in cy_rtos_queue_space()
874     return convert_error(tx_queue_info_get(&(queue->tx_queue), TX_NULL, TX_NULL, (ULONG*)num_spaces,  in cy_rtos_queue_space()
882 cy_rslt_t cy_rtos_queue_reset(cy_queue_t* queue)  in cy_rtos_queue_reset()  argument
884     if (queue == NULL)  in cy_rtos_queue_reset()
888     return convert_error(tx_queue_flush(&(queue->tx_queue)));  in cy_rtos_queue_reset()
895 cy_rslt_t cy_rtos_queue_deinit(cy_queue_t* queue)  in cy_rtos_queue_deinit()  argument
897     if (queue == NULL)  in cy_rtos_queue_deinit()
901     cy_rslt_t result = convert_error(tx_queue_delete(&(queue->tx_queue)));  in cy_rtos_queue_deinit()
904         free(queue->mem);  in cy_rtos_queue_deinit()