Lines Matching refs:xQueue
107 …QueuePointers_t xQueue; /**< Data required exclusively when this structure is used as a queue.… member
296 BaseType_t xQueueGenericReset( QueueHandle_t xQueue, in xQueueGenericReset() argument
300 Queue_t * const pxQueue = xQueue; in xQueueGenericReset()
311 …pxQueue->u.xQueue.pcTail = pxQueue->pcHead + ( pxQueue->uxLength * pxQueue->uxItemSize ); /*lint !… in xQueueGenericReset()
314 …pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead + ( ( pxQueue->uxLength - 1U ) * pxQueue->uxItemSiz… in xQueueGenericReset()
428 BaseType_t xQueueGenericGetStaticBuffers( QueueHandle_t xQueue, in xQueueGenericGetStaticBuffers() argument
433 Queue_t * const pxQueue = xQueue; in xQueueGenericGetStaticBuffers()
884 BaseType_t xQueueGenericSend( QueueHandle_t xQueue, in xQueueGenericSend() argument
891 Queue_t * const pxQueue = xQueue; in xQueueGenericSend()
1096 BaseType_t xQueueGenericSendFromISR( QueueHandle_t xQueue, in xQueueGenericSendFromISR() argument
1103 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR()
1261 BaseType_t xQueueGiveFromISR( QueueHandle_t xQueue, in xQueueGiveFromISR() argument
1266 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR()
1427 BaseType_t xQueueReceive( QueueHandle_t xQueue, in xQueueReceive() argument
1433 Queue_t * const pxQueue = xQueue; in xQueueReceive()
1570 BaseType_t xQueueSemaphoreTake( QueueHandle_t xQueue, in xQueueSemaphoreTake() argument
1575 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake()
1780 BaseType_t xQueuePeek( QueueHandle_t xQueue, in xQueuePeek() argument
1787 Queue_t * const pxQueue = xQueue; in xQueuePeek()
1819 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeek()
1825 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeek()
1931 BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue, in xQueueReceiveFromISR() argument
1937 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR()
2024 BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue, in xQueuePeekFromISR() argument
2030 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR()
2061 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeekFromISR()
2063 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeekFromISR()
2079 UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue ) in uxQueueMessagesWaiting() argument
2083 configASSERT( xQueue ); in uxQueueMessagesWaiting()
2087 uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting; in uxQueueMessagesWaiting()
2095 UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue ) in uxQueueSpacesAvailable() argument
2098 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable()
2112 UBaseType_t uxQueueMessagesWaitingFromISR( const QueueHandle_t xQueue ) in uxQueueMessagesWaitingFromISR() argument
2115 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR()
2124 void vQueueDelete( QueueHandle_t xQueue ) in vQueueDelete() argument
2126 Queue_t * const pxQueue = xQueue; in vQueueDelete()
2168 UBaseType_t uxQueueGetQueueNumber( QueueHandle_t xQueue ) in uxQueueGetQueueNumber() argument
2170 return ( ( Queue_t * ) xQueue )->uxQueueNumber; in uxQueueGetQueueNumber()
2178 void vQueueSetQueueNumber( QueueHandle_t xQueue, in vQueueSetQueueNumber() argument
2181 ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber; in vQueueSetQueueNumber()
2189 uint8_t ucQueueGetQueueType( QueueHandle_t xQueue ) in ucQueueGetQueueType() argument
2191 return ( ( Queue_t * ) xQueue )->ucQueueType; in ucQueueGetQueueType()
2197 UBaseType_t uxQueueGetQueueItemSize( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */ in uxQueueGetQueueItemSize() argument
2199 return ( ( Queue_t * ) xQueue )->uxItemSize; in uxQueueGetQueueItemSize()
2203 UBaseType_t uxQueueGetQueueLength( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */ in uxQueueGetQueueLength() argument
2205 return ( ( Queue_t * ) xQueue )->uxLength; in uxQueueGetQueueLength()
2269 …if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail ) /… 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()
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()
2481 BaseType_t xQueueIsQueueEmptyFromISR( const QueueHandle_t xQueue ) in xQueueIsQueueEmptyFromISR() argument
2484 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR()
2522 BaseType_t xQueueIsQueueFullFromISR( const QueueHandle_t xQueue ) in xQueueIsQueueFullFromISR() argument
2525 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR()
2544 BaseType_t xQueueCRSend( QueueHandle_t xQueue, in xQueueCRSend() argument
2549 Queue_t * const pxQueue = xQueue; in xQueueCRSend()
2623 BaseType_t xQueueCRReceive( QueueHandle_t xQueue, in xQueueCRReceive() argument
2628 Queue_t * const pxQueue = xQueue; 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()
2677 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceive()
2717 BaseType_t xQueueCRSendFromISR( QueueHandle_t xQueue, in xQueueCRSendFromISR() argument
2721 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR()
2767 BaseType_t xQueueCRReceiveFromISR( QueueHandle_t xQueue, in xQueueCRReceiveFromISR() argument
2772 Queue_t * const pxQueue = xQueue; 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()
2791 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceiveFromISR()
2831 void vQueueAddToRegistry( QueueHandle_t xQueue, in vQueueAddToRegistry() argument
2837 configASSERT( xQueue ); in vQueueAddToRegistry()
2846 if( xQueue == xQueueRegistry[ ux ].xHandle ) in vQueueAddToRegistry()
2867 pxEntryToWrite->xHandle = xQueue; in vQueueAddToRegistry()
2869 traceQUEUE_REGISTRY_ADD( xQueue, pcQueueName ); in vQueueAddToRegistry()
2878 …const char * pcQueueGetName( QueueHandle_t xQueue ) /*lint !e971 Unqualified char types are allowe… in pcQueueGetName() argument
2883 configASSERT( xQueue ); in pcQueueGetName()
2890 if( xQueueRegistry[ ux ].xHandle == xQueue ) in pcQueueGetName()
2909 void vQueueUnregisterQueue( QueueHandle_t xQueue ) in vQueueUnregisterQueue() argument
2913 configASSERT( xQueue ); in vQueueUnregisterQueue()
2919 if( xQueueRegistry[ ux ].xHandle == xQueue ) in vQueueUnregisterQueue()
2942 void vQueueWaitForMessageRestricted( QueueHandle_t xQueue, in vQueueWaitForMessageRestricted() argument
2946 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted()