Lines Matching refs:xQueue
104 QueuePointers_t xQueue; /*< Data required exclusively when this structure is used as a queue. */ member
260 BaseType_t xQueueGenericReset( QueueHandle_t xQueue, BaseType_t xNewQueue ) in xQueueGenericReset() argument
262 Queue_t * const pxQueue = xQueue; in xQueueGenericReset()
273 …pxQueue->u.xQueue.pcTail = pxQueue->pcHead + ( pxQueue->uxLength * pxQueue->uxItemSize ); /*lint !… in xQueueGenericReset()
276 …pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead + ( ( pxQueue->uxLength - 1U ) * pxQueue->uxItemSiz… in xQueueGenericReset()
764 BaseType_t xQueueGenericSend( QueueHandle_t xQueue, const void * const pvItemToQueue, TickType_t xT… in xQueueGenericSend() argument
768 Queue_t * const pxQueue = xQueue; in xQueueGenericSend()
978 BaseType_t xQueueGenericSendFromISR( QueueHandle_t xQueue, const void * const pvItemToQueue, BaseTy… in xQueueGenericSendFromISR() argument
982 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR()
1133 BaseType_t xQueueGiveFromISR( QueueHandle_t xQueue, BaseType_t * const pxHigherPriorityTaskWoken ) in xQueueGiveFromISR() argument
1137 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR()
1301 BaseType_t xQueueReceive( QueueHandle_t xQueue, void * const pvBuffer, TickType_t xTicksToWait ) in xQueueReceive() argument
1305 Queue_t * const pxQueue = xQueue; in xQueueReceive()
1436 BaseType_t xQueueSemaphoreTake( QueueHandle_t xQueue, TickType_t xTicksToWait ) in xQueueSemaphoreTake() argument
1440 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake()
1648 BaseType_t xQueuePeek( QueueHandle_t xQueue, void * const pvBuffer, TickType_t xTicksToWait ) in xQueuePeek() argument
1653 Queue_t * const pxQueue = xQueue; in xQueuePeek()
1686 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeek()
1692 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeek()
1791 BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue, void * const pvBuffer, BaseType_t * const px… in xQueueReceiveFromISR() argument
1795 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR()
1885 BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue, void * const pvBuffer ) in xQueuePeekFromISR() argument
1890 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR()
1922 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeekFromISR()
1924 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeekFromISR()
1941 UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue ) in uxQueueMessagesWaiting() argument
1944 Queue_t * const pxQueue = ( Queue_t * ) xQueue; in uxQueueMessagesWaiting()
1946 configASSERT( xQueue ); in uxQueueMessagesWaiting()
1950 uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting; in uxQueueMessagesWaiting()
1958 UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue ) in uxQueueSpacesAvailable() argument
1961 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable()
1975 UBaseType_t uxQueueMessagesWaitingFromISR( const QueueHandle_t xQueue ) in uxQueueMessagesWaitingFromISR() argument
1978 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR()
1987 void vQueueDelete( QueueHandle_t xQueue ) in vQueueDelete() argument
1989 Queue_t * const pxQueue = xQueue; in vQueueDelete()
2031 UBaseType_t uxQueueGetQueueNumber( QueueHandle_t xQueue ) in uxQueueGetQueueNumber() argument
2033 return ( ( Queue_t * ) xQueue )->uxQueueNumber; in uxQueueGetQueueNumber()
2041 void vQueueSetQueueNumber( QueueHandle_t xQueue, UBaseType_t uxQueueNumber ) in vQueueSetQueueNumber() argument
2043 ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber; in vQueueSetQueueNumber()
2051 uint8_t ucQueueGetQueueType( QueueHandle_t xQueue ) in ucQueueGetQueueType() argument
2053 return ( ( Queue_t * ) xQueue )->ucQueueType; in ucQueueGetQueueType()
2116 …if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail ) /*lint !e946 MISRA exception justified as com… in prvCopyDataToQueue()
2127 …( void ) memcpy( ( void * ) pxQueue->u.xQueue.pcReadFrom, pvItemToQueue, ( size_t ) pxQueue->uxIte… in prvCopyDataToQueue()
2128 pxQueue->u.xQueue.pcReadFrom -= pxQueue->uxItemSize; in prvCopyDataToQueue()
2129 …if( pxQueue->u.xQueue.pcReadFrom < pxQueue->pcHead ) /*lint !e946 MISRA exception justified as com… in prvCopyDataToQueue()
2131 pxQueue->u.xQueue.pcReadFrom = ( pxQueue->u.xQueue.pcTail - pxQueue->uxItemSize ); in prvCopyDataToQueue()
2169 …pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; /*lint !e9016 Pointer arithmetic on char type… in prvCopyDataFromQueue()
2170 …if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) /*lint !e946 MISRA exception justif… in prvCopyDataFromQueue()
2172 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in prvCopyDataFromQueue()
2178 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( size_t ) pxQueue-… in prvCopyDataFromQueue()
2324 BaseType_t xQueueIsQueueEmptyFromISR( const QueueHandle_t xQueue ) in xQueueIsQueueEmptyFromISR() argument
2327 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR()
2362 BaseType_t xQueueIsQueueFullFromISR( const QueueHandle_t xQueue ) in xQueueIsQueueFullFromISR() argument
2365 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR()
2383 BaseType_t xQueueCRSend( QueueHandle_t xQueue, const void *pvItemToQueue, TickType_t xTicksToWait ) in xQueueCRSend() argument
2386 Queue_t * const pxQueue = xQueue; in xQueueCRSend()
2460 BaseType_t xQueueCRReceive( QueueHandle_t xQueue, void *pvBuffer, TickType_t xTicksToWait ) in xQueueCRReceive() argument
2463 Queue_t * const pxQueue = xQueue; in xQueueCRReceive()
2500 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceive()
2501 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceive()
2503 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceive()
2510 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceive()
2550 …BaseType_t xQueueCRSendFromISR( QueueHandle_t xQueue, const void *pvItemToQueue, BaseType_t xCoRou… in xQueueCRSendFromISR() argument
2552 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR()
2598 …BaseType_t xQueueCRReceiveFromISR( QueueHandle_t xQueue, void *pvBuffer, BaseType_t *pxCoRoutineWo… in xQueueCRReceiveFromISR() argument
2601 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR()
2608 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceiveFromISR()
2609 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceiveFromISR()
2611 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceiveFromISR()
2618 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceiveFromISR()
2658 …void vQueueAddToRegistry( QueueHandle_t xQueue, const char *pcQueueName ) /*lint !e971 Unqualified… in vQueueAddToRegistry() argument
2671 xQueueRegistry[ ux ].xHandle = xQueue; in vQueueAddToRegistry()
2673 traceQUEUE_REGISTRY_ADD( xQueue, pcQueueName ); in vQueueAddToRegistry()
2689 …const char *pcQueueGetName( QueueHandle_t xQueue ) /*lint !e971 Unqualified char types are allowed… in pcQueueGetName() argument
2699 if( xQueueRegistry[ ux ].xHandle == xQueue ) in pcQueueGetName()
2719 void vQueueUnregisterQueue( QueueHandle_t xQueue ) in vQueueUnregisterQueue() argument
2728 if( xQueueRegistry[ ux ].xHandle == xQueue ) in vQueueUnregisterQueue()
2753 …void vQueueWaitForMessageRestricted( QueueHandle_t xQueue, TickType_t xTicksToWait, const BaseType… in vQueueWaitForMessageRestricted() argument
2755 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted()