semphr.h

/*
 * FreeRTOS Kernel V10.0.1
 * Copyright (C) 2017 Amazon.com, Inc. or its affiliates.  All Rights Reserved.
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of
 * this software and associated documentation files (the "Software"), to deal in
 * the Software without restriction, including without limitation the rights to
 * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
 * the Software, and to permit persons to whom the Software is furnished to do so,
 * subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
 * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
 * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
 * IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 *
 * http://www.FreeRTOS.org
 * http://aws.amazon.com/freertos
 *
 * 1 tab == 4 spaces!
 */
 
#ifndef SEMAPHORE_H
#define SEMAPHORE_H
 
#ifndef INC_FREERTOS_H
    #error "include FreeRTOS.h" must appear in source files before "include semphr.h"
#endif
 
#include "queue.h"
#include "task.h"
 
typedef queue_t sem_t;
typedef queue_t mutex_t;
 
#define semBINARY_SEMAPHORE_QUEUE_LENGTH    ( ( uint8_t ) 1U )
#define semSEMAPHORE_QUEUE_ITEM_LENGTH      ( ( uint8_t ) 0U )
#define semGIVE_BLOCK_TIME                  ( ( uint32_t ) 0U )
 

#if( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
    #define vSemaphoreCreateBinary( xSemaphore )                                                                                            \
        {                                                                                                                                   \
            ( xSemaphore ) = xQueueGenericCreate( ( uint32_t ) 1, semSEMAPHORE_QUEUE_ITEM_LENGTH, queueQUEUE_TYPE_BINARY_SEMAPHORE );   \
            if( ( xSemaphore ) != NULL )                                                                                                    \
            {                                                                                                                               \
                ( void ) sem_post( ( xSemaphore ) );                                                                                    \
            }                                                                                                                               \
        }
#endif

#if( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
    sem_t sem_binary_create();
#endif

#if( configSUPPORT_STATIC_ALLOCATION == 1 )
    #define xSemaphoreCreateBinaryStatic( pxStaticSemaphore ) xQueueGenericCreateStatic( ( uint32_t ) 1, semSEMAPHORE_QUEUE_ITEM_LENGTH, NULL, pxStaticSemaphore, queueQUEUE_TYPE_BINARY_SEMAPHORE )
#endif /* configSUPPORT_STATIC_ALLOCATION */

uint8_t sem_wait(sem_t sem, uint32_t block_time);

#if( configUSE_RECURSIVE_MUTEXES == 1 )
    uint8_t mutex_recursive_take(mutex_t mutex, uint32_t block_time);
#endif

uint8_t sem_post(sem_t sem);

#if( configUSE_RECURSIVE_MUTEXES == 1 )
    uint8_t mutex_recursive_give(mutex_t mutex);
#endif

#define xSemaphoreGiveFromISR( xSemaphore, pxHigherPriorityTaskWoken )  xQueueGiveFromISR( ( queue_t ) ( xSemaphore ), ( pxHigherPriorityTaskWoken ) )

#define xSemaphoreTakeFromISR( xSemaphore, pxHigherPriorityTaskWoken )  xQueueReceiveFromISR( ( queue_t ) ( xSemaphore ), NULL, ( pxHigherPriorityTaskWoken ) )

#if( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
    mutex_t mutex_create();
#endif

 #if( configSUPPORT_STATIC_ALLOCATION == 1 )
    mutex_t mutex_create_static(static_sem_s_t* pxMutexBuffer);
#endif /* configSUPPORT_STATIC_ALLOCATION */
 

#if( ( configSUPPORT_DYNAMIC_ALLOCATION == 1 ) && ( configUSE_RECURSIVE_MUTEXES == 1 ) )
    mutex_t mutex_recursive_create();
#endif

#if( ( configSUPPORT_STATIC_ALLOCATION == 1 ) && ( configUSE_RECURSIVE_MUTEXES == 1 ) )
    #define xSemaphoreCreateRecursiveMutexStatic( pxStaticSemaphore ) xQueueCreateMutexStatic( queueQUEUE_TYPE_RECURSIVE_MUTEX, pxStaticSemaphore )
#endif /* configSUPPORT_STATIC_ALLOCATION */

#if( configSUPPORT_DYNAMIC_ALLOCATION == 1 )
    sem_t sem_create(uint32_t uxMaxCount, uint32_t uxInitialCount);
#endif

#if( configSUPPORT_STATIC_ALLOCATION == 1 )
    sem_t sem_create_static(uint32_t uxMaxCount, uint32_t uxInitialCount, static_sem_s_t* pxSemaphoreBuffer);
#endif /* configSUPPORT_STATIC_ALLOCATION */

void sem_delete(sem_t xSemaphore);

task_t mutex_get_owner(sem_t xMutex);

#define xSemaphoreGetMutexHolderFromISR( xSemaphore ) xQueueGetMutexHolderFromISR( ( xSemaphore ) )

uint32_t sem_get_count(sem_t xSemaphore);
 
#endif /* SEMAPHORE_H */