1 /* Threads compatibility routines for libgcc2 and libobjc. */
2 /* Compile this one with gcc. */
3 /* Copyright (C) 1997, 1999, 2000, 2001, 2002, 2003, 2004, 2005
4 Free Software Foundation, Inc.
6 This file is part of GCC.
8 GCC is free software; you can redistribute it and/or modify it under
9 the terms of the GNU General Public License as published by the Free
10 Software Foundation; either version 2, or (at your option) any later
13 GCC is distributed in the hope that it will be useful, but WITHOUT ANY
14 WARRANTY; without even the implied warranty of MERCHANTABILITY or
15 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
18 You should have received a copy of the GNU General Public License
19 along with GCC; see the file COPYING. If not, write to the Free
20 Software Foundation, 51 Franklin Street, Fifth Floor, Boston, MA
23 /* As a special exception, if you link this library with other files,
24 some of which are compiled with GCC, to produce an executable,
25 this library does not by itself cause the resulting executable
26 to be covered by the GNU General Public License.
27 This exception does not however invalidate any other reasons why
28 the executable file might be covered by the GNU General Public License. */
30 #ifndef GCC_GTHR_POSIX_H
31 #define GCC_GTHR_POSIX_H
33 /* POSIX threads specific definitions.
34 Easy, since the interface is just one-to-one mapping. */
38 /* Some implementations of <pthread.h> require this to be defined. */
46 typedef pthread_key_t __gthread_key_t
;
47 typedef pthread_once_t __gthread_once_t
;
48 typedef pthread_mutex_t __gthread_mutex_t
;
49 typedef pthread_mutex_t __gthread_recursive_mutex_t
;
51 #define __GTHREAD_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
52 #define __GTHREAD_ONCE_INIT PTHREAD_ONCE_INIT
53 #if defined(PTHREAD_RECURSIVE_MUTEX_INITIALIZER)
54 #define __GTHREAD_RECURSIVE_MUTEX_INIT PTHREAD_RECURSIVE_MUTEX_INITIALIZER
55 #elif defined(PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP)
56 #define __GTHREAD_RECURSIVE_MUTEX_INIT PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP
58 #define __GTHREAD_RECURSIVE_MUTEX_INIT_FUNCTION __gthread_recursive_mutex_init_function
61 #if SUPPORTS_WEAK && GTHREAD_USE_WEAK
62 # define __gthrw(name) \
63 static __typeof(name) __gthrw_ ## name __attribute__ ((__weakref__(#name)));
64 # define __gthrw_(name) __gthrw_ ## name
66 # define __gthrw(name)
67 # define __gthrw_(name) name
71 __gthrw(pthread_key_create
)
72 __gthrw(pthread_key_delete
)
73 __gthrw(pthread_getspecific
)
74 __gthrw(pthread_setspecific
)
75 __gthrw(pthread_create
)
76 __gthrw(pthread_cancel
)
78 __gthrw(pthread_mutex_lock
)
79 __gthrw(pthread_mutex_trylock
)
80 __gthrw(pthread_mutex_unlock
)
81 __gthrw(pthread_mutexattr_init
)
82 __gthrw(pthread_mutexattr_settype
)
83 __gthrw(pthread_mutexattr_destroy
)
85 __gthrw(pthread_mutex_init
)
87 #if defined(_LIBOBJC) || defined(_LIBOBJC_WEAK)
89 __gthrw(pthread_cond_broadcast
)
90 __gthrw(pthread_cond_destroy
)
91 __gthrw(pthread_cond_init
)
92 __gthrw(pthread_cond_signal
)
93 __gthrw(pthread_cond_wait
)
95 __gthrw(pthread_mutex_destroy
)
97 #ifdef _POSIX_PRIORITY_SCHEDULING
98 #ifdef _POSIX_THREAD_PRIORITY_SCHEDULING
99 __gthrw(sched_get_priority_max
)
100 __gthrw(sched_get_priority_min
)
101 #endif /* _POSIX_THREAD_PRIORITY_SCHEDULING */
102 #endif /* _POSIX_PRIORITY_SCHEDULING */
104 __gthrw(pthread_attr_destroy
)
105 __gthrw(pthread_attr_init
)
106 __gthrw(pthread_attr_setdetachstate
)
107 #ifdef _POSIX_THREAD_PRIORITY_SCHEDULING
108 __gthrw(pthread_getschedparam
)
109 __gthrw(pthread_setschedparam
)
110 #endif /* _POSIX_THREAD_PRIORITY_SCHEDULING */
111 #endif /* _LIBOBJC || _LIBOBJC_WEAK */
113 #if SUPPORTS_WEAK && GTHREAD_USE_WEAK
116 __gthread_active_p (void)
118 static void *const __gthread_active_ptr
119 = __extension__ (void *) &__gthrw_(pthread_cancel
);
120 return __gthread_active_ptr
!= 0;
123 #else /* not SUPPORTS_WEAK */
126 __gthread_active_p (void)
131 #endif /* SUPPORTS_WEAK */
135 /* This is the config.h file in libobjc/ */
142 /* Key structure for maintaining thread specific storage */
143 static pthread_key_t _objc_thread_storage
;
144 static pthread_attr_t _objc_thread_attribs
;
146 /* Thread local storage for a single thread */
147 static void *thread_local_storage
= NULL
;
149 /* Backend initialization functions */
151 /* Initialize the threads subsystem. */
153 __gthread_objc_init_thread_system (void)
155 if (__gthread_active_p ())
157 /* Initialize the thread storage key. */
158 if (__gthrw_(pthread_key_create
) (&_objc_thread_storage
, NULL
) == 0)
160 /* The normal default detach state for threads is
161 * PTHREAD_CREATE_JOINABLE which causes threads to not die
162 * when you think they should. */
163 if (__gthrw_(pthread_attr_init
) (&_objc_thread_attribs
) == 0
164 && __gthrw_(pthread_attr_setdetachstate
) (&_objc_thread_attribs
,
165 PTHREAD_CREATE_DETACHED
) == 0)
173 /* Close the threads subsystem. */
175 __gthread_objc_close_thread_system (void)
177 if (__gthread_active_p ()
178 && __gthrw_(pthread_key_delete
) (_objc_thread_storage
) == 0
179 && __gthrw_(pthread_attr_destroy
) (&_objc_thread_attribs
) == 0)
185 /* Backend thread functions */
187 /* Create a new thread of execution. */
188 static inline objc_thread_t
189 __gthread_objc_thread_detach (void (*func
)(void *), void *arg
)
191 objc_thread_t thread_id
;
192 pthread_t new_thread_handle
;
194 if (!__gthread_active_p ())
197 if (!(__gthrw_(pthread_create
) (&new_thread_handle
, NULL
, (void *) func
, arg
)))
198 thread_id
= (objc_thread_t
) new_thread_handle
;
205 /* Set the current thread's priority. */
207 __gthread_objc_thread_set_priority (int priority
)
209 if (!__gthread_active_p ())
213 #ifdef _POSIX_PRIORITY_SCHEDULING
214 #ifdef _POSIX_THREAD_PRIORITY_SCHEDULING
215 pthread_t thread_id
= __gthrw_(pthread_self
) ();
217 struct sched_param params
;
218 int priority_min
, priority_max
;
220 if (__gthrw_(pthread_getschedparam
) (thread_id
, &policy
, ¶ms
) == 0)
222 if ((priority_max
= __gthrw_(sched_get_priority_max
) (policy
)) == -1)
225 if ((priority_min
= __gthrw_(sched_get_priority_min
) (policy
)) == -1)
228 if (priority
> priority_max
)
229 priority
= priority_max
;
230 else if (priority
< priority_min
)
231 priority
= priority_min
;
232 params
.sched_priority
= priority
;
235 * The solaris 7 and several other man pages incorrectly state that
236 * this should be a pointer to policy but pthread.h is universally
239 if (__gthrw_(pthread_setschedparam
) (thread_id
, policy
, ¶ms
) == 0)
242 #endif /* _POSIX_THREAD_PRIORITY_SCHEDULING */
243 #endif /* _POSIX_PRIORITY_SCHEDULING */
248 /* Return the current thread's priority. */
250 __gthread_objc_thread_get_priority (void)
252 #ifdef _POSIX_PRIORITY_SCHEDULING
253 #ifdef _POSIX_THREAD_PRIORITY_SCHEDULING
254 if (__gthread_active_p ())
257 struct sched_param params
;
259 if (__gthrw_(pthread_getschedparam
) (__gthrw_(pthread_self
) (), &policy
, ¶ms
) == 0)
260 return params
.sched_priority
;
265 #endif /* _POSIX_THREAD_PRIORITY_SCHEDULING */
266 #endif /* _POSIX_PRIORITY_SCHEDULING */
267 return OBJC_THREAD_INTERACTIVE_PRIORITY
;
270 /* Yield our process time to another thread. */
272 __gthread_objc_thread_yield (void)
274 if (__gthread_active_p ())
275 __gthrw_(sched_yield
) ();
278 /* Terminate the current thread. */
280 __gthread_objc_thread_exit (void)
282 if (__gthread_active_p ())
283 /* exit the thread */
284 __gthrw_(pthread_exit
) (&__objc_thread_exit_status
);
286 /* Failed if we reached here */
290 /* Returns an integer value which uniquely describes a thread. */
291 static inline objc_thread_t
292 __gthread_objc_thread_id (void)
294 if (__gthread_active_p ())
295 return (objc_thread_t
) __gthrw_(pthread_self
) ();
297 return (objc_thread_t
) 1;
300 /* Sets the thread's local storage pointer. */
302 __gthread_objc_thread_set_data (void *value
)
304 if (__gthread_active_p ())
305 return __gthrw_(pthread_setspecific
) (_objc_thread_storage
, value
);
308 thread_local_storage
= value
;
313 /* Returns the thread's local storage pointer. */
315 __gthread_objc_thread_get_data (void)
317 if (__gthread_active_p ())
318 return __gthrw_(pthread_getspecific
) (_objc_thread_storage
);
320 return thread_local_storage
;
323 /* Backend mutex functions */
325 /* Allocate a mutex. */
327 __gthread_objc_mutex_allocate (objc_mutex_t mutex
)
329 if (__gthread_active_p ())
331 mutex
->backend
= objc_malloc (sizeof (pthread_mutex_t
));
333 if (__gthrw_(pthread_mutex_init
) ((pthread_mutex_t
*) mutex
->backend
, NULL
))
335 objc_free (mutex
->backend
);
336 mutex
->backend
= NULL
;
344 /* Deallocate a mutex. */
346 __gthread_objc_mutex_deallocate (objc_mutex_t mutex
)
348 if (__gthread_active_p ())
353 * Posix Threads specifically require that the thread be unlocked
354 * for __gthrw_(pthread_mutex_destroy) to work.
359 count
= __gthrw_(pthread_mutex_unlock
) ((pthread_mutex_t
*) mutex
->backend
);
365 if (__gthrw_(pthread_mutex_destroy
) ((pthread_mutex_t
*) mutex
->backend
))
368 objc_free (mutex
->backend
);
369 mutex
->backend
= NULL
;
374 /* Grab a lock on a mutex. */
376 __gthread_objc_mutex_lock (objc_mutex_t mutex
)
378 if (__gthread_active_p ()
379 && __gthrw_(pthread_mutex_lock
) ((pthread_mutex_t
*) mutex
->backend
) != 0)
387 /* Try to grab a lock on a mutex. */
389 __gthread_objc_mutex_trylock (objc_mutex_t mutex
)
391 if (__gthread_active_p ()
392 && __gthrw_(pthread_mutex_trylock
) ((pthread_mutex_t
*) mutex
->backend
) != 0)
400 /* Unlock the mutex */
402 __gthread_objc_mutex_unlock (objc_mutex_t mutex
)
404 if (__gthread_active_p ()
405 && __gthrw_(pthread_mutex_unlock
) ((pthread_mutex_t
*) mutex
->backend
) != 0)
413 /* Backend condition mutex functions */
415 /* Allocate a condition. */
417 __gthread_objc_condition_allocate (objc_condition_t condition
)
419 if (__gthread_active_p ())
421 condition
->backend
= objc_malloc (sizeof (pthread_cond_t
));
423 if (__gthrw_(pthread_cond_init
) ((pthread_cond_t
*) condition
->backend
, NULL
))
425 objc_free (condition
->backend
);
426 condition
->backend
= NULL
;
434 /* Deallocate a condition. */
436 __gthread_objc_condition_deallocate (objc_condition_t condition
)
438 if (__gthread_active_p ())
440 if (__gthrw_(pthread_cond_destroy
) ((pthread_cond_t
*) condition
->backend
))
443 objc_free (condition
->backend
);
444 condition
->backend
= NULL
;
449 /* Wait on the condition */
451 __gthread_objc_condition_wait (objc_condition_t condition
, objc_mutex_t mutex
)
453 if (__gthread_active_p ())
454 return __gthrw_(pthread_cond_wait
) ((pthread_cond_t
*) condition
->backend
,
455 (pthread_mutex_t
*) mutex
->backend
);
460 /* Wake up all threads waiting on this condition. */
462 __gthread_objc_condition_broadcast (objc_condition_t condition
)
464 if (__gthread_active_p ())
465 return __gthrw_(pthread_cond_broadcast
) ((pthread_cond_t
*) condition
->backend
);
470 /* Wake up one thread waiting on this condition. */
472 __gthread_objc_condition_signal (objc_condition_t condition
)
474 if (__gthread_active_p ())
475 return __gthrw_(pthread_cond_signal
) ((pthread_cond_t
*) condition
->backend
);
483 __gthread_once (__gthread_once_t
*once
, void (*func
) (void))
485 if (__gthread_active_p ())
486 return __gthrw_(pthread_once
) (once
, func
);
492 __gthread_key_create (__gthread_key_t
*key
, void (*dtor
) (void *))
494 return __gthrw_(pthread_key_create
) (key
, dtor
);
498 __gthread_key_delete (__gthread_key_t key
)
500 return __gthrw_(pthread_key_delete
) (key
);
504 __gthread_getspecific (__gthread_key_t key
)
506 return __gthrw_(pthread_getspecific
) (key
);
510 __gthread_setspecific (__gthread_key_t key
, const void *ptr
)
512 return __gthrw_(pthread_setspecific
) (key
, ptr
);
516 __gthread_mutex_lock (__gthread_mutex_t
*mutex
)
518 if (__gthread_active_p ())
519 return __gthrw_(pthread_mutex_lock
) (mutex
);
525 __gthread_mutex_trylock (__gthread_mutex_t
*mutex
)
527 if (__gthread_active_p ())
528 return __gthrw_(pthread_mutex_trylock
) (mutex
);
534 __gthread_mutex_unlock (__gthread_mutex_t
*mutex
)
536 if (__gthread_active_p ())
537 return __gthrw_(pthread_mutex_unlock
) (mutex
);
542 #ifndef PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP
544 __gthread_recursive_mutex_init_function (__gthread_recursive_mutex_t
*mutex
)
546 if (__gthread_active_p ())
548 pthread_mutexattr_t attr
;
551 r
= __gthrw_(pthread_mutexattr_init
) (&attr
);
553 r
= __gthrw_(pthread_mutexattr_settype
) (&attr
, PTHREAD_MUTEX_RECURSIVE
);
555 r
= __gthrw_(pthread_mutex_init
) (mutex
, &attr
);
557 r
= __gthrw_(pthread_mutexattr_destroy
) (&attr
);
565 __gthread_recursive_mutex_lock (__gthread_recursive_mutex_t
*mutex
)
567 return __gthread_mutex_lock (mutex
);
571 __gthread_recursive_mutex_trylock (__gthread_recursive_mutex_t
*mutex
)
573 return __gthread_mutex_trylock (mutex
);
577 __gthread_recursive_mutex_unlock (__gthread_recursive_mutex_t
*mutex
)
579 return __gthread_mutex_unlock (mutex
);
582 #endif /* _LIBOBJC */
584 #endif /* ! GCC_GTHR_POSIX_H */