Lines Matching refs:xQueue
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()
949 BaseType_t xQueueGenericSend( QueueHandle_t xQueue, in xQueueGenericSend() argument
956 Queue_t * const pxQueue = xQueue; in xQueueGenericSend()
958 traceENTER_xQueueGenericSend( xQueue, pvItemToQueue, xTicksToWait, xCopyPosition ); in xQueueGenericSend()
1167 BaseType_t xQueueGenericSendFromISR( QueueHandle_t xQueue, in xQueueGenericSendFromISR() argument
1174 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR()
1176 …traceENTER_xQueueGenericSendFromISR( xQueue, pvItemToQueue, pxHigherPriorityTaskWoken, xCopyPositi… in xQueueGenericSendFromISR()
1338 BaseType_t xQueueGiveFromISR( QueueHandle_t xQueue, in xQueueGiveFromISR() argument
1343 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR()
1345 traceENTER_xQueueGiveFromISR( xQueue, pxHigherPriorityTaskWoken ); in xQueueGiveFromISR()
1509 BaseType_t xQueueReceive( QueueHandle_t xQueue, in xQueueReceive() argument
1515 Queue_t * const pxQueue = xQueue; in xQueueReceive()
1517 traceENTER_xQueueReceive( xQueue, pvBuffer, xTicksToWait ); in xQueueReceive()
1659 BaseType_t xQueueSemaphoreTake( QueueHandle_t xQueue, in xQueueSemaphoreTake() argument
1664 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake()
1670 traceENTER_xQueueSemaphoreTake( xQueue, xTicksToWait ); in xQueueSemaphoreTake()
1884 BaseType_t xQueuePeek( QueueHandle_t xQueue, in xQueuePeek() argument
1891 Queue_t * const pxQueue = xQueue; in xQueuePeek()
1893 traceENTER_xQueuePeek( xQueue, pvBuffer, xTicksToWait ); in xQueuePeek()
1919 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeek()
1925 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeek()
2039 BaseType_t xQueueReceiveFromISR( QueueHandle_t xQueue, in xQueueReceiveFromISR() argument
2045 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR()
2047 traceENTER_xQueueReceiveFromISR( xQueue, pvBuffer, pxHigherPriorityTaskWoken ); in xQueueReceiveFromISR()
2139 BaseType_t xQueuePeekFromISR( QueueHandle_t xQueue, in xQueuePeekFromISR() argument
2145 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR()
2147 traceENTER_xQueuePeekFromISR( xQueue, pvBuffer ); in xQueuePeekFromISR()
2180 pcOriginalReadPosition = pxQueue->u.xQueue.pcReadFrom; in xQueuePeekFromISR()
2182 pxQueue->u.xQueue.pcReadFrom = pcOriginalReadPosition; in xQueuePeekFromISR()
2200 UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue ) in uxQueueMessagesWaiting() argument
2204 traceENTER_uxQueueMessagesWaiting( xQueue ); in uxQueueMessagesWaiting()
2206 configASSERT( xQueue ); in uxQueueMessagesWaiting()
2210 uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting; in uxQueueMessagesWaiting()
2220 UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue ) in uxQueueSpacesAvailable() argument
2223 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable()
2225 traceENTER_uxQueueSpacesAvailable( xQueue ); in uxQueueSpacesAvailable()
2241 UBaseType_t uxQueueMessagesWaitingFromISR( const QueueHandle_t xQueue ) in uxQueueMessagesWaitingFromISR() argument
2244 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR()
2246 traceENTER_uxQueueMessagesWaitingFromISR( xQueue ); in uxQueueMessagesWaitingFromISR()
2257 void vQueueDelete( QueueHandle_t xQueue ) in vQueueDelete() argument
2259 Queue_t * const pxQueue = xQueue; in vQueueDelete()
2261 traceENTER_vQueueDelete( xQueue ); in vQueueDelete()
2305 UBaseType_t uxQueueGetQueueNumber( QueueHandle_t xQueue ) in uxQueueGetQueueNumber() argument
2307 traceENTER_uxQueueGetQueueNumber( xQueue ); in uxQueueGetQueueNumber()
2309 traceRETURN_uxQueueGetQueueNumber( ( ( Queue_t * ) xQueue )->uxQueueNumber ); in uxQueueGetQueueNumber()
2311 return ( ( Queue_t * ) xQueue )->uxQueueNumber; in uxQueueGetQueueNumber()
2319 void vQueueSetQueueNumber( QueueHandle_t xQueue, in vQueueSetQueueNumber() argument
2322 traceENTER_vQueueSetQueueNumber( xQueue, uxQueueNumber ); in vQueueSetQueueNumber()
2324 ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber; in vQueueSetQueueNumber()
2334 uint8_t ucQueueGetQueueType( QueueHandle_t xQueue ) in ucQueueGetQueueType() argument
2336 traceENTER_ucQueueGetQueueType( xQueue ); in ucQueueGetQueueType()
2338 traceRETURN_ucQueueGetQueueType( ( ( Queue_t * ) xQueue )->ucQueueType ); in ucQueueGetQueueType()
2340 return ( ( Queue_t * ) xQueue )->ucQueueType; in ucQueueGetQueueType()
2346 UBaseType_t uxQueueGetQueueItemSize( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */ in uxQueueGetQueueItemSize() argument
2348 traceENTER_uxQueueGetQueueItemSize( xQueue ); in uxQueueGetQueueItemSize()
2350 traceRETURN_uxQueueGetQueueItemSize( ( ( Queue_t * ) xQueue )->uxItemSize ); in uxQueueGetQueueItemSize()
2352 return ( ( Queue_t * ) xQueue )->uxItemSize; in uxQueueGetQueueItemSize()
2356 UBaseType_t uxQueueGetQueueLength( QueueHandle_t xQueue ) /* PRIVILEGED_FUNCTION */ in uxQueueGetQueueLength() argument
2358 traceENTER_uxQueueGetQueueLength( xQueue ); in uxQueueGetQueueLength()
2360 traceRETURN_uxQueueGetQueueLength( ( ( Queue_t * ) xQueue )->uxLength ); in uxQueueGetQueueLength()
2362 return ( ( Queue_t * ) xQueue )->uxLength; in uxQueueGetQueueLength()
2426 if( pxQueue->pcWriteTo >= pxQueue->u.xQueue.pcTail ) in prvCopyDataToQueue()
2437 …( void ) memcpy( ( void * ) pxQueue->u.xQueue.pcReadFrom, pvItemToQueue, ( size_t ) pxQueue->uxIte… in prvCopyDataToQueue()
2438 pxQueue->u.xQueue.pcReadFrom -= pxQueue->uxItemSize; in prvCopyDataToQueue()
2440 if( pxQueue->u.xQueue.pcReadFrom < pxQueue->pcHead ) in prvCopyDataToQueue()
2442 pxQueue->u.xQueue.pcReadFrom = ( pxQueue->u.xQueue.pcTail - pxQueue->uxItemSize ); in prvCopyDataToQueue()
2481 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in prvCopyDataFromQueue()
2483 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in prvCopyDataFromQueue()
2485 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in prvCopyDataFromQueue()
2492 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( size_t ) pxQueue-… in prvCopyDataFromQueue()
2638 BaseType_t xQueueIsQueueEmptyFromISR( const QueueHandle_t xQueue ) in xQueueIsQueueEmptyFromISR() argument
2641 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR()
2643 traceENTER_xQueueIsQueueEmptyFromISR( xQueue ); in xQueueIsQueueEmptyFromISR()
2683 BaseType_t xQueueIsQueueFullFromISR( const QueueHandle_t xQueue ) in xQueueIsQueueFullFromISR() argument
2686 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR()
2688 traceENTER_xQueueIsQueueFullFromISR( xQueue ); in xQueueIsQueueFullFromISR()
2709 BaseType_t xQueueCRSend( QueueHandle_t xQueue, in xQueueCRSend() argument
2714 Queue_t * const pxQueue = xQueue; in xQueueCRSend()
2716 traceENTER_xQueueCRSend( xQueue, pvItemToQueue, xTicksToWait ); in xQueueCRSend()
2792 BaseType_t xQueueCRReceive( QueueHandle_t xQueue, in xQueueCRReceive() argument
2797 Queue_t * const pxQueue = xQueue; in xQueueCRReceive()
2799 traceENTER_xQueueCRReceive( xQueue, pvBuffer, xTicksToWait ); in xQueueCRReceive()
2836 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceive()
2838 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceive()
2840 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceive()
2848 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceive()
2890 BaseType_t xQueueCRSendFromISR( QueueHandle_t xQueue, in xQueueCRSendFromISR() argument
2894 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR()
2896 traceENTER_xQueueCRSendFromISR( xQueue, pvItemToQueue, xCoRoutinePreviouslyWoken ); in xQueueCRSendFromISR()
2944 BaseType_t xQueueCRReceiveFromISR( QueueHandle_t xQueue, in xQueueCRReceiveFromISR() argument
2949 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR()
2951 traceENTER_xQueueCRReceiveFromISR( xQueue, pvBuffer, pxCoRoutineWoken ); in xQueueCRReceiveFromISR()
2958 pxQueue->u.xQueue.pcReadFrom += pxQueue->uxItemSize; in xQueueCRReceiveFromISR()
2960 if( pxQueue->u.xQueue.pcReadFrom >= pxQueue->u.xQueue.pcTail ) in xQueueCRReceiveFromISR()
2962 pxQueue->u.xQueue.pcReadFrom = pxQueue->pcHead; in xQueueCRReceiveFromISR()
2970 …( void ) memcpy( ( void * ) pvBuffer, ( void * ) pxQueue->u.xQueue.pcReadFrom, ( unsigned ) pxQueu… in xQueueCRReceiveFromISR()
3012 void vQueueAddToRegistry( QueueHandle_t xQueue, in vQueueAddToRegistry() argument
3018 traceENTER_vQueueAddToRegistry( xQueue, pcQueueName ); in vQueueAddToRegistry()
3020 configASSERT( xQueue ); in vQueueAddToRegistry()
3029 if( xQueue == xQueueRegistry[ ux ].xHandle ) in vQueueAddToRegistry()
3050 pxEntryToWrite->xHandle = xQueue; in vQueueAddToRegistry()
3052 traceQUEUE_REGISTRY_ADD( xQueue, pcQueueName ); in vQueueAddToRegistry()
3063 const char * pcQueueGetName( QueueHandle_t xQueue ) in pcQueueGetName() argument
3068 traceENTER_pcQueueGetName( xQueue ); in pcQueueGetName()
3070 configASSERT( xQueue ); in pcQueueGetName()
3077 if( xQueueRegistry[ ux ].xHandle == xQueue ) in pcQueueGetName()
3098 void vQueueUnregisterQueue( QueueHandle_t xQueue ) in vQueueUnregisterQueue() argument
3102 traceENTER_vQueueUnregisterQueue( xQueue ); in vQueueUnregisterQueue()
3104 configASSERT( xQueue ); in vQueueUnregisterQueue()
3110 if( xQueueRegistry[ ux ].xHandle == xQueue ) in vQueueUnregisterQueue()
3135 void vQueueWaitForMessageRestricted( QueueHandle_t xQueue, in vQueueWaitForMessageRestricted() argument
3139 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted()
3141 traceENTER_vQueueWaitForMessageRestricted( xQueue, xTicksToWait, xWaitIndefinitely ); in vQueueWaitForMessageRestricted()