Lines Matching refs:xQueue
1566 void vQueueDelete(QueueHandle_t xQueue) in vQueueDelete() argument
1570 configASSERT(xQueue != NULL); in vQueueDelete()
1572 ret = tx_semaphore_delete(&xQueue->read_sem); in vQueueDelete()
1577 ret = tx_semaphore_delete(&xQueue->write_sem); in vQueueDelete()
1582 if(xQueue->allocated == 1u) { in vQueueDelete()
1583 vPortFree(xQueue->p_mem); in vQueueDelete()
1584 vPortFree(xQueue); in vQueueDelete()
1588 BaseType_t xQueueSend(QueueHandle_t xQueue, in xQueueSend() argument
1596 configASSERT(xQueue != NULL); in xQueueSend()
1606 ret = tx_semaphore_get(&xQueue->write_sem, timeout); in xQueueSend()
1613 memcpy(xQueue->p_write, pvItemToQueue, xQueue->msg_size); in xQueueSend()
1614 if(xQueue->p_write >= (xQueue->p_mem + (xQueue->msg_size * (xQueue->queue_length - 1u)))) { in xQueueSend()
1615 xQueue->p_write = xQueue->p_mem; in xQueueSend()
1617 xQueue->p_write += xQueue->msg_size; in xQueueSend()
1622 ret = tx_semaphore_put(&xQueue->read_sem); in xQueueSend()
1628 if(xQueue->p_set != NULL) { in xQueueSend()
1630 ret = tx_queue_send(&xQueue->p_set->queue, &xQueue, TX_NO_WAIT); in xQueueSend()
1642 BaseType_t xQueueSendFromISR(QueueHandle_t xQueue, in xQueueSendFromISR() argument
1646 configASSERT(xQueue != NULL); in xQueueSendFromISR()
1649 return xQueueSend(xQueue, pvItemToQueue, 0u); in xQueueSendFromISR()
1652 BaseType_t xQueueSendToBack(QueueHandle_t xQueue, in xQueueSendToBack() argument
1656 configASSERT(xQueue != NULL); in xQueueSendToBack()
1659 return xQueueSend(xQueue, pvItemToQueue, xTicksToWait); in xQueueSendToBack()
1662 BaseType_t xQueueSendToBackFromISR(QueueHandle_t xQueue, in xQueueSendToBackFromISR() argument
1666 configASSERT(xQueue != NULL); in xQueueSendToBackFromISR()
1669 return xQueueSend(xQueue, pvItemToQueue, 0u); in xQueueSendToBackFromISR()
1672 BaseType_t xQueueSendToFront(QueueHandle_t xQueue, in xQueueSendToFront() argument
1681 configASSERT(xQueue != NULL); in xQueueSendToFront()
1690 if(xQueue->p_set != NULL) { in xQueueSendToFront()
1696 ret = tx_semaphore_get(&xQueue->write_sem, timeout); in xQueueSendToFront()
1704 if(xQueue->p_read == xQueue->p_mem) { in xQueueSendToFront()
1705 xQueue->p_read = xQueue->p_mem + (xQueue->msg_size * (xQueue->queue_length - 1u)); in xQueueSendToFront()
1707 xQueue->p_read -= xQueue->msg_size; in xQueueSendToFront()
1710 memcpy(xQueue->p_read, pvItemToQueue, xQueue->msg_size); in xQueueSendToFront()
1714 ret = tx_semaphore_put(&xQueue->read_sem); in xQueueSendToFront()
1716 if(xQueue->p_set != NULL) { in xQueueSendToFront()
1724 if(xQueue->p_set != NULL) { in xQueueSendToFront()
1726 ret = tx_queue_send(&xQueue->p_set->queue, &xQueue, TX_NO_WAIT); in xQueueSendToFront()
1744 BaseType_t xQueueSendToFrontFromISR(QueueHandle_t xQueue, in xQueueSendToFrontFromISR() argument
1748 configASSERT(xQueue != NULL); in xQueueSendToFrontFromISR()
1751 return xQueueSendToFront(xQueue, pvItemToQueue, 0u); in xQueueSendToFrontFromISR()
1754 BaseType_t xQueueReceive(QueueHandle_t xQueue, in xQueueReceive() argument
1762 configASSERT(xQueue != NULL); in xQueueReceive()
1772 ret = tx_semaphore_get(&xQueue->read_sem, timeout); in xQueueReceive()
1779 memcpy(pvBuffer, xQueue->p_read, xQueue->msg_size); in xQueueReceive()
1780 if(xQueue->p_read >= (xQueue->p_mem + (xQueue->msg_size * (xQueue->queue_length - 1u)))) { in xQueueReceive()
1781 xQueue->p_read = xQueue->p_mem; in xQueueReceive()
1783 xQueue->p_read += xQueue->msg_size; in xQueueReceive()
1788 ret = tx_semaphore_put(&xQueue->write_sem); in xQueueReceive()
1797 BaseType_t xQueueReceiveFromISR(QueueHandle_t xQueue, in xQueueReceiveFromISR() argument
1803 configASSERT(xQueue != NULL); in xQueueReceiveFromISR()
1806 ret = xQueueReceive(xQueue, pvBuffer, 0u); in xQueueReceiveFromISR()
1811 BaseType_t xQueuePeek(QueueHandle_t xQueue, in xQueuePeek() argument
1819 configASSERT(xQueue != NULL); in xQueuePeek()
1829 ret = tx_semaphore_get(&xQueue->read_sem, timeout); in xQueuePeek()
1838 memcpy(pvBuffer, xQueue->p_read, xQueue->msg_size); in xQueuePeek()
1841 ret = tx_semaphore_put(&xQueue->read_sem); in xQueuePeek()
1853 BaseType_t xQueuePeekFromISR(QueueHandle_t xQueue, in xQueuePeekFromISR() argument
1856 configASSERT(xQueue != NULL); in xQueuePeekFromISR()
1859 return xQueuePeek(xQueue, pvBuffer, 0u); in xQueuePeekFromISR()
1862 UBaseType_t uxQueueMessagesWaiting(QueueHandle_t xQueue) in uxQueueMessagesWaiting() argument
1867 configASSERT(xQueue != NULL); in uxQueueMessagesWaiting()
1869 ret = tx_semaphore_info_get(&xQueue->read_sem, NULL, &count, NULL, NULL, NULL); in uxQueueMessagesWaiting()
1878 UBaseType_t uxQueueMessagesWaitingFromISR(QueueHandle_t xQueue) in uxQueueMessagesWaitingFromISR() argument
1880 configASSERT(xQueue != NULL); in uxQueueMessagesWaitingFromISR()
1882 return uxQueueMessagesWaiting(xQueue); in uxQueueMessagesWaitingFromISR()
1885 UBaseType_t uxQueueSpacesAvailable(QueueHandle_t xQueue) in uxQueueSpacesAvailable() argument
1890 configASSERT(xQueue != NULL); in uxQueueSpacesAvailable()
1892 ret = tx_semaphore_info_get(&xQueue->write_sem, NULL, &count, NULL, NULL, NULL); in uxQueueSpacesAvailable()
1901 BaseType_t xQueueIsQueueEmptyFromISR(const QueueHandle_t xQueue) in xQueueIsQueueEmptyFromISR() argument
1906 configASSERT(xQueue != NULL); in xQueueIsQueueEmptyFromISR()
1908 ret = tx_semaphore_info_get(&xQueue->read_sem, NULL, &count, NULL, NULL, NULL); in xQueueIsQueueEmptyFromISR()
1921 BaseType_t xQueueIsQueueFullFromISR(const QueueHandle_t xQueue) in xQueueIsQueueFullFromISR() argument
1926 configASSERT(xQueue != NULL); in xQueueIsQueueFullFromISR()
1928 ret = tx_semaphore_info_get(&xQueue->write_sem, NULL, &count, NULL, NULL, NULL); in xQueueIsQueueFullFromISR()
1942 BaseType_t xQueueReset(QueueHandle_t xQueue) in xQueueReset() argument
1948 configASSERT(xQueue != NULL); in xQueueReset()
1955 xQueue->p_write = xQueue->p_mem; in xQueueReset()
1956 xQueue->p_read = xQueue->p_mem; in xQueueReset()
1959 xQueue->read_sem.tx_semaphore_count = 0u; in xQueueReset()
1962 if(xQueue->write_sem.tx_semaphore_count != xQueue->queue_length) { in xQueueReset()
1964 xQueue->write_sem.tx_semaphore_count = xQueue->queue_length - 1u; in xQueueReset()
1972 ret = tx_semaphore_put(&xQueue->write_sem); in xQueueReset()
1985 BaseType_t xQueueOverwrite(QueueHandle_t xQueue, in xQueueOverwrite() argument
1993 configASSERT(xQueue != NULL); in xQueueOverwrite()
1999 if(xQueue->read_sem.tx_semaphore_count != 0u) { in xQueueOverwrite()
2001 p_write_temp = xQueue->p_write; in xQueueOverwrite()
2002 if(p_write_temp == xQueue->p_mem) { in xQueueOverwrite()
2003 p_write_temp = (xQueue->p_mem + (xQueue->msg_size * (xQueue->queue_length - 1u))); in xQueueOverwrite()
2005 p_write_temp -= xQueue->msg_size; in xQueueOverwrite()
2008 memcpy(p_write_temp, pvItemToQueue, xQueue->msg_size); in xQueueOverwrite()
2010 memcpy(xQueue->p_write, pvItemToQueue, xQueue->msg_size); in xQueueOverwrite()
2011 if(xQueue->p_write >= (xQueue->p_mem + (xQueue->msg_size * (xQueue->queue_length - 1u)))) { in xQueueOverwrite()
2012 xQueue->p_write = xQueue->p_mem; in xQueueOverwrite()
2014 xQueue->p_write += xQueue->msg_size; in xQueueOverwrite()
2023 ret = tx_semaphore_put(&xQueue->read_sem); in xQueueOverwrite()
2034 BaseType_t xQueueOverwriteFromISR(QueueHandle_t xQueue, in xQueueOverwriteFromISR() argument
2038 configASSERT(xQueue != NULL); in xQueueOverwriteFromISR()
2041 return xQueueOverwrite(xQueue, pvItemToQueue); in xQueueOverwriteFromISR()