diff options
Diffstat (limited to 'branches/1.0/tinySAK/src/tsk_semaphore.c')
| -rw-r--r-- | branches/1.0/tinySAK/src/tsk_semaphore.c | 198 |
1 files changed, 0 insertions, 198 deletions
diff --git a/branches/1.0/tinySAK/src/tsk_semaphore.c b/branches/1.0/tinySAK/src/tsk_semaphore.c deleted file mode 100644 index 649c4a8..0000000 --- a/branches/1.0/tinySAK/src/tsk_semaphore.c +++ /dev/null @@ -1,198 +0,0 @@ -/* -* Copyright (C) 2009-2010 Mamadou Diop. -* -* Contact: Mamadou Diop <diopmamadou(at)doubango.org> -* -* This file is part of Open Source Doubango Framework. -* -* DOUBANGO is free software: you can redistribute it and/or modify -* it under the terms of the GNU General Public License as published by -* the Free Software Foundation, either version 3 of the License, or -* (at your option) any later version. -* -* DOUBANGO 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 -* along with DOUBANGO. -* -*/ - -/**@file tsk_semaphore.c -* @brief Pthread/Windows Semaphore utility functions. -* -* @author Mamadou Diop <diopmamadou(at)doubango.org> -* -* @date Created: Sat Nov 8 16:54:58 2009 mdiop -*/ -#include "tsk_semaphore.h" -#include "tsk_memory.h" -#include "tsk_debug.h" -#include "tsk_string.h" - -/* Apple claims that they fully support POSIX semaphore but ... - */ -#if defined(__APPLE__) /* Mac OSX/Darwin/Iphone/Ipod Touch */ -# define TSK_USE_NAMED_SEM 1 -#else -# define TSK_USE_NAMED_SEM 0 -#endif - -#if TSK_UNDER_WINDOWS /* Windows XP/Vista/7/CE */ - -# include <windows.h> -# include "tsk_errno.h" -# define SEMAPHORE_S void - typedef HANDLE SEMAPHORE_T; -//#else if define(__APPLE__) /* Mac OSX/Darwin/Iphone/Ipod Touch */ -//# include <march/semaphore.h> -//# include <march/task.h> -#else /* All *nix */ - -# include <pthread.h> -# include <semaphore.h> -# if TSK_USE_NAMED_SEM -# include <fcntl.h> /* O_CREAT */ -# include <sys/stat.h> /* S_IRUSR, S_IWUSR*/ - - static int sem_count = 0; - typedef struct named_sem_s - { - sem_t* sem; - char* name; - } named_sem_t; -# define SEMAPHORE_S named_sem_t -# define GET_SEM(PSEM) (((named_sem_t*)(PSEM))->sem) -# else -# define SEMAPHORE_S sem_t -# define GET_SEM(PSEM) ((PSEM)) -# endif /* TSK_USE_NAMED_SEM */ - typedef sem_t* SEMAPHORE_T; - -#endif - -#if defined(__GNUC__) || defined(__SYMBIAN32__) -# include <errno.h> -#endif - - - -/**@defgroup tsk_semaphore_group Pthread/Windows Semaphore functions. -*/ - -/**@ingroup tsk_semaphore_group -* Creates new semaphore handle. -* @retval A New semaphore handle. -* You MUST call @ref tsk_semaphore_destroy to free the semaphore. -* @sa @ref tsk_semaphore_destroy -*/ -tsk_semaphore_handle_t* tsk_semaphore_create() -{ - SEMAPHORE_T handle = 0; - -#if TSK_UNDER_WINDOWS - handle = CreateSemaphore(NULL, 0, 0x7FFFFFFF, NULL); -#else - handle = tsk_calloc(1, sizeof(SEMAPHORE_S)); - -#if TSK_USE_NAMED_SEM - named_sem_t * nsem = (named_sem_t*)handle; - tsk_sprintf(&(nsem->name), "/sem-%d", sem_count++); - if((nsem->sem = sem_open(nsem->name, O_CREAT /*| O_EXCL*/, S_IRUSR | S_IWUSR, 0)) == SEM_FAILED) - { - TSK_FREE(nsem->name); -#else - if(sem_init((SEMAPHORE_T)handle, 0, 0)) - { -#endif - TSK_FREE(handle); - TSK_DEBUG_ERROR("Failed to initialize the new semaphore (errno=%d).", errno); - } -#endif - - if(!handle){ - TSK_DEBUG_ERROR("Failed to create new mutex."); - } - return handle; -} - -/**@ingroup tsk_semaphore_group -* Increments a semaphore. -* @param handle The semaphore to increment. -* @retval Zero if succeed and otherwise the function returns -1 and sets errno to indicate the error. -* @sa @ref tsk_semaphore_decrement. -*/ -int tsk_semaphore_increment(tsk_semaphore_handle_t* handle) -{ - int ret = EINVAL; - if(handle) - { -#if TSK_UNDER_WINDOWS - if((ret = ReleaseSemaphore((SEMAPHORE_T)handle, 1L, 0L) ? 0 : -1)) -#else - if(ret = sem_post((SEMAPHORE_T)GET_SEM(handle))) -#endif - { - TSK_DEBUG_ERROR("sem_post function failed: %d", ret); - } - } - return ret; -} - -/**@ingroup tsk_semaphore_group -* Decrements a semaphore. -* @param handle The semaphore to decrement. -* @retval Zero if succeed and otherwise the function returns -1 and sets errno to indicate the error. -* @sa @ref tsk_semaphore_increment. -*/ -int tsk_semaphore_decrement(tsk_semaphore_handle_t* handle) -{ - int ret = EINVAL; - if(handle) - { -#if TSK_UNDER_WINDOWS - ret = (WaitForSingleObject((SEMAPHORE_T)handle, INFINITE) == WAIT_OBJECT_0 ? 0 : -1); - if(ret) TSK_DEBUG_ERROR("sem_wait function failed: %d", ret); -#else - do - { - ret = sem_wait((SEMAPHORE_T)GET_SEM(handle)); - } - while ( errno == EINTR ); - if(ret) TSK_DEBUG_ERROR("sem_wait function failed: %d", errno); -#endif - } - - return ret; -} - -/**@ingroup tsk_semaphore_group -* Destroy a semaphore previously created using @ref tsk_semaphore_create. -* @param handle The semaphore to free. -* @sa @ref tsk_semaphore_create -*/ -void tsk_semaphore_destroy(tsk_semaphore_handle_t** handle) -{ - if(handle && *handle) - { -#if TSK_UNDER_WINDOWS - CloseHandle((SEMAPHORE_T)*handle); - *handle = 0; -#else -# if TSK_USE_NAMED_SEM - named_sem_t * nsem = ((named_sem_t*)*handle); - sem_close(nsem->sem); - TSK_FREE(nsem->name); -#else - sem_destroy((SEMAPHORE_T)GET_SEM(*handle)); -#endif /* TSK_USE_NAMED_SEM */ - tsk_free(handle); -#endif - } - else{ - TSK_DEBUG_WARN("Cannot free an uninitialized semaphore object"); - } -} - |
