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()
1329 BaseType_t xQueueGiveFromISR( QueueHandle_t xQueue,  in xQueueGiveFromISR()  argument
1334     Queue_t * const pxQueue = xQueue;  in xQueueGiveFromISR()
1336     traceENTER_xQueueGiveFromISR( xQueue, pxHigherPriorityTaskWoken );  in xQueueGiveFromISR()
1502 BaseType_t xQueueReceive( QueueHandle_t xQueue,  in xQueueReceive()  argument
1508     Queue_t * const pxQueue = xQueue;  in xQueueReceive()
1510     traceENTER_xQueueReceive( xQueue, pvBuffer, xTicksToWait );  in xQueueReceive()
1652 BaseType_t xQueueSemaphoreTake( QueueHandle_t xQueue,  in xQueueSemaphoreTake()  argument
1657     Queue_t * const pxQueue = xQueue;  in xQueueSemaphoreTake()
1663     traceENTER_xQueueSemaphoreTake( xQueue, xTicksToWait );  in xQueueSemaphoreTake()
1877 BaseType_t xQueuePeek( QueueHandle_t xQueue,  in xQueuePeek()  argument
1884     Queue_t * const pxQueue = xQueue;  in xQueuePeek()
1886     traceENTER_xQueuePeek( xQueue, pvBuffer, xTicksToWait );  in xQueuePeek()
1915                 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom;  in xQueuePeek()
1921                 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition;  in xQueuePeek()
2035 BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue,  in xQueueReceiveFromISR()  argument
2041     Queue_t * const pxQueue = xQueue;  in xQueueReceiveFromISR()
2043     traceENTER_xQueueReceiveFromISR( xQueue, pvBuffer, pxHigherPriorityTaskWoken );  in xQueueReceiveFromISR()
2135 BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue,  in xQueuePeekFromISR()  argument
2141     Queue_t * const pxQueue = xQueue;  in xQueuePeekFromISR()
2143     traceENTER_xQueuePeekFromISR( xQueue, pvBuffer );  in xQueuePeekFromISR()
2177             pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom;  in xQueuePeekFromISR()
2179             pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition;  in xQueuePeekFromISR()
2197 UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue )  in uxQueueMessagesWaiting()  argument
2201     traceENTER_uxQueueMessagesWaiting( xQueue );  in uxQueueMessagesWaiting()
2203     configASSERT( xQueue );  in uxQueueMessagesWaiting()
2207         uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting;  in uxQueueMessagesWaiting()
2217 UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue )  in uxQueueSpacesAvailable()  argument
2220     Queue_t * const pxQueue = xQueue;  in uxQueueSpacesAvailable()
2222     traceENTER_uxQueueSpacesAvailable( xQueue );  in uxQueueSpacesAvailable()
2238 UBaseType_t uxQueueMessagesWaitingFromISR( const QueueHandle_t xQueue )  in uxQueueMessagesWaitingFromISR()  argument
2241     Queue_t * const pxQueue = xQueue;  in uxQueueMessagesWaitingFromISR()
2243     traceENTER_uxQueueMessagesWaitingFromISR( xQueue );  in uxQueueMessagesWaitingFromISR()
2254 void vQueueDelete( QueueHandle_t xQueue )  in vQueueDelete()  argument
2256     Queue_t * const pxQueue = xQueue;  in vQueueDelete()
2258     traceENTER_vQueueDelete( xQueue );  in vQueueDelete()
2302     UBaseType_t uxQueueGetQueueNumber( QueueHandle_t xQueue )  in uxQueueGetQueueNumber()  argument
2304         traceENTER_uxQueueGetQueueNumber( xQueue );  in uxQueueGetQueueNumber()
2306         traceRETURN_uxQueueGetQueueNumber( ( ( Queue_t * ) xQueue )->uxQueueNumber );  in uxQueueGetQueueNumber()
2308         return ( ( Queue_t * ) xQueue )->uxQueueNumber;  in uxQueueGetQueueNumber()
2316     void vQueueSetQueueNumber( QueueHandle_t xQueue,  in vQueueSetQueueNumber()  argument
2319         traceENTER_vQueueSetQueueNumber( xQueue, uxQueueNumber );  in vQueueSetQueueNumber()
2321         ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber;  in vQueueSetQueueNumber()
2331     uint8_t ucQueueGetQueueType( QueueHandle_t xQueue )  in ucQueueGetQueueType()  argument
2333         traceENTER_ucQueueGetQueueType( xQueue );  in ucQueueGetQueueType()
2335         traceRETURN_ucQueueGetQueueType( ( ( Queue_t * ) xQueue )->ucQueueType );  in ucQueueGetQueueType()
2337         return ( ( Queue_t * ) xQueue )->ucQueueType;  in ucQueueGetQueueType()
2343 UBaseType_t uxQueueGetQueueItemSize( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */  in uxQueueGetQueueItemSize()  argument
2345     traceENTER_uxQueueGetQueueItemSize( xQueue );  in uxQueueGetQueueItemSize()
2347     traceRETURN_uxQueueGetQueueItemSize( ( ( Queue_t * ) xQueue )->uxItemSize );  in uxQueueGetQueueItemSize()
2349     return ( ( Queue_t * ) xQueue )->uxItemSize;  in uxQueueGetQueueItemSize()
2353 UBaseType_t uxQueueGetQueueLength( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */  in uxQueueGetQueueLength()  argument
2355     traceENTER_uxQueueGetQueueLength( xQueue );  in uxQueueGetQueueLength()
2357     traceRETURN_uxQueueGetQueueLength( ( ( Queue_t * ) xQueue )->uxLength );  in uxQueueGetQueueLength()
2359     return ( ( Queue_t * ) xQueue )->uxLength;  in uxQueueGetQueueLength()
2423         if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail )  in prvCopyDataToQueue()
2434 …( void ) memcpy( ( void * ) pxQueue->u.xQueue.pcReadFrom, pvItemToQueue, ( size_t ) pxQueue->uxIte…  in prvCopyDataToQueue()
2435         pxQueue->u.xQueue.pcReadFrom -= pxQueue->uxItemSize;  in prvCopyDataToQueue()
2437         if( pxQueue->u.xQueue.pcReadFrom < pxQueue->pcHead )  in prvCopyDataToQueue()
2439             pxQueue->u.xQueue.pcReadFrom = ( pxQueue->u.xQueue.pcTail - pxQueue->uxItemSize );  in prvCopyDataToQueue()
2478         pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize;  in prvCopyDataFromQueue()
2480         if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail )  in prvCopyDataFromQueue()
2482             pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead;  in prvCopyDataFromQueue()
2489 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( size_t ) pxQueue-…  in prvCopyDataFromQueue()
2635 BaseType_t xQueueIsQueueEmptyFromISR( const QueueHandle_t xQueue )  in xQueueIsQueueEmptyFromISR()  argument
2638     Queue_t * const pxQueue = xQueue;  in xQueueIsQueueEmptyFromISR()
2640     traceENTER_xQueueIsQueueEmptyFromISR( xQueue );  in xQueueIsQueueEmptyFromISR()
2680 BaseType_t xQueueIsQueueFullFromISR( const QueueHandle_t xQueue )  in xQueueIsQueueFullFromISR()  argument
2683     Queue_t * const pxQueue = xQueue;  in xQueueIsQueueFullFromISR()
2685     traceENTER_xQueueIsQueueFullFromISR( xQueue );  in xQueueIsQueueFullFromISR()
2706     BaseType_t xQueueCRSend( QueueHandle_t xQueue,  in xQueueCRSend()  argument
2711         Queue_t * const pxQueue = xQueue;  in xQueueCRSend()
2713         traceENTER_xQueueCRSend( xQueue, pvItemToQueue, xTicksToWait );  in xQueueCRSend()
2789     BaseType_t xQueueCRReceive( QueueHandle_t xQueue,  in xQueueCRReceive()  argument
2794         Queue_t * const pxQueue = xQueue;  in xQueueCRReceive()
2796         traceENTER_xQueueCRReceive( xQueue, pvBuffer, xTicksToWait );  in xQueueCRReceive()
2833                 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize;  in xQueueCRReceive()
2835                 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail )  in xQueueCRReceive()
2837                     pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead;  in xQueueCRReceive()
2845 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu…  in xQueueCRReceive()
2887     BaseType_t xQueueCRSendFromISR( QueueHandle_t xQueue,  in xQueueCRSendFromISR()  argument
2891         Queue_t * const pxQueue = xQueue;  in xQueueCRSendFromISR()
2893         traceENTER_xQueueCRSendFromISR( xQueue, pvItemToQueue, xCoRoutinePreviouslyWoken );  in xQueueCRSendFromISR()
2941     BaseType_t xQueueCRReceiveFromISR( QueueHandle_t xQueue,  in xQueueCRReceiveFromISR()  argument
2946         Queue_t * const pxQueue = xQueue;  in xQueueCRReceiveFromISR()
2948         traceENTER_xQueueCRReceiveFromISR( xQueue, pvBuffer, pxCoRoutineWoken );  in xQueueCRReceiveFromISR()
2955             pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize;  in xQueueCRReceiveFromISR()
2957             if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail )  in xQueueCRReceiveFromISR()
2959                 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead;  in xQueueCRReceiveFromISR()
2967 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu…  in xQueueCRReceiveFromISR()
3009     void vQueueAddToRegistry( QueueHandle_t xQueue,  in vQueueAddToRegistry()  argument
3015         traceENTER_vQueueAddToRegistry( xQueue, pcQueueName );  in vQueueAddToRegistry()
3017         configASSERT( xQueue );  in vQueueAddToRegistry()
3026                 if( xQueue == xQueueRegistry[ ux ].xHandle )  in vQueueAddToRegistry()
3047             pxEntryToWrite->xHandle = xQueue;  in vQueueAddToRegistry()
3049             traceQUEUE_REGISTRY_ADD( xQueue, pcQueueName );  in vQueueAddToRegistry()
3060     const char * pcQueueGetName( QueueHandle_t xQueue )  in pcQueueGetName()  argument
3065         traceENTER_pcQueueGetName( xQueue );  in pcQueueGetName()
3067         configASSERT( xQueue );  in pcQueueGetName()
3074             if( xQueueRegistry[ ux ].xHandle == xQueue )  in pcQueueGetName()
3095     void vQueueUnregisterQueue( QueueHandle_t xQueue )  in vQueueUnregisterQueue()  argument
3099         traceENTER_vQueueUnregisterQueue( xQueue );  in vQueueUnregisterQueue()
3101         configASSERT( xQueue );  in vQueueUnregisterQueue()
3107             if( xQueueRegistry[ ux ].xHandle == xQueue )  in vQueueUnregisterQueue()
3132     void vQueueWaitForMessageRestricted( QueueHandle_t xQueue,  in vQueueWaitForMessageRestricted()  argument
3136         Queue_t * const pxQueue = xQueue;  in vQueueWaitForMessageRestricted()
3138         traceENTER_vQueueWaitForMessageRestricted( xQueue, xTicksToWait, xWaitIndefinitely );  in vQueueWaitForMessageRestricted()