queue.c File Reference

Data Structures
struct	QueuePointers_t
struct	SemaphoreData_t
struct	xQUEUE

Macros
#define	MPU_WRAPPERS_INCLUDED_FROM_API_FILE
#define	queueUNLOCKED
#define	queueLOCKED_UNMODIFIED
#define	uxQueueType
#define	queueQUEUE_IS_MUTEX
#define	queueSEMAPHORE_QUEUE_ITEM_LENGTH
#define	queueMUTEX_GIVE_BLOCK_TIME
#define	queueYIELD_IF_USING_PREEMPTION()
#define	prvLockQueue(pxQueue)

Typedefs
typedef xQUEUE	Queue_t

Functions
static void	prvUnlockQueue (Queue_t *const pxQueue) 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	prvCopyDataToQueue (Queue_t *const pxQueue, const void *pvItemToQueue, const BaseType_t xPosition) PRIVILEGED_FUNCTION
static void	prvCopyDataFromQueue (Queue_t *const pxQueue, void *const pvBuffer) 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
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	xQueueReceive (QueueHandle_t xQueue, void *const pvBuffer, TickType_t xTicksToWait)
BaseType_t	xQueueSemaphoreTake (QueueHandle_t xQueue, TickType_t xTicksToWait)
BaseType_t	xQueuePeek (QueueHandle_t xQueue, void *const pvBuffer, TickType_t xTicksToWait)
BaseType_t	xQueueReceiveFromISR (QueueHandle_t xQueue, void *const pvBuffer, BaseType_t *const pxHigherPriorityTaskWoken)
BaseType_t	xQueuePeekFromISR (QueueHandle_t xQueue, void *const pvBuffer)
UBaseType_t	uxQueueMessagesWaiting (const QueueHandle_t xQueue)
UBaseType_t	uxQueueSpacesAvailable (const QueueHandle_t xQueue)
UBaseType_t	uxQueueMessagesWaitingFromISR (const QueueHandle_t xQueue)
void	vQueueDelete (QueueHandle_t xQueue)
BaseType_t	xQueueIsQueueEmptyFromISR (const QueueHandle_t xQueue)
BaseType_t	xQueueIsQueueFullFromISR (const QueueHandle_t xQueue)

Macro Definition Documentation

#define MPU_WRAPPERS_INCLUDED_FROM_API_FILE

#define prvLockQueue

(

pxQueue

)

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

#define queueLOCKED_UNMODIFIED

Referenced by prvUnlockQueue().

#define queueMUTEX_GIVE_BLOCK_TIME

#define queueQUEUE_IS_MUTEX

Referenced by prvCopyDataToQueue(), xQueueGiveFromISR(), and xQueueSemaphoreTake().

#define queueSEMAPHORE_QUEUE_ITEM_LENGTH

#define queueUNLOCKED

Referenced by prvUnlockQueue(), xQueueGenericReset(), xQueueGenericSendFromISR(), xQueueGiveFromISR(), and xQueueReceiveFromISR().

#define queueYIELD_IF_USING_PREEMPTION

(

)

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

#define uxQueueType

Typedef Documentation

typedef xQUEUE Queue_t

Function Documentation

static void prvCopyDataFromQueue ( Queue_t *const  pxQueue, void *const  pvBuffer  )

static

References memcpy(), mtCOVERAGE_TEST_MARKER, xQUEUE::pcHead, QueuePointers_t::pcReadFrom, QueuePointers_t::pcTail, xQUEUE::u, xQUEUE::uxItemSize, and xQUEUE::xQueue.

Referenced by xQueuePeek(), xQueuePeekFromISR(), xQueueReceive(), and xQueueReceiveFromISR().

static BaseType_t prvCopyDataToQueue ( Queue_t *const  pxQueue, const void *  pvItemToQueue, const BaseType_t  xPosition  )

static

References memcpy(), mtCOVERAGE_TEST_MARKER, xQUEUE::pcHead, QueuePointers_t::pcReadFrom, QueuePointers_t::pcTail, xQUEUE::pcWriteTo, pdFALSE, queueOVERWRITE, queueQUEUE_IS_MUTEX, queueSEND_TO_BACK, xQUEUE::u, xQUEUE::uxItemSize, xQUEUE::uxMessagesWaiting, SemaphoreData_t::xMutexHolder, xQUEUE::xQueue, xQUEUE::xSemaphore, and xTaskPriorityDisinherit().

