Lines Matching refs:Queue_t
137 typedef xQUEUE Queue_t; typedef
179 static void prvUnlockQueue( Queue_t * const pxQueue ) PRIVILEGED_FUNCTION;
186 static BaseType_t prvIsQueueEmpty( const Queue_t *pxQueue ) PRIVILEGED_FUNCTION;
193 static BaseType_t prvIsQueueFull( const Queue_t *pxQueue ) PRIVILEGED_FUNCTION;
199 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue, const void *pvItemToQueue, const Bas…
204 static void prvCopyDataFromQueue( Queue_t * const pxQueue, void * const pvBuffer ) PRIVILEGED_FUNCT…
211 …static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue, const BaseType_t xCop…
218 …eType_t uxItemSize, uint8_t *pucQueueStorage, const uint8_t ucQueueType, Queue_t *pxNewQueue ) PRI…
226 static void prvInitialiseMutex( Queue_t *pxNewQueue ) PRIVILEGED_FUNCTION;
237 …static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) PRIVILEGE…
262 Queue_t * const pxQueue = xQueue; in xQueueGenericReset()
322 Queue_t *pxNewQueue; in xQueueGenericCreateStatic()
341 configASSERT( xSize == sizeof( Queue_t ) ); in xQueueGenericCreateStatic()
349 …pxNewQueue = ( Queue_t * ) pxStaticQueue; /*lint !e740 !e9087 Unusual cast is ok as the structures… in xQueueGenericCreateStatic()
380 Queue_t *pxNewQueue; in xQueueGenericCreate()
402 configASSERT( ( sizeof( Queue_t ) + xQueueSizeInBytes ) > xQueueSizeInBytes ); in xQueueGenericCreate()
413 …pxNewQueue = ( Queue_t * ) pvPortMalloc( sizeof( Queue_t ) + xQueueSizeInBytes ); /*lint !e9087 !e… in xQueueGenericCreate()
420 …pucQueueStorage += sizeof( Queue_t ); /*lint !e9016 Pointer arithmetic allowed on char types, espe… in xQueueGenericCreate()
445 … UBaseType_t uxItemSize, uint8_t *pucQueueStorage, const uint8_t ucQueueType, Queue_t *pxNewQueue ) in prvInitialiseNewQueue()
489 static void prvInitialiseMutex( Queue_t *pxNewQueue ) in prvInitialiseMutex()
526 prvInitialiseMutex( ( Queue_t * ) xNewQueue ); in xQueueCreateMutex()
546 prvInitialiseMutex( ( Queue_t * ) xNewQueue ); in xQueueCreateMutexStatic()
559 Queue_t * const pxSemaphore = ( Queue_t * ) xSemaphore; in xQueueGetMutexHolder()
596 if( ( ( Queue_t * ) xSemaphore )->uxQueueType == queueQUEUE_IS_MUTEX ) in xQueueGetMutexHolderFromISR()
598 pxReturn = ( ( Queue_t * ) xSemaphore )->u.xSemaphore.xMutexHolder; in xQueueGetMutexHolderFromISR()
616 Queue_t * const pxMutex = ( Queue_t * ) xMutex; in xQueueGiveMutexRecursive()
671 Queue_t * const pxMutex = ( Queue_t * ) xMutex; in xQueueTakeMutexRecursive()
721 ( ( Queue_t * ) xHandle )->uxMessagesWaiting = uxInitialCount; in xQueueCreateCountingSemaphoreStatic()
749 ( ( Queue_t * ) xHandle )->uxMessagesWaiting = uxInitialCount; in xQueueCreateCountingSemaphore()
768 Queue_t * const pxQueue = xQueue; in xQueueGenericSend()
982 Queue_t * const pxQueue = xQueue; in xQueueGenericSendFromISR()
1137 Queue_t * const pxQueue = xQueue; in xQueueGiveFromISR()
1305 Queue_t * const pxQueue = xQueue; in xQueueReceive()
1440 Queue_t * const pxQueue = xQueue; in xQueueSemaphoreTake()
1653 Queue_t * const pxQueue = xQueue; in xQueuePeek()
1795 Queue_t * const pxQueue = xQueue; in xQueueReceiveFromISR()
1890 Queue_t * const pxQueue = xQueue; in xQueuePeekFromISR()
1944 Queue_t * const pxQueue = ( Queue_t * ) xQueue; in uxQueueMessagesWaiting()
1950 uxReturn = ( ( Queue_t * ) xQueue )->uxMessagesWaiting; in uxQueueMessagesWaiting()
1961 Queue_t * const pxQueue = xQueue; in uxQueueSpacesAvailable()
1978 Queue_t * const pxQueue = xQueue; in uxQueueMessagesWaitingFromISR()
1989 Queue_t * const pxQueue = xQueue; in vQueueDelete()
2033 return ( ( Queue_t * ) xQueue )->uxQueueNumber; in uxQueueGetQueueNumber()
2043 ( ( Queue_t * ) xQueue )->uxQueueNumber = uxQueueNumber; in vQueueSetQueueNumber()
2053 return ( ( Queue_t * ) xQueue )->ucQueueType; in ucQueueGetQueueType()
2061 static UBaseType_t prvGetDisinheritPriorityAfterTimeout( const Queue_t * const pxQueue ) in prvGetDisinheritPriorityAfterTimeout()
2086 static BaseType_t prvCopyDataToQueue( Queue_t * const pxQueue, const void *pvItemToQueue, const Bas… in prvCopyDataToQueue()
2165 static void prvCopyDataFromQueue( Queue_t * const pxQueue, void * const pvBuffer ) in prvCopyDataFromQueue()
2183 static void prvUnlockQueue( Queue_t * const pxQueue ) in prvUnlockQueue()
2303 static BaseType_t prvIsQueueEmpty( const Queue_t *pxQueue ) in prvIsQueueEmpty()
2306 Queue_t *pxQ = (Queue_t *)pxQueue; in prvIsQueueEmpty()
2327 Queue_t * const pxQueue = xQueue; in xQueueIsQueueEmptyFromISR()
2343 static BaseType_t prvIsQueueFull( const Queue_t *pxQueue ) in prvIsQueueFull()
2365 Queue_t * const pxQueue = xQueue; in xQueueIsQueueFullFromISR()
2386 Queue_t * const pxQueue = xQueue; in xQueueCRSend()
2463 Queue_t * const pxQueue = xQueue; in xQueueCRReceive()
2552 Queue_t * const pxQueue = xQueue; in xQueueCRSendFromISR()
2601 Queue_t * const pxQueue = xQueue; in xQueueCRReceiveFromISR()
2755 Queue_t * const pxQueue = xQueue; in vQueueWaitForMessageRestricted()
2793 …pxQueue = xQueueGenericCreate( uxEventQueueLength, ( UBaseType_t ) sizeof( Queue_t * ), queueQUEUE… in xQueueCreateSet()
2807 taskENTER_CRITICAL(&(((Queue_t * )xQueueOrSemaphore)->mux)); in xQueueAddToSet()
2809 if( ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer != NULL ) in xQueueAddToSet()
2814 else if( ( ( Queue_t * ) xQueueOrSemaphore )->uxMessagesWaiting != ( UBaseType_t ) 0 ) in xQueueAddToSet()
2822 ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer = xQueueSet; in xQueueAddToSet()
2826 taskEXIT_CRITICAL(&(((Queue_t * )xQueueOrSemaphore)->mux)); in xQueueAddToSet()
2839 Queue_t * const pxQueueOrSemaphore = ( Queue_t * ) xQueueOrSemaphore; in xQueueRemoveFromSet()
2898 …static BaseType_t prvNotifyQueueSetContainer( const Queue_t * const pxQueue, const BaseType_t xCop… in prvNotifyQueueSetContainer()
2900 Queue_t *pxQueueSetContainer = pxQueue->pxQueueSetContainer; in prvNotifyQueueSetContainer()