AltPollQ.h File Reference

Go to the source code of this file.

Functions
void	vStartAltPolledQueueTasks (unsigned portBASE_TYPE uxPriority)
portBASE_TYPE	xAreAltPollingQueuesStillRunning (void)

---

Function Documentation

void vStartAltPolledQueueTasks

(

unsigned portBASE_TYPE

uxPriority

)

Definition at line 112 of file AltPollQ.c.

References pollqQUEUE_SIZE, pollqSTACK_SIZE, portBASE_TYPE, portCHAR, portSHORT, vQueueAddToRegistry, xQueueCreate(), and xTaskCreate.

{
static xQueueHandle xPolledQueue;

    /* Create the queue used by the producer and consumer. */
    xPolledQueue = xQueueCreate( pollqQUEUE_SIZE, ( unsigned portBASE_TYPE ) sizeof( unsigned portSHORT ) );

    /* vQueueAddToRegistry() adds the queue to the queue registry, if one is
    in use.  The queue registry is provided as a means for kernel aware 
    debuggers to locate queues and has no purpose if a kernel aware debugger
    is not being used.  The call to vQueueAddToRegistry() will be removed
    by the pre-processor if configQUEUE_REGISTRY_SIZE is not defined or is 
    defined to be less than 1. */
    vQueueAddToRegistry( xPolledQueue, ( signed portCHAR * ) "AltPollQueue" );


    /* Spawn the producer and consumer. */
    xTaskCreate( vPolledQueueConsumer, ( signed portCHAR * ) "QConsNB", pollqSTACK_SIZE, ( void * ) &xPolledQueue, uxPriority, ( xTaskHandle * ) NULL );
    xTaskCreate( vPolledQueueProducer, ( signed portCHAR * ) "QProdNB", pollqSTACK_SIZE, ( void * ) &xPolledQueue, uxPriority, ( xTaskHandle * ) NULL );
}

portBASE_TYPE xAreAltPollingQueuesStillRunning

(

void

)

Definition at line 238 of file AltPollQ.c.

References pdFALSE, pdTRUE, pollqINITIAL_VALUE, portBASE_TYPE, xPollingConsumerCount, and xPollingProducerCount.

{
portBASE_TYPE xReturn;

    /* Check both the consumer and producer poll count to check they have both
    been changed since out last trip round.  We do not need a critical section
    around the check variables as this is called from a higher priority than
    the other tasks that access the same variables. */
    if( ( xPollingConsumerCount == pollqINITIAL_VALUE ) ||
        ( xPollingProducerCount == pollqINITIAL_VALUE )
      )
    {
        xReturn = pdFALSE;
    }
    else
    {
        xReturn = pdTRUE;
    }

    /* Set the check variables back down so we know if they have been
    incremented the next time around. */
    xPollingConsumerCount = pollqINITIAL_VALUE;
    xPollingProducerCount = pollqINITIAL_VALUE;

    return xReturn;
}