1/*
2 *
3Copyright 1993, 1998 The Open Group
4
5Permission to use, copy, modify, distribute, and sell this software and its
6documentation for any purpose is hereby granted without fee, provided that
7the above copyright notice appear in all copies and that both that
8copyright notice and this permission notice appear in supporting
9documentation.
10
11The above copyright notice and this permission notice shall be included in
12all copies or substantial portions of the Software.
13
14THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17OPEN GROUP BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
18AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
19CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
20
21Except as contained in this notice, the name of The Open Group shall not be
22used in advertising or otherwise to promote the sale, use or other dealings
23in this Software without prior written authorization from The Open Group.
24 * *
25 */
26
27#ifndef _XTHREADS_H_
28# define _XTHREADS_H_
29
30/* Redefine these to XtMalloc/XtFree or whatever you want before including
31 * this header file.
32 */
33# ifndef xmalloc
34# define xmalloc malloc
35# endif
36# ifndef xfree
37# define xfree free
38# endif
39
40# ifdef CTHREADS
41# include <cthreads.h>
42typedef cthread_t xthread_t;
43typedef struct condition xcondition_rec;
44typedef struct mutex xmutex_rec;
45# define xthread_init() cthread_init()
46# define xthread_self cthread_self
47# define xthread_fork(func,closure) cthread_fork(func,closure)
48# define xthread_yield() cthread_yield()
49# define xthread_exit(v) cthread_exit(v)
50# define xthread_set_name(t,str) cthread_set_name(t,str)
51# define xmutex_init(m) mutex_init(m)
52# define xmutex_clear(m) mutex_clear(m)
53# define xmutex_lock(m) mutex_lock(m)
54# define xmutex_unlock(m) mutex_unlock(m)
55# define xmutex_set_name(m,str) mutex_set_name(m,str)
56# define xcondition_init(cv) condition_init(cv)
57# define xcondition_clear(cv) condition_clear(cv)
58# define xcondition_wait(cv,m) condition_wait(cv,m)
59# define xcondition_signal(cv) condition_signal(cv)
60# define xcondition_broadcast(cv) condition_broadcast(cv)
61# define xcondition_set_name(cv,str) condition_set_name(cv,str)
62# else /* !CTHREADS */
63# if defined(SVR4)
64# include <thread.h>
65# include <synch.h>
66typedef thread_t xthread_t;
67typedef thread_key_t xthread_key_t;
68typedef cond_t xcondition_rec;
69typedef mutex_t xmutex_rec;
70# if defined(__UNIXWARE__)
71extern xthread_t (*_x11_thr_self)();
72# define xthread_self (_x11_thr_self)
73# else
74# define xthread_self thr_self
75# endif
76# define xthread_fork(func,closure) thr_create(NULL,0,func,closure,THR_NEW_LWP|THR_DETACHED,NULL)
77# define xthread_yield() thr_yield()
78# define xthread_exit(v) thr_exit(v)
79# define xthread_key_create(kp,d) thr_keycreate(kp,d)
80# ifdef __sun
81# define xthread_key_delete(k) 0
82# else
83# define xthread_key_delete(k) thr_keydelete(k)
84# endif
85# define xthread_set_specific(k,v) thr_setspecific(k,v)
86# define xthread_get_specific(k,vp) thr_getspecific(k,vp)
87# define xmutex_init(m) mutex_init(m,USYNC_THREAD,0)
88# define xmutex_clear(m) mutex_destroy(m)
89# define xmutex_lock(m) mutex_lock(m)
90# define xmutex_unlock(m) mutex_unlock(m)
91# define xcondition_init(cv) cond_init(cv,USYNC_THREAD,0)
92# define xcondition_clear(cv) cond_destroy(cv)
93# define xcondition_wait(cv,m) cond_wait(cv,m)
94# define xcondition_signal(cv) cond_signal(cv)
95# define xcondition_broadcast(cv) cond_broadcast(cv)
96# else /* !SVR4 */
97# ifdef WIN32
98# include <X11/Xwindows.h>
99typedef DWORD xthread_t;
100typedef DWORD xthread_key_t;
101struct _xthread_waiter {
102 HANDLE sem;
103 struct _xthread_waiter *next;
104};
105typedef struct {
106 CRITICAL_SECTION cs;
107 struct _xthread_waiter *waiters;
108} xcondition_rec;
109typedef CRITICAL_SECTION xmutex_rec;
110extern void _Xthread_init(void);
111# define xthread_init() _Xthread_init()
112# define xthread_self GetCurrentThreadId
113# define xthread_fork(func,closure) { \
114 DWORD _tmptid; \
115 CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)func, (LPVOID)closure, 0, \
116 &_tmptid); \
117}
118# define xthread_yield() Sleep(0)
119# define xthread_exit(v) ExitThread((DWORD)(v))
120# define xthread_key_create(kp,d) *(kp) = TlsAlloc()
121# define xthread_key_delete(k) TlsFree(k)
122# define xthread_set_specific(k,v) TlsSetValue(k,v)
123# define xthread_get_specific(k,vp) TlsGetValue(k)
124# define xmutex_init(m) InitializeCriticalSection(m)
125# define xmutex_clear(m) DeleteCriticalSection(m)
126# define _XMUTEX_NESTS
127# define xmutex_lock(m) EnterCriticalSection(m)
128# define xmutex_unlock(m) LeaveCriticalSection(m)
129# define xcondition_init(cv) { \
130 InitializeCriticalSection(&(cv)->cs); \
131 (cv)->waiters = NULL; \
132}
133# define xcondition_clear(cv) DeleteCriticalSection(&(cv)->cs)
134extern struct _xthread_waiter *_Xthread_waiter();
135# define xcondition_wait(cv,m) { \
136 struct _xthread_waiter *_tmpthr = _Xthread_waiter(); \
137 EnterCriticalSection(&(cv)->cs); \
138 _tmpthr->next = (cv)->waiters; \
139 (cv)->waiters = _tmpthr; \
140 LeaveCriticalSection(&(cv)->cs); \
141 LeaveCriticalSection(m); \
142 WaitForSingleObject(_tmpthr->sem, INFINITE); \
143 EnterCriticalSection(m); \
144}
145# define xcondition_signal(cv) { \
146 EnterCriticalSection(&(cv)->cs); \
147 if ((cv)->waiters) { \
148 ReleaseSemaphore((cv)->waiters->sem, 1, NULL); \
149 (cv)->waiters = (cv)->waiters->next; \
150 } \
151 LeaveCriticalSection(&(cv)->cs); \
152}
153# define xcondition_broadcast(cv) { \
154 struct _xthread_waiter *_tmpthr; \
155 EnterCriticalSection(&(cv)->cs); \
156 for (_tmpthr = (cv)->waiters; _tmpthr; _tmpthr = _tmpthr->next) \
157 ReleaseSemaphore(_tmpthr->sem, 1, NULL); \
158 (cv)->waiters = NULL; \
159 LeaveCriticalSection(&(cv)->cs); \
160}
161# else /* !WIN32 */
162# ifdef USE_TIS_SUPPORT
163/*
164 * TIS support is intended for thread safe libraries.
165 * This should not be used for general client programming.
166 */
167# include <tis.h>
168typedef pthread_t xthread_t;
169typedef pthread_key_t xthread_key_t;
170typedef pthread_cond_t xcondition_rec;
171typedef pthread_mutex_t xmutex_rec;
172# define xthread_self tis_self
173# define xthread_fork(func,closure) { pthread_t _tmpxthr; \
174 pthread_create(&_tmpxthr,NULL,func,closure); }
175# define xthread_yield() pthread_yield_np()
176# define xthread_exit(v) pthread_exit(v)
177# define xthread_key_create(kp,d) tis_key_create(kp,d)
178# define xthread_key_delete(k) tis_key_delete(k)
179# define xthread_set_specific(k,v) tis_setspecific(k,v)
180# define xthread_get_specific(k,vp) *(vp) = tis_getspecific(k)
181# define XMUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
182# define xmutex_init(m) tis_mutex_init(m)
183# define xmutex_clear(m) tis_mutex_destroy(m)
184# define xmutex_lock(m) tis_mutex_lock(m)
185# define xmutex_unlock(m) tis_mutex_unlock(m)
186# define xcondition_init(c) tis_cond_init(c)
187# define xcondition_clear(c) tis_cond_destroy(c)
188# define xcondition_wait(c,m) tis_cond_wait(c,m)
189# define xcondition_signal(c) tis_cond_signal(c)
190# define xcondition_broadcast(c) tis_cond_broadcast(c)
191# else
192# ifdef USE_NBSD_THREADLIB
193/*
194 * NetBSD threadlib support is intended for thread safe libraries.
195 * This should not be used for general client programming.
196 */
197# include <threadlib.h>
198typedef thr_t xthread_t;
199typedef thread_key_t xthread_key_t;
200typedef cond_t xcondition_rec;
201typedef mutex_t xmutex_rec;
202# define xthread_self thr_self
203# define xthread_fork(func,closure) { thr_t _tmpxthr; \
204 /* XXX Create it detached? --thorpej */ \
205 thr_create(&_tmpxthr,NULL,func,closure); }
206# define xthread_yield() thr_yield()
207# define xthread_exit(v) thr_exit(v)
208# define xthread_key_create(kp,d) thr_keycreate(kp,d)
209# define xthread_key_delete(k) thr_keydelete(k)
210# define xthread_set_specific(k,v) thr_setspecific(k,v)
211# define xthread_get_specific(k,vp) *(vp) = thr_getspecific(k)
212# define XMUTEX_INITIALIZER MUTEX_INITIALIZER
213# define xmutex_init(m) mutex_init(m, 0)
214# define xmutex_clear(m) mutex_destroy(m)
215# define xmutex_lock(m) mutex_lock(m)
216# define xmutex_unlock(m) mutex_unlock(m)
217# define xcondition_init(c) cond_init(c, 0, 0)
218# define xcondition_clear(c) cond_destroy(c)
219# define xcondition_wait(c,m) cond_wait(c,m)
220# define xcondition_signal(c) cond_signal(c)
221# define xcondition_broadcast(c) cond_broadcast(c)
222# else
223# include <pthread.h>
224typedef pthread_t xthread_t;
225typedef pthread_key_t xthread_key_t;
226typedef pthread_cond_t xcondition_rec;
227typedef pthread_mutex_t xmutex_rec;
228# define xthread_self pthread_self
229# define xthread_yield() pthread_yield()
230# define xthread_exit(v) pthread_exit(v)
231# define xthread_set_specific(k,v) pthread_setspecific(k,v)
232# define xmutex_clear(m) pthread_mutex_destroy(m)
233# define xmutex_lock(m) pthread_mutex_lock(m)
234# define xmutex_unlock(m) pthread_mutex_unlock(m)
235# ifndef XPRE_STANDARD_API
236# define xthread_key_create(kp,d) pthread_key_create(kp,d)
237# define xthread_key_delete(k) pthread_key_delete(k)
238# define xthread_get_specific(k,vp) *(vp) = pthread_getspecific(k)
239# define xthread_fork(func,closure) { pthread_t _tmpxthr; \
240 pthread_create(&_tmpxthr,NULL,func,closure); }
241# define XMUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
242# define xmutex_init(m) pthread_mutex_init(m, NULL)
243# define xcondition_init(c) pthread_cond_init(c, NULL)
244# else /* XPRE_STANDARD_API */
245# define xthread_key_create(kp,d) pthread_keycreate(kp,d)
246# define xthread_key_delete(k) 0
247# define xthread_get_specific(k,vp) pthread_getspecific(k,vp)
248# define xthread_fork(func,closure) { pthread_t _tmpxthr; \
249 pthread_create(&_tmpxthr,pthread_attr_default,func,closure); }
250# define xmutex_init(m) pthread_mutex_init(m, pthread_mutexattr_default)
251# define xcondition_init(c) pthread_cond_init(c, pthread_condattr_default)
252# endif /* XPRE_STANDARD_API */
253# define xcondition_clear(c) pthread_cond_destroy(c)
254# define xcondition_wait(c,m) pthread_cond_wait(c,m)
255# define xcondition_signal(c) pthread_cond_signal(c)
256# define xcondition_broadcast(c) pthread_cond_broadcast(c)
257# if defined(_DECTHREADS_)
258static xthread_t _X_no_thread_id;
259# define xthread_have_id(id) !pthread_equal(id, _X_no_thread_id)
260# define xthread_clear_id(id) id = _X_no_thread_id
261# define xthread_equal(id1,id2) pthread_equal(id1, id2)
262# endif /* _DECTHREADS_ */
263# if defined(__linux__)
264# define xthread_have_id(id) !pthread_equal(id, 0)
265# define xthread_clear_id(id) id = 0
266# define xthread_equal(id1,id2) pthread_equal(id1, id2)
267# endif /* linux */
268# if defined(_CMA_VENDOR_) && defined(_CMA__IBM) && (_CMA_VENDOR_ == _CMA__IBM)
269# ifdef DEBUG /* too much of a hack to enable normally */
270/* see also cma__obj_set_name() */
271# define xmutex_set_name(m,str) ((char**)(m)->field1)[5] = (str)
272# define xcondition_set_name(cv,str) ((char**)(cv)->field1)[5] = (str)
273# endif /* DEBUG */
274# endif /* _CMA_VENDOR_ == _CMA__IBM */
275# endif /* USE_NBSD_THREADLIB */
276# endif /* USE_TIS_SUPPORT */
277# endif /* WIN32 */
278# endif /* SVR4 */
279# endif /* CTHREADS */
280typedef xcondition_rec *xcondition_t;
281typedef xmutex_rec *xmutex_t;
282# ifndef xcondition_malloc
283# define xcondition_malloc() (xcondition_t)xmalloc(sizeof(xcondition_rec))
284# endif
285# ifndef xcondition_free
286# define xcondition_free(c) xfree((char *)c)
287# endif
288# ifndef xmutex_malloc
289# define xmutex_malloc() (xmutex_t)xmalloc(sizeof(xmutex_rec))
290# endif
291# ifndef xmutex_free
292# define xmutex_free(m) xfree((char *)m)
293# endif
294# ifndef xthread_have_id
295# define xthread_have_id(id) id
296# endif
297# ifndef xthread_clear_id
298# define xthread_clear_id(id) id = 0
299# endif
300# ifndef xthread_equal
301# define xthread_equal(id1,id2) ((id1) == (id2))
302# endif
303/* aids understood by some debuggers */
304# ifndef xthread_set_name
305# define xthread_set_name(t,str)
306# endif
307# ifndef xmutex_set_name
308# define xmutex_set_name(m,str)
309# endif
310# ifndef xcondition_set_name
311# define xcondition_set_name(cv,str)
312# endif
313
314#endif /* _XTHREADS_H_ */
315

source code of include/X11/Xthreads.h