]> git.sur5r.net Git - freertos/blobdiff - Source/queue.c
Update counting semaphore function prototype.
[freertos] / Source / queue.c
index 22f8d9a42c1c8ecd6afe36c9672211c95051a500..2c6e34215716bf7cdcfc2511424b226b7d65dbd9 100644 (file)
@@ -1,5 +1,5 @@
 /*\r
-       FreeRTOS.org V4.6.1 - Copyright (C) 2003-2007 Richard Barry.\r
+       FreeRTOS.org V4.7.0 - Copyright (C) 2003-2007 Richard Barry.\r
 \r
        This file is part of the FreeRTOS.org distribution.\r
 \r
 /* Effectively make a union out of the xQUEUE structure. */\r
 #define pxMutexHolder                          pcTail\r
 #define uxQueueType                                    pcHead\r
+#define uxRecursiveCallCount           pcReadFrom\r
 #define queueQUEUE_IS_MUTEX                    NULL\r
 \r
 /* Semaphores do not actually store or copy data, so have an items size of\r
 zero. */\r
 #define queueSEMAPHORE_QUEUE_ITEM_LENGTH ( 0 )\r
 #define queueDONT_BLOCK                                         ( ( portTickType ) 0 )\r
-\r
+#define queueMUTEX_GIVE_BLOCK_TIME              ( ( portTickType ) 0 )\r
 /*\r
  * Definition of the queue used by the scheduler.\r
  * Items are queued by copy, not reference.\r
@@ -107,6 +108,8 @@ signed portBASE_TYPE xQueueGenericReceive( xQueueHandle pxQueue, const void * co
 signed portBASE_TYPE xQueueReceiveFromISR( xQueueHandle pxQueue, const void * const pvBuffer, signed portBASE_TYPE *pxTaskWoken );\r
 xQueueHandle xQueueCreateMutex( void );\r
 xQueueHandle xQueueCreateCountingSemaphore( unsigned portBASE_TYPE uxCountValue, unsigned portBASE_TYPE uxInitialCount );\r
+portBASE_TYPE xQueueTakeMutexRecursive( xQueueHandle xMutex, portTickType xBlockTime );\r
+portBASE_TYPE xQueueGiveMutexRecursive( xQueueHandle xMutex );\r
 signed portBASE_TYPE xQueueAltGenericSend( xQueueHandle pxQueue, const void * const pvItemToQueue, portTickType xTicksToWait, portBASE_TYPE xCopyPosition );\r
 signed portBASE_TYPE xQueueAltGenericReceive( xQueueHandle pxQueue, const void * const pvBuffer, portTickType xTicksToWait, portBASE_TYPE xJustPeeking );\r
 \r
@@ -261,6 +264,81 @@ size_t xQueueSizeInBytes;
 #endif /* configUSE_MUTEXES */\r
 /*-----------------------------------------------------------*/\r
 \r
