Microchip® Advanced Software Framework

queue.c File Reference
#include <stdlib.h>
#include <string.h>
#include "FreeRTOS.h"
#include "task.h"
#include "queue.h"
#include "croutine.h"

Data Structures

struct  QueueDefinition
 

Macros

#define MPU_WRAPPERS_INCLUDED_FROM_API_FILE
 
#define prvLockQueue(pxQueue)
 
#define pxMutexHolder   pcTail
 
#define queueLOCKED_UNMODIFIED   ( ( int8_t ) 0 )
 
#define queueMUTEX_GIVE_BLOCK_TIME   ( ( TickType_t ) 0U )
 
#define queueQUEUE_IS_MUTEX   NULL
 
#define queueSEMAPHORE_QUEUE_ITEM_LENGTH   ( ( UBaseType_t ) 0 )
 
#define queueUNLOCKED   ( ( int8_t ) -1 )
 
#define queueYIELD_IF_USING_PREEMPTION()   portYIELD_WITHIN_API()
 
#define uxQueueType   pcHead
 

Typedefs

typedef xQUEUE Queue_t
 
typedef struct QueueDefinition xQUEUE
 

Functions

static void prvCopyDataFromQueue (Queue_t *const pxQueue, void *const pvBuffer) PRIVILEGED_FUNCTION
 
static BaseType_t prvCopyDataToQueue (Queue_t *const pxQueue, const void *pvItemToQueue, const BaseType_t xPosition) PRIVILEGED_FUNCTION
 
static UBaseType_t prvGetDisinheritPriorityAfterTimeout (const Queue_t *const pxQueue) PRIVILEGED_FUNCTION
 
static void prvInitialiseMutex (Queue_t *pxNewQueue) PRIVILEGED_FUNCTION
 
static void prvInitialiseNewQueue (const UBaseType_t uxQueueLength, const UBaseType_t uxItemSize, uint8_t *pucQueueStorage, const uint8_t ucQueueType, Queue_t *pxNewQueue) PRIVILEGED_FUNCTION
 
static BaseType_t prvIsQueueEmpty (const Queue_t *pxQueue) PRIVILEGED_FUNCTION
 
static BaseType_t prvIsQueueFull (const Queue_t *pxQueue) PRIVILEGED_FUNCTION
 
static BaseType_t prvNotifyQueueSetContainer (const Queue_t *const pxQueue, const BaseType_t xCopyPosition) PRIVILEGED_FUNCTION
 
static void prvUnlockQueue (Queue_t *const pxQueue) PRIVILEGED_FUNCTION
 
UBaseType_t uxQueueMessagesWaiting (const QueueHandle_t xQueue)
 
UBaseType_t uxQueueMessagesWaitingFromISR (const QueueHandle_t xQueue)
 
UBaseType_t uxQueueSpacesAvailable (const QueueHandle_t xQueue)
 
void vQueueDelete (QueueHandle_t xQueue)
 
BaseType_t xQueueAddToSet (QueueSetMemberHandle_t xQueueOrSemaphore, QueueSetHandle_t xQueueSet)
 
QueueHandle_t xQueueCreateCountingSemaphore (const UBaseType_t uxMaxCount, const UBaseType_t uxInitialCount)
 
QueueHandle_t xQueueCreateMutex (const uint8_t ucQueueType)
 
QueueSetHandle_t xQueueCreateSet (const UBaseType_t uxEventQueueLength)
 
BaseType_t xQueueCRReceive (QueueHandle_t xQueue, void *pvBuffer, TickType_t xTicksToWait)
 
BaseType_t xQueueCRReceiveFromISR (QueueHandle_t xQueue, void *pvBuffer, BaseType_t *pxCoRoutineWoken)
 
BaseType_t xQueueCRSend (QueueHandle_t xQueue, const void *pvItemToQueue, TickType_t xTicksToWait)
 
BaseType_t xQueueCRSendFromISR (QueueHandle_t xQueue, const void *pvItemToQueue, BaseType_t xCoRoutinePreviouslyWoken)
 
QueueHandle_t xQueueGenericCreate (const UBaseType_t uxQueueLength, const UBaseType_t uxItemSize, const uint8_t ucQueueType)
 
BaseType_t xQueueGenericReset (QueueHandle_t xQueue, BaseType_t xNewQueue)
 
BaseType_t xQueueGenericSend (QueueHandle_t xQueue, const void *const pvItemToQueue, TickType_t xTicksToWait, const BaseType_t xCopyPosition)
 
BaseType_t xQueueGenericSendFromISR (QueueHandle_t xQueue, const void *const pvItemToQueue, BaseType_t *const pxHigherPriorityTaskWoken, const BaseType_t xCopyPosition)
 
BaseType_t xQueueGiveFromISR (QueueHandle_t xQueue, BaseType_t *const pxHigherPriorityTaskWoken)
 
BaseType_t xQueueGiveMutexRecursive (QueueHandle_t xMutex)
 
BaseType_t xQueueIsQueueEmptyFromISR (const QueueHandle_t xQueue)
 
BaseType_t xQueueIsQueueFullFromISR (const QueueHandle_t xQueue)
 
BaseType_t xQueuePeek (QueueHandle_t xQueue, void *const pvBuffer, TickType_t xTicksToWait)
 
BaseType_t xQueuePeekFromISR (QueueHandle_t xQueue, void *const pvBuffer)
 
BaseType_t xQueueReceive (QueueHandle_t xQueue, void *const pvBuffer, TickType_t xTicksToWait)
 
BaseType_t xQueueReceiveFromISR (QueueHandle_t xQueue, void *const pvBuffer, BaseType_t *const pxHigherPriorityTaskWoken)
 
BaseType_t xQueueRemoveFromSet (QueueSetMemberHandle_t xQueueOrSemaphore, QueueSetHandle_t xQueueSet)
 
QueueSetMemberHandle_t xQueueSelectFromSet (QueueSetHandle_t xQueueSet, TickType_t const xTicksToWait)
 
QueueSetMemberHandle_t xQueueSelectFromSetFromISR (QueueSetHandle_t xQueueSet)
 
BaseType_t xQueueSemaphoreTake (QueueHandle_t xQueue, TickType_t xTicksToWait)
 
BaseType_t xQueueTakeMutexRecursive (QueueHandle_t xMutex, TickType_t xTicksToWait)
 

#define MPU_WRAPPERS_INCLUDED_FROM_API_FILE
#define prvLockQueue (   pxQueue)
Value:
{ \
if( ( pxQueue )->cRxLock == queueUNLOCKED ) \
{ \
( pxQueue )->cRxLock = queueLOCKED_UNMODIFIED; \
} \
if( ( pxQueue )->cTxLock == queueUNLOCKED ) \
{ \
( pxQueue )->cTxLock = queueLOCKED_UNMODIFIED; \
} \
} \
#define queueLOCKED_UNMODIFIED
Definition: queue.c:54
#define taskEXIT_CRITICAL()
Definition: task.h:194
#define queueUNLOCKED
Definition: queue.c:53
#define taskENTER_CRITICAL()
Definition: task.h:179

Referenced by xQueueGenericSend(), xQueuePeek(), xQueueReceive(), and xQueueSemaphoreTake().

#define pxMutexHolder   pcTail
#define queueLOCKED_UNMODIFIED   ( ( int8_t ) 0 )

Referenced by prvUnlockQueue().

#define queueMUTEX_GIVE_BLOCK_TIME   ( ( TickType_t ) 0U )
#define queueQUEUE_IS_MUTEX   NULL
#define queueSEMAPHORE_QUEUE_ITEM_LENGTH   ( ( UBaseType_t ) 0 )
#define queueYIELD_IF_USING_PREEMPTION ( )    portYIELD_WITHIN_API()
#define uxQueueType   pcHead

typedef xQUEUE Queue_t
typedef struct QueueDefinition xQUEUE

static UBaseType_t prvGetDisinheritPriorityAfterTimeout ( const Queue_t *const  pxQueue)
static
static void prvInitialiseNewQueue ( const UBaseType_t  uxQueueLength,
const UBaseType_t  uxItemSize,
uint8_t *  pucQueueStorage,
const uint8_t  ucQueueType,
Queue_t pxNewQueue 
)
static
static BaseType_t prvIsQueueEmpty ( const Queue_t pxQueue)
static
static BaseType_t prvIsQueueFull ( const Queue_t pxQueue)
static
UBaseType_t uxQueueMessagesWaiting ( const QueueHandle_t  xQueue)
UBaseType_t uxQueueMessagesWaitingFromISR ( const QueueHandle_t  xQueue)

References configASSERT.

UBaseType_t uxQueueSpacesAvailable ( const QueueHandle_t  xQueue)
BaseType_t xQueueAddToSet ( QueueSetMemberHandle_t  xQueueOrSemaphore,
QueueSetHandle_t  xQueueSet 
)
QueueHandle_t xQueueCreateCountingSemaphore ( const UBaseType_t  uxMaxCount,
const UBaseType_t  uxInitialCount 
)
QueueHandle_t xQueueCreateMutex ( const uint8_t  ucQueueType)
QueueSetHandle_t xQueueCreateSet ( const UBaseType_t  uxEventQueueLength)
QueueHandle_t xQueueGenericCreate ( const UBaseType_t  uxQueueLength,
const UBaseType_t  uxItemSize,
const uint8_t  ucQueueType 
)
BaseType_t xQueueIsQueueEmptyFromISR ( const QueueHandle_t  xQueue)

References configASSERT, pdFALSE, and pdTRUE.

BaseType_t xQueueIsQueueFullFromISR ( const QueueHandle_t  xQueue)

References configASSERT, pdFALSE, and pdTRUE.

QueueSetMemberHandle_t xQueueSelectFromSet ( QueueSetHandle_t  xQueueSet,
TickType_t const  xTicksToWait 
)

References xQueueReceive().

QueueSetMemberHandle_t xQueueSelectFromSetFromISR ( QueueSetHandle_t  xQueueSet)