1 /*
2  *  Copyright (c) 2010 The WebM project authors. All Rights Reserved.
3  *
4  *  Use of this source code is governed by a BSD-style license
5  *  that can be found in the LICENSE file in the root of the source
6  *  tree. An additional intellectual property rights grant can be found
7  *  in the file PATENTS.  All contributing project authors may
8  *  be found in the AUTHORS file in the root of the source tree.
9  */
10 
11 
12 #ifndef VP8_COMMON_THREADING_H_
13 #define VP8_COMMON_THREADING_H_
14 
15 #ifdef __cplusplus
16 extern "C" {
17 #endif
18 
19 #if CONFIG_OS_SUPPORT && CONFIG_MULTITHREAD
20 
21 /* Thread management macros */
22 #ifdef _WIN32
23 /* Win32 */
24 #include <process.h>
25 #include <windows.h>
26 #define THREAD_FUNCTION DWORD WINAPI
27 #define THREAD_FUNCTION_RETURN DWORD
28 #define THREAD_SPECIFIC_INDEX DWORD
29 #define pthread_t HANDLE
30 #define pthread_attr_t DWORD
31 #define pthread_create(thhandle,attr,thfunc,tharg) (int)((*thhandle=(HANDLE)_beginthreadex(NULL,0,(unsigned int (__stdcall *)(void *))thfunc,tharg,0,NULL))==NULL)
32 #define pthread_join(thread, result) ((WaitForSingleObject((thread),INFINITE)!=WAIT_OBJECT_0) || !CloseHandle(thread))
33 #define pthread_detach(thread) if(thread!=NULL)CloseHandle(thread)
34 #define thread_sleep(nms) Sleep(nms)
35 #define pthread_cancel(thread) terminate_thread(thread,0)
36 #define ts_key_create(ts_key, destructor) {ts_key = TlsAlloc();};
37 #define pthread_getspecific(ts_key) TlsGetValue(ts_key)
38 #define pthread_setspecific(ts_key, value) TlsSetValue(ts_key, (void *)value)
39 #define pthread_self() GetCurrentThreadId()
40 
41 #elif defined(__OS2__)
42 /* OS/2 */
43 #define INCL_DOS
44 #include <os2.h>
45 
46 #include <stdlib.h>
47 #define THREAD_FUNCTION void
48 #define THREAD_FUNCTION_RETURN void
49 #define THREAD_SPECIFIC_INDEX PULONG
50 #define pthread_t TID
51 #define pthread_attr_t ULONG
52 #define pthread_create(thhandle,attr,thfunc,tharg) \
53     ((int)((*(thhandle)=_beginthread(thfunc,NULL,1024*1024,tharg))==-1))
54 #define pthread_join(thread, result) ((int)DosWaitThread(&(thread),0))
55 #define pthread_detach(thread) 0
56 #define thread_sleep(nms) DosSleep(nms)
57 #define pthread_cancel(thread) DosKillThread(thread)
58 #define ts_key_create(ts_key, destructor) \
59     DosAllocThreadLocalMemory(1, &(ts_key));
60 #define pthread_getspecific(ts_key) ((void *)(*(ts_key)))
61 #define pthread_setspecific(ts_key, value) (*(ts_key)=(ULONG)(value))
62 #define pthread_self() _gettid()
63 #else
64 #ifdef __APPLE__
65 #include <mach/mach_init.h>
66 #include <mach/semaphore.h>
67 #include <mach/task.h>
68 #include <time.h>
69 #include <unistd.h>
70 
71 #else
72 #include <semaphore.h>
73 #endif
74 
75 #include <pthread.h>
76 /* pthreads */
77 /* Nearly everything is already defined */
78 #define THREAD_FUNCTION void *
79 #define THREAD_FUNCTION_RETURN void *
80 #define THREAD_SPECIFIC_INDEX pthread_key_t
81 #define ts_key_create(ts_key, destructor) pthread_key_create (&(ts_key), destructor);
82 #endif
83 
84 /* Syncrhronization macros: Win32 and Pthreads */
85 #ifdef _WIN32
86 #define sem_t HANDLE
87 #define pause(voidpara) __asm PAUSE
88 #define sem_init(sem, sem_attr1, sem_init_value) (int)((*sem = CreateSemaphore(NULL,0,32768,NULL))==NULL)
89 #define sem_wait(sem) (int)(WAIT_OBJECT_0 != WaitForSingleObject(*sem,INFINITE))
90 #define sem_post(sem) ReleaseSemaphore(*sem,1,NULL)
91 #define sem_destroy(sem) if(*sem)((int)(CloseHandle(*sem))==TRUE)
92 #define thread_sleep(nms) Sleep(nms)
93 
94 #elif defined(__OS2__)
95 typedef struct
96 {
97     HEV  event;
98     HMTX wait_mutex;
99     HMTX count_mutex;
100     int  count;
101 } sem_t;
102 
103 static inline int sem_init(sem_t *sem, int pshared, unsigned int value)
104 {
105     DosCreateEventSem(NULL, &sem->event, pshared ? DC_SEM_SHARED : 0,
106                       value > 0 ? TRUE : FALSE);
107     DosCreateMutexSem(NULL, &sem->wait_mutex, 0, FALSE);
108     DosCreateMutexSem(NULL, &sem->count_mutex, 0, FALSE);
109 
110     sem->count = value;
111 
112     return 0;
113 }
114 
115 static inline int sem_wait(sem_t * sem)
116 {
117     DosRequestMutexSem(sem->wait_mutex, -1);
118 
119     DosWaitEventSem(sem->event, -1);
120 
121     DosRequestMutexSem(sem->count_mutex, -1);
122 
123     sem->count--;
124     if (sem->count == 0)
125     {
126         ULONG post_count;
127 
128         DosResetEventSem(sem->event, &post_count);
129     }
130 
131     DosReleaseMutexSem(sem->count_mutex);
132 
133     DosReleaseMutexSem(sem->wait_mutex);
134 
135     return 0;
136 }
137 
138 static inline int sem_post(sem_t * sem)
139 {
140     DosRequestMutexSem(sem->count_mutex, -1);
141 
142     if (sem->count < 32768)
143     {
144         sem->count++;
145         DosPostEventSem(sem->event);
146     }
147 
148     DosReleaseMutexSem(sem->count_mutex);
149 
150     return 0;
151 }
152 
153 static inline int sem_destroy(sem_t * sem)
154 {
155     DosCloseEventSem(sem->event);
156     DosCloseMutexSem(sem->wait_mutex);
157     DosCloseMutexSem(sem->count_mutex);
158 
159     return 0;
160 }
161 
162 #define thread_sleep(nms) DosSleep(nms)
163 
164 #else
165 
166 #ifdef __APPLE__
167 #define sem_t semaphore_t
168 #define sem_init(X,Y,Z) semaphore_create(mach_task_self(), X, SYNC_POLICY_FIFO, Z)
169 #define sem_wait(sem) (semaphore_wait(*sem) )
170 #define sem_post(sem) semaphore_signal(*sem)
171 #define sem_destroy(sem) semaphore_destroy(mach_task_self(),*sem)
172 #define thread_sleep(nms) /* { struct timespec ts;ts.tv_sec=0; ts.tv_nsec = 1000*nms;nanosleep(&ts, NULL);} */
173 #else
174 #include <unistd.h>
175 #include <sched.h>
176 #define thread_sleep(nms) sched_yield();/* {struct timespec ts;ts.tv_sec=0; ts.tv_nsec = 1000*nms;nanosleep(&ts, NULL);} */
177 #endif
178 /* Not Windows. Assume pthreads */
179 
180 #endif
181 
182 #if ARCH_X86_32 || ARCH_X86_64
183 #include "vpx_ports/x86.h"
184 #else
185 #define x86_pause_hint()
186 #endif
187 
188 #endif /* CONFIG_OS_SUPPORT && CONFIG_MULTITHREAD */
189 
190 #ifdef __cplusplus
191 }  // extern "C"
192 #endif
193 
194 #endif  // VP8_COMMON_THREADING_H_
195