1/*****************************************************************************/
2// Copyright 2002-2008 Adobe Systems Incorporated
3// All Rights Reserved.
4//
5// NOTICE: Adobe permits you to use, modify, and distribute this file in
6// accordance with the terms of the Adobe license agreement accompanying it.
7/*****************************************************************************/
8
9/* $Id: //mondo/dng_sdk_1_4/dng_sdk/source/dng_pthread.h#1 $ */
10/* $DateTime: 2012/05/30 13:28:51 $ */
11/* $Change: 832332 $ */
12/* $Author: tknoll $ */
13
14/*****************************************************************************/
15
16#ifndef __dng_pthread__
17#define __dng_pthread__
18
19/*****************************************************************************/
20
21#include "dng_flags.h"
22
23/*****************************************************************************/
24
25#if qDNGThreadSafe
26
27/*****************************************************************************/
28
29#if !qWinOS
30
31/*****************************************************************************/
32
33/* Try generic POSIX compile */
34
35#include <errno.h>
36#include <pthread.h>
37
38#define dng_pthread_disassociate()
39#define dng_pthread_terminate()
40
41/*****************************************************************************/
42
43#else
44
45/*****************************************************************************/
46
47#include <stdlib.h>
48
49#if _MSC_VER >= 1600
50
51// Get this included so ETIMEDOUT is predefined.
52#include <errno.h>
53
54#endif
55
56#include <time.h>
57#define dng_timespec timespec
58
59#ifdef __cplusplus
60extern "C"
61{
62#endif
63
64/*****************************************************************************/
65
66#define DNG_ETIMEDOUT 60 /* Operation timed out */
67
68typedef unsigned long dng_pthread_t;
69
70typedef struct dng_pthread_mutex_impl *dng_pthread_mutex_t;
71typedef struct dng_pthread_cond_impl *dng_pthread_cond_t;
72typedef unsigned long dng_pthread_key_t;
73
74
75#define DNG_PTHREAD_MUTEX_INITIALIZER ((struct dng_pthread_mutex_impl *)-1)
76#define DNG_PTHREAD_COND_INITIALIZER ((struct dng_pthread_cond_impl *)-1)
77
78struct _dng_pthread_once_t {
79 int inited;
80 long semaphore;
81};
82
83typedef struct _dng_pthread_once_t dng_pthread_once_t;
84#define DNG_PTHREAD_ONCE_INIT { 0, -1 }
85
86#define dng_pthread_equal(t1, t2) ((t1) == (t2))
87
88typedef struct dng_pthread_attr_impl *dng_pthread_attr_t;
89
90int dng_pthread_attr_init(dng_pthread_attr_t *attr);
91int dng_pthread_attr_destroy(dng_pthread_attr_t *attr);
92
93int dng_pthread_attr_setstacksize(dng_pthread_attr_t *attr, size_t stacksize);
94int dng_pthread_attr_getstacksize(const dng_pthread_attr_t *attr, size_t *stacksize);
95
96int dng_pthread_create(dng_pthread_t *thread, const dng_pthread_attr_t * /* attrs */, void * (*func)(void *), void *arg);
97int dng_pthread_detach(dng_pthread_t thread);
98int dng_pthread_join(dng_pthread_t thread, void **result);
99dng_pthread_t dng_pthread_self();
100void dng_pthread_exit(void *result);
101
102#define DNG_PTHREAD_MUTEX_RECURSIVE 0
103typedef unsigned long dng_pthread_mutexattr_t;
104
105int dng_pthread_mutexattr_init(dng_pthread_mutexattr_t *mutexattr);
106int dng_pthread_mutexattr_settype(dng_pthread_mutexattr_t *mutexattr, int /*the options*/);
107
108int dng_pthread_mutex_init(dng_pthread_mutex_t *mutex, void * /* attrs */);
109int dng_pthread_mutex_destroy(dng_pthread_mutex_t *mutex);
110int dng_pthread_mutex_lock(dng_pthread_mutex_t *mutex);
111int dng_pthread_mutex_unlock(dng_pthread_mutex_t *mutex);
112
113int dng_pthread_cond_init(dng_pthread_cond_t *cond, void * /* attrs */);
114int dng_pthread_cond_destroy(dng_pthread_cond_t *cond);
115int dng_pthread_cond_wait(dng_pthread_cond_t *cond, dng_pthread_mutex_t *mutex);
116int dng_pthread_cond_timedwait(dng_pthread_cond_t *cond, dng_pthread_mutex_t *mutex, struct dng_timespec *latest_time);
117int dng_pthread_cond_signal(dng_pthread_cond_t *cond);
118int dng_pthread_cond_broadcast(dng_pthread_cond_t *cond);
119
120int dng_pthread_once(dng_pthread_once_t *once, void (*init_func)());
121
122int dng_pthread_key_create(dng_pthread_key_t * key, void (*destructor) (void *));
123int dng_pthread_key_delete(dng_pthread_key_t key);
124int dng_pthread_setspecific(dng_pthread_key_t key, const void *value);
125void *dng_pthread_getspecific(dng_pthread_key_t key);
126
127typedef struct dng_pthread_rwlock_impl *dng_pthread_rwlock_t;
128typedef void *pthread_rwlockattr_t;
129
130int dng_pthread_rwlock_destroy(dng_pthread_rwlock_t * rwlock);
131int dng_pthread_rwlock_init(dng_pthread_rwlock_t * rwlock, const pthread_rwlockattr_t * attrs);
132int dng_pthread_rwlock_rdlock(dng_pthread_rwlock_t * rwlock);
133int dng_pthread_rwlock_tryrdlock(dng_pthread_rwlock_t * rwlock);
134int dng_pthread_rwlock_trywrlock(dng_pthread_rwlock_t * rwlock);
135int dng_pthread_rwlock_unlock(dng_pthread_rwlock_t * rwlock);
136int dng_pthread_rwlock_wrlock(dng_pthread_rwlock_t * rwlock);
137
138typedef struct dng_pthread_rwlock_impl *dng_pthread_rwlock_t;
139typedef void *pthread_rwlockattr_t;
140
141int dng_pthread_rwlock_destroy(dng_pthread_rwlock_t * rwlock);
142int dng_pthread_rwlock_init(dng_pthread_rwlock_t * rwlock, const pthread_rwlockattr_t * attrs);
143int dng_pthread_rwlock_rdlock(dng_pthread_rwlock_t * rwlock);
144int dng_pthread_rwlock_tryrdlock(dng_pthread_rwlock_t * rwlock);
145int dng_pthread_rwlock_trywrlock(dng_pthread_rwlock_t * rwlock);
146int dng_pthread_rwlock_unlock(dng_pthread_rwlock_t * rwlock);
147int dng_pthread_rwlock_wrlock(dng_pthread_rwlock_t * rwlock);
148
149// dng_pthread may maintain per-thread global state. This routine frees that global state.
150// there is no need to call this for threads created by dng_pthread and one can call
151// dng_pthread routines of a thread after dng_pthread_disassociate as the global state will
152// be recreated as necessary. However dng_pthread_disassociate will need to be called again
153// and there is a slight performance cost. Do not call this routine while holding a mutex, etc.
154void dng_pthread_disassociate();
155
156void dng_pthread_terminate();
157
158/*****************************************************************************/
159
160// Map symbols back to plain pthread names. This whole mechanism is so the DNG pthreads library
161// symbols do not collide with another pthread emulation library
162// that may be in use in the same linked entity. However if that is the case, it would be far better
163// to have the DNG code use the same pthread library as the rest of the code.
164
165#define pthread_t dng_pthread_t
166#define pthread_mutex_t dng_pthread_mutex_t
167#define pthread_cond_t dng_pthread_cond_t
168#define pthread_once_t dng_pthread_once_t
169#define pthread_key_t dng_pthread_key_t
170
171#undef PTHREAD_MUTEX_INITIALIZER
172#define PTHREAD_MUTEX_INITIALIZER DNG_PTHREAD_MUTEX_INITIALIZER
173#undef PTHREAD_COND_INITIALIZER
174#define PTHREAD_COND_INITIALIZER DNG_PTHREAD_COND_INITIALIZER
175
176#undef PTHREAD_ONCE_INIT
177#define PTHREAD_ONCE_INIT DNG_PTHREAD_ONCE_INIT
178
179/* If it is defined on Windows, it probably has the wrong value... */
180#if defined(WIN32) || !defined(ETIMEDOUT)
181#undef ETIMEDOUT
182#define ETIMEDOUT DNG_ETIMEDOUT
183#endif
184
185#define pthread_equal dng_pthread_equal
186
187#define pthread_attr_t dng_pthread_attr_t
188
189#define pthread_attr_init dng_pthread_attr_init
190#define pthread_attr_destroy dng_pthread_attr_destroy
191
192#define pthread_attr_setstacksize dng_pthread_attr_setstacksize
193#define pthread_attr_getstacksize dng_pthread_attr_getstacksize
194
195#define pthread_create dng_pthread_create
196#define pthread_detach dng_pthread_detach
197#define pthread_join dng_pthread_join
198#define pthread_self dng_pthread_self
199#define pthread_exit dng_pthread_exit
200
201#define pthread_mutex_init dng_pthread_mutex_init
202#define pthread_mutex_destroy dng_pthread_mutex_destroy
203#define pthread_mutex_lock dng_pthread_mutex_lock
204#define pthread_mutex_unlock dng_pthread_mutex_unlock
205
206#define pthread_cond_init dng_pthread_cond_init
207#define pthread_cond_destroy dng_pthread_cond_destroy
208#define pthread_cond_wait dng_pthread_cond_wait
209#define pthread_cond_timedwait dng_pthread_cond_timedwait
210#define pthread_cond_signal dng_pthread_cond_signal
211#define pthread_cond_broadcast dng_pthread_cond_broadcast
212
213#define pthread_once dng_pthread_once
214
215#define pthread_key_create dng_pthread_key_create
216#define pthread_key_delete dng_pthread_key_delete
217#define pthread_setspecific dng_pthread_setspecific
218#define pthread_getspecific dng_pthread_getspecific
219
220#define pthread_rwlock_t dng_pthread_rwlock_t
221
222#define pthread_rwlock_destroy dng_pthread_rwlock_destroy
223#define pthread_rwlock_init dng_pthread_rwlock_init
224#define pthread_rwlock_rdlock dng_pthread_rwlock_rdlock
225#define pthread_rwlock_tryrdlock dng_pthread_rwlock_tryrdlock
226#define pthread_rwlock_trywrlock dng_pthread_rwlock_trywrlock
227#define pthread_rwlock_unlock dng_pthread_rwlock_unlock
228#define pthread_rwlock_wrlock dng_pthread_rwlock_wrlock
229
230/*****************************************************************************/
231
232#ifdef __cplusplus
233}
234#endif
235
236/*****************************************************************************/
237
238#endif
239
240/*****************************************************************************/
241
242#ifdef __cplusplus
243extern "C"
244{
245#endif
246
247int dng_pthread_now (struct timespec *now);
248
249#ifdef __cplusplus
250}
251#endif
252
253/*****************************************************************************/
254
255#endif // qDNGThreadSafe
256
257/*****************************************************************************/
258
259#endif
260
261/*****************************************************************************/
262