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 60 extern "C" 61 { 62 #endif 63 64 /*****************************************************************************/ 65 66 #define DNG_ETIMEDOUT 60 /* Operation timed out */ 67 68 typedef unsigned long dng_pthread_t; 69 70 typedef struct dng_pthread_mutex_impl *dng_pthread_mutex_t; 71 typedef struct dng_pthread_cond_impl *dng_pthread_cond_t; 72 typedef 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 78 struct _dng_pthread_once_t { 79 int inited; 80 long semaphore; 81 }; 82 83 typedef 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 88 typedef struct dng_pthread_attr_impl *dng_pthread_attr_t; 89 90 int dng_pthread_attr_init(dng_pthread_attr_t *attr); 91 int dng_pthread_attr_destroy(dng_pthread_attr_t *attr); 92 93 int dng_pthread_attr_setstacksize(dng_pthread_attr_t *attr, size_t stacksize); 94 int dng_pthread_attr_getstacksize(const dng_pthread_attr_t *attr, size_t *stacksize); 95 96 int dng_pthread_create(dng_pthread_t *thread, const dng_pthread_attr_t * /* attrs */, void * (*func)(void *), void *arg); 97 int dng_pthread_detach(dng_pthread_t thread); 98 int dng_pthread_join(dng_pthread_t thread, void **result); 99 dng_pthread_t dng_pthread_self(); 100 void dng_pthread_exit(void *result); 101 102 #define DNG_PTHREAD_MUTEX_RECURSIVE 0 103 typedef unsigned long dng_pthread_mutexattr_t; 104 105 int dng_pthread_mutexattr_init(dng_pthread_mutexattr_t *mutexattr); 106 int dng_pthread_mutexattr_settype(dng_pthread_mutexattr_t *mutexattr, int /*the options*/); 107 108 int dng_pthread_mutex_init(dng_pthread_mutex_t *mutex, void * /* attrs */); 109 int dng_pthread_mutex_destroy(dng_pthread_mutex_t *mutex); 110 int dng_pthread_mutex_lock(dng_pthread_mutex_t *mutex); 111 int dng_pthread_mutex_unlock(dng_pthread_mutex_t *mutex); 112 113 int dng_pthread_cond_init(dng_pthread_cond_t *cond, void * /* attrs */); 114 int dng_pthread_cond_destroy(dng_pthread_cond_t *cond); 115 int dng_pthread_cond_wait(dng_pthread_cond_t *cond, dng_pthread_mutex_t *mutex); 116 int dng_pthread_cond_timedwait(dng_pthread_cond_t *cond, dng_pthread_mutex_t *mutex, struct dng_timespec *latest_time); 117 int dng_pthread_cond_signal(dng_pthread_cond_t *cond); 118 int dng_pthread_cond_broadcast(dng_pthread_cond_t *cond); 119 120 int dng_pthread_once(dng_pthread_once_t *once, void (*init_func)()); 121 122 int dng_pthread_key_create(dng_pthread_key_t * key, void (*destructor) (void *)); 123 int dng_pthread_key_delete(dng_pthread_key_t key); 124 int dng_pthread_setspecific(dng_pthread_key_t key, const void *value); 125 void *dng_pthread_getspecific(dng_pthread_key_t key); 126 127 typedef struct dng_pthread_rwlock_impl *dng_pthread_rwlock_t; 128 typedef void *pthread_rwlockattr_t; 129 130 int dng_pthread_rwlock_destroy(dng_pthread_rwlock_t * rwlock); 131 int dng_pthread_rwlock_init(dng_pthread_rwlock_t * rwlock, const pthread_rwlockattr_t * attrs); 132 int dng_pthread_rwlock_rdlock(dng_pthread_rwlock_t * rwlock); 133 int dng_pthread_rwlock_tryrdlock(dng_pthread_rwlock_t * rwlock); 134 int dng_pthread_rwlock_trywrlock(dng_pthread_rwlock_t * rwlock); 135 int dng_pthread_rwlock_unlock(dng_pthread_rwlock_t * rwlock); 136 int dng_pthread_rwlock_wrlock(dng_pthread_rwlock_t * rwlock); 137 138 typedef struct dng_pthread_rwlock_impl *dng_pthread_rwlock_t; 139 typedef void *pthread_rwlockattr_t; 140 141 int dng_pthread_rwlock_destroy(dng_pthread_rwlock_t * rwlock); 142 int dng_pthread_rwlock_init(dng_pthread_rwlock_t * rwlock, const pthread_rwlockattr_t * attrs); 143 int dng_pthread_rwlock_rdlock(dng_pthread_rwlock_t * rwlock); 144 int dng_pthread_rwlock_tryrdlock(dng_pthread_rwlock_t * rwlock); 145 int dng_pthread_rwlock_trywrlock(dng_pthread_rwlock_t * rwlock); 146 int dng_pthread_rwlock_unlock(dng_pthread_rwlock_t * rwlock); 147 int 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. 154 void dng_pthread_disassociate(); 155 156 void 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 243 extern "C" 244 { 245 #endif 246 247 int 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
