Lines Matching refs:Queue_t
140 typedef xQUEUE Queue_t; typedef
183 static void prvUnlockQueue( Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
190 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) PRIVILEGED_FUNCTION;
197 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) PRIVILEGED_FUNCTION;
203 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue,
210 static void prvCopyDataFromQueue( Queue_t * const pxQueue,
219 … static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
230 Queue_t * pxNewQueue ) PRIVILEGED_FUNCTION;
238 static void prvInitialiseMutex( Queue_t * pxNewQueue ) PRIVILEGED_FUNCTION;
250 …static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) PRIVILEGE…
307 Queue_t * const pxQueue = xQueue; in xQueueGenericReset()
382 Queue_t * pxNewQueue = NULL; in xQueueGenericCreateStatic()
406 configASSERT( xSize == sizeof( Queue_t ) ); /* LCOV_EXCL_BR_LINE */ in xQueueGenericCreateStatic()
417 pxNewQueue = ( Queue_t * ) pxStaticQueue; in xQueueGenericCreateStatic()
451 Queue_t * const pxQueue = xQueue; in xQueueGenericGetStaticBuffers()
506 Queue_t * pxNewQueue = NULL; in xQueueGenericCreate()
516 ( ( UBaseType_t ) ( SIZE_MAX - sizeof( Queue_t ) ) >= ( uxQueueLength * uxItemSize ) ) ) in xQueueGenericCreate()
526 pxNewQueue = ( Queue_t * ) pvPortMalloc( sizeof( Queue_t ) + xQueueSizeInBytes ); in xQueueGenericCreate()
533 pucQueueStorage += sizeof( Queue_t ); in xQueueGenericCreate()
570 Queue_t * pxNewQueue ) in prvInitialiseNewQueue()
614 static void prvInitialiseMutex( Queue_t * pxNewQueue ) in prvInitialiseMutex()
652 prvInitialiseMutex( ( Queue_t * ) xNewQueue ); in xQueueCreateMutex()
677 prvInitialiseMutex( ( Queue_t * ) xNewQueue ); in xQueueCreateMutexStatic()
692 Queue_t * const pxSemaphore = ( Queue_t * ) xSemaphore; in xQueueGetMutexHolder()
737 if( ( ( Queue_t * ) xSemaphore )->uxQueueType == queueQUEUE_IS_MUTEX ) in xQueueGetMutexHolderFromISR()
739 pxReturn = ( ( Queue_t * ) xSemaphore )->u.xSemaphore.xMutexHolder; in xQueueGetMutexHolderFromISR()
759 Queue_t * const pxMutex = ( Queue_t * ) xMutex; in xQueueGiveMutexRecursive()
819 Queue_t * const pxMutex = ( Queue_t * ) xMutex; in xQueueTakeMutexRecursive()
877 ( ( Queue_t * ) xHandle )->uxMessagesWaiting = uxInitialCount; in xQueueCreateCountingSemaphoreStatic()
916 ( ( Queue_t * ) xHandle )->uxMessagesWaiting = uxInitialCount; in xQueueCreateCountingSemaphore()
946 Queue_t * const pxQueue = xQueue; in xQueueGenericSend()
1164 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR()
1331 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR()
1502 Queue_t * const pxQueue = xQueue; in xQueueReceive()
1651 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake()
1878 Queue_t * const pxQueue = xQueue; in xQueuePeek()
2035 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR()
2132 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR()
2195 uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting; in uxQueueMessagesWaiting()
2208 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable()
2229 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR()
2244 Queue_t * const pxQueue = xQueue; in vQueueDelete()
2294 traceRETURN_uxQueueGetQueueNumber( ( ( Queue_t * ) xQueue )->uxQueueNumber ); in uxQueueGetQueueNumber()
2296 return ( ( Queue_t * ) xQueue )->uxQueueNumber; in uxQueueGetQueueNumber()
2309 ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber; in vQueueSetQueueNumber()
2323 traceRETURN_ucQueueGetQueueType( ( ( Queue_t * ) xQueue )->ucQueueType ); in ucQueueGetQueueType()
2325 return ( ( Queue_t * ) xQueue )->ucQueueType; in ucQueueGetQueueType()
2335 traceRETURN_uxQueueGetQueueItemSize( ( ( Queue_t * ) xQueue )->uxItemSize ); in uxQueueGetQueueItemSize()
2337 return ( ( Queue_t * ) xQueue )->uxItemSize; in uxQueueGetQueueItemSize()
2345 traceRETURN_uxQueueGetQueueLength( ( ( Queue_t * ) xQueue )->uxLength ); in uxQueueGetQueueLength()
2347 return ( ( Queue_t * ) xQueue )->uxLength; in uxQueueGetQueueLength()
2353 static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) in prvGetDisinheritPriorityAfterTimeout()
2378 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue, in prvCopyDataToQueue()
2461 static void prvCopyDataFromQueue( Queue_t * const pxQueue, in prvCopyDataFromQueue()
2482 static void prvUnlockQueue( Queue_t * const pxQueue ) in prvUnlockQueue()
2602 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) in prvIsQueueEmpty()
2626 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR()
2647 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) in prvIsQueueFull()
2671 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR()
2699 Queue_t * const pxQueue = xQueue; in xQueueCRSend()
2782 Queue_t * const pxQueue = xQueue; in xQueueCRReceive()
2879 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR()
2934 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR()
3124 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted()
3170 …pxQueue = xQueueGenericCreate( uxEventQueueLength, ( UBaseType_t ) sizeof( Queue_t * ), queueQUEUE… in xQueueCreateSet()
3191 if( ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer != NULL ) in xQueueAddToSet()
3196 else if( ( ( Queue_t * ) xQueueOrSemaphore )->uxMessagesWaiting != ( UBaseType_t ) 0 ) in xQueueAddToSet()
3204 ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer = xQueueSet; in xQueueAddToSet()
3224 Queue_t * const pxQueueOrSemaphore = ( Queue_t * ) xQueueOrSemaphore; in xQueueRemoveFromSet()
3298 static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) in prvNotifyQueueSetContainer()
3300 Queue_t * pxQueueSetContainer = pxQueue->pxQueueSetContainer; in prvNotifyQueueSetContainer()