#include <Copyright.h>
/********************************************************************************
* osSem.c
*
* DESCRIPTION:
*       Semaphore related routines
*
* DEPENDENCIES:
*       OS Dependent.
*
* FILE REVISION NUMBER:
*
*******************************************************************************/

#ifdef _VXWORKS
#include "vxWorks.h"
#include "semLib.h"
#include "errnoLib.h"
#include "objLib.h"

int sysClkRateGet(void);

#elif defined(WIN32)
#include "windows.h"
#include "wdm.h"
#elif defined(LINUX)
#include "/usr/include/semaphore.h"
typedef    sem_t          semaphore ;
#endif

#include <msApi.h>

GT_SEM osSemCreate( GT_SEM_BEGIN_STATE state);
GT_STATUS osSemDelete(GT_SEM smid);
GT_STATUS osSemWait(  GT_SEM smid, GT_U32 timeOut);
GT_STATUS osSemSignal(GT_SEM smid);

/*******************************************************************************
* osSemCreate
*
* DESCRIPTION:
*       Create semaphore.
*
* INPUTS:
*       name   - semaphore Name
*       init   - init value of semaphore counter
*       count  - max counter (must be >= 1)
*
* OUTPUTS:
*       smid - semaphore Id
*
* RETURNS:
*       GT_OK   - on success
*       GT_FAIL - on error
*
* COMMENTS:
*       None
*
*******************************************************************************/
GT_SEM osSemCreate(GT_SEM_BEGIN_STATE state)
{
#ifdef _VXWORKS
#if 0
    return (GT_SEM)semBCreate(SEM_Q_FIFO, state);
#else
    GT_SEM semid;
    semid =(GT_SEM)semBCreate(SEM_Q_FIFO, state);
    return semid;
#endif

#elif defined(WIN32)
    return (GT_SEM)CreateSemaphore(NULL, state, 1, NULL);
#elif defined(LINUX)
    semaphore lxSem;

    sem_init(&lxSem, state, 1);
    return lxSem;
#else
    return 1;
#endif
    return GT_OK;
}

/*******************************************************************************
* osSemDelete
*
* DESCRIPTION:
*       Delete semaphore.
*
* INPUTS:
*       smid - semaphore Id
*
* OUTPUTS:
*       None
*
* RETURNS:
*       GT_OK   - on success
*       GT_FAIL - on error
*
* COMMENTS:
*       None
*
*******************************************************************************/
GT_STATUS osSemDelete(GT_SEM smid)
{
#ifdef _VXWORKS
    STATUS rc;

    rc = semDelete((SEM_ID) smid);
    if (rc != OK)
        return GT_FAIL;

#elif defined(WIN32)
    if (CloseHandle((HANDLE)smid) == 0)
        return GT_FAIL;

#elif defined(LINUX)
    sem_destroy((semaphore*) smid);
#else
    return GT_OK;
#endif

    return GT_OK;
}

/*******************************************************************************
* osSemWait
*
* DESCRIPTION:
*       Wait on semaphore.
*
* INPUTS:
*       smid    - semaphore Id
*       timeOut - time out in miliseconds or 0 to wait forever
*
* OUTPUTS:
*       None
*
* RETURNS:
*       GT_OK   - on success
*       GT_FAIL - on error
*       OS_TIMEOUT - on time out
*
* COMMENTS:
*       None
*
*******************************************************************************/
GT_STATUS osSemWait(GT_SEM smid, GT_U32 timeOut)
{
#ifdef _VXWORKS
    STATUS rc;

    if (timeOut == 0)
    rc = semTake ((SEM_ID) smid, WAIT_FOREVER);
    else
    {
        int num, delay;

        num = sysClkRateGet();
        delay = (num * timeOut) / 1000;
        if (delay < 1)
            rc = semTake ((SEM_ID) smid, 1);
        else
            rc = semTake ((SEM_ID) smid, delay);
    }

    if (rc != OK)
    {
        if (errno == S_objLib_OBJ_TIMEOUT)
            return GT_TIMEOUT;
        else
            return GT_FAIL;
    }

#elif defined(WIN32)
    DWORD rc;

    rc = WaitForSingleObject((HANDLE)smid, timeOut);

    if (rc == WAIT_ABANDONED)
        return GT_FAIL;
    if (rc == WAIT_TIMEOUT)
        return GT_TIMEOUT;

#elif defined(LINUX)
    sem_wait((semaphore*) smid) ;
#else
    return GT_OK;

#endif

    return GT_OK;
}

/*******************************************************************************
* osSemSignal
*
* DESCRIPTION:
*       Signal a semaphore.
*
* INPUTS:
*       smid    - semaphore Id
*
* OUTPUTS:
*       None
*
* RETURNS:
*       GT_OK   - on success
*       GT_FAIL - on error
*
* COMMENTS:
*       None
*
*******************************************************************************/
GT_STATUS osSemSignal(GT_SEM smid)
{
#ifdef _VXWORKS
    STATUS rc;
    rc = semGive ((SEM_ID) smid);
    if (rc != OK)
        return GT_FAIL;

#elif defined(WIN32)
    if(ReleaseSemaphore((HANDLE) smid, 1, NULL) == 0)
        return GT_FAIL;

#elif defined(LINUX)
    sem_post((semaphore*) smid) ;
#else
    return GT_OK;
#endif
    return GT_OK;
}