Lines Matching refs:queue

925 cy_rslt_t cy_rtos_queue_init(cy_queue_t* queue, size_t length, size_t itemsize)  in cy_rtos_queue_init()  argument
928 if (queue == NULL) in cy_rtos_queue_init()
934 *queue = xQueueCreate(length, itemsize); in cy_rtos_queue_init()
935 if (*queue == NULL) in cy_rtos_queue_init()
954 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
957 if ((queue == NULL) || (item_ptr == NULL)) in cy_rtos_queue_put()
967 ret = xQueueSendToBackFromISR(*queue, item_ptr, &xHigherPriorityTaskWoken); in cy_rtos_queue_put()
976 ret = xQueueSendToBack(*queue, item_ptr, ticks); in cy_rtos_queue_put()
1003 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
1006 if ((queue == NULL) || (item_ptr == NULL)) in cy_rtos_queue_get()
1016 ret = xQueueReceiveFromISR(*queue, item_ptr, &xHigherPriorityTaskWoken); in cy_rtos_queue_get()
1025 ret = xQueueReceive(*queue, item_ptr, ticks); in cy_rtos_queue_get()
1049 cy_rslt_t cy_rtos_queue_count(cy_queue_t* queue, size_t* num_waiting) in cy_rtos_queue_count() argument
1052 if ((queue == NULL) || (num_waiting == NULL)) in cy_rtos_queue_count()
1059 ? uxQueueMessagesWaitingFromISR(*queue) in cy_rtos_queue_count()
1060 : uxQueueMessagesWaiting(*queue); in cy_rtos_queue_count()
1070 cy_rslt_t cy_rtos_queue_space(cy_queue_t* queue, size_t* num_spaces) in cy_rtos_queue_space() argument
1073 if ((queue == NULL) || (num_spaces == NULL)) in cy_rtos_queue_space()
1079 *num_spaces = uxQueueSpacesAvailable(*queue); in cy_rtos_queue_space()
1089 cy_rslt_t cy_rtos_queue_reset(cy_queue_t* queue) in cy_rtos_queue_reset() argument
1092 if (queue == NULL) in cy_rtos_queue_reset()
1098 BaseType_t ret = xQueueReset(*queue); in cy_rtos_queue_reset()
1116 cy_rslt_t cy_rtos_queue_deinit(cy_queue_t* queue) in cy_rtos_queue_deinit() argument
1119 if (queue == NULL) in cy_rtos_queue_deinit()
1125 vQueueDelete(*queue); in cy_rtos_queue_deinit()