390 lines
		
	
	
		
			15 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			390 lines
		
	
	
		
			15 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
/*
 | 
						|
    FreeRTOS V7.3.0 - Copyright (C) 2012 Real Time Engineers Ltd.
 | 
						|
 | 
						|
    FEATURES AND PORTS ARE ADDED TO FREERTOS ALL THE TIME.  PLEASE VISIT 
 | 
						|
    http://www.FreeRTOS.org TO ENSURE YOU ARE USING THE LATEST VERSION.
 | 
						|
 | 
						|
    ***************************************************************************
 | 
						|
     *                                                                       *
 | 
						|
     *    FreeRTOS tutorial books are available in pdf and paperback.        *
 | 
						|
     *    Complete, revised, and edited pdf reference manuals are also       *
 | 
						|
     *    available.                                                         *
 | 
						|
     *                                                                       *
 | 
						|
     *    Purchasing FreeRTOS documentation will not only help you, by       *
 | 
						|
     *    ensuring you get running as quickly as possible and with an        *
 | 
						|
     *    in-depth knowledge of how to use FreeRTOS, it will also help       *
 | 
						|
     *    the FreeRTOS project to continue with its mission of providing     *
 | 
						|
     *    professional grade, cross platform, de facto standard solutions    *
 | 
						|
     *    for microcontrollers - completely free of charge!                  *
 | 
						|
     *                                                                       *
 | 
						|
     *    >>> See http://www.FreeRTOS.org/Documentation for details. <<<     *
 | 
						|
     *                                                                       *
 | 
						|
     *    Thank you for using FreeRTOS, and thank you for your support!      *
 | 
						|
     *                                                                       *
 | 
						|
    ***************************************************************************
 | 
						|
 | 
						|
 | 
						|
    This file is part of the FreeRTOS distribution.
 | 
						|
 | 
						|
    FreeRTOS is free software; you can redistribute it and/or modify it under
 | 
						|
    the terms of the GNU General Public License (version 2) as published by the
 | 
						|
    Free Software Foundation AND MODIFIED BY the FreeRTOS exception.
 | 
						|
    >>>NOTE<<< The modification to the GPL is included to allow you to
 | 
						|
    distribute a combined work that includes FreeRTOS without being obliged to
 | 
						|
    provide the source code for proprietary components outside of the FreeRTOS
 | 
						|
    kernel.  FreeRTOS is distributed in the hope that it will be useful, but
 | 
						|
    WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 | 
						|
    or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
 | 
						|
    more details. You should have received a copy of the GNU General Public
 | 
						|
    License and the FreeRTOS license exception along with FreeRTOS; if not it
 | 
						|
    can be viewed here: http://www.freertos.org/a00114.html and also obtained
 | 
						|
    by writing to Richard Barry, contact details for whom are available on the
 | 
						|
    FreeRTOS WEB site.
 | 
						|
 | 
						|
    1 tab == 4 spaces!
 | 
						|
    
 | 
						|
    ***************************************************************************
 | 
						|
     *                                                                       *
 | 
						|
     *    Having a problem?  Start by reading the FAQ "My application does   *
 | 
						|
     *    not run, what could be wrong?"                                     *
 | 
						|
     *                                                                       *
 | 
						|
     *    http://www.FreeRTOS.org/FAQHelp.html                               *
 | 
						|
     *                                                                       *
 | 
						|
    ***************************************************************************
 | 
						|
 | 
						|
    
 | 
						|
    http://www.FreeRTOS.org - Documentation, training, latest versions, license 
 | 
						|
    and contact details.  
 | 
						|
    
 | 
						|
    http://www.FreeRTOS.org/plus - A selection of FreeRTOS ecosystem products,
 | 
						|
    including FreeRTOS+Trace - an indispensable productivity tool.
 | 
						|
 | 
						|
    Real Time Engineers ltd license FreeRTOS to High Integrity Systems, who sell 
 | 
						|
    the code with commercial support, indemnification, and middleware, under 
 | 
						|
    the OpenRTOS brand: http://www.OpenRTOS.com.  High Integrity Systems also
 | 
						|
    provide a safety engineered and independently SIL3 certified version under 
 | 
						|
    the SafeRTOS brand: http://www.SafeRTOS.com.
 | 
						|
*/
 | 
						|
 | 
						|
#include "FreeRTOS.h"
 | 
						|
#include "task.h"
 | 
						|
#include "croutine.h"
 | 
						|
 | 
						|
/*
 | 
						|
 * Some kernel aware debuggers require data to be viewed to be global, rather
 | 
						|
 * than file scope.
 | 
						|
 */
 | 
						|
#ifdef portREMOVE_STATIC_QUALIFIER
 | 
						|
	#define static
 | 
						|
#endif
 | 
						|
 | 
						|
 | 
						|
/* Lists for ready and blocked co-routines. --------------------*/
 | 
						|
static xList pxReadyCoRoutineLists[ configMAX_CO_ROUTINE_PRIORITIES ];	/*< Prioritised ready co-routines. */
 | 
						|
static xList xDelayedCoRoutineList1;									/*< Delayed co-routines. */
 | 
						|
static xList xDelayedCoRoutineList2;									/*< Delayed co-routines (two lists are used - one for delays that have overflowed the current tick count. */
 | 
						|
static xList * pxDelayedCoRoutineList;									/*< Points to the delayed co-routine list currently being used. */
 | 
						|
static xList * pxOverflowDelayedCoRoutineList;							/*< Points to the delayed co-routine list currently being used to hold co-routines that have overflowed the current tick count. */
 | 
						|
static xList xPendingReadyCoRoutineList;											/*< Holds co-routines that have been readied by an external event.  They cannot be added directly to the ready lists as the ready lists cannot be accessed by interrupts. */
 | 
						|
 | 
						|
/* Other file private variables. --------------------------------*/
 | 
						|
corCRCB * pxCurrentCoRoutine = NULL;
 | 
						|
static unsigned portBASE_TYPE uxTopCoRoutineReadyPriority = 0;
 | 
						|
static portTickType xCoRoutineTickCount = 0, xLastTickCount = 0, xPassedTicks = 0;
 | 
						|
 | 
						|
/* The initial state of the co-routine when it is created. */
 | 
						|
#define corINITIAL_STATE	( 0 )
 | 
						|
 | 
						|
/*
 | 
						|
 * Place the co-routine represented by pxCRCB into the appropriate ready queue
 | 
						|
 * for the priority.  It is inserted at the end of the list.
 | 
						|
 *
 | 
						|
 * This macro accesses the co-routine ready lists and therefore must not be
 | 
						|
 * used from within an ISR.
 | 
						|
 */
 | 
						|
#define prvAddCoRoutineToReadyQueue( pxCRCB )																		\
 | 
						|
{																													\
 | 
						|
	if( pxCRCB->uxPriority > uxTopCoRoutineReadyPriority )															\
 | 
						|
	{																												\
 | 
						|
		uxTopCoRoutineReadyPriority = pxCRCB->uxPriority;															\
 | 
						|
	}																												\
 | 
						|
	vListInsertEnd( ( xList * ) &( pxReadyCoRoutineLists[ pxCRCB->uxPriority ] ), &( pxCRCB->xGenericListItem ) );	\
 | 
						|
}	
 | 
						|
 | 
						|
/*
 | 
						|
 * Utility to ready all the lists used by the scheduler.  This is called
 | 
						|
 * automatically upon the creation of the first co-routine.
 | 
						|
 */
 | 
						|
static void prvInitialiseCoRoutineLists( void );
 | 
						|
 | 
						|
/*
 | 
						|
 * Co-routines that are readied by an interrupt cannot be placed directly into
 | 
						|
 * the ready lists (there is no mutual exclusion).  Instead they are placed in
 | 
						|
 * in the pending ready list in order that they can later be moved to the ready
 | 
						|
 * list by the co-routine scheduler.
 | 
						|
 */
 | 
						|
static void prvCheckPendingReadyList( void );
 | 
						|
 | 
						|
/*
 | 
						|
 * Macro that looks at the list of co-routines that are currently delayed to
 | 
						|
 * see if any require waking.
 | 
						|
 *
 | 
						|
 * Co-routines are stored in the queue in the order of their wake time -
 | 
						|
 * meaning once one co-routine has been found whose timer has not expired
 | 
						|
 * we need not look any further down the list.
 | 
						|
 */
 | 
						|
static void prvCheckDelayedList( void );
 | 
						|
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
signed portBASE_TYPE xCoRoutineCreate( crCOROUTINE_CODE pxCoRoutineCode, unsigned portBASE_TYPE uxPriority, unsigned portBASE_TYPE uxIndex )
 | 
						|
{
 | 
						|
signed portBASE_TYPE xReturn;
 | 
						|
corCRCB *pxCoRoutine;
 | 
						|
 | 
						|
	/* Allocate the memory that will store the co-routine control block. */
 | 
						|
	pxCoRoutine = ( corCRCB * ) pvPortMalloc( sizeof( corCRCB ) );
 | 
						|
	if( pxCoRoutine )
 | 
						|
	{
 | 
						|
		/* If pxCurrentCoRoutine is NULL then this is the first co-routine to
 | 
						|
		be created and the co-routine data structures need initialising. */
 | 
						|
		if( pxCurrentCoRoutine == NULL )
 | 
						|
		{
 | 
						|
			pxCurrentCoRoutine = pxCoRoutine;
 | 
						|
			prvInitialiseCoRoutineLists();
 | 
						|
		}
 | 
						|
 | 
						|
		/* Check the priority is within limits. */
 | 
						|
		if( uxPriority >= configMAX_CO_ROUTINE_PRIORITIES )
 | 
						|
		{
 | 
						|
			uxPriority = configMAX_CO_ROUTINE_PRIORITIES - 1;
 | 
						|
		}
 | 
						|
 | 
						|
		/* Fill out the co-routine control block from the function parameters. */
 | 
						|
		pxCoRoutine->uxState = corINITIAL_STATE;
 | 
						|
		pxCoRoutine->uxPriority = uxPriority;
 | 
						|
		pxCoRoutine->uxIndex = uxIndex;
 | 
						|
		pxCoRoutine->pxCoRoutineFunction = pxCoRoutineCode;
 | 
						|
 | 
						|
		/* Initialise all the other co-routine control block parameters. */
 | 
						|
		vListInitialiseItem( &( pxCoRoutine->xGenericListItem ) );
 | 
						|
		vListInitialiseItem( &( pxCoRoutine->xEventListItem ) );
 | 
						|
 | 
						|
		/* Set the co-routine control block as a link back from the xListItem.
 | 
						|
		This is so we can get back to the containing CRCB from a generic item
 | 
						|
		in a list. */
 | 
						|
		listSET_LIST_ITEM_OWNER( &( pxCoRoutine->xGenericListItem ), pxCoRoutine );
 | 
						|
		listSET_LIST_ITEM_OWNER( &( pxCoRoutine->xEventListItem ), pxCoRoutine );
 | 
						|
	
 | 
						|
		/* Event lists are always in priority order. */
 | 
						|
		listSET_LIST_ITEM_VALUE( &( pxCoRoutine->xEventListItem ), configMAX_PRIORITIES - ( portTickType ) uxPriority );
 | 
						|
		
 | 
						|
		/* Now the co-routine has been initialised it can be added to the ready
 | 
						|
		list at the correct priority. */
 | 
						|
		prvAddCoRoutineToReadyQueue( pxCoRoutine );
 | 
						|
 | 
						|
		xReturn = pdPASS;
 | 
						|
	}
 | 
						|
	else
 | 
						|
	{		
 | 
						|
		xReturn = errCOULD_NOT_ALLOCATE_REQUIRED_MEMORY;
 | 
						|
	}
 | 
						|
	
 | 
						|
	return xReturn;	
 | 
						|
}
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
void vCoRoutineAddToDelayedList( portTickType xTicksToDelay, xList *pxEventList )
 | 
						|
{
 | 
						|
portTickType xTimeToWake;
 | 
						|
 | 
						|
	/* Calculate the time to wake - this may overflow but this is
 | 
						|
	not a problem. */
 | 
						|
	xTimeToWake = xCoRoutineTickCount + xTicksToDelay;
 | 
						|
 | 
						|
	/* We must remove ourselves from the ready list before adding
 | 
						|
	ourselves to the blocked list as the same list item is used for
 | 
						|
	both lists. */
 | 
						|
	uxListRemove( ( xListItem * ) &( pxCurrentCoRoutine->xGenericListItem ) );
 | 
						|
 | 
						|
	/* The list item will be inserted in wake time order. */
 | 
						|
	listSET_LIST_ITEM_VALUE( &( pxCurrentCoRoutine->xGenericListItem ), xTimeToWake );
 | 
						|
 | 
						|
	if( xTimeToWake < xCoRoutineTickCount )
 | 
						|
	{
 | 
						|
		/* Wake time has overflowed.  Place this item in the
 | 
						|
		overflow list. */
 | 
						|
		vListInsert( ( xList * ) pxOverflowDelayedCoRoutineList, ( xListItem * ) &( pxCurrentCoRoutine->xGenericListItem ) );
 | 
						|
	}
 | 
						|
	else
 | 
						|
	{
 | 
						|
		/* The wake time has not overflowed, so we can use the
 | 
						|
		current block list. */
 | 
						|
		vListInsert( ( xList * ) pxDelayedCoRoutineList, ( xListItem * ) &( pxCurrentCoRoutine->xGenericListItem ) );
 | 
						|
	}
 | 
						|
 | 
						|
	if( pxEventList )
 | 
						|
	{
 | 
						|
		/* Also add the co-routine to an event list.  If this is done then the
 | 
						|
		function must be called with interrupts disabled. */
 | 
						|
		vListInsert( pxEventList, &( pxCurrentCoRoutine->xEventListItem ) );
 | 
						|
	}
 | 
						|
}
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
static void prvCheckPendingReadyList( void )
 | 
						|
{
 | 
						|
	/* Are there any co-routines waiting to get moved to the ready list?  These
 | 
						|
	are co-routines that have been readied by an ISR.  The ISR cannot access
 | 
						|
	the	ready lists itself. */
 | 
						|
	while( listLIST_IS_EMPTY( &xPendingReadyCoRoutineList ) == pdFALSE )
 | 
						|
	{
 | 
						|
		corCRCB *pxUnblockedCRCB;
 | 
						|
 | 
						|
		/* The pending ready list can be accessed by an ISR. */
 | 
						|
		portDISABLE_INTERRUPTS();
 | 
						|
		{	
 | 
						|
			pxUnblockedCRCB = ( corCRCB * ) listGET_OWNER_OF_HEAD_ENTRY( (&xPendingReadyCoRoutineList) );			
 | 
						|
			uxListRemove( &( pxUnblockedCRCB->xEventListItem ) );
 | 
						|
		}
 | 
						|
		portENABLE_INTERRUPTS();
 | 
						|
 | 
						|
		uxListRemove( &( pxUnblockedCRCB->xGenericListItem ) );
 | 
						|
		prvAddCoRoutineToReadyQueue( pxUnblockedCRCB );	
 | 
						|
	}
 | 
						|
}
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
static void prvCheckDelayedList( void )
 | 
						|
{
 | 
						|
corCRCB *pxCRCB;
 | 
						|
 | 
						|
	xPassedTicks = xTaskGetTickCount() - xLastTickCount;
 | 
						|
	while( xPassedTicks )
 | 
						|
	{
 | 
						|
		xCoRoutineTickCount++;
 | 
						|
		xPassedTicks--;
 | 
						|
 | 
						|
		/* If the tick count has overflowed we need to swap the ready lists. */
 | 
						|
		if( xCoRoutineTickCount == 0 )
 | 
						|
		{
 | 
						|
			xList * pxTemp;
 | 
						|
 | 
						|
			/* Tick count has overflowed so we need to swap the delay lists.  If there are
 | 
						|
			any items in pxDelayedCoRoutineList here then there is an error! */
 | 
						|
			pxTemp = pxDelayedCoRoutineList;
 | 
						|
			pxDelayedCoRoutineList = pxOverflowDelayedCoRoutineList;
 | 
						|
			pxOverflowDelayedCoRoutineList = pxTemp;
 | 
						|
		}
 | 
						|
 | 
						|
		/* See if this tick has made a timeout expire. */
 | 
						|
		while( listLIST_IS_EMPTY( pxDelayedCoRoutineList ) == pdFALSE )
 | 
						|
		{
 | 
						|
			pxCRCB = ( corCRCB * ) listGET_OWNER_OF_HEAD_ENTRY( pxDelayedCoRoutineList );
 | 
						|
 | 
						|
			if( xCoRoutineTickCount < listGET_LIST_ITEM_VALUE( &( pxCRCB->xGenericListItem ) ) )				
 | 
						|
			{			
 | 
						|
				/* Timeout not yet expired. */																			
 | 
						|
				break;																				
 | 
						|
			}																						
 | 
						|
 | 
						|
			portDISABLE_INTERRUPTS();
 | 
						|
			{
 | 
						|
				/* The event could have occurred just before this critical
 | 
						|
				section.  If this is the case then the generic list item will
 | 
						|
				have been moved to the pending ready list and the following
 | 
						|
				line is still valid.  Also the pvContainer parameter will have
 | 
						|
				been set to NULL so the following lines are also valid. */
 | 
						|
				uxListRemove( &( pxCRCB->xGenericListItem ) );											
 | 
						|
 | 
						|
				/* Is the co-routine waiting on an event also? */												
 | 
						|
				if( pxCRCB->xEventListItem.pvContainer )													
 | 
						|
				{															
 | 
						|
					uxListRemove( &( pxCRCB->xEventListItem ) );											
 | 
						|
				}
 | 
						|
			}
 | 
						|
			portENABLE_INTERRUPTS();
 | 
						|
 | 
						|
			prvAddCoRoutineToReadyQueue( pxCRCB );													
 | 
						|
		}																									
 | 
						|
	}
 | 
						|
 | 
						|
	xLastTickCount = xCoRoutineTickCount;
 | 
						|
}
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
void vCoRoutineSchedule( void )
 | 
						|
{
 | 
						|
	/* See if any co-routines readied by events need moving to the ready lists. */
 | 
						|
	prvCheckPendingReadyList();
 | 
						|
 | 
						|
	/* See if any delayed co-routines have timed out. */
 | 
						|
	prvCheckDelayedList();
 | 
						|
 | 
						|
	/* Find the highest priority queue that contains ready co-routines. */
 | 
						|
	while( listLIST_IS_EMPTY( &( pxReadyCoRoutineLists[ uxTopCoRoutineReadyPriority ] ) ) )
 | 
						|
	{
 | 
						|
		if( uxTopCoRoutineReadyPriority == 0 )
 | 
						|
		{
 | 
						|
			/* No more co-routines to check. */
 | 
						|
			return;
 | 
						|
		}
 | 
						|
		--uxTopCoRoutineReadyPriority;
 | 
						|
	}
 | 
						|
 | 
						|
	/* listGET_OWNER_OF_NEXT_ENTRY walks through the list, so the co-routines
 | 
						|
	 of the	same priority get an equal share of the processor time. */
 | 
						|
	listGET_OWNER_OF_NEXT_ENTRY( pxCurrentCoRoutine, &( pxReadyCoRoutineLists[ uxTopCoRoutineReadyPriority ] ) );
 | 
						|
 | 
						|
	/* Call the co-routine. */
 | 
						|
	( pxCurrentCoRoutine->pxCoRoutineFunction )( pxCurrentCoRoutine, pxCurrentCoRoutine->uxIndex );
 | 
						|
 | 
						|
	return;
 | 
						|
}
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
static void prvInitialiseCoRoutineLists( void )
 | 
						|
{
 | 
						|
unsigned portBASE_TYPE uxPriority;
 | 
						|
 | 
						|
	for( uxPriority = 0; uxPriority < configMAX_CO_ROUTINE_PRIORITIES; uxPriority++ )
 | 
						|
	{
 | 
						|
		vListInitialise( ( xList * ) &( pxReadyCoRoutineLists[ uxPriority ] ) );
 | 
						|
	}
 | 
						|
 | 
						|
	vListInitialise( ( xList * ) &xDelayedCoRoutineList1 );
 | 
						|
	vListInitialise( ( xList * ) &xDelayedCoRoutineList2 );
 | 
						|
	vListInitialise( ( xList * ) &xPendingReadyCoRoutineList );
 | 
						|
 | 
						|
	/* Start with pxDelayedCoRoutineList using list1 and the
 | 
						|
	pxOverflowDelayedCoRoutineList using list2. */
 | 
						|
	pxDelayedCoRoutineList = &xDelayedCoRoutineList1;
 | 
						|
	pxOverflowDelayedCoRoutineList = &xDelayedCoRoutineList2;
 | 
						|
}
 | 
						|
/*-----------------------------------------------------------*/
 | 
						|
 | 
						|
signed portBASE_TYPE xCoRoutineRemoveFromEventList( const xList *pxEventList )
 | 
						|
{
 | 
						|
corCRCB *pxUnblockedCRCB;
 | 
						|
signed portBASE_TYPE xReturn;
 | 
						|
 | 
						|
	/* This function is called from within an interrupt.  It can only access
 | 
						|
	event lists and the pending ready list.  This function assumes that a
 | 
						|
	check has already been made to ensure pxEventList is not empty. */
 | 
						|
	pxUnblockedCRCB = ( corCRCB * ) listGET_OWNER_OF_HEAD_ENTRY( pxEventList );
 | 
						|
	uxListRemove( &( pxUnblockedCRCB->xEventListItem ) );
 | 
						|
	vListInsertEnd( ( xList * ) &( xPendingReadyCoRoutineList ), &( pxUnblockedCRCB->xEventListItem ) );
 | 
						|
 | 
						|
	if( pxUnblockedCRCB->uxPriority >= pxCurrentCoRoutine->uxPriority )
 | 
						|
	{
 | 
						|
		xReturn = pdTRUE;
 | 
						|
	}
 | 
						|
	else
 | 
						|
	{
 | 
						|
		xReturn = pdFALSE;
 | 
						|
	}
 | 
						|
 | 
						|
	return xReturn;
 | 
						|
}
 | 
						|
 |