Lines Matching refs:pxQueue
183 static void prvUnlockQueue( Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
190 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) PRIVILEGED_FUNCTION;
197 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) PRIVILEGED_FUNCTION;
203 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue,
210 static void prvCopyDataFromQueue( Queue_t * const pxQueue,
219 … static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
250 …static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) PRIVILEGE…
258 #define prvLockQueue( pxQueue ) \ argument
261 if( ( pxQueue )->cRxLock == queueUNLOCKED ) \
263 ( pxQueue )->cRxLock = queueLOCKED_UNMODIFIED; \
265 if( ( pxQueue )->cTxLock == queueUNLOCKED ) \
267 ( pxQueue )->cTxLock = queueLOCKED_UNMODIFIED; \
277 #define prvIncrementQueueTxLock( pxQueue, cTxLock ) \ argument
283 ( pxQueue )->cTxLock = ( int8_t ) ( ( cTxLock ) + ( int8_t ) 1 ); \
292 #define prvIncrementQueueRxLock( pxQueue, cRxLock ) \ argument
298 ( pxQueue )->cRxLock = ( int8_t ) ( ( cRxLock ) + ( int8_t ) 1 ); \
307 Queue_t * const pxQueue = xQueue; in xQueueGenericReset() local
311 configASSERT( pxQueue ); in xQueueGenericReset()
313 if( ( pxQueue != NULL ) && in xQueueGenericReset()
314 ( pxQueue->uxLength >= 1U ) && in xQueueGenericReset()
316 ( ( SIZE_MAX / pxQueue->uxLength ) >= pxQueue->uxItemSize ) ) in xQueueGenericReset()
320 … pxQueue->u.xQueue.pcTail = pxQueue->pcHead + ( pxQueue->uxLength * pxQueue->uxItemSize ); in xQueueGenericReset()
321 pxQueue->uxMessagesWaiting = ( UBaseType_t ) 0U; in xQueueGenericReset()
322 pxQueue->pcWriteTo = pxQueue->pcHead; in xQueueGenericReset()
323 …pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead + ( ( pxQueue->uxLength - 1U ) * pxQueue->uxItemSiz… in xQueueGenericReset()
324 pxQueue->cRxLock = queueUNLOCKED; in xQueueGenericReset()
325 pxQueue->cTxLock = queueUNLOCKED; in xQueueGenericReset()
334 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueGenericReset()
336 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueGenericReset()
353 vListInitialise( &( pxQueue->xTasksWaitingToSend ) ); in xQueueGenericReset()
354 vListInitialise( &( pxQueue->xTasksWaitingToReceive ) ); in xQueueGenericReset()
451 Queue_t * const pxQueue = xQueue; in xQueueGenericGetStaticBuffers() local
455 configASSERT( pxQueue ); in xQueueGenericGetStaticBuffers()
461 if( pxQueue->ucStaticallyAllocated == ( uint8_t ) pdTRUE ) in xQueueGenericGetStaticBuffers()
465 *ppucQueueStorage = ( uint8_t * ) pxQueue->pcHead; in xQueueGenericGetStaticBuffers()
471 *ppxStaticQueue = ( StaticQueue_t * ) pxQueue; in xQueueGenericGetStaticBuffers()
484 *ppucQueueStorage = ( uint8_t * ) pxQueue->pcHead; in xQueueGenericGetStaticBuffers()
487 *ppxStaticQueue = ( StaticQueue_t * ) pxQueue; in xQueueGenericGetStaticBuffers()
946 Queue_t * const pxQueue = xQueue; in xQueueGenericSend() local
950 configASSERT( pxQueue ); in xQueueGenericSend()
951 configASSERT( !( ( pvItemToQueue == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueGenericSend()
952 configASSERT( !( ( xCopyPosition == queueOVERWRITE ) && ( pxQueue->uxLength != 1 ) ) ); in xQueueGenericSend()
967 … if( ( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) || ( xCopyPosition == queueOVERWRITE ) ) in xQueueGenericSend()
969 traceQUEUE_SEND( pxQueue ); in xQueueGenericSend()
973 const UBaseType_t uxPreviousMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueGenericSend()
975 xYieldRequired = prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition ); in xQueueGenericSend()
977 if( pxQueue->pxQueueSetContainer != NULL ) in xQueueGenericSend()
986 else if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in xQueueGenericSend()
1002 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSend()
1004 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSend()
1033 xYieldRequired = prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition ); in xQueueGenericSend()
1037 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSend()
1039 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSend()
1083 traceQUEUE_SEND_FAILED( pxQueue ); in xQueueGenericSend()
1108 prvLockQueue( pxQueue ); in xQueueGenericSend()
1113 if( prvIsQueueFull( pxQueue ) != pdFALSE ) in xQueueGenericSend()
1115 traceBLOCKING_ON_QUEUE_SEND( pxQueue ); in xQueueGenericSend()
1116 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToSend ), xTicksToWait ); in xQueueGenericSend()
1123 prvUnlockQueue( pxQueue ); in xQueueGenericSend()
1138 prvUnlockQueue( pxQueue ); in xQueueGenericSend()
1145 prvUnlockQueue( pxQueue ); in xQueueGenericSend()
1148 traceQUEUE_SEND_FAILED( pxQueue ); in xQueueGenericSend()
1164 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR() local
1168 configASSERT( pxQueue ); in xQueueGenericSendFromISR()
1169 configASSERT( !( ( pvItemToQueue == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueGenericSendFromISR()
1170 configASSERT( !( ( xCopyPosition == queueOVERWRITE ) && ( pxQueue->uxLength != 1 ) ) ); in xQueueGenericSendFromISR()
1195 … if( ( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) || ( xCopyPosition == queueOVERWRITE ) ) in xQueueGenericSendFromISR()
1197 const int8_t cTxLock = pxQueue->cTxLock; in xQueueGenericSendFromISR()
1198 const UBaseType_t uxPreviousMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueGenericSendFromISR()
1200 traceQUEUE_SEND_FROM_ISR( pxQueue ); in xQueueGenericSendFromISR()
1207 ( void ) prvCopyDataToQueue( pxQueue, pvItemToQueue, xCopyPosition ); in xQueueGenericSendFromISR()
1215 if( pxQueue->pxQueueSetContainer != NULL ) in xQueueGenericSendFromISR()
1224 else if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in xQueueGenericSendFromISR()
1245 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSendFromISR()
1247 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSendFromISR()
1273 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGenericSendFromISR()
1275 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGenericSendFromISR()
1307 prvIncrementQueueTxLock( pxQueue, cTxLock ); in xQueueGenericSendFromISR()
1314 traceQUEUE_SEND_FROM_ISR_FAILED( pxQueue ); in xQueueGenericSendFromISR()
1331 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR() local
1341 configASSERT( pxQueue ); in xQueueGiveFromISR()
1345 configASSERT( pxQueue->uxItemSize == 0 ); in xQueueGiveFromISR()
1350 …configASSERT( !( ( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) && ( pxQueue->u.xSemaphore.xMutex… in xQueueGiveFromISR()
1370 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueGiveFromISR()
1375 if( uxMessagesWaiting < pxQueue->uxLength ) in xQueueGiveFromISR()
1377 const int8_t cTxLock = pxQueue->cTxLock; in xQueueGiveFromISR()
1379 traceQUEUE_SEND_FROM_ISR( pxQueue ); in xQueueGiveFromISR()
1387 pxQueue->uxMessagesWaiting = ( UBaseType_t ) ( uxMessagesWaiting + ( UBaseType_t ) 1 ); in xQueueGiveFromISR()
1395 if( pxQueue->pxQueueSetContainer != NULL ) in xQueueGiveFromISR()
1397 if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in xQueueGiveFromISR()
1418 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGiveFromISR()
1420 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGiveFromISR()
1446 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueGiveFromISR()
1448 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueGiveFromISR()
1477 prvIncrementQueueTxLock( pxQueue, cTxLock ); in xQueueGiveFromISR()
1484 traceQUEUE_SEND_FROM_ISR_FAILED( pxQueue ); in xQueueGiveFromISR()
1502 Queue_t * const pxQueue = xQueue; in xQueueReceive() local
1507 configASSERT( ( pxQueue ) ); in xQueueReceive()
1511 …configASSERT( !( ( ( pvBuffer ) == NULL ) && ( ( pxQueue )->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueReceive()
1524 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueReceive()
1531 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueueReceive()
1532 traceQUEUE_RECEIVE( pxQueue ); in xQueueReceive()
1533 … pxQueue->uxMessagesWaiting = ( UBaseType_t ) ( uxMessagesWaiting - ( UBaseType_t ) 1 ); in xQueueReceive()
1538 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueReceive()
1540 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueReceive()
1568 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueReceive()
1593 prvLockQueue( pxQueue ); in xQueueReceive()
1600 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueReceive()
1602 traceBLOCKING_ON_QUEUE_RECEIVE( pxQueue ); in xQueueReceive()
1603 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait ); in xQueueReceive()
1604 prvUnlockQueue( pxQueue ); in xQueueReceive()
1619 prvUnlockQueue( pxQueue ); in xQueueReceive()
1627 prvUnlockQueue( pxQueue ); in xQueueReceive()
1630 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueReceive()
1632 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueReceive()
1651 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake() local
1660 configASSERT( ( pxQueue ) ); in xQueueSemaphoreTake()
1664 configASSERT( pxQueue->uxItemSize == 0 ); in xQueueSemaphoreTake()
1679 const UBaseType_t uxSemaphoreCount = pxQueue->uxMessagesWaiting; in xQueueSemaphoreTake()
1685 traceQUEUE_RECEIVE( pxQueue ); in xQueueSemaphoreTake()
1689 … pxQueue->uxMessagesWaiting = ( UBaseType_t ) ( uxSemaphoreCount - ( UBaseType_t ) 1 ); in xQueueSemaphoreTake()
1693 if( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) in xQueueSemaphoreTake()
1697 pxQueue->u.xSemaphore.xMutexHolder = pvTaskIncrementMutexHeldCount(); in xQueueSemaphoreTake()
1708 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueSemaphoreTake()
1710 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueSemaphoreTake()
1738 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueSemaphoreTake()
1763 prvLockQueue( pxQueue ); in xQueueSemaphoreTake()
1772 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueSemaphoreTake()
1774 traceBLOCKING_ON_QUEUE_RECEIVE( pxQueue ); in xQueueSemaphoreTake()
1778 if( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) in xQueueSemaphoreTake()
1782 … xInheritanceOccurred = xTaskPriorityInherit( pxQueue->u.xSemaphore.xMutexHolder ); in xQueueSemaphoreTake()
1793 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait ); in xQueueSemaphoreTake()
1794 prvUnlockQueue( pxQueue ); in xQueueSemaphoreTake()
1809 prvUnlockQueue( pxQueue ); in xQueueSemaphoreTake()
1816 prvUnlockQueue( pxQueue ); in xQueueSemaphoreTake()
1823 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueueSemaphoreTake()
1841 … uxHighestWaitingPriority = prvGetDisinheritPriorityAfterTimeout( pxQueue ); in xQueueSemaphoreTake()
1850 …vTaskPriorityDisinheritAfterTimeout( pxQueue->u.xSemaphore.xMutexHolder, uxHighestWaitingPriority … in xQueueSemaphoreTake()
1857 traceQUEUE_RECEIVE_FAILED( pxQueue ); in xQueueSemaphoreTake()
1878 Queue_t * const pxQueue = xQueue; in xQueuePeek() local
1883 configASSERT( ( pxQueue ) ); in xQueuePeek()
1887 …configASSERT( !( ( ( pvBuffer ) == NULL ) && ( ( pxQueue )->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueuePeek()
1900 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueuePeek()
1909 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeek()
1911 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueuePeek()
1912 traceQUEUE_PEEK( pxQueue ); in xQueuePeek()
1915 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeek()
1919 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueuePeek()
1921 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueuePeek()
1950 traceQUEUE_PEEK_FAILED( pxQueue ); in xQueuePeek()
1976 prvLockQueue( pxQueue ); in xQueuePeek()
1983 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueuePeek()
1985 traceBLOCKING_ON_QUEUE_PEEK( pxQueue ); in xQueuePeek()
1986 vTaskPlaceOnEventList( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait ); in xQueuePeek()
1987 prvUnlockQueue( pxQueue ); in xQueuePeek()
2002 prvUnlockQueue( pxQueue ); in xQueuePeek()
2010 prvUnlockQueue( pxQueue ); in xQueuePeek()
2013 if( prvIsQueueEmpty( pxQueue ) != pdFALSE ) in xQueuePeek()
2015 traceQUEUE_PEEK_FAILED( pxQueue ); in xQueuePeek()
2035 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR() local
2039 configASSERT( pxQueue ); in xQueueReceiveFromISR()
2040 configASSERT( !( ( pvBuffer == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueueReceiveFromISR()
2060 const UBaseType_t uxMessagesWaiting = pxQueue->uxMessagesWaiting; in xQueueReceiveFromISR()
2065 const int8_t cRxLock = pxQueue->cRxLock; in xQueueReceiveFromISR()
2067 traceQUEUE_RECEIVE_FROM_ISR( pxQueue ); in xQueueReceiveFromISR()
2069 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueueReceiveFromISR()
2070 pxQueue->uxMessagesWaiting = ( UBaseType_t ) ( uxMessagesWaiting - ( UBaseType_t ) 1 ); in xQueueReceiveFromISR()
2078 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueReceiveFromISR()
2080 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueReceiveFromISR()
2107 prvIncrementQueueRxLock( pxQueue, cRxLock ); in xQueueReceiveFromISR()
2115 traceQUEUE_RECEIVE_FROM_ISR_FAILED( pxQueue ); in xQueueReceiveFromISR()
2132 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR() local
2136 configASSERT( pxQueue ); in xQueuePeekFromISR()
2137 configASSERT( !( ( pvBuffer == NULL ) && ( pxQueue->uxItemSize != ( UBaseType_t ) 0U ) ) ); in xQueuePeekFromISR()
2138 configASSERT( pxQueue->uxItemSize != 0 ); /* Can't peek a semaphore. */ in xQueuePeekFromISR()
2159 if( pxQueue->uxMessagesWaiting > ( UBaseType_t ) 0 ) in xQueuePeekFromISR()
2161 traceQUEUE_PEEK_FROM_ISR( pxQueue ); in xQueuePeekFromISR()
2165 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeekFromISR()
2166 prvCopyDataFromQueue( pxQueue, pvBuffer ); in xQueuePeekFromISR()
2167 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeekFromISR()
2174 traceQUEUE_PEEK_FROM_ISR_FAILED( pxQueue ); in xQueuePeekFromISR()
2208 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable() local
2212 configASSERT( pxQueue ); in uxQueueSpacesAvailable()
2216 uxReturn = ( UBaseType_t ) ( pxQueue->uxLength - pxQueue->uxMessagesWaiting ); in uxQueueSpacesAvailable()
2229 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR() local
2233 configASSERT( pxQueue ); in uxQueueMessagesWaitingFromISR()
2234 uxReturn = pxQueue->uxMessagesWaiting; in uxQueueMessagesWaitingFromISR()
2244 Queue_t * const pxQueue = xQueue; in vQueueDelete() local
2248 configASSERT( pxQueue ); in vQueueDelete()
2249 traceQUEUE_DELETE( pxQueue ); in vQueueDelete()
2253 vQueueUnregisterQueue( pxQueue ); in vQueueDelete()
2261 vPortFree( pxQueue ); in vQueueDelete()
2267 if( pxQueue->ucStaticallyAllocated == ( uint8_t ) pdFALSE ) in vQueueDelete()
2269 vPortFree( pxQueue ); in vQueueDelete()
2280 ( void ) pxQueue; in vQueueDelete()
2353 static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) in prvGetDisinheritPriorityAfterTimeout() argument
2363 if( listCURRENT_LIST_LENGTH( &( pxQueue->xTasksWaitingToReceive ) ) > 0U ) in prvGetDisinheritPriorityAfterTimeout()
2365 …figMAX_PRIORITIES - ( UBaseType_t ) listGET_ITEM_VALUE_OF_HEAD_ENTRY( &( pxQueue->xTasksWaitingToR… in prvGetDisinheritPriorityAfterTimeout()
2378 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue, in prvCopyDataToQueue() argument
2387 uxMessagesWaiting = pxQueue->uxMessagesWaiting; in prvCopyDataToQueue()
2389 if( pxQueue->uxItemSize == ( UBaseType_t ) 0 ) in prvCopyDataToQueue()
2393 if( pxQueue->uxQueueType == queueQUEUE_IS_MUTEX ) in prvCopyDataToQueue()
2396 xReturn = xTaskPriorityDisinherit( pxQueue->u.xSemaphore.xMutexHolder ); in prvCopyDataToQueue()
2397 pxQueue->u.xSemaphore.xMutexHolder = NULL; in prvCopyDataToQueue()
2408 … ( void ) memcpy( ( void * ) pxQueue->pcWriteTo, pvItemToQueue, ( size_t ) pxQueue->uxItemSize ); in prvCopyDataToQueue()
2409 pxQueue->pcWriteTo += pxQueue->uxItemSize; in prvCopyDataToQueue()
2411 if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail ) in prvCopyDataToQueue()
2413 pxQueue->pcWriteTo = pxQueue->pcHead; in prvCopyDataToQueue()
2422 …( void ) memcpy( ( void * ) pxQueue->u.xQueue.pcReadFrom, pvItemToQueue, ( size_t ) pxQueue->uxIte… in prvCopyDataToQueue()
2423 pxQueue->u.xQueue.pcReadFrom -= pxQueue->uxItemSize; in prvCopyDataToQueue()
2425 if( pxQueue->u.xQueue.pcReadFrom < pxQueue->pcHead ) in prvCopyDataToQueue()
2427 pxQueue->u.xQueue.pcReadFrom = ( pxQueue->u.xQueue.pcTail - pxQueue->uxItemSize ); in prvCopyDataToQueue()
2455 pxQueue->uxMessagesWaiting = ( UBaseType_t ) ( uxMessagesWaiting + ( UBaseType_t ) 1 ); in prvCopyDataToQueue()
2461 static void prvCopyDataFromQueue( Queue_t * const pxQueue, in prvCopyDataFromQueue() argument
2464 if( pxQueue->uxItemSize != ( UBaseType_t ) 0 ) in prvCopyDataFromQueue()
2466 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in prvCopyDataFromQueue()
2468 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in prvCopyDataFromQueue()
2470 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in prvCopyDataFromQueue()
2477 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( size_t ) pxQueue-… in prvCopyDataFromQueue()
2482 static void prvUnlockQueue( Queue_t * const pxQueue ) in prvUnlockQueue() argument
2492 int8_t cTxLock = pxQueue->cTxLock; in prvUnlockQueue()
2501 if( pxQueue->pxQueueSetContainer != NULL ) in prvUnlockQueue()
2503 if( prvNotifyQueueSetContainer( pxQueue ) != pdFALSE ) in prvUnlockQueue()
2520 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in prvUnlockQueue()
2522 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in prvUnlockQueue()
2543 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in prvUnlockQueue()
2545 … if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in prvUnlockQueue()
2566 pxQueue->cTxLock = queueUNLOCKED; in prvUnlockQueue()
2573 int8_t cRxLock = pxQueue->cRxLock; in prvUnlockQueue()
2577 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in prvUnlockQueue()
2579 if( xTaskRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in prvUnlockQueue()
2596 pxQueue->cRxLock = queueUNLOCKED; in prvUnlockQueue()
2602 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) in prvIsQueueEmpty() argument
2608 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0 ) in prvIsQueueEmpty()
2626 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR() local
2630 configASSERT( pxQueue ); in xQueueIsQueueEmptyFromISR()
2632 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0 ) in xQueueIsQueueEmptyFromISR()
2647 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) in prvIsQueueFull() argument
2653 if( pxQueue->uxMessagesWaiting == pxQueue->uxLength ) in prvIsQueueFull()
2671 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR() local
2675 configASSERT( pxQueue ); in xQueueIsQueueFullFromISR()
2677 if( pxQueue->uxMessagesWaiting == pxQueue->uxLength ) in xQueueIsQueueFullFromISR()
2699 Queue_t * const pxQueue = xQueue; in xQueueCRSend() local
2708 if( prvIsQueueFull( pxQueue ) != pdFALSE ) in xQueueCRSend()
2716 vCoRoutineAddToDelayedList( xTicksToWait, &( pxQueue->xTasksWaitingToSend ) ); in xQueueCRSend()
2731 if( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) in xQueueCRSend()
2734 prvCopyDataToQueue( pxQueue, pvItemToQueue, queueSEND_TO_BACK ); in xQueueCRSend()
2738 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueCRSend()
2744 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueCRSend()
2782 Queue_t * const pxQueue = xQueue; in xQueueCRReceive() local
2791 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0 ) in xQueueCRReceive()
2799 … vCoRoutineAddToDelayedList( xTicksToWait, &( pxQueue->xTasksWaitingToReceive ) ); in xQueueCRReceive()
2818 if( pxQueue->uxMessagesWaiting > ( UBaseType_t ) 0 ) in xQueueCRReceive()
2821 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceive()
2823 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceive()
2825 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceive()
2832 --( pxQueue->uxMessagesWaiting ); in xQueueCRReceive()
2833 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceive()
2838 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueCRReceive()
2844 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueCRReceive()
2879 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR() local
2885 if( pxQueue->uxMessagesWaiting < pxQueue->uxLength ) in xQueueCRSendFromISR()
2887 prvCopyDataToQueue( pxQueue, pvItemToQueue, queueSEND_TO_BACK ); in xQueueCRSendFromISR()
2893 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToReceive ) ) == pdFALSE ) in xQueueCRSendFromISR()
2895 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToReceive ) ) != pdFALSE ) in xQueueCRSendFromISR()
2934 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR() local
2940 if( pxQueue->uxMessagesWaiting > ( UBaseType_t ) 0 ) in xQueueCRReceiveFromISR()
2943 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceiveFromISR()
2945 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceiveFromISR()
2947 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceiveFromISR()
2954 --( pxQueue->uxMessagesWaiting ); in xQueueCRReceiveFromISR()
2955 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceiveFromISR()
2959 if( listLIST_IS_EMPTY( &( pxQueue->xTasksWaitingToSend ) ) == pdFALSE ) in xQueueCRReceiveFromISR()
2961 … if( xCoRoutineRemoveFromEventList( &( pxQueue->xTasksWaitingToSend ) ) != pdFALSE ) in xQueueCRReceiveFromISR()
3124 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted() local
3142 prvLockQueue( pxQueue ); in vQueueWaitForMessageRestricted()
3144 if( pxQueue->uxMessagesWaiting == ( UBaseType_t ) 0U ) in vQueueWaitForMessageRestricted()
3147 …vTaskPlaceOnEventListRestricted( &( pxQueue->xTasksWaitingToReceive ), xTicksToWait, xWaitIndefini… in vQueueWaitForMessageRestricted()
3154 prvUnlockQueue( pxQueue ); in vQueueWaitForMessageRestricted()
3166 QueueSetHandle_t pxQueue; in xQueueCreateSet() local
3170 …pxQueue = xQueueGenericCreate( uxEventQueueLength, ( UBaseType_t ) sizeof( Queue_t * ), queueQUEUE… in xQueueCreateSet()
3172 traceRETURN_xQueueCreateSet( pxQueue ); in xQueueCreateSet()
3174 return pxQueue; in xQueueCreateSet()
3298 static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) in prvNotifyQueueSetContainer() argument
3300 Queue_t * pxQueueSetContainer = pxQueue->pxQueueSetContainer; in prvNotifyQueueSetContainer()
3318 xReturn = prvCopyDataToQueue( pxQueueSetContainer, &pxQueue, queueSEND_TO_BACK ); in prvNotifyQueueSetContainer()