Lines Matching refs:pxQueue
176 static void prvUnlockQueue( Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
183 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) PRIVILEGED_FUNCTION;
190 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) PRIVILEGED_FUNCTION;
196 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue,
203 static void prvCopyDataFromQueue( Queue_t * const pxQueue,
212 … static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
243 …static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) PRIVILEGE…
251 #define prvLockQueue( pxQueue ) \ argument
254 if( ( pxQueue )->cRxLock == queueUNLOCKED ) \
256 ( pxQueue )->cRxLock = queueLOCKED_UNMODIFIED; \
258 if( ( pxQueue )->cTxLock == queueUNLOCKED ) \
260 ( pxQueue )->cTxLock = queueLOCKED_UNMODIFIED; \
270 #define prvIncrementQueueTxLock( pxQueue, cTxLock ) \ argument
276 ( pxQueue )->cTxLock = ( int8_t ) ( ( cTxLock ) + ( int8_t ) 1 ); \
285 #define prvIncrementQueueRxLock( pxQueue, cRxLock ) \ argument
291 ( pxQueue )->cRxLock = ( int8_t ) ( ( cRxLock ) + ( int8_t ) 1 ); \
300 Queue_t * const pxQueue = xQueue; in xQueueGenericReset() local
302 configASSERT( pxQueue ); in xQueueGenericReset()
304 if( ( pxQueue != NULL ) && in xQueueGenericReset()
305 ( pxQueue->uxLength >= 1U ) && in xQueueGenericReset()
307 ( ( SIZE_MAX / pxQueue->uxLength ) >= pxQueue->uxItemSize ) ) in xQueueGenericReset()
311 …pxQueue->u.xQueue.pcTail = pxQueue->pcHead + ( pxQueue->uxLength * pxQueue->uxItemSize ); /*lint !… in xQueueGenericReset()
312 pxQueue->uxMessagesWaiting = ( UBaseType_t ) 0U; in xQueueGenericReset()
313 pxQueue->pcWriteTo = pxQueue->pcHead; in xQueueGenericReset()
314 …pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead + ( ( pxQueue->uxLength - 1U ) * pxQueue->uxItemSiz… in xQueueGenericReset()
315 pxQueue->cRxLock = queueUNLOCKED; in xQueueGenericReset()
316 pxQueue->cTxLock = queueUNLOCKED; in xQueueGenericReset()
325 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueGenericReset()
327 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueGenericReset()
344 vListInitialise( &( pxQueue->xTasksWaitingToSend ) ); in xQueueGenericReset()
345 vListInitialise( &( pxQueue->xTasksWaitingToReceive ) ); in xQueueGenericReset()
433 Queue_t * const pxQueue = xQueue; in xQueueGenericGetStaticBuffers() local
435 configASSERT( pxQueue ); in xQueueGenericGetStaticBuffers()
441 if( pxQueue->ucStaticallyAllocated == ( uint8_t ) pdTRUE ) in xQueueGenericGetStaticBuffers()
445 *ppucQueueStorage = ( uint8_t * ) pxQueue->pcHead; in xQueueGenericGetStaticBuffers()
448 *ppxStaticQueue = ( StaticQueue_t * ) pxQueue; in xQueueGenericGetStaticBuffers()
461 *ppucQueueStorage = ( uint8_t * ) pxQueue->pcHead; in xQueueGenericGetStaticBuffers()
464 *ppxStaticQueue = ( StaticQueue_t * ) pxQueue; in xQueueGenericGetStaticBuffers()
891 Queue_t * const pxQueue = xQueue; in xQueueGenericSend() local
893 configASSERT( pxQueue ); in xQueueGenericSend()
894 configASSERT( !( ( pvItemToQueue == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueGenericSend()
895 configASSERT( !( ( xCopyPosition == queueOVERWRITE ) && ( pxQueue->uxLength != 1 ) ) ); in xQueueGenericSend()
913 … if( ( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) || ( xCopyPosition == queueOVERWRITE ) ) in xQueueGenericSend()
915 traceQUEUE_SEND( pxQueue ); in xQueueGenericSend()
919 const UBaseType_t uxPreviousMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueGenericSend()
921 xYieldRequired = prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition ); in xQueueGenericSend()
923 if( pxQueue->pxQueueSetContainer != NULL ) in xQueueGenericSend()
932 else if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in xQueueGenericSend()
948 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSend()
950 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSend()
979 xYieldRequired = prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition ); in xQueueGenericSend()
983 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSend()
985 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSend()
1026 traceQUEUE_SEND_FAILED( pxQueue ); in xQueueGenericSend()
1049 prvLockQueue( pxQueue ); in xQueueGenericSend()
1054 if( prvIsQueueFull( pxQueue ) != pdFALSE ) in xQueueGenericSend()
1056 traceBLOCKING_ON_QUEUE_SEND( pxQueue ); in xQueueGenericSend()
1057 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToSend ), xTicksToWait ); in xQueueGenericSend()
1064 prvUnlockQueue( pxQueue ); in xQueueGenericSend()
1079 prvUnlockQueue( pxQueue ); in xQueueGenericSend()
1086 prvUnlockQueue( pxQueue ); in xQueueGenericSend()
1089 traceQUEUE_SEND_FAILED( pxQueue ); in xQueueGenericSend()
1103 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR() local
1105 configASSERT( pxQueue ); in xQueueGenericSendFromISR()
1106 configASSERT( !( ( pvItemToQueue == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueGenericSendFromISR()
1107 configASSERT( !( ( xCopyPosition == queueOVERWRITE ) && ( pxQueue->uxLength != 1 ) ) ); in xQueueGenericSendFromISR()
1132 … if( ( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) || ( xCopyPosition == queueOVERWRITE ) ) in xQueueGenericSendFromISR()
1134 const int8_t cTxLock = pxQueue->cTxLock; in xQueueGenericSendFromISR()
1135 const UBaseType_t uxPreviousMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueGenericSendFromISR()
1137 traceQUEUE_SEND_FROM_ISR( pxQueue ); in xQueueGenericSendFromISR()
1144 ( void ) prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition ); in xQueueGenericSendFromISR()
1152 if( pxQueue->pxQueueSetContainer != NULL ) in xQueueGenericSendFromISR()
1161 else if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in xQueueGenericSendFromISR()
1182 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSendFromISR()
1184 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSendFromISR()
1210 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSendFromISR()
1212 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSendFromISR()
1244 prvIncrementQueueTxLock( pxQueue, cTxLock ); in xQueueGenericSendFromISR()
1251 traceQUEUE_SEND_FROM_ISR_FAILED( pxQueue ); in xQueueGenericSendFromISR()
1266 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR() local
1274 configASSERT( pxQueue ); in xQueueGiveFromISR()
1278 configASSERT( pxQueue->uxItemSize == 0 ); in xQueueGiveFromISR()
1283 …configASSERT( !( ( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) && ( pxQueue->u.xSemaphore.xMutex… in xQueueGiveFromISR()
1303 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueGiveFromISR()
1308 if( uxMessagesWaiting < pxQueue->uxLength ) in xQueueGiveFromISR()
1310 const int8_t cTxLock = pxQueue->cTxLock; in xQueueGiveFromISR()
1312 traceQUEUE_SEND_FROM_ISR( pxQueue ); in xQueueGiveFromISR()
1320 pxQueue->uxMessagesWaiting = uxMessagesWaiting + ( UBaseType_t ) 1; in xQueueGiveFromISR()
1328 if( pxQueue->pxQueueSetContainer != NULL ) in xQueueGiveFromISR()
1330 if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in xQueueGiveFromISR()
1351 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGiveFromISR()
1353 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGiveFromISR()
1379 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGiveFromISR()
1381 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGiveFromISR()
1410 prvIncrementQueueTxLock( pxQueue, cTxLock ); in xQueueGiveFromISR()
1417 traceQUEUE_SEND_FROM_ISR_FAILED( pxQueue ); in xQueueGiveFromISR()
1433 Queue_t * const pxQueue = xQueue; in xQueueReceive() local
1436 configASSERT( ( pxQueue ) ); in xQueueReceive()
1440 …configASSERT( !( ( ( pvBuffer ) == NULL ) && ( ( pxQueue )->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueReceive()
1456 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueReceive()
1463 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueueReceive()
1464 traceQUEUE_RECEIVE( pxQueue ); in xQueueReceive()
1465 pxQueue->uxMessagesWaiting = uxMessagesWaiting - ( UBaseType_t ) 1; in xQueueReceive()
1470 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueReceive()
1472 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueReceive()
1496 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueReceive()
1519 prvLockQueue( pxQueue ); in xQueueReceive()
1526 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueReceive()
1528 traceBLOCKING_ON_QUEUE_RECEIVE( pxQueue ); in xQueueReceive()
1529 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait ); in xQueueReceive()
1530 prvUnlockQueue( pxQueue ); in xQueueReceive()
1545 prvUnlockQueue( pxQueue ); in xQueueReceive()
1553 prvUnlockQueue( pxQueue ); in xQueueReceive()
1556 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueReceive()
1558 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueReceive()
1575 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake() local
1582 configASSERT( ( pxQueue ) ); in xQueueSemaphoreTake()
1586 configASSERT( pxQueue->uxItemSize == 0 ); in xQueueSemaphoreTake()
1604 const UBaseType_t uxSemaphoreCount = pxQueue->uxMessagesWaiting; in xQueueSemaphoreTake()
1610 traceQUEUE_RECEIVE( pxQueue ); in xQueueSemaphoreTake()
1614 pxQueue->uxMessagesWaiting = uxSemaphoreCount - ( UBaseType_t ) 1; in xQueueSemaphoreTake()
1618 if( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) in xQueueSemaphoreTake()
1622 pxQueue->u.xSemaphore.xMutexHolder = pvTaskIncrementMutexHeldCount(); in xQueueSemaphoreTake()
1633 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueSemaphoreTake()
1635 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueSemaphoreTake()
1659 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueSemaphoreTake()
1682 prvLockQueue( pxQueue ); in xQueueSemaphoreTake()
1691 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueSemaphoreTake()
1693 traceBLOCKING_ON_QUEUE_RECEIVE( pxQueue ); in xQueueSemaphoreTake()
1697 if( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) in xQueueSemaphoreTake()
1701 … xInheritanceOccurred = xTaskPriorityInherit( pxQueue->u.xSemaphore.xMutexHolder ); in xQueueSemaphoreTake()
1712 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait ); in xQueueSemaphoreTake()
1713 prvUnlockQueue( pxQueue ); in xQueueSemaphoreTake()
1728 prvUnlockQueue( pxQueue ); in xQueueSemaphoreTake()
1735 prvUnlockQueue( pxQueue ); in xQueueSemaphoreTake()
1742 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueSemaphoreTake()
1760 … uxHighestWaitingPriority = prvGetDisinheritPriorityAfterTimeout( pxQueue ); in xQueueSemaphoreTake()
1761 …vTaskPriorityDisinheritAfterTimeout( pxQueue->u.xSemaphore.xMutexHolder, uxHighestWaitingPriority … in xQueueSemaphoreTake()
1768 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueSemaphoreTake()
1787 Queue_t * const pxQueue = xQueue; in xQueuePeek() local
1790 configASSERT( ( pxQueue ) ); in xQueuePeek()
1794 …configASSERT( !( ( ( pvBuffer ) == NULL ) && ( ( pxQueue )->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueuePeek()
1810 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueuePeek()
1819 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeek()
1821 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueuePeek()
1822 traceQUEUE_PEEK( pxQueue ); in xQueuePeek()
1825 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeek()
1829 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueuePeek()
1831 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueuePeek()
1856 traceQUEUE_PEEK_FAILED( pxQueue ); in xQueuePeek()
1880 prvLockQueue( pxQueue ); in xQueuePeek()
1887 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueuePeek()
1889 traceBLOCKING_ON_QUEUE_PEEK( pxQueue ); in xQueuePeek()
1890 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait ); in xQueuePeek()
1891 prvUnlockQueue( pxQueue ); in xQueuePeek()
1906 prvUnlockQueue( pxQueue ); in xQueuePeek()
1914 prvUnlockQueue( pxQueue ); in xQueuePeek()
1917 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueuePeek()
1919 traceQUEUE_PEEK_FAILED( pxQueue ); in xQueuePeek()
1937 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR() local
1939 configASSERT( pxQueue ); in xQueueReceiveFromISR()
1940 configASSERT( !( ( pvBuffer == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueReceiveFromISR()
1960 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueReceiveFromISR()
1965 const int8_t cRxLock = pxQueue->cRxLock; in xQueueReceiveFromISR()
1967 traceQUEUE_RECEIVE_FROM_ISR( pxQueue ); in xQueueReceiveFromISR()
1969 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueueReceiveFromISR()
1970 pxQueue->uxMessagesWaiting = uxMessagesWaiting - ( UBaseType_t ) 1; in xQueueReceiveFromISR()
1978 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueReceiveFromISR()
1980 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueReceiveFromISR()
2007 prvIncrementQueueRxLock( pxQueue, cRxLock ); in xQueueReceiveFromISR()
2015 traceQUEUE_RECEIVE_FROM_ISR_FAILED( pxQueue ); in xQueueReceiveFromISR()
2030 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR() local
2032 configASSERT( pxQueue ); in xQueuePeekFromISR()
2033 configASSERT( !( ( pvBuffer == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueuePeekFromISR()
2034 configASSERT( pxQueue->uxItemSize != 0 ); /* Can't peek a semaphore. */ in xQueuePeekFromISR()
2055 if( pxQueue->uxMessagesWaiting > ( UBaseType_t ) 0 ) in xQueuePeekFromISR()
2057 traceQUEUE_PEEK_FROM_ISR( pxQueue ); in xQueuePeekFromISR()
2061 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeekFromISR()
2062 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueuePeekFromISR()
2063 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeekFromISR()
2070 traceQUEUE_PEEK_FROM_ISR_FAILED( pxQueue ); in xQueuePeekFromISR()
2098 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable() local
2100 configASSERT( pxQueue ); in uxQueueSpacesAvailable()
2104 uxReturn = pxQueue->uxLength - pxQueue->uxMessagesWaiting; in uxQueueSpacesAvailable()
2115 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR() local
2117 configASSERT( pxQueue ); in uxQueueMessagesWaitingFromISR()
2118 uxReturn = pxQueue->uxMessagesWaiting; in uxQueueMessagesWaitingFromISR()
2126 Queue_t * const pxQueue = xQueue; in vQueueDelete() local
2128 configASSERT( pxQueue ); in vQueueDelete()
2129 traceQUEUE_DELETE( pxQueue ); in vQueueDelete()
2133 vQueueUnregisterQueue( pxQueue ); in vQueueDelete()
2141 vPortFree( pxQueue ); in vQueueDelete()
2147 if( pxQueue->ucStaticallyAllocated == ( uint8_t ) pdFALSE ) in vQueueDelete()
2149 vPortFree( pxQueue ); in vQueueDelete()
2160 ( void ) pxQueue; in vQueueDelete()
2211 static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) in prvGetDisinheritPriorityAfterTimeout() argument
2221 if( listCURRENT_LIST_LENGTH( &( pxQueue->xTasksWaitingToReceive ) ) > 0U ) in prvGetDisinheritPriorityAfterTimeout()
2223 …figMAX_PRIORITIES - ( UBaseType_t ) listGET_ITEM_VALUE_OF_HEAD_ENTRY( &( pxQueue->xTasksWaitingToR… in prvGetDisinheritPriorityAfterTimeout()
2236 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue, in prvCopyDataToQueue() argument
2245 uxMessagesWaiting = pxQueue->uxMessagesWaiting; in prvCopyDataToQueue()
2247 if( pxQueue->uxItemSize == ( UBaseType_t ) 0 ) in prvCopyDataToQueue()
2251 if( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) in prvCopyDataToQueue()
2254 xReturn = xTaskPriorityDisinherit( pxQueue->u.xSemaphore.xMutexHolder ); in prvCopyDataToQueue()
2255 pxQueue->u.xSemaphore.xMutexHolder = NULL; in prvCopyDataToQueue()
2266 …( void ) memcpy( ( void * ) pxQueue->pcWriteTo, pvItemToQueue, ( size_t ) pxQueue->uxItemSize ); /… in prvCopyDataToQueue()
2267 …pxQueue->pcWriteTo += pxQueue->uxItemSize; /… in prvCopyDataToQueue()
2269 …if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail ) /… in prvCopyDataToQueue()
2271 pxQueue->pcWriteTo = pxQueue->pcHead; in prvCopyDataToQueue()
2280 …( void ) memcpy( ( void * ) pxQueue->u.xQueue.pcReadFrom, pvItemToQueue, ( size_t ) pxQueue->uxIte… in prvCopyDataToQueue()
2281 pxQueue->u.xQueue.pcReadFrom -= pxQueue->uxItemSize; in prvCopyDataToQueue()
2283 …if( pxQueue->u.xQueue.pcReadFrom < pxQueue->pcHead ) /*lint !e946 MISRA exception justified as com… in prvCopyDataToQueue()
2285 pxQueue->u.xQueue.pcReadFrom = ( pxQueue->u.xQueue.pcTail - pxQueue->uxItemSize ); in prvCopyDataToQueue()
2313 pxQueue->uxMessagesWaiting = uxMessagesWaiting + ( UBaseType_t ) 1; in prvCopyDataToQueue()
2319 static void prvCopyDataFromQueue( Queue_t * const pxQueue, in prvCopyDataFromQueue() argument
2322 if( pxQueue->uxItemSize != ( UBaseType_t ) 0 ) in prvCopyDataFromQueue()
2324 …pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; /*lint !e9016 Pointer arithmetic on… in prvCopyDataFromQueue()
2326 …if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) /*lint !e946 MISRA exception justif… in prvCopyDataFromQueue()
2328 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in prvCopyDataFromQueue()
2335 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( size_t ) pxQueue-… in prvCopyDataFromQueue()
2340 static void prvUnlockQueue( Queue_t * const pxQueue ) in prvUnlockQueue() argument
2350 int8_t cTxLock = pxQueue->cTxLock; in prvUnlockQueue()
2359 if( pxQueue->pxQueueSetContainer != NULL ) in prvUnlockQueue()
2361 if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in prvUnlockQueue()
2378 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in prvUnlockQueue()
2380 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in prvUnlockQueue()
2401 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in prvUnlockQueue()
2403 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in prvUnlockQueue()
2424 pxQueue->cTxLock = queueUNLOCKED; in prvUnlockQueue()
2431 int8_t cRxLock = pxQueue->cRxLock; in prvUnlockQueue()
2435 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in prvUnlockQueue()
2437 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in prvUnlockQueue()
2454 pxQueue->cRxLock = queueUNLOCKED; in prvUnlockQueue()
2460 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) in prvIsQueueEmpty() argument
2466 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0 ) in prvIsQueueEmpty()
2484 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR() local
2486 configASSERT( pxQueue ); in xQueueIsQueueEmptyFromISR()
2488 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0 ) in xQueueIsQueueEmptyFromISR()
2501 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) in prvIsQueueFull() argument
2507 if( pxQueue->uxMessagesWaiting == pxQueue->uxLength ) in prvIsQueueFull()
2525 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR() local
2527 configASSERT( pxQueue ); in xQueueIsQueueFullFromISR()
2529 if( pxQueue->uxMessagesWaiting == pxQueue->uxLength ) in xQueueIsQueueFullFromISR()
2549 Queue_t * const pxQueue = xQueue; in xQueueCRSend() local
2556 if( prvIsQueueFull( pxQueue ) != pdFALSE ) in xQueueCRSend()
2564 vCoRoutineAddToDelayedList( xTicksToWait, &( pxQueue->xTasksWaitingToSend ) ); in xQueueCRSend()
2579 if( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) in xQueueCRSend()
2582 prvCopyDataToQueue( pxQueue, pvItemToQueue, queueSEND_TO_BACK ); in xQueueCRSend()
2586 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueCRSend()
2592 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueCRSend()
2628 Queue_t * const pxQueue = xQueue; in xQueueCRReceive() local
2635 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0 ) in xQueueCRReceive()
2643 … vCoRoutineAddToDelayedList( xTicksToWait, &( pxQueue->xTasksWaitingToReceive ) ); in xQueueCRReceive()
2662 if( pxQueue->uxMessagesWaiting > ( UBaseType_t ) 0 ) in xQueueCRReceive()
2665 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceive()
2667 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceive()
2669 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceive()
2676 --( pxQueue->uxMessagesWaiting ); in xQueueCRReceive()
2677 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceive()
2682 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueCRReceive()
2688 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueCRReceive()
2721 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR() local
2725 if( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) in xQueueCRSendFromISR()
2727 prvCopyDataToQueue( pxQueue, pvItemToQueue, queueSEND_TO_BACK ); in xQueueCRSendFromISR()
2733 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueCRSendFromISR()
2735 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueCRSendFromISR()
2772 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR() local
2776 if( pxQueue->uxMessagesWaiting > ( UBaseType_t ) 0 ) in xQueueCRReceiveFromISR()
2779 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceiveFromISR()
2781 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceiveFromISR()
2783 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceiveFromISR()
2790 --( pxQueue->uxMessagesWaiting ); in xQueueCRReceiveFromISR()
2791 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceiveFromISR()
2795 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueCRReceiveFromISR()
2797 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueCRReceiveFromISR()
2946 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted() local
2962 prvLockQueue( pxQueue ); in vQueueWaitForMessageRestricted()
2964 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0U ) in vQueueWaitForMessageRestricted()
2967 …vTaskPlaceOnEventListRestricted( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait, xWaitIndefini… in vQueueWaitForMessageRestricted()
2974 prvUnlockQueue( pxQueue ); in vQueueWaitForMessageRestricted()
2984 QueueSetHandle_t pxQueue; in xQueueCreateSet() local
2986 …pxQueue = xQueueGenericCreate( uxEventQueueLength, ( UBaseType_t ) sizeof( Queue_t * ), queueQUEUE… in xQueueCreateSet()
2988 return pxQueue; in xQueueCreateSet()
3094 static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) in prvNotifyQueueSetContainer() argument
3096 Queue_t * pxQueueSetContainer = pxQueue->pxQueueSetContainer; in prvNotifyQueueSetContainer()
3114 xReturn = prvCopyDataToQueue( pxQueueSetContainer, &pxQueue, queueSEND_TO_BACK ); in prvNotifyQueueSetContainer()