110 …QueuePointers_t xQueue;     /**< Data required exclusively when this structure is used as a queue.…  member
303 BaseType_t xQueueGenericReset( QueueHandle_t xQueue,  in xQueueGenericReset()  argument
307     Queue_t * const pxQueue = xQueue;  in xQueueGenericReset()
309     traceENTER_xQueueGenericReset( xQueue, xNewQueue );  in xQueueGenericReset()
320 …          pxQueue->u.xQueue.pcTail = pxQueue->pcHead + ( pxQueue->uxLength * pxQueue->uxItemSize );  in xQueueGenericReset()
323 …pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead + ( ( pxQueue->uxLength - 1U ) * pxQueue->uxItemSiz…  in xQueueGenericReset()
446     BaseType_t xQueueGenericGetStaticBuffers( QueueHandle_t xQueue,  in xQueueGenericGetStaticBuffers()  argument
451         Queue_t * const pxQueue = xQueue;  in xQueueGenericGetStaticBuffers()
453         traceENTER_xQueueGenericGetStaticBuffers( xQueue, ppucQueueStorage, ppxStaticQueue );  in xQueueGenericGetStaticBuffers()
939 BaseType_t xQueueGenericSend( QueueHandle_t xQueue,  in xQueueGenericSend()  argument
946     Queue_t * const pxQueue = xQueue;  in xQueueGenericSend()
948     traceENTER_xQueueGenericSend( xQueue, pvItemToQueue, xTicksToWait, xCopyPosition );  in xQueueGenericSend()
1157 BaseType_t xQueueGenericSendFromISR( QueueHandle_t xQueue,  in xQueueGenericSendFromISR()  argument
1164     Queue_t * const pxQueue = xQueue;  in xQueueGenericSendFromISR()
1166 …traceENTER_xQueueGenericSendFromISR( xQueue, pvItemToQueue, pxHigherPriorityTaskWoken, xCopyPositi…  in xQueueGenericSendFromISR()
1326 BaseType_t xQueueGiveFromISR( QueueHandle_t xQueue,  in xQueueGiveFromISR()  argument
1331     Queue_t * const pxQueue = xQueue;  in xQueueGiveFromISR()
1333     traceENTER_xQueueGiveFromISR( xQueue, pxHigherPriorityTaskWoken );  in xQueueGiveFromISR()
1496 BaseType_t xQueueReceive( QueueHandle_t xQueue,  in xQueueReceive()  argument
1502     Queue_t * const pxQueue = xQueue;  in xQueueReceive()
1504     traceENTER_xQueueReceive( xQueue, pvBuffer, xTicksToWait );  in xQueueReceive()
1646 BaseType_t xQueueSemaphoreTake( QueueHandle_t xQueue,  in xQueueSemaphoreTake()  argument
1651     Queue_t * const pxQueue = xQueue;  in xQueueSemaphoreTake()
1657     traceENTER_xQueueSemaphoreTake( xQueue, xTicksToWait );  in xQueueSemaphoreTake()
1871 BaseType_t xQueuePeek( QueueHandle_t xQueue,  in xQueuePeek()  argument
1878     Queue_t * const pxQueue = xQueue;  in xQueuePeek()
1880     traceENTER_xQueuePeek( xQueue, pvBuffer, xTicksToWait );  in xQueuePeek()
1909                 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom;  in xQueuePeek()
1915                 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition;  in xQueuePeek()
2029 BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue,  in xQueueReceiveFromISR()  argument
2035     Queue_t * const pxQueue = xQueue;  in xQueueReceiveFromISR()
2037     traceENTER_xQueueReceiveFromISR( xQueue, pvBuffer, pxHigherPriorityTaskWoken );  in xQueueReceiveFromISR()
2126 BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue,  in xQueuePeekFromISR()  argument
2132     Queue_t * const pxQueue = xQueue;  in xQueuePeekFromISR()
2134     traceENTER_xQueuePeekFromISR( xQueue, pvBuffer );  in xQueuePeekFromISR()
2165             pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom;  in xQueuePeekFromISR()
2167             pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition;  in xQueuePeekFromISR()
2185 UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue )  in uxQueueMessagesWaiting()  argument
2189     traceENTER_uxQueueMessagesWaiting( xQueue );  in uxQueueMessagesWaiting()
2191     configASSERT( xQueue );  in uxQueueMessagesWaiting()
2195         uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting;  in uxQueueMessagesWaiting()
2205 UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue )  in uxQueueSpacesAvailable()  argument
2208     Queue_t * const pxQueue = xQueue;  in uxQueueSpacesAvailable()
2210     traceENTER_uxQueueSpacesAvailable( xQueue );  in uxQueueSpacesAvailable()
2226 UBaseType_t uxQueueMessagesWaitingFromISR( const QueueHandle_t xQueue )  in uxQueueMessagesWaitingFromISR()  argument
2229     Queue_t * const pxQueue = xQueue;  in uxQueueMessagesWaitingFromISR()
2231     traceENTER_uxQueueMessagesWaitingFromISR( xQueue );  in uxQueueMessagesWaitingFromISR()
2242 void vQueueDelete( QueueHandle_t xQueue )  in vQueueDelete()  argument
2244     Queue_t * const pxQueue = xQueue;  in vQueueDelete()
2246     traceENTER_vQueueDelete( xQueue );  in vQueueDelete()
2290     UBaseType_t uxQueueGetQueueNumber( QueueHandle_t xQueue )  in uxQueueGetQueueNumber()  argument
2292         traceENTER_uxQueueGetQueueNumber( xQueue );  in uxQueueGetQueueNumber()
2294         traceRETURN_uxQueueGetQueueNumber( ( ( Queue_t * ) xQueue )->uxQueueNumber );  in uxQueueGetQueueNumber()
2296         return ( ( Queue_t * ) xQueue )->uxQueueNumber;  in uxQueueGetQueueNumber()
2304     void vQueueSetQueueNumber( QueueHandle_t xQueue,  in vQueueSetQueueNumber()  argument
2307         traceENTER_vQueueSetQueueNumber( xQueue, uxQueueNumber );  in vQueueSetQueueNumber()
2309         ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber;  in vQueueSetQueueNumber()
2319     uint8_t ucQueueGetQueueType( QueueHandle_t xQueue )  in ucQueueGetQueueType()  argument
2321         traceENTER_ucQueueGetQueueType( xQueue );  in ucQueueGetQueueType()
2323         traceRETURN_ucQueueGetQueueType( ( ( Queue_t * ) xQueue )->ucQueueType );  in ucQueueGetQueueType()
2325         return ( ( Queue_t * ) xQueue )->ucQueueType;  in ucQueueGetQueueType()
2331 UBaseType_t uxQueueGetQueueItemSize( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */  in uxQueueGetQueueItemSize()  argument
2333     traceENTER_uxQueueGetQueueItemSize( xQueue );  in uxQueueGetQueueItemSize()
2335     traceRETURN_uxQueueGetQueueItemSize( ( ( Queue_t * ) xQueue )->uxItemSize );  in uxQueueGetQueueItemSize()
2337     return ( ( Queue_t * ) xQueue )->uxItemSize;  in uxQueueGetQueueItemSize()
2341 UBaseType_t uxQueueGetQueueLength( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */  in uxQueueGetQueueLength()  argument
2343     traceENTER_uxQueueGetQueueLength( xQueue );  in uxQueueGetQueueLength()
2345     traceRETURN_uxQueueGetQueueLength( ( ( Queue_t * ) xQueue )->uxLength );  in uxQueueGetQueueLength()
2347     return ( ( Queue_t * ) xQueue )->uxLength;  in uxQueueGetQueueLength()
2411         if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail )  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()
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()
2623 BaseType_t xQueueIsQueueEmptyFromISR( const QueueHandle_t xQueue )  in xQueueIsQueueEmptyFromISR()  argument
2626     Queue_t * const pxQueue = xQueue;  in xQueueIsQueueEmptyFromISR()
2628     traceENTER_xQueueIsQueueEmptyFromISR( xQueue );  in xQueueIsQueueEmptyFromISR()
2668 BaseType_t xQueueIsQueueFullFromISR( const QueueHandle_t xQueue )  in xQueueIsQueueFullFromISR()  argument
2671     Queue_t * const pxQueue = xQueue;  in xQueueIsQueueFullFromISR()
2673     traceENTER_xQueueIsQueueFullFromISR( xQueue );  in xQueueIsQueueFullFromISR()
2694     BaseType_t xQueueCRSend( QueueHandle_t xQueue,  in xQueueCRSend()  argument
2699         Queue_t * const pxQueue = xQueue;  in xQueueCRSend()
2701         traceENTER_xQueueCRSend( xQueue, pvItemToQueue, xTicksToWait );  in xQueueCRSend()
2777     BaseType_t xQueueCRReceive( QueueHandle_t xQueue,  in xQueueCRReceive()  argument
2782         Queue_t * const pxQueue = xQueue;  in xQueueCRReceive()
2784         traceENTER_xQueueCRReceive( xQueue, pvBuffer, xTicksToWait );  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()
2833 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu…  in xQueueCRReceive()
2875     BaseType_t xQueueCRSendFromISR( QueueHandle_t xQueue,  in xQueueCRSendFromISR()  argument
2879         Queue_t * const pxQueue = xQueue;  in xQueueCRSendFromISR()
2881         traceENTER_xQueueCRSendFromISR( xQueue, pvItemToQueue, xCoRoutinePreviouslyWoken );  in xQueueCRSendFromISR()
2929     BaseType_t xQueueCRReceiveFromISR( QueueHandle_t xQueue,  in xQueueCRReceiveFromISR()  argument
2934         Queue_t * const pxQueue = xQueue;  in xQueueCRReceiveFromISR()
2936         traceENTER_xQueueCRReceiveFromISR( xQueue, pvBuffer, pxCoRoutineWoken );  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()
2955 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu…  in xQueueCRReceiveFromISR()
2997     void vQueueAddToRegistry( QueueHandle_t xQueue,  in vQueueAddToRegistry()  argument
3003         traceENTER_vQueueAddToRegistry( xQueue, pcQueueName );  in vQueueAddToRegistry()
3005         configASSERT( xQueue );  in vQueueAddToRegistry()
3014                 if( xQueue == xQueueRegistry[ ux ].xHandle )  in vQueueAddToRegistry()
3035             pxEntryToWrite->xHandle = xQueue;  in vQueueAddToRegistry()
3037             traceQUEUE_REGISTRY_ADD( xQueue, pcQueueName );  in vQueueAddToRegistry()
3048     const char * pcQueueGetName( QueueHandle_t xQueue )  in pcQueueGetName()  argument
3053         traceENTER_pcQueueGetName( xQueue );  in pcQueueGetName()
3055         configASSERT( xQueue );  in pcQueueGetName()
3062             if( xQueueRegistry[ ux ].xHandle == xQueue )  in pcQueueGetName()
3083     void vQueueUnregisterQueue( QueueHandle_t xQueue )  in vQueueUnregisterQueue()  argument
3087         traceENTER_vQueueUnregisterQueue( xQueue );  in vQueueUnregisterQueue()
3089         configASSERT( xQueue );  in vQueueUnregisterQueue()
3095             if( xQueueRegistry[ ux ].xHandle == xQueue )  in vQueueUnregisterQueue()
3120     void vQueueWaitForMessageRestricted( QueueHandle_t xQueue,  in vQueueWaitForMessageRestricted()  argument
3124         Queue_t * const pxQueue = xQueue;  in vQueueWaitForMessageRestricted()
3126         traceENTER_vQueueWaitForMessageRestricted( xQueue, xTicksToWait, xWaitIndefinitely );  in vQueueWaitForMessageRestricted()