media/libvpx/vp8/common/threading.h@ac0c01689b40
media/libvpx/vp8/common/threading.h
Thu, 15 Jan 2015 15:59:08 +0100
- author
- Michael Schloh von Bennewitz <michael@schloh.com>
- date
- Thu, 15 Jan 2015 15:59:08 +0100
- branch
- TOR_BUG_9701
- changeset 10
- ac0c01689b40
- permissions
- -rw-r--r--
Implement a real Private Browsing Mode condition by changing the API/ABI;
This solves Tor bug #9701, complying with disk avoidance documented in
https://www.torproject.org/projects/torbrowser/design/#disk-avoidance.
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 */
12 #ifndef _PTHREAD_EMULATION
13 #define _PTHREAD_EMULATION
15 #if CONFIG_OS_SUPPORT && CONFIG_MULTITHREAD
17 /* Thread management macros */
18 #ifdef _WIN32
19 /* Win32 */
20 #include <process.h>
21 #include <windows.h>
22 #define THREAD_FUNCTION DWORD WINAPI
23 #define THREAD_FUNCTION_RETURN DWORD
24 #define THREAD_SPECIFIC_INDEX DWORD
25 #define pthread_t HANDLE
26 #define pthread_attr_t DWORD
27 #define pthread_create(thhandle,attr,thfunc,tharg) (int)((*thhandle=(HANDLE)_beginthreadex(NULL,0,(unsigned int (__stdcall *)(void *))thfunc,tharg,0,NULL))==NULL)
28 #define pthread_join(thread, result) ((WaitForSingleObject((thread),INFINITE)!=WAIT_OBJECT_0) || !CloseHandle(thread))
29 #define pthread_detach(thread) if(thread!=NULL)CloseHandle(thread)
30 #define thread_sleep(nms) Sleep(nms)
31 #define pthread_cancel(thread) terminate_thread(thread,0)
32 #define ts_key_create(ts_key, destructor) {ts_key = TlsAlloc();};
33 #define pthread_getspecific(ts_key) TlsGetValue(ts_key)
34 #define pthread_setspecific(ts_key, value) TlsSetValue(ts_key, (void *)value)
35 #define pthread_self() GetCurrentThreadId()
37 #elif defined(__OS2__)
38 /* OS/2 */
39 #define INCL_DOS
40 #include <os2.h>
42 #include <stdlib.h>
43 #define THREAD_FUNCTION void
44 #define THREAD_FUNCTION_RETURN void
45 #define THREAD_SPECIFIC_INDEX PULONG
46 #define pthread_t TID
47 #define pthread_attr_t ULONG
48 #define pthread_create(thhandle,attr,thfunc,tharg) \
49 ((int)((*(thhandle)=_beginthread(thfunc,NULL,1024*1024,tharg))==-1))
50 #define pthread_join(thread, result) ((int)DosWaitThread(&(thread),0))
51 #define pthread_detach(thread) 0
52 #define thread_sleep(nms) DosSleep(nms)
53 #define pthread_cancel(thread) DosKillThread(thread)
54 #define ts_key_create(ts_key, destructor) \
55 DosAllocThreadLocalMemory(1, &(ts_key));
56 #define pthread_getspecific(ts_key) ((void *)(*(ts_key)))
57 #define pthread_setspecific(ts_key, value) (*(ts_key)=(ULONG)(value))
58 #define pthread_self() _gettid()
59 #else
60 #ifdef __APPLE__
61 #include <mach/mach_init.h>
62 #include <mach/semaphore.h>
63 #include <mach/task.h>
64 #include <time.h>
65 #include <unistd.h>
67 #else
68 #include <semaphore.h>
69 #endif
71 #include <pthread.h>
72 /* pthreads */
73 /* Nearly everything is already defined */
74 #define THREAD_FUNCTION void *
75 #define THREAD_FUNCTION_RETURN void *
76 #define THREAD_SPECIFIC_INDEX pthread_key_t
77 #define ts_key_create(ts_key, destructor) pthread_key_create (&(ts_key), destructor);
78 #endif
80 /* Syncrhronization macros: Win32 and Pthreads */
81 #ifdef _WIN32
82 #define sem_t HANDLE
83 #define pause(voidpara) __asm PAUSE
84 #define sem_init(sem, sem_attr1, sem_init_value) (int)((*sem = CreateSemaphore(NULL,0,32768,NULL))==NULL)
85 #define sem_wait(sem) (int)(WAIT_OBJECT_0 != WaitForSingleObject(*sem,INFINITE))
86 #define sem_post(sem) ReleaseSemaphore(*sem,1,NULL)
87 #define sem_destroy(sem) if(*sem)((int)(CloseHandle(*sem))==TRUE)
88 #define thread_sleep(nms) Sleep(nms)
90 #elif defined(__OS2__)
91 typedef struct
92 {
93 HEV event;
94 HMTX wait_mutex;
95 HMTX count_mutex;
96 int count;
97 } sem_t;
99 static inline int sem_init(sem_t *sem, int pshared, unsigned int value)
100 {
101 DosCreateEventSem(NULL, &sem->event, pshared ? DC_SEM_SHARED : 0,
102 value > 0 ? TRUE : FALSE);
103 DosCreateMutexSem(NULL, &sem->wait_mutex, 0, FALSE);
104 DosCreateMutexSem(NULL, &sem->count_mutex, 0, FALSE);
106 sem->count = value;
108 return 0;
109 }
111 static inline int sem_wait(sem_t * sem)
112 {
113 DosRequestMutexSem(sem->wait_mutex, -1);
115 DosWaitEventSem(sem->event, -1);
117 DosRequestMutexSem(sem->count_mutex, -1);
119 sem->count--;
120 if (sem->count == 0)
121 {
122 ULONG post_count;
124 DosResetEventSem(sem->event, &post_count);
125 }
127 DosReleaseMutexSem(sem->count_mutex);
129 DosReleaseMutexSem(sem->wait_mutex);
131 return 0;
132 }
134 static inline int sem_post(sem_t * sem)
135 {
136 DosRequestMutexSem(sem->count_mutex, -1);
138 if (sem->count < 32768)
139 {
140 sem->count++;
141 DosPostEventSem(sem->event);
142 }
144 DosReleaseMutexSem(sem->count_mutex);
146 return 0;
147 }
149 static inline int sem_destroy(sem_t * sem)
150 {
151 DosCloseEventSem(sem->event);
152 DosCloseMutexSem(sem->wait_mutex);
153 DosCloseMutexSem(sem->count_mutex);
155 return 0;
156 }
158 #define thread_sleep(nms) DosSleep(nms)
160 #else
162 #ifdef __APPLE__
163 #define sem_t semaphore_t
164 #define sem_init(X,Y,Z) semaphore_create(mach_task_self(), X, SYNC_POLICY_FIFO, Z)
165 #define sem_wait(sem) (semaphore_wait(*sem) )
166 #define sem_post(sem) semaphore_signal(*sem)
167 #define sem_destroy(sem) semaphore_destroy(mach_task_self(),*sem)
168 #define thread_sleep(nms) /* { struct timespec ts;ts.tv_sec=0; ts.tv_nsec = 1000*nms;nanosleep(&ts, NULL);} */
169 #else
170 #include <unistd.h>
171 #include <sched.h>
172 #define thread_sleep(nms) sched_yield();/* {struct timespec ts;ts.tv_sec=0; ts.tv_nsec = 1000*nms;nanosleep(&ts, NULL);} */
173 #endif
174 /* Not Windows. Assume pthreads */
176 #endif
178 #if ARCH_X86 || ARCH_X86_64
179 #include "vpx_ports/x86.h"
180 #else
181 #define x86_pause_hint()
182 #endif
184 #endif /* CONFIG_OS_SUPPORT && CONFIG_MULTITHREAD */
186 #endif
