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()
1334 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR()
1508 Queue_t * const pxQueue = xQueue; in xQueueReceive()
1657 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake()
1884 Queue_t * const pxQueue = xQueue; in xQueuePeek()
2041 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR()
2141 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR()
2207 uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting; in uxQueueMessagesWaiting()
2220 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable()
2241 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR()
2256 Queue_t * const pxQueue = xQueue; in vQueueDelete()
2306 traceRETURN_uxQueueGetQueueNumber( ( ( Queue_t * ) xQueue )->uxQueueNumber ); in uxQueueGetQueueNumber()
2308 return ( ( Queue_t * ) xQueue )->uxQueueNumber; in uxQueueGetQueueNumber()
2321 ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber; in vQueueSetQueueNumber()
2335 traceRETURN_ucQueueGetQueueType( ( ( Queue_t * ) xQueue )->ucQueueType ); in ucQueueGetQueueType()
2337 return ( ( Queue_t * ) xQueue )->ucQueueType; in ucQueueGetQueueType()
2347 traceRETURN_uxQueueGetQueueItemSize( ( ( Queue_t * ) xQueue )->uxItemSize ); in uxQueueGetQueueItemSize()
2349 return ( ( Queue_t * ) xQueue )->uxItemSize; in uxQueueGetQueueItemSize()
2357 traceRETURN_uxQueueGetQueueLength( ( ( Queue_t * ) xQueue )->uxLength ); in uxQueueGetQueueLength()
2359 return ( ( Queue_t * ) xQueue )->uxLength; in uxQueueGetQueueLength()
2365 static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) in prvGetDisinheritPriorityAfterTimeout()
2390 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue, in prvCopyDataToQueue()
2473 static void prvCopyDataFromQueue( Queue_t * const pxQueue, in prvCopyDataFromQueue()
2494 static void prvUnlockQueue( Queue_t * const pxQueue ) in prvUnlockQueue()
2614 static BaseType_t prvIsQueueEmpty( const Queue_t * pxQueue ) in prvIsQueueEmpty()
2638 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR()
2659 static BaseType_t prvIsQueueFull( const Queue_t * pxQueue ) in prvIsQueueFull()
2683 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR()
2711 Queue_t * const pxQueue = xQueue; in xQueueCRSend()
2794 Queue_t * const pxQueue = xQueue; in xQueueCRReceive()
2891 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR()
2946 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR()
3136 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted()
3182 …pxQueue = xQueueGenericCreate( uxEventQueueLength, ( UBaseType_t ) sizeof( Queue_t * ), queueQUEUE… in xQueueCreateSet()
3203 if( ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer != NULL ) in xQueueAddToSet()
3208 else if( ( ( Queue_t * ) xQueueOrSemaphore )->uxMessagesWaiting != ( UBaseType_t ) 0 ) in xQueueAddToSet()
3216 ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer = xQueueSet; in xQueueAddToSet()
3236 Queue_t * const pxQueueOrSemaphore = ( Queue_t * ) xQueueOrSemaphore; in xQueueRemoveFromSet()
3310 static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue ) in prvNotifyQueueSetContainer()
3312 Queue_t * pxQueueSetContainer = pxQueue->pxQueueSetContainer; in prvNotifyQueueSetContainer()