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
16extern "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__)
95typedef struct
96{
97    HEV  event;
98    HMTX wait_mutex;
99    HMTX count_mutex;
100    int  count;
101} sem_t;
102
103static 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
115static 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
138static 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
153static 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 || 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