gcc/gthr-posix.h

   1 /* Threads compatibility routines for libgcc2 and libobjc.  */
   2 /* Compile this one with gcc.  */
   3 /* Copyright (C) 1997, 1999, 2000, 2001 Free Software Foundation, Inc.
   4
   5 This file is part of GNU CC.
   6
   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)
  10 any later version.
  11
  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.
  16
  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.  */
  21
  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.  */
  28
  29 #ifndef GCC_GTHR_POSIX_H
  30 #define GCC_GTHR_POSIX_H
  31
  32 /* POSIX threads specific definitions.
  33    Easy, since the interface is just one-to-one mapping. */
  34
  35 #define __GTHREADS 1
  36
  37 #include <pthread.h>
  38
  39 typedef pthread_key_t __gthread_key_t;
  40 typedef pthread_once_t __gthread_once_t;
  41 typedef pthread_mutex_t __gthread_mutex_t;
  42
  43 #define __GTHREAD_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
  44 #define __GTHREAD_ONCE_INIT PTHREAD_ONCE_INIT
  45
  46 #if SUPPORTS_WEAK && GTHREAD_USE_WEAK
  47
  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
  54
  55 #pragma weak pthread_mutex_lock
  56 #pragma weak pthread_mutex_trylock
  57 #pragma weak pthread_mutex_unlock
  58
  59 #ifdef _LIBOBJC
  60 /* Objective C. */
  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_get_priority_max
  71 #pragma weak sched_get_priority_min
  72 #pragma weak sched_yield
  73 #pragma weak pthread_attr_destroy
  74 #pragma weak pthread_attr_init
  75 #pragma weak pthread_attr_setdetachstate
  76 #pragma weak pthread_getschedparam
  77 #pragma weak pthread_setschedparam
  78 #endif
  79
  80 static void *__gthread_active_ptr = (void *) &pthread_create;
  81
  82 static inline int
  83 __gthread_active_p (void)
  84 {
  85   return __gthread_active_ptr != 0;
  86 }
  87
  88 #else /* not SUPPORTS_WEAK */
  89
  90 static inline int
  91 __gthread_active_p (void)
  92 {
  93   return 1;
  94 }
  95
  96 #endif /* SUPPORTS_WEAK */
  97
  98 #ifdef _LIBOBJC
  99
 100 /* This is the config.h file in libobjc/ */
 101 #include <config.h>
 102
 103 #ifdef HAVE_SCHED_H
 104 # include <sched.h>
 105 #endif
 106
 107 /* Key structure for maintaining thread specific storage */
 108 static pthread_key_t _objc_thread_storage;
 109 static pthread_attr_t _objc_thread_attribs;
 110
 111 /* Thread local storage for a single thread */
 112 static void *thread_local_storage = NULL;
 113
 114 /* Backend initialization functions */
 115
 116 /* Initialize the threads subsystem. */
 117 static inline int
 118 __gthread_objc_init_thread_system(void)
 119 {
 120   if (__gthread_active_p ())
 121     {
 122       /* Initialize the thread storage key */
 123       if (pthread_key_create(&_objc_thread_storage, NULL) == 0)
 124         {
 125           /* The normal default detach state for threads is
 126            * PTHREAD_CREATE_JOINABLE which causes threads to not die
 127            * when you think they should.  */
 128           if (pthread_attr_init(&_objc_thread_attribs) == 0
 129               && pthread_attr_setdetachstate(&_objc_thread_attribs,
 130                                              PTHREAD_CREATE_DETACHED) == 0)
 131             return 0;
 132         }
 133     }
 134
 135   return -1;
 136 }
 137
 138 /* Close the threads subsystem. */
 139 static inline int
 140 __gthread_objc_close_thread_system(void)
 141 {
 142   if (__gthread_active_p ()
 143       && pthread_key_delete(_objc_thread_storage) == 0
 144       && pthread_attr_destroy(&_objc_thread_attribs) == 0)
 145     return 0;
 146
 147   return -1;
 148 }
 149
 150 /* Backend thread functions */
 151
 152 /* Create a new thread of execution. */
 153 static inline objc_thread_t
 154 __gthread_objc_thread_detach(void (*func)(void *), void *arg)
 155 {
 156   objc_thread_t thread_id;
 157   pthread_t new_thread_handle;
 158
 159   if (!__gthread_active_p ())
 160     return NULL;
 161
 162   if ( !(pthread_create(&new_thread_handle, NULL, (void *)func, arg)) )
 163     thread_id = (objc_thread_t) new_thread_handle;
 164   else
 165     thread_id = NULL;
 166
 167   return thread_id;
 168 }
 169
 170 /* Set the current thread's priority. */
 171 static inline int
 172 __gthread_objc_thread_set_priority(int priority)
 173 {
 174   if (!__gthread_active_p())
 175     return -1;
 176   else {
 177     pthread_t thread_id = pthread_self();
 178     int policy;
 179     struct sched_param params;
 180     int priority_min, priority_max;
 181
 182     if (pthread_getschedparam(thread_id, &policy, &params) == 0)
 183       {
 184         if ((priority_max = sched_get_priority_max(policy)) != 0)
 185           return -1;
 186
 187         if ((priority_min = sched_get_priority_min(policy)) != 0)
 188           return -1;
 189
 190         if (priority > priority_max)
 191           priority = priority_max;
 192         else if (priority < priority_min)
 193           priority = priority_min;
 194         params.sched_priority = priority;
 195
 196         /*
 197          * The solaris 7 and several other man pages incorrectly state that
 198          * this should be a pointer to policy but pthread.h is universally
 199          * at odds with this.
 200          */
 201         if (pthread_setschedparam(thread_id, policy, &params) == 0)
 202           return 0;
 203       }
 204     return -1;
 205   }
 206 }
 207
 208 /* Return the current thread's priority. */
 209 static inline int
 210 __gthread_objc_thread_get_priority(void)
 211 {
 212   if (__gthread_active_p ())
 213     {
 214       int policy;
 215       struct sched_param params;
 216
 217       if (pthread_getschedparam(pthread_self(), &policy, &params) == 0)
 218         return params.sched_priority;
 219       else
 220         return -1;
 221     }
 222   else
 223     return OBJC_THREAD_INTERACTIVE_PRIORITY;
 224 }
 225
 226 /* Yield our process time to another thread. */
 227 static inline void
 228 __gthread_objc_thread_yield(void)
 229 {
 230   if (__gthread_active_p ())
 231     sched_yield();
 232 }
 233
 234 /* Terminate the current thread. */
 235 static inline int
 236 __gthread_objc_thread_exit(void)
 237 {
 238   if (__gthread_active_p ())
 239     /* exit the thread */
 240     pthread_exit(&__objc_thread_exit_status);
 241
 242   /* Failed if we reached here */
 243   return -1;
 244 }
 245
 246 /* Returns an integer value which uniquely describes a thread. */
 247 static inline objc_thread_t
 248 __gthread_objc_thread_id(void)
 249 {
 250   if (__gthread_active_p ())
 251     return (objc_thread_t) pthread_self();
 252   else
 253     return (objc_thread_t) 1;
 254 }
 255
 256 /* Sets the thread's local storage pointer. */
 257 static inline int
 258 __gthread_objc_thread_set_data(void *value)
 259 {
 260   if (__gthread_active_p ())
 261     return pthread_setspecific(_objc_thread_storage, value);
 262   else
 263     {
 264       thread_local_storage = value;
 265       return 0;
 266     }
 267 }
 268
 269 /* Returns the thread's local storage pointer. */
 270 static inline void *
 271 __gthread_objc_thread_get_data(void)
 272 {
 273   if (__gthread_active_p ())
 274     return pthread_getspecific(_objc_thread_storage);
 275   else
 276     return thread_local_storage;
 277 }
 278
 279 /* Backend mutex functions */
 280
 281 /* Allocate a mutex. */
 282 static inline int
 283 __gthread_objc_mutex_allocate(objc_mutex_t mutex)
 284 {
 285   if (__gthread_active_p ())
 286     {
 287       mutex->backend = objc_malloc(sizeof(pthread_mutex_t));
 288
 289       if (pthread_mutex_init((pthread_mutex_t *)mutex->backend, NULL))
 290         {
 291           objc_free(mutex->backend);
 292           mutex->backend = NULL;
 293           return -1;
 294         }
 295     }
 296
 297   return 0;
 298 }
 299
 300 /* Deallocate a mutex. */
 301 static inline int
 302 __gthread_objc_mutex_deallocate(objc_mutex_t mutex)
 303 {
 304   if (__gthread_active_p ())
 305     {
 306       int count;
 307
 308       /*
 309        * Posix Threads specifically require that the thread be unlocked
 310        * for pthread_mutex_destroy to work.
 311        */
 312
 313       do
 314         {
 315           count = pthread_mutex_unlock((pthread_mutex_t *)mutex->backend);
 316           if (count < 0)
 317             return -1;
 318         }
 319       while (count);
 320
 321       if (pthread_mutex_destroy((pthread_mutex_t *)mutex->backend))
 322         return -1;
 323
 324       objc_free(mutex->backend);
 325       mutex->backend = NULL;
 326     }
 327   return 0;
 328 }
 329
 330 /* Grab a lock on a mutex. */
 331 static inline int
 332 __gthread_objc_mutex_lock(objc_mutex_t mutex)
 333 {
 334   if (__gthread_active_p ()
 335       && pthread_mutex_lock((pthread_mutex_t *)mutex->backend) != 0)
 336     {
 337       return -1;
 338     }
 339
 340   return 0;
 341 }
 342
 343 /* Try to grab a lock on a mutex. */
 344 static inline int
 345 __gthread_objc_mutex_trylock(objc_mutex_t mutex)
 346 {
 347   if (__gthread_active_p ()
 348       && pthread_mutex_trylock((pthread_mutex_t *)mutex->backend) != 0)
 349     {
 350       return -1;
 351     }
 352
 353   return 0;
 354 }
 355
 356 /* Unlock the mutex */
 357 static inline int
 358 __gthread_objc_mutex_unlock(objc_mutex_t mutex)
 359 {
 360   if (__gthread_active_p ()
 361       && pthread_mutex_unlock((pthread_mutex_t *)mutex->backend) != 0)
 362     {
 363       return -1;
 364     }
 365
 366   return 0;
 367 }
 368
 369 /* Backend condition mutex functions */
 370
 371 /* Allocate a condition. */
 372 static inline int
 373 __gthread_objc_condition_allocate(objc_condition_t condition)
 374 {
 375   if (__gthread_active_p ())
 376     {
 377       condition->backend = objc_malloc(sizeof(pthread_cond_t));
 378
 379       if (pthread_cond_init((pthread_cond_t *)condition->backend, NULL))
 380         {
 381           objc_free(condition->backend);
 382           condition->backend = NULL;
 383           return -1;
 384         }
 385     }
 386
 387   return 0;
 388 }
 389
 390 /* Deallocate a condition. */
 391 static inline int
 392 __gthread_objc_condition_deallocate(objc_condition_t condition)
 393 {
 394   if (__gthread_active_p ())
 395     {
 396       if (pthread_cond_destroy((pthread_cond_t *)condition->backend))
 397         return -1;
 398
 399       objc_free(condition->backend);
 400       condition->backend = NULL;
 401     }
 402   return 0;
 403 }
 404
 405 /* Wait on the condition */
 406 static inline int
 407 __gthread_objc_condition_wait(objc_condition_t condition, objc_mutex_t mutex)
 408 {
 409   if (__gthread_active_p ())
 410     return pthread_cond_wait((pthread_cond_t *)condition->backend,
 411                            (pthread_mutex_t *)mutex->backend);
 412   else
 413     return 0;
 414 }
 415
 416 /* Wake up all threads waiting on this condition. */
 417 static inline int
 418 __gthread_objc_condition_broadcast(objc_condition_t condition)
 419 {
 420   if (__gthread_active_p ())
 421     return pthread_cond_broadcast((pthread_cond_t *)condition->backend);
 422   else
 423     return 0;
 424 }
 425
 426 /* Wake up one thread waiting on this condition. */
 427 static inline int
 428 __gthread_objc_condition_signal(objc_condition_t condition)
 429 {
 430   if (__gthread_active_p ())
 431     return pthread_cond_signal((pthread_cond_t *)condition->backend);
 432   else
 433     return 0;
 434 }
 435
 436 #else /* _LIBOBJC */
 437
 438 static inline int
 439 __gthread_once (__gthread_once_t *once, void (*func) (void))
 440 {
 441   if (__gthread_active_p ())
 442     return pthread_once (once, func);
 443   else
 444     return -1;
 445 }
 446
 447 static inline int
 448 __gthread_key_create (__gthread_key_t *key, void (*dtor) (void *))
 449 {
 450   return pthread_key_create (key, dtor);
 451 }
 452
 453 static inline int
 454 __gthread_key_dtor (__gthread_key_t key, void *ptr)
 455 {
 456   /* Just reset the key value to zero. */
 457   if (ptr)
 458     return pthread_setspecific (key, 0);
 459   else
 460     return 0;
 461 }
 462
 463 static inline int
 464 __gthread_key_delete (__gthread_key_t key)
 465 {
 466   return pthread_key_delete (key);
 467 }
 468
 469 static inline void *
 470 __gthread_getspecific (__gthread_key_t key)
 471 {
 472   return pthread_getspecific (key);
 473 }
 474
 475 static inline int
 476 __gthread_setspecific (__gthread_key_t key, const void *ptr)
 477 {
 478   return pthread_setspecific (key, ptr);
 479 }
 480
 481 static inline int
 482 __gthread_mutex_lock (__gthread_mutex_t *mutex)
 483 {
 484   if (__gthread_active_p ())
 485     return pthread_mutex_lock (mutex);
 486   else
 487     return 0;
 488 }
 489
 490 static inline int
 491 __gthread_mutex_trylock (__gthread_mutex_t *mutex)
 492 {
 493   if (__gthread_active_p ())
 494     return pthread_mutex_trylock (mutex);
 495   else
 496     return 0;
 497 }
 498
 499 static inline int
 500 __gthread_mutex_unlock (__gthread_mutex_t *mutex)
 501 {
 502   if (__gthread_active_p ())
 503     return pthread_mutex_unlock (mutex);
 504   else
 505     return 0;
 506 }
 507
 508 #endif /* _LIBOBJC */
 509
 510 #endif /* ! GCC_GTHR_POSIX_H */