1 /* Threads compatibility routines for libgcc2 and libobjc. */
2 /* Compile this one with gcc. */
3 /* Copyright (C) 1997, 1999, 2000 Free Software Foundation, Inc.
5 This file is part of GNU CC.
7 GNU CC is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 2, or (at your option)
12 GNU CC is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with GNU CC; see the file COPYING. If not, write to
19 the Free Software Foundation, 59 Temple Place - Suite 330,
20 Boston, MA 02111-1307, USA. */
22 /* As a special exception, if you link this library with other files,
23 some of which are compiled with GCC, to produce an executable,
24 this library does not by itself cause the resulting executable
25 to be covered by the GNU General Public License.
26 This exception does not however invalidate any other reasons why
27 the executable file might be covered by the GNU General Public License. */
29 #ifndef __gthr_posix_h
30 #define __gthr_posix_h
32 /* POSIX threads specific definitions.
33 Easy, since the interface is just one-to-one mapping. */
39 typedef pthread_key_t __gthread_key_t;
40 typedef pthread_once_t __gthread_once_t;
41 typedef pthread_mutex_t __gthread_mutex_t;
43 #define __GTHREAD_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
44 #define __GTHREAD_ONCE_INIT PTHREAD_ONCE_INIT
46 #if SUPPORTS_WEAK && GTHREAD_USE_WEAK
48 #pragma weak pthread_once
49 #pragma weak pthread_key_create
50 #pragma weak pthread_key_delete
51 #pragma weak pthread_getspecific
52 #pragma weak pthread_setspecific
53 #pragma weak pthread_create
55 #pragma weak pthread_mutex_lock
56 #pragma weak pthread_mutex_trylock
57 #pragma weak pthread_mutex_unlock
61 #pragma weak pthread_cond_broadcast
62 #pragma weak pthread_cond_destroy
63 #pragma weak pthread_cond_init
64 #pragma weak pthread_cond_signal
65 #pragma weak pthread_cond_wait
66 #pragma weak pthread_exit
67 #pragma weak pthread_mutex_init
68 #pragma weak pthread_mutex_destroy
69 #pragma weak pthread_self
70 #pragma weak sched_yield
73 static void *__gthread_active_ptr = &pthread_create;
76 __gthread_active_p (void)
78 return __gthread_active_ptr != 0;
81 #else /* not SUPPORTS_WEAK */
84 __gthread_active_p (void)
89 #endif /* SUPPORTS_WEAK */
93 #include <auto-host.h>
99 /* Key structure for maintaining thread specific storage */
100 static pthread_key_t _objc_thread_storage;
101 static pthread_attr_t _objc_thread_attribs;
103 /* Thread local storage for a single thread */
104 static void *thread_local_storage = NULL;
106 /* Backend initialization functions */
108 /* Initialize the threads subsystem. */
110 __gthread_objc_init_thread_system(void)
112 if (__gthread_active_p ())
114 /* Initialize the thread storage key */
115 if (pthread_key_create(&_objc_thread_storage, NULL) == 0)
117 /* The normal default detach state for threads is
118 * PTHREAD_CREATE_JOINABLE which causes threads to not die
119 * when you think they should. */
120 if (pthread_attr_init(&_objc_thread_attribs) == 0
121 && pthread_attr_setdetachstate(&_objc_thread_attribs,
122 PTHREAD_CREATE_DETACHED) == 0)
130 /* Close the threads subsystem. */
132 __gthread_objc_close_thread_system(void)
134 if (__gthread_active_p ()
135 && pthread_key_delete(_objc_thread_storage) == 0
136 && pthread_attr_destroy(&_objc_thread_attribs) == 0)
142 /* Backend thread functions */
144 /* Create a new thread of execution. */
145 static inline objc_thread_t
146 __gthread_objc_thread_detach(void (*func)(void *), void *arg)
148 objc_thread_t thread_id;
149 pthread_t new_thread_handle;
151 if (!__gthread_active_p ())
154 if ( !(pthread_create(&new_thread_handle, NULL, (void *)func, arg)) )
155 thread_id = *(objc_thread_t *)&new_thread_handle;
162 /* Set the current thread's priority. */
164 __gthread_objc_thread_set_priority(int priority)
166 if (!__gthread_active_p())
169 pthread_t thread_id = pthread_self();
171 struct sched_param params;
172 int priority_min, priority_max;
174 if (pthread_getschedparam(thread_id, &policy, ¶ms) == 0)
176 if ((priority_max = sched_get_priority_max(policy)) != 0)
179 if ((priority_min = sched_get_priority_min(policy)) != 0)
182 if (priority > priority_max)
183 priority = priority_max;
184 else if (priority < priority_min)
185 priority = priority_min;
186 params.sched_priority = priority;
189 * The solaris 7 and several other man pages incorrectly state that
190 * this should be a pointer to policy but pthread.h is universally
193 if (pthread_setschedparam(thread_id, policy, ¶ms) == 0)
200 /* Return the current thread's priority. */
202 __gthread_objc_thread_get_priority(void)
204 if (__gthread_active_p ())
207 struct sched_param params;
209 if (pthread_getschedparam(pthread_self(), &policy, ¶ms) == 0)
210 return params.sched_priority;
215 return OBJC_THREAD_INTERACTIVE_PRIORITY;
218 /* Yield our process time to another thread. */
220 __gthread_objc_thread_yield(void)
222 if (__gthread_active_p ())
226 /* Terminate the current thread. */
228 __gthread_objc_thread_exit(void)
230 if (__gthread_active_p ())
231 /* exit the thread */
232 pthread_exit(&__objc_thread_exit_status);
234 /* Failed if we reached here */
238 /* Returns an integer value which uniquely describes a thread. */
239 static inline objc_thread_t
240 __gthread_objc_thread_id(void)
242 if (__gthread_active_p ())
244 pthread_t self = pthread_self();
246 return *(objc_thread_t *)&self;
249 return (objc_thread_t)1;
252 /* Sets the thread's local storage pointer. */
254 __gthread_objc_thread_set_data(void *value)
256 if (__gthread_active_p ())
257 return pthread_setspecific(_objc_thread_storage, value);
260 thread_local_storage = value;
265 /* Returns the thread's local storage pointer. */
267 __gthread_objc_thread_get_data(void)
269 if (__gthread_active_p ())
270 return pthread_getspecific(_objc_thread_storage);
272 return thread_local_storage;
275 /* Backend mutex functions */
277 /* Allocate a mutex. */
279 __gthread_objc_mutex_allocate(objc_mutex_t mutex)
281 if (__gthread_active_p ())
283 mutex->backend = objc_malloc(sizeof(pthread_mutex_t));
285 if (pthread_mutex_init((pthread_mutex_t *)mutex->backend, NULL))
287 objc_free(mutex->backend);
288 mutex->backend = NULL;
296 /* Deallocate a mutex. */
298 __gthread_objc_mutex_deallocate(objc_mutex_t mutex)
300 if (__gthread_active_p ())
305 * Posix Threads specifically require that the thread be unlocked
306 * for pthread_mutex_destroy to work.
311 count = pthread_mutex_unlock((pthread_mutex_t *)mutex->backend);
317 if (pthread_mutex_destroy((pthread_mutex_t *)mutex->backend))
320 objc_free(mutex->backend);
321 mutex->backend = NULL;
326 /* Grab a lock on a mutex. */
328 __gthread_objc_mutex_lock(objc_mutex_t mutex)
330 if (__gthread_active_p ())
331 return pthread_mutex_lock((pthread_mutex_t *)mutex->backend);
336 /* Try to grab a lock on a mutex. */
338 __gthread_objc_mutex_trylock(objc_mutex_t mutex)
340 if (__gthread_active_p ())
341 return pthread_mutex_trylock((pthread_mutex_t *)mutex->backend);
346 /* Unlock the mutex */
348 __gthread_objc_mutex_unlock(objc_mutex_t mutex)
350 if (__gthread_active_p ())
351 return pthread_mutex_unlock((pthread_mutex_t *)mutex->backend);
356 /* Backend condition mutex functions */
358 /* Allocate a condition. */
360 __gthread_objc_condition_allocate(objc_condition_t condition)
362 if (__gthread_active_p ())
364 condition->backend = objc_malloc(sizeof(pthread_cond_t));
366 if (pthread_cond_init((pthread_cond_t *)condition->backend, NULL))
368 objc_free(condition->backend);
369 condition->backend = NULL;
377 /* Deallocate a condition. */
379 __gthread_objc_condition_deallocate(objc_condition_t condition)
381 if (__gthread_active_p ())
383 if (pthread_cond_destroy((pthread_cond_t *)condition->backend))
386 objc_free(condition->backend);
387 condition->backend = NULL;
392 /* Wait on the condition */
394 __gthread_objc_condition_wait(objc_condition_t condition, objc_mutex_t mutex)
396 if (__gthread_active_p ())
397 return pthread_cond_wait((pthread_cond_t *)condition->backend,
398 (pthread_mutex_t *)mutex->backend);
403 /* Wake up all threads waiting on this condition. */
405 __gthread_objc_condition_broadcast(objc_condition_t condition)
407 if (__gthread_active_p ())
408 return pthread_cond_broadcast((pthread_cond_t *)condition->backend);
413 /* Wake up one thread waiting on this condition. */
415 __gthread_objc_condition_signal(objc_condition_t condition)
417 if (__gthread_active_p ())
418 return pthread_cond_signal((pthread_cond_t *)condition->backend);
426 __gthread_once (__gthread_once_t *once, void (*func) (void))
428 if (__gthread_active_p ())
429 return pthread_once (once, func);
435 __gthread_key_create (__gthread_key_t *key, void (*dtor) (void *))
437 return pthread_key_create (key, dtor);
441 __gthread_key_dtor (__gthread_key_t key, void *ptr)
443 /* Just reset the key value to zero. */
445 return pthread_setspecific (key, 0);
451 __gthread_key_delete (__gthread_key_t key)
453 return pthread_key_delete (key);
457 __gthread_getspecific (__gthread_key_t key)
459 return pthread_getspecific (key);
463 __gthread_setspecific (__gthread_key_t key, const void *ptr)
465 return pthread_setspecific (key, ptr);
469 __gthread_mutex_lock (__gthread_mutex_t *mutex)
471 if (__gthread_active_p ())
472 return pthread_mutex_lock (mutex);
478 __gthread_mutex_trylock (__gthread_mutex_t *mutex)
480 if (__gthread_active_p ())
481 return pthread_mutex_trylock (mutex);
487 __gthread_mutex_unlock (__gthread_mutex_t *mutex)
489 if (__gthread_active_p ())
490 return pthread_mutex_unlock (mutex);
495 #endif /* _LIBOBJC */
497 #endif /* not __gthr_posix_h */