Referenced by xQueueGenericSend(), and xQueueGenericSendFromISR().

static void prvInitialiseNewQueue ( const UBaseType_t  uxQueueLength, const UBaseType_t  uxItemSize, uint8_t *  pucQueueStorage, const uint8_t  ucQueueType, Queue_t *  pxNewQueue  )

static

References xQUEUE::pcHead, pdTRUE, traceQUEUE_CREATE, xQUEUE::uxItemSize, xQUEUE::uxLength, and xQueueGenericReset().

static BaseType_t prvIsQueueEmpty ( const Queue_t *  pxQueue )

static

References pdFALSE, pdTRUE, taskENTER_CRITICAL, taskEXIT_CRITICAL, and xQUEUE::uxMessagesWaiting.

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

static BaseType_t prvIsQueueFull ( const Queue_t *  pxQueue )

static

References pdFALSE, pdTRUE, taskENTER_CRITICAL, taskEXIT_CRITICAL, xQUEUE::uxLength, and xQUEUE::uxMessagesWaiting.

Referenced by xQueueGenericSend().

static void prvUnlockQueue ( Queue_t *const  pxQueue )

static

References xQUEUE::cRxLock, xQUEUE::cTxLock, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFALSE, queueLOCKED_UNMODIFIED, queueSEND_TO_BACK, queueUNLOCKED, taskENTER_CRITICAL, taskEXIT_CRITICAL, vTaskMissedYield(), xTaskRemoveFromEventList(), xQUEUE::xTasksWaitingToReceive, and xQUEUE::xTasksWaitingToSend.

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

UBaseType_t uxQueueMessagesWaiting

(

const QueueHandle_t

xQueue

)

References configASSERT, taskENTER_CRITICAL, and taskEXIT_CRITICAL.

Referenced by MPU_uxQueueMessagesWaiting().

UBaseType_t uxQueueMessagesWaitingFromISR

(

const QueueHandle_t

xQueue

)

References configASSERT, and xQUEUE::uxMessagesWaiting.

UBaseType_t uxQueueSpacesAvailable

(

const QueueHandle_t

xQueue

)

References configASSERT, taskENTER_CRITICAL, taskEXIT_CRITICAL, xQUEUE::uxLength, and xQUEUE::uxMessagesWaiting.

Referenced by MPU_uxQueueSpacesAvailable().

void vQueueDelete

(

QueueHandle_t

xQueue

)

References configASSERT, mtCOVERAGE_TEST_MARKER, pdFALSE, traceQUEUE_DELETE, vPortFree, and vQueueUnregisterQueue.

Referenced by MPU_vQueueDelete().

BaseType_t xQueueGenericReset	(	QueueHandle_t	xQueue,
		BaseType_t	xNewQueue
	)

References configASSERT, xQUEUE::cRxLock, xQUEUE::cTxLock, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, xQUEUE::pcHead, QueuePointers_t::pcReadFrom, QueuePointers_t::pcTail, xQUEUE::pcWriteTo, pdFALSE, pdPASS, queueUNLOCKED, queueYIELD_IF_USING_PREEMPTION, taskENTER_CRITICAL, taskEXIT_CRITICAL, xQUEUE::u, xQUEUE::uxItemSize, xQUEUE::uxLength, xQUEUE::uxMessagesWaiting, vListInitialise(), xQUEUE::xQueue, xTaskRemoveFromEventList(), xQUEUE::xTasksWaitingToReceive, and xQUEUE::xTasksWaitingToSend.

Referenced by MPU_xQueueGenericReset(), and prvInitialiseNewQueue().

BaseType_t xQueueGenericSend	(	QueueHandle_t	xQueue,
		const void *const	pvItemToQueue,
		TickType_t	xTicksToWait,
		const BaseType_t	xCopyPosition
	)

References configASSERT, errQUEUE_FULL, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFALSE, pdPASS, pdTRUE, portYIELD_WITHIN_API, prvCopyDataToQueue(), prvIsQueueFull(), prvLockQueue, prvUnlockQueue(), queueOVERWRITE, queueYIELD_IF_USING_PREEMPTION, taskENTER_CRITICAL, taskEXIT_CRITICAL, taskSCHEDULER_SUSPENDED, traceBLOCKING_ON_QUEUE_SEND, traceQUEUE_SEND, traceQUEUE_SEND_FAILED, xQUEUE::uxItemSize, xQUEUE::uxLength, xQUEUE::uxMessagesWaiting, vTaskInternalSetTimeOutState(), vTaskPlaceOnEventList(), vTaskSuspendAll(), xTaskCheckForTimeOut(), xTaskGetSchedulerState(), xTaskRemoveFromEventList(), xTaskResumeAll(), xQUEUE::xTasksWaitingToReceive, and xQUEUE::xTasksWaitingToSend.

Referenced by MPU_xQueueGenericSend().

BaseType_t xQueueGenericSendFromISR	(	QueueHandle_t	xQueue,
		const void *const	pvItemToQueue,
		BaseType_t *const	pxHigherPriorityTaskWoken,
		const BaseType_t	xCopyPosition
	)

References configASSERT, xQUEUE::cTxLock, errQUEUE_FULL, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFALSE, pdPASS, pdTRUE, portASSERT_IF_INTERRUPT_PRIORITY_INVALID, portCLEAR_INTERRUPT_MASK_FROM_ISR, portSET_INTERRUPT_MASK_FROM_ISR, prvCopyDataToQueue(), queueOVERWRITE, queueUNLOCKED, traceQUEUE_SEND_FROM_ISR, traceQUEUE_SEND_FROM_ISR_FAILED, xQUEUE::uxItemSize, xQUEUE::uxLength, xQUEUE::uxMessagesWaiting, xTaskRemoveFromEventList(), and xQUEUE::xTasksWaitingToReceive.

BaseType_t xQueueGiveFromISR	(	QueueHandle_t	xQueue,
		BaseType_t *const	pxHigherPriorityTaskWoken
	)

References configASSERT, xQUEUE::cTxLock, errQUEUE_FULL, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFALSE, pdPASS, pdTRUE, portASSERT_IF_INTERRUPT_PRIORITY_INVALID, portCLEAR_INTERRUPT_MASK_FROM_ISR, portSET_INTERRUPT_MASK_FROM_ISR, queueQUEUE_IS_MUTEX, queueSEND_TO_BACK, queueUNLOCKED, traceQUEUE_SEND_FROM_ISR, traceQUEUE_SEND_FROM_ISR_FAILED, xQUEUE::u, xQUEUE::uxItemSize, xQUEUE::uxMessagesWaiting, SemaphoreData_t::xMutexHolder, xQUEUE::xSemaphore, xTaskRemoveFromEventList(), and xQUEUE::xTasksWaitingToReceive.

BaseType_t xQueueIsQueueEmptyFromISR

(

const QueueHandle_t

xQueue

)

References configASSERT, pdFALSE, pdTRUE, and xQUEUE::uxMessagesWaiting.

BaseType_t xQueueIsQueueFullFromISR

(

const QueueHandle_t

xQueue

)

References configASSERT, pdFALSE, pdTRUE, xQUEUE::uxLength, and xQUEUE::uxMessagesWaiting.

BaseType_t xQueuePeek	(	QueueHandle_t	xQueue,
		void *const	pvBuffer,
		TickType_t	xTicksToWait
	)

References configASSERT, errQUEUE_EMPTY, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, QueuePointers_t::pcReadFrom, pdFALSE, pdPASS, pdTRUE, portYIELD_WITHIN_API, prvCopyDataFromQueue(), prvIsQueueEmpty(), prvLockQueue, prvUnlockQueue(), queueYIELD_IF_USING_PREEMPTION, taskENTER_CRITICAL, taskEXIT_CRITICAL, taskSCHEDULER_SUSPENDED, traceBLOCKING_ON_QUEUE_PEEK, traceQUEUE_PEEK, traceQUEUE_PEEK_FAILED, xQUEUE::u, xQUEUE::uxMessagesWaiting, vTaskInternalSetTimeOutState(), vTaskPlaceOnEventList(), vTaskSuspendAll(), xQUEUE::xQueue, xTaskCheckForTimeOut(), xTaskGetSchedulerState(), xTaskRemoveFromEventList(), xTaskResumeAll(), and xQUEUE::xTasksWaitingToReceive.

Referenced by MPU_xQueuePeek().

BaseType_t xQueuePeekFromISR	(	QueueHandle_t	xQueue,
		void *const	pvBuffer
	)

References configASSERT, QueuePointers_t::pcReadFrom, pdFAIL, pdPASS, portASSERT_IF_INTERRUPT_PRIORITY_INVALID, portCLEAR_INTERRUPT_MASK_FROM_ISR, portSET_INTERRUPT_MASK_FROM_ISR, prvCopyDataFromQueue(), traceQUEUE_PEEK_FROM_ISR, traceQUEUE_PEEK_FROM_ISR_FAILED, xQUEUE::u, xQUEUE::uxItemSize, xQUEUE::uxMessagesWaiting, and xQUEUE::xQueue.

BaseType_t xQueueReceive	(	QueueHandle_t	xQueue,
		void *const	pvBuffer,
		TickType_t	xTicksToWait
	)

References configASSERT, errQUEUE_EMPTY, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFALSE, pdPASS, pdTRUE, portYIELD_WITHIN_API, prvCopyDataFromQueue(), prvIsQueueEmpty(), prvLockQueue, prvUnlockQueue(), queueYIELD_IF_USING_PREEMPTION, taskENTER_CRITICAL, taskEXIT_CRITICAL, taskSCHEDULER_SUSPENDED, traceBLOCKING_ON_QUEUE_RECEIVE, traceQUEUE_RECEIVE, traceQUEUE_RECEIVE_FAILED, xQUEUE::uxMessagesWaiting, vTaskInternalSetTimeOutState(), vTaskPlaceOnEventList(), vTaskSuspendAll(), xTaskCheckForTimeOut(), xTaskGetSchedulerState(), xTaskRemoveFromEventList(), xTaskResumeAll(), xQUEUE::xTasksWaitingToReceive, and xQUEUE::xTasksWaitingToSend.

Referenced by MPU_xQueueReceive().

BaseType_t xQueueReceiveFromISR	(	QueueHandle_t	xQueue,
		void *const	pvBuffer,
		BaseType_t *const	pxHigherPriorityTaskWoken
	)

References configASSERT, xQUEUE::cRxLock, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFAIL, pdFALSE, pdPASS, pdTRUE, portASSERT_IF_INTERRUPT_PRIORITY_INVALID, portCLEAR_INTERRUPT_MASK_FROM_ISR, portSET_INTERRUPT_MASK_FROM_ISR, prvCopyDataFromQueue(), queueUNLOCKED, traceQUEUE_RECEIVE_FROM_ISR, traceQUEUE_RECEIVE_FROM_ISR_FAILED, xQUEUE::uxItemSize, xQUEUE::uxMessagesWaiting, xTaskRemoveFromEventList(), and xQUEUE::xTasksWaitingToSend.

BaseType_t xQueueSemaphoreTake	(	QueueHandle_t	xQueue,
		TickType_t	xTicksToWait
	)

References configASSERT, errQUEUE_EMPTY, listLIST_IS_EMPTY, mtCOVERAGE_TEST_MARKER, pdFALSE, pdPASS, pdTRUE, portYIELD_WITHIN_API, prvIsQueueEmpty(), prvLockQueue, prvUnlockQueue(), pvTaskIncrementMutexHeldCount(), queueQUEUE_IS_MUTEX, queueYIELD_IF_USING_PREEMPTION, taskENTER_CRITICAL, taskEXIT_CRITICAL, taskSCHEDULER_SUSPENDED, traceBLOCKING_ON_QUEUE_RECEIVE, traceQUEUE_RECEIVE, traceQUEUE_RECEIVE_FAILED, xQUEUE::u, xQUEUE::uxItemSize, xQUEUE::uxMessagesWaiting, vTaskInternalSetTimeOutState(), vTaskPlaceOnEventList(), vTaskPriorityDisinheritAfterTimeout(), vTaskSuspendAll(), SemaphoreData_t::xMutexHolder, xQUEUE::xSemaphore, xTaskCheckForTimeOut(), xTaskGetSchedulerState(), xTaskPriorityInherit(), xTaskRemoveFromEventList(), xTaskResumeAll(), xQUEUE::xTasksWaitingToReceive, and xQUEUE::xTasksWaitingToSend.

Referenced by MPU_xQueueSemaphoreTake().