Lines Matching refs:queue
861 cy_rslt_t cy_rtos_queue_init(cy_queue_t* queue, size_t length, size_t itemsize) in cy_rtos_queue_init() argument
866 if (queue == NULL) in cy_rtos_queue_init()
894 *queue = osMessageQueueNew(length, itemsize, &attr); in cy_rtos_queue_init()
895 CY_ASSERT((*queue == attr.cb_mem) || (*queue == NULL)); in cy_rtos_queue_init()
896 status = (*queue == NULL) ? CY_RTOS_GENERAL_ERROR : CY_RSLT_SUCCESS; in cy_rtos_queue_init()
907 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
913 if ((queue == NULL) || (item_ptr == NULL)) in cy_rtos_queue_put()
922 statusInternal = osMessageQueuePut(*queue, (uint8_t*)item_ptr, 0u, timeout_ms); in cy_rtos_queue_put()
939 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
945 if ((queue == NULL) || (item_ptr == NULL)) in cy_rtos_queue_get()
954 statusInternal = osMessageQueueGet(*queue, (uint8_t*)item_ptr, NULL, timeout_ms); in cy_rtos_queue_get()
971 cy_rslt_t cy_rtos_queue_count(cy_queue_t* queue, size_t* num_waiting) in cy_rtos_queue_count() argument
975 if ((queue == NULL) || (num_waiting == NULL)) in cy_rtos_queue_count()
981 *num_waiting = osMessageQueueGetCount(*queue); in cy_rtos_queue_count()
991 cy_rslt_t cy_rtos_queue_space(cy_queue_t* queue, size_t* num_spaces) in cy_rtos_queue_space() argument
995 if ((queue == NULL) || (num_spaces == NULL)) in cy_rtos_queue_space()
1001 *num_spaces = osMessageQueueGetSpace(*queue); in cy_rtos_queue_space()
1011 cy_rslt_t cy_rtos_queue_reset(cy_queue_t* queue) in cy_rtos_queue_reset() argument
1016 if (queue == NULL) in cy_rtos_queue_reset()
1022 statusInternal = osMessageQueueReset(*queue); in cy_rtos_queue_reset()
1033 cy_rslt_t cy_rtos_queue_deinit(cy_queue_t* queue) in cy_rtos_queue_deinit() argument
1038 if (queue == NULL) in cy_rtos_queue_deinit()
1044 statusInternal = osMessageQueueDelete(*queue); in cy_rtos_queue_deinit()
1049 free(*queue); in cy_rtos_queue_deinit()
1050 *queue = NULL; in cy_rtos_queue_deinit()