jh163888/xrdp
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

thread_calls and added semaphore

Browse Source
This commit is contained in:
jsorg71 2007-02-04 07:54:23 +00:00
parent 7ed52495d0
commit 281d804923
2 changed files with 76 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
common/thread_calls.c
View File

@ -24,6 +24,7 @@
#include <windows.h> #include <windows.h>
#else #else
#include <pthread.h> #include <pthread.h>
#include <semaphore.h>
#endif #endif
#include "arch.h" #include "arch.h"
#include "thread_calls.h" #include "thread_calls.h"
@ -72,7 +73,7 @@ tc_get_threadid(void)
/*****************************************************************************/ /*****************************************************************************/
long APP_CC long APP_CC
tc_create_mutex(void) tc_mutex_create(void)
{ {
#if defined(_WIN32) #if defined(_WIN32)
return (long)CreateMutex(0, 0, 0); return (long)CreateMutex(0, 0, 0);
@ -87,7 +88,7 @@ tc_create_mutex(void)
/*****************************************************************************/ /*****************************************************************************/
void APP_CC void APP_CC
tc_delete_mutex(long mutex) tc_mutex_delete(long mutex)
{ {
#if defined(_WIN32) #if defined(_WIN32)
CloseHandle((HANDLE)mutex); CloseHandle((HANDLE)mutex);
@ -102,7 +103,7 @@ tc_delete_mutex(long mutex)
/*****************************************************************************/ /*****************************************************************************/
int APP_CC int APP_CC
tc_lock_mutex(long mutex) tc_mutex_lock(long mutex)
{ {
#if defined(_WIN32) #if defined(_WIN32)
WaitForSingleObject((HANDLE)mutex, INFINITE); WaitForSingleObject((HANDLE)mutex, INFINITE);
@ -115,7 +116,7 @@ tc_lock_mutex(long mutex)
/*****************************************************************************/ /*****************************************************************************/
int APP_CC int APP_CC
tc_unlock_mutex(long mutex) tc_mutex_unlock(long mutex)
{ {
#if defined(_WIN32) #if defined(_WIN32)
ReleaseMutex((HANDLE)mutex); ReleaseMutex((HANDLE)mutex);
@ -125,3 +126,62 @@ tc_unlock_mutex(long mutex)
return 0; return 0;
#endif #endif
} }
/*****************************************************************************/
long APP_CC
tc_sem_create(int init_count)
{
#if defined(_WIN32)
HANDLE sem;
sem = CreateSemaphore(0, init_count, init_count + 10, 0);
return (long)sem;
#else
sem_t* sem;
sem = g_malloc(sizeof(sem_t), 0);
sem_init(sem, 0, init_count);
return (long)sem;
#endif
}
/*****************************************************************************/
void APP_CC
tc_sem_delete(long sem)
{
#if defined(_WIN32)
CloseHandle((HANDLE)sem);
#else
sem_t* lsem;
lsem = (sem_t*)sem;
sem_destroy(lsem);
g_free(lsem);
#endif
}
/*****************************************************************************/
int APP_CC
tc_sem_dec(long sem)
{
#if defined(_WIN32)
WaitForSingleObject((HANDLE)sem, INFINITE);
return 0;
#else
sem_wait((sem_t*)sem);
return 0;
#endif
}
/*****************************************************************************/
int APP_CC
tc_sem_inc(long sem)
{
#if defined(_WIN32)
ReleaseSemaphore((HANDLE)sem, 1, 0);
return 0;
#else
sem_post((sem_t*)sem);
return 0;
#endif
}

16
common/thread_calls.h
View File

@ -28,12 +28,20 @@ tc_thread_create(THREAD_RV (THREAD_CC * start_routine)(void*), void* arg);
long APP_CC long APP_CC
tc_get_threadid(void); tc_get_threadid(void);
long APP_CC long APP_CC
tc_create_mutex(void); tc_mutex_create(void);
void APP_CC void APP_CC
tc_delete_mutex(long mutex); tc_mutex_delete(long mutex);
int APP_CC int APP_CC
tc_lock_mutex(long mutex); tc_mutex_lock(long mutex);
int APP_CC int APP_CC
tc_unlock_mutex(long mutex); tc_mutex_unlock(long mutex);
long APP_CC
tc_sem_create(int init_count);
void APP_CC
tc_sem_delete(long sem);
int APP_CC
tc_sem_dec(long sem);
int APP_CC
tc_sem_inc(long sem);
#endif #endif