diff options
Diffstat (limited to 'domx/mm_osal/src/timm_osal_mutex.c')
| -rwxr-xr-x | domx/mm_osal/src/timm_osal_mutex.c | 244 |
1 files changed, 244 insertions, 0 deletions
diff --git a/domx/mm_osal/src/timm_osal_mutex.c b/domx/mm_osal/src/timm_osal_mutex.c new file mode 100755 index 0000000..5cfecf8 --- /dev/null +++ b/domx/mm_osal/src/timm_osal_mutex.c @@ -0,0 +1,244 @@ +/* + * Copyright (c) 2010, Texas Instruments Incorporated + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * * Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * + * * Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * * Neither the name of Texas Instruments Incorporated nor the names of + * its contributors may be used to endorse or promote products derived + * from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" + * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, + * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; + * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR + * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, + * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/* +* @file timm_osal_Mutexs.c +* This file contains methods that provides the functionality +* +* @path \ +* +*/ +/* -------------------------------------------------------------------------- */ +/* ========================================================================= + *! + *! Revision History + *! =================================== + *! 04-Nov-2008 Maiya ShreeHarsha: Linux specific changes + *! 0.1: Created the first draft version, ksrini@ti.com + * ========================================================================= */ + +/****************************************************************************** +* Includes +******************************************************************************/ + + +#include "timm_osal_types.h" +#include "timm_osal_trace.h" +#include "timm_osal_error.h" +#include "timm_osal_memory.h" +#include "timm_osal_semaphores.h" + +#include <errno.h> + +#include <pthread.h> +#include <sys/time.h> + + +/* ========================================================================== */ +/** +* @fn TIMM_OSAL_MutexCreate function +* +* +*/ +/* ========================================================================== */ +TIMM_OSAL_ERRORTYPE TIMM_OSAL_MutexCreate(TIMM_OSAL_PTR * pMutex) +{ + TIMM_OSAL_ERRORTYPE bReturnStatus = TIMM_OSAL_ERR_UNKNOWN; + pthread_mutex_t *plMutex = TIMM_OSAL_NULL; + + plMutex = + (pthread_mutex_t *) TIMM_OSAL_Malloc(sizeof(pthread_mutex_t), 0, + 0, 0); + if (TIMM_OSAL_NULL == plMutex) + { + bReturnStatus = TIMM_OSAL_ERR_ALLOC; + goto EXIT; + } + + /*if (SUCCESS != pthread_mutex_init(plMutex, pAttr)) */ + if (SUCCESS != pthread_mutex_init(plMutex, TIMM_OSAL_NULL)) + { + /*TIMM_OSAL_Error ("Mutex Create failed !"); */ + /*goto EXIT; */ + } else + { + /**pMutex = (TIMM_OSAL_PTR *)plMutex;*/ + *pMutex = (TIMM_OSAL_PTR) plMutex; + bReturnStatus = TIMM_OSAL_ERR_NONE; + } + EXIT: + /*if((TIMM_OSAL_ERR_NONE != bReturnStatus)) { + TIMM_OSAL_Free(plMutex); + } */ + if ((TIMM_OSAL_ERR_NONE != bReturnStatus) && + (TIMM_OSAL_NULL != plMutex)) + { + TIMM_OSAL_Free(plMutex); + } + return bReturnStatus; + +/**********************************************************/ +/*return TIMM_OSAL_SemaphoreCreate(pMutex, 1);*/ +/**********************************************************/ +} + +/* ========================================================================== */ +/** +* @fn TIMM_OSAL_MutexDelete function +* +* +*/ +/* ========================================================================== */ +TIMM_OSAL_ERRORTYPE TIMM_OSAL_MutexDelete(TIMM_OSAL_PTR pMutex) +{ + TIMM_OSAL_ERRORTYPE bReturnStatus = TIMM_OSAL_ERR_NONE; + pthread_mutex_t *plMutex = (pthread_mutex_t *) pMutex; + + if (plMutex == TIMM_OSAL_NULL) + { + bReturnStatus = TIMM_OSAL_ERR_PARAMETER; + goto EXIT; + } + /*can we do away with if or with switch case */ + if (SUCCESS != pthread_mutex_destroy(plMutex)) + { + /*TIMM_OSAL_Error("Delete Mutex failed !"); */ + bReturnStatus = TIMM_OSAL_ERR_UNKNOWN;; + } + + TIMM_OSAL_Free(plMutex); + EXIT: + return bReturnStatus; +/**********************************************************/ +/*return TIMM_OSAL_SemaphoreDelete(pMutex);*/ +/**********************************************************/ + +} + +/* ========================================================================== */ +/** +* @fn TIMM_OSAL_MutexObtain function +* +* +*/ +/* ========================================================================== */ + +TIMM_OSAL_ERRORTYPE TIMM_OSAL_MutexObtain(TIMM_OSAL_PTR pMutex, + TIMM_OSAL_U32 uTimeOut) +{ + TIMM_OSAL_ERRORTYPE bReturnStatus = TIMM_OSAL_ERR_UNKNOWN; + struct timespec abs_timeout; + struct timeval ltime_now; + TIMM_OSAL_U32 ltimenow_us; + pthread_mutex_t *plMutex = (pthread_mutex_t *) pMutex; + + if (plMutex == TIMM_OSAL_NULL) + { + bReturnStatus = TIMM_OSAL_ERR_PARAMETER; + goto EXIT; + } + + if (TIMM_OSAL_SUSPEND == uTimeOut) + { + if (SUCCESS != pthread_mutex_lock(plMutex)) + { + /*TIMM_OSAL_Error("Lock Mutex failed !"); */ + goto EXIT; + } + } else if (TIMM_OSAL_NO_SUSPEND == uTimeOut) + { + if (SUCCESS != pthread_mutex_trylock(plMutex)) + { + /*TIMM_OSAL_Error("Lock Mutex failed !"); */ + goto EXIT; + } + } else + { + gettimeofday(<ime_now, NULL); + /*uTimeOut is assumed to be in milliseconds */ + ltimenow_us = ltime_now.tv_usec + 1000 * uTimeOut; + abs_timeout.tv_sec = ltime_now.tv_sec + uTimeOut / 1000; + abs_timeout.tv_nsec = (ltimenow_us % 1000000) * 1000; + +#ifdef _POSIX_VERSION_1_ + if (SUCCESS != pthread_mutex_lock(plMutex)) + { //Some Posix versions dont support timeout +#else + if (SUCCESS != pthread_mutex_timedlock(plMutex, &abs_timeout)) + { +#endif + /*TIMM_OSAL_Error("Lock Mutex failed !"); */ + goto EXIT; + } + } + bReturnStatus = TIMM_OSAL_ERR_NONE; + + EXIT: + return bReturnStatus; +/**********************************************************/ +/*return TIMM_OSAL_SemaphoreObtain(pMutex, uTimeOut);*/ +/**********************************************************/ +} + + + +/* ========================================================================== */ +/** +* @fn TIMM_OSAL_MutexRelease function +* +* +*/ +/* ========================================================================== */ +TIMM_OSAL_ERRORTYPE TIMM_OSAL_MutexRelease(TIMM_OSAL_PTR pMutex) +{ + TIMM_OSAL_ERRORTYPE bReturnStatus = TIMM_OSAL_ERR_UNKNOWN; + pthread_mutex_t *plMutex = (pthread_mutex_t *) pMutex; + + if (TIMM_OSAL_NULL == plMutex) + { + bReturnStatus = TIMM_OSAL_ERR_PARAMETER; + goto EXIT; + } + + if (SUCCESS != pthread_mutex_unlock(plMutex)) + { + /*TIMM_OSAL_Error("Unlock Mutex failed !"); */ + } else + { + bReturnStatus = TIMM_OSAL_ERR_NONE; + } + EXIT: + return bReturnStatus; +/**********************************************************/ +/*return TIMM_OSAL_SemaphoreRelease(pMutex);*/ +/**********************************************************/ +} |