+#if configUSE_RECURSIVE_MUTEXES == 1\r
+\r
+       portBASE_TYPE xQueueGiveMutexRecursive( xQueueHandle pxMutex )\r
+       {\r
+       portBASE_TYPE xReturn;\r
+\r
+               /* If this is the task that holds the mutex then pxMutexHolder will not \r
+               change outside of this task.  If this task does not hold the mutex then\r
+               pxMutexHolder can never coincidentally equal the tasks handle, and as\r
+               this is the only condition we are interested in it does not matter if\r
+               pxMutexHolder is accessed simultaneously by another task.  Therefore no\r
+               mutual exclusion is required to test the pxMutexHolder variable. */\r
+               if( pxMutex->pxMutexHolder == xTaskGetCurrentTaskHandle() )\r
+               {\r
+                       /* uxRecursiveCallCount cannot be zero if pxMutexHolder is equal to\r
+                       the task handle, therefore no underflow check is required.  Also, \r
+                       uxRecursiveCallCount is only modified by the mutex holder, and as\r
+                       there can only be one, no mutual exclusion is required to modify the\r
+                       uxRecursiveCallCount member. */\r
+                       ( pxMutex->uxRecursiveCallCount )--;\r
+\r
+                       /* Have we unwound the call count? */\r
+                       if( pxMutex->uxRecursiveCallCount == 0 )\r
+                       {\r
+                               /* Return the mutex.  This will automatically unblock any other\r
+                               task that might be waiting to access the mutex. */\r
+                xQueueGenericSend( pxMutex, NULL, queueMUTEX_GIVE_BLOCK_TIME, queueSEND_TO_BACK );\r
+                       }\r
+\r
+                       xReturn = pdPASS;\r
+               }\r
+               else\r
+               {\r
+                       /* We cannot give the mutex because we are not the holder. */\r
+                       xReturn = pdFAIL;\r
+               }\r
+\r
+               return xReturn;\r
+       }\r
+\r
+#endif /* configUSE_RECURSIVE_MUTEXES */\r
+/*-----------------------------------------------------------*/\r
+\r
+#if configUSE_RECURSIVE_MUTEXES == 1\r
+\r
+       portBASE_TYPE xQueueTakeMutexRecursive( xQueueHandle pxMutex, portTickType xBlockTime )\r
+       {\r
+       portBASE_TYPE xReturn;\r
+\r
+               /* Comments regarding mutual exclusion as per those within \r
+               xQueueGiveMutexRecursive(). */\r
+\r
+               if( pxMutex->pxMutexHolder == xTaskGetCurrentTaskHandle() )\r
+               {\r
+                       ( pxMutex->uxRecursiveCallCount )++;\r
+                       xReturn = pdPASS;\r
+               }\r
+               else\r
+               {\r
+            xReturn = xQueueGenericReceive( pxMutex, NULL, xBlockTime, pdFALSE );\r
+\r
+                       /* pdPASS will only be returned if we successfully obtained the mutex,\r
+                       we may have blocked to reach here. */\r
+                       if( xReturn == pdPASS )\r
+                       {\r
+                               ( pxMutex->uxRecursiveCallCount )++;\r
+                       }\r
+               }\r
+\r
+               return xReturn;\r
+       }\r
+\r
+#endif /* configUSE_RECURSIVE_MUTEXES */\r
+/*-----------------------------------------------------------*/\r
+\r
 #if configUSE_COUNTING_SEMAPHORES == 1\r
 \r
        xQueueHandle xQueueCreateCountingSemaphore( unsigned portBASE_TYPE uxCountValue, unsigned portBASE_TYPE uxInitialCount )\r
@@ -464,12 +542,12 @@ xTimeOutType xTimeOut;
        signed portBASE_TYPE xReturn;\r
        xTimeOutType xTimeOut;\r
 \r
-               /* The source code that implements the light weight (fast) API is much \r
+               /* The source code that implements the alternative (Alt) API is much \r
                simpler because it executes everything from within a critical section.  \r
                This is the approach taken by many other RTOSes, but FreeRTOS.org has the \r
-               fully featured API as an alternative.  The fully featured API has more \r
+               preferred fully featured API too.  The fully featured API has more \r
                complex code that takes longer to execute, but makes much less use of \r
-               critical sections.  Therefore the light weight API sacrifices interrupt \r
+               critical sections.  Therefore the alternative API sacrifices interrupt \r
                responsiveness to gain execution speed, whereas the fully featured API\r
                sacrifices execution speed to ensure better interrupt responsiveness.  */\r
 \r
@@ -528,10 +606,6 @@ xTimeOutType xTimeOut;
                                                        xReturn = queueERRONEOUS_UNBLOCK;\r
                                                }\r
                                        }\r
-                                       else\r
-                                       {\r
-                                               \r
-                                       }\r
                                }\r
                        }\r
                        while( xReturn == queueERRONEOUS_UNBLOCK );\r
@@ -552,12 +626,12 @@ xTimeOutType xTimeOut;
        xTimeOutType xTimeOut;\r
        signed portCHAR *pcOriginalReadPosition;\r
 \r
-               /* The source code that implements the light weight (fast) API is much \r
+               /* The source code that implements the alternative (Alt) API is much \r
                simpler because it executes everything from within a critical section.  \r
                This is the approach taken by many other RTOSes, but FreeRTOS.org has the \r
-               fully featured API as an alternative.  The fully featured API has more \r
+               preferred fully featured API too.  The fully featured API has more \r
                complex code that takes longer to execute, but makes much less use of \r
-               critical sections.  Therefore the light weight API sacrifices interrupt \r
+               critical sections.  Therefore the alternative API sacrifices interrupt \r
                responsiveness to gain execution speed, whereas the fully featured API\r
                sacrifices execution speed to ensure better interrupt responsiveness.  */\r
 \r
@@ -906,6 +980,7 @@ static void prvCopyDataToQueue( xQUEUE *pxQueue, const void *pvItemToQueue, port
                        {\r
                                /* The mutex is no longer being held. */\r
                                vTaskPriorityDisinherit( ( void * const ) pxQueue->pxMutexHolder );\r
+                pxQueue->pxMutexHolder = NULL;\r
                        }\r
                }\r
                #endif\r