Mercurial > hg > CbC > CbC_gcc
annotate gcc/gthr-nks.h @ 86:12b3180c7d07
modify calls.c.
| author | Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp> |
|---|---|
| date | Thu, 15 Dec 2011 02:37:13 +0900 |
| parents | 77e2b8dfacca |
| children |
| rev | line source |
|---|---|
| 0 | 1 /* Threads compatibility routines for libgcc2 and libobjc. */ |
| 2 /* Compile this one with gcc. */ | |
| 3 /* Copyright (C) 2002, 2003, 2004, 2008, 2009 Free Software Foundation, Inc. | |
| 4 | |
| 5 This file is part of GCC. | |
| 6 | |
| 7 GCC is free software; you can redistribute it and/or modify it under | |
| 8 the terms of the GNU General Public License as published by the Free | |
| 9 Software Foundation; either version 3, or (at your option) any later | |
| 10 version. | |
| 11 | |
| 12 GCC is distributed in the hope that it will be useful, but WITHOUT ANY | |
| 13 WARRANTY; without even the implied warranty of MERCHANTABILITY or | |
| 14 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License | |
| 15 for more details. | |
| 16 | |
| 17 Under Section 7 of GPL version 3, you are granted additional | |
| 18 permissions described in the GCC Runtime Library Exception, version | |
| 19 3.1, as published by the Free Software Foundation. | |
| 20 | |
| 21 You should have received a copy of the GNU General Public License and | |
| 22 a copy of the GCC Runtime Library Exception along with this program; | |
| 23 see the files COPYING3 and COPYING.RUNTIME respectively. If not, see | |
| 24 <http://www.gnu.org/licenses/>. */ | |
| 25 | |
| 26 #ifndef GCC_GTHR_NKS_H | |
| 27 #define GCC_GTHR_NKS_H | |
| 28 | |
| 29 /* NKS threads specific definitions. | |
| 30 Easy, since the interface is mostly one-to-one mapping. */ | |
| 31 | |
| 32 #define __GTHREADS 1 | |
| 33 | |
| 34 #define NKS_NO_INLINE_FUNCS | |
| 35 #include <nksapi.h> | |
| 36 #include <string.h> | |
| 37 | |
| 38 typedef NXKey_t __gthread_key_t; | |
| 39 typedef NXMutex_t *__gthread_mutex_t; | |
| 40 typedef NXMutex_t *__gthread_recursive_mutex_t; | |
| 41 | |
| 42 #define __GTHREAD_MUTEX_INIT_FUNCTION __gthread_mutex_init_function | |
| 43 #define __GTHREAD_RECURSIVE_MUTEX_INIT_FUNCTION __gthread_recursive_mutex_init_function | |
| 44 | |
| 45 static inline int | |
| 46 __gthread_active_p (void) | |
| 47 { | |
| 48 return 1; | |
| 49 } | |
| 50 | |
| 51 #ifdef _LIBOBJC | |
| 52 | |
| 53 /* This is the config.h file in libobjc/ */ | |
| 54 #include <config.h> | |
| 55 | |
| 56 #ifdef HAVE_SCHED_H | |
| 57 # include <sched.h> | |
| 58 #endif | |
| 59 | |
| 60 /* Key structure for maintaining thread specific storage */ | |
| 61 static NXKey_t _objc_thread_storage; | |
| 62 | |
| 63 /* Backend initialization functions */ | |
| 64 | |
| 65 /* Initialize the threads subsystem. */ | |
| 66 static inline int | |
| 67 __gthread_objc_init_thread_system (void) | |
| 68 { | |
| 69 /* Initialize the thread storage key. */ | |
| 70 if (NXKeyCreate (NULL, NULL, &_objc_thread_storage) == 0) | |
| 71 return 0; | |
| 72 return -1; | |
| 73 } | |
| 74 | |
| 75 /* Close the threads subsystem. */ | |
| 76 static inline int | |
| 77 __gthread_objc_close_thread_system (void) | |
| 78 { | |
| 79 if (NXKeyDelete (_objc_thread_storage) == 0) | |
| 80 return 0; | |
| 81 return -1; | |
| 82 } | |
| 83 | |
| 84 /* Backend thread functions */ | |
| 85 | |
| 86 /* Create a new thread of execution. */ | |
| 87 static inline objc_thread_t | |
| 88 __gthread_objc_thread_detach (void (*func)(void *), void *arg) | |
| 89 { | |
| 90 objc_thread_t thread_id; | |
| 91 NXContext_t context; | |
| 92 NXThreadId_t new_thread_handle; | |
| 93 int err; | |
| 94 | |
| 95 if ((context = NXContextAlloc (func, arg, NX_PRIO_MED, 0, 0, 0, &err)) == NULL) | |
| 96 thread_id = NULL; | |
| 97 else if (NXThreadCreate (context, NX_THR_DETACHED, &new_thread_handle) == 0) | |
| 98 thread_id = (objc_thread_t) new_thread_handle; | |
| 99 else { | |
| 100 NXContextFree (context); | |
| 101 thread_id = NULL; | |
| 102 } | |
|
55
77e2b8dfacca
update it from 4.4.3 to 4.5.0
ryoma <e075725@ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
103 |
| 0 | 104 return thread_id; |
| 105 } | |
| 106 | |
| 107 /* Set the current thread's priority. */ | |
| 108 static inline int | |
| 109 __gthread_objc_thread_set_priority (int priority) | |
| 110 { | |
| 111 if (NXThreadSetPriority (NXThreadGetId (), priority) == 0) | |
| 112 return 0; | |
| 113 return -1; | |
| 114 } | |
| 115 | |
| 116 /* Return the current thread's priority. */ | |
| 117 static inline int | |
| 118 __gthread_objc_thread_get_priority (void) | |
| 119 { | |
| 120 int priority; | |
| 121 | |
| 122 if (NXThreadGetPriority (NXThreadGetId (), &priority) == 0) | |
| 123 return priority; | |
| 124 return -1; | |
| 125 } | |
| 126 | |
| 127 /* Yield our process time to another thread. */ | |
| 128 static inline void | |
| 129 __gthread_objc_thread_yield (void) | |
| 130 { | |
| 131 NXThreadYield (); | |
| 132 } | |
| 133 | |
| 134 /* Terminate the current thread. */ | |
| 135 static inline int | |
| 136 __gthread_objc_thread_exit (void) | |
| 137 { | |
| 138 /* exit the thread */ | |
| 139 NXThreadExit (&__objc_thread_exit_status); | |
| 140 | |
| 141 /* Failed if we reached here */ | |
| 142 return -1; | |
| 143 } | |
| 144 | |
| 145 /* Returns an integer value which uniquely describes a thread. */ | |
| 146 static inline objc_thread_t | |
| 147 __gthread_objc_thread_id (void) | |
| 148 { | |
| 149 (objc_thread_t) NXThreadGetId (); | |
| 150 } | |
| 151 | |
| 152 /* Sets the thread's local storage pointer. */ | |
| 153 static inline int | |
| 154 __gthread_objc_thread_set_data (void *value) | |
| 155 { | |
| 156 return NXKeySetValue (_objc_thread_storage, value); | |
| 157 } | |
| 158 | |
| 159 /* Returns the thread's local storage pointer. */ | |
| 160 static inline void * | |
| 161 __gthread_objc_thread_get_data (void) | |
| 162 { | |
| 163 void *value; | |
| 164 | |
| 165 if (NXKeyGetValue (_objc_thread_storage, &value) == 0) | |
| 166 return value; | |
| 167 return NULL; | |
| 168 } | |
| 169 | |
| 170 /* Backend mutex functions */ | |
| 171 | |
| 172 /* Allocate a mutex. */ | |
| 173 static inline int | |
| 174 __gthread_objc_mutex_allocate (objc_mutex_t mutex) | |
| 175 { | |
| 176 static const NX_LOCK_INFO_ALLOC (info, "GNU ObjC", 0); | |
| 177 | |
| 178 if ((mutex->backend = NXMutexAlloc (0, 0, &info)) == NULL) | |
| 179 return 0; | |
| 180 return -1; | |
| 181 } | |
| 182 | |
| 183 /* Deallocate a mutex. */ | |
| 184 static inline int | |
| 185 __gthread_objc_mutex_deallocate (objc_mutex_t mutex) | |
| 186 { | |
| 187 while (NXMutexIsOwned ((NXMutex_t *)mutex->backend)) | |
| 188 NXUnlock ((NXMutex_t *)mutex->backend); | |
| 189 if (NXMutexFree ((NXMutex_t *)mutex->backend) != 0) | |
| 190 return -1; | |
| 191 mutex->backend = NULL; | |
| 192 return 0; | |
| 193 } | |
| 194 | |
| 195 /* Grab a lock on a mutex. */ | |
| 196 static inline int | |
| 197 __gthread_objc_mutex_lock (objc_mutex_t mutex) | |
| 198 { | |
| 199 return NXLock ((NXMutex_t *)mutex->backend); | |
| 200 } | |
| 201 | |
| 202 /* Try to grab a lock on a mutex. */ | |
| 203 static inline int | |
| 204 __gthread_objc_mutex_trylock (objc_mutex_t mutex) | |
| 205 { | |
| 206 if (!NXTryLock ((NXMutex_t *)mutex->backend)) | |
| 207 return -1; | |
| 208 return 0; | |
| 209 } | |
| 210 | |
| 211 /* Unlock the mutex */ | |
| 212 static inline int | |
| 213 __gthread_objc_mutex_unlock (objc_mutex_t mutex) | |
| 214 { | |
| 215 return NXUnlock ((NXMutex_t *)mutex->backend); | |
| 216 } | |
| 217 | |
| 218 /* Backend condition mutex functions */ | |
| 219 | |
| 220 /* Allocate a condition. */ | |
| 221 static inline int | |
| 222 __gthread_objc_condition_allocate (objc_condition_t condition) | |
| 223 { | |
| 224 condition->backend = NXCondAlloc (NULL); | |
| 225 if (condition->backend == NULL) | |
| 226 return -1; | |
| 227 | |
| 228 return 0; | |
| 229 } | |
| 230 | |
| 231 /* Deallocate a condition. */ | |
| 232 static inline int | |
| 233 __gthread_objc_condition_deallocate (objc_condition_t condition) | |
| 234 { | |
| 235 if (NXCondFree ((NXCond_t *)condition->backend) != 0) | |
| 236 return -1; | |
| 237 condition->backend = NULL; | |
| 238 return 0; | |
| 239 } | |
| 240 | |
| 241 /* Wait on the condition */ | |
| 242 static inline int | |
| 243 __gthread_objc_condition_wait (objc_condition_t condition, objc_mutex_t mutex) | |
| 244 { | |
| 245 return NXCondWait ((NXCond_t *)condition->backend, (NXMutex_t *)mutex->backend); | |
| 246 } | |
| 247 | |
| 248 /* Wake up all threads waiting on this condition. */ | |
| 249 static inline int | |
| 250 __gthread_objc_condition_broadcast (objc_condition_t condition) | |
| 251 { | |
| 252 return NXCondBroadcast ((NXCond_t *)condition->backend); | |
| 253 } | |
| 254 | |
| 255 /* Wake up one thread waiting on this condition. */ | |
| 256 static inline int | |
| 257 __gthread_objc_condition_signal (objc_condition_t condition) | |
| 258 { | |
| 259 return NXCondSignal ((NXCond_t *)condition->backend); | |
| 260 } | |
| 261 | |
| 262 #else /* _LIBOBJC */ | |
| 263 | |
| 264 #if defined(__cplusplus) | |
| 265 # include <bits/atomicity.h> | |
| 266 /* The remaining conditions here are temporary until there is | |
| 267 an application accessible atomic operations API set... */ | |
| 268 #elif defined(_M_IA64) || defined(__ia64__) | |
| 269 # include <../libstdc++-v3/config/cpu/ia64/bits/atomicity.h> | |
| 270 #elif defined(_M_IX86) || defined(__i486__) | |
| 271 # include <../libstdc++-v3/config/cpu/i486/bits/atomicity.h> | |
| 272 #elif defined(_M_AMD64) || defined(__x86_64__) | |
| 273 # include <../libstdc++-v3/config/cpu/x86-64/bits/atomicity.h> | |
| 274 #endif | |
| 275 | |
| 276 typedef volatile long __gthread_once_t; | |
| 277 | |
| 278 #define __GTHREAD_ONCE_INIT 0 | |
| 279 | |
| 280 static inline int | |
| 281 __gthread_once (__gthread_once_t *__once, void (*__func) (void)) | |
| 282 { | |
| 283 if (__compare_and_swap (__once, 0, 1)) | |
| 284 { | |
| 285 __func (); | |
| 286 *__once |= 2; | |
| 287 } | |
| 288 else | |
| 289 { | |
| 290 while (!(*__once & 2)) | |
| 291 NXThreadYield (); | |
| 292 } | |
| 293 return 0; | |
| 294 } | |
| 295 | |
| 296 static inline int | |
| 297 __gthread_key_create (__gthread_key_t *__key, void (*__dtor) (void *)) | |
| 298 { | |
| 299 return NXKeyCreate (__dtor, NULL, __key); | |
| 300 } | |
| 301 | |
| 302 static inline int | |
| 303 __gthread_key_dtor (__gthread_key_t __key, void *__ptr) | |
| 304 { | |
| 305 /* Just reset the key value to zero. */ | |
| 306 if (__ptr) | |
| 307 return NXKeySetValue (__key, NULL); | |
| 308 return 0; | |
| 309 } | |
| 310 | |
| 311 static inline int | |
| 312 __gthread_key_delete (__gthread_key_t __key) | |
| 313 { | |
| 314 return NXKeyDelete (__key); | |
| 315 } | |
| 316 | |
| 317 static inline void * | |
| 318 __gthread_getspecific (__gthread_key_t __key) | |
| 319 { | |
| 320 void *__value; | |
| 321 | |
| 322 if (NXKeyGetValue (__key, &__value) == 0) | |
| 323 return __value; | |
| 324 return NULL; | |
| 325 } | |
| 326 | |
| 327 static inline int | |
| 328 __gthread_setspecific (__gthread_key_t __key, const void *__ptr) | |
| 329 { | |
| 330 return NXKeySetValue (__key, (void *)__ptr); | |
| 331 } | |
| 332 | |
| 333 static inline void | |
| 334 __gthread_mutex_init_function (__gthread_mutex_t *__mutex) | |
| 335 { | |
| 336 static const NX_LOCK_INFO_ALLOC (__info, "GTHREADS", 0); | |
| 337 | |
| 338 *__mutex = NXMutexAlloc (0, 0, &__info); | |
| 339 } | |
| 340 | |
| 341 static inline int | |
| 342 __gthread_mutex_destroy (__gthread_mutex_t * UNUSED(__mutex)) | |
| 343 { | |
| 344 return 0; | |
| 345 } | |
| 346 | |
| 347 static inline int | |
| 348 __gthread_mutex_lock (__gthread_mutex_t *__mutex) | |
| 349 { | |
| 350 return NXLock (*__mutex); | |
| 351 } | |
| 352 | |
| 353 static inline int | |
| 354 __gthread_mutex_trylock (__gthread_mutex_t *__mutex) | |
| 355 { | |
| 356 if (NXTryLock (*__mutex)) | |
| 357 return 0; | |
| 358 return -1; | |
| 359 } | |
| 360 | |
| 361 static inline int | |
| 362 __gthread_mutex_unlock (__gthread_mutex_t *__mutex) | |
| 363 { | |
| 364 return NXUnlock (*__mutex); | |
| 365 } | |
| 366 | |
| 367 static inline void | |
| 368 __gthread_recursive_mutex_init_function (__gthread_recursive_mutex_t *__mutex) | |
| 369 { | |
| 370 static const NX_LOCK_INFO_ALLOC (__info, "GTHREADS", 0); | |
| 371 | |
| 372 *__mutex = NXMutexAlloc (NX_MUTEX_RECURSIVE, 0, &__info); | |
| 373 } | |
| 374 | |
| 375 static inline int | |
| 376 __gthread_recursive_mutex_lock (__gthread_recursive_mutex_t *__mutex) | |
| 377 { | |
| 378 return NXLock (*__mutex); | |
| 379 } | |
| 380 | |
| 381 static inline int | |
| 382 __gthread_recursive_mutex_trylock (__gthread_recursive_mutex_t *__mutex) | |
| 383 { | |
| 384 if (NXTryLock (*__mutex)) | |
| 385 return 0; | |
| 386 return -1; | |
| 387 } | |
| 388 | |
| 389 static inline int | |
| 390 __gthread_recursive_mutex_unlock (__gthread_recursive_mutex_t *__mutex) | |
| 391 { | |
| 392 return NXUnlock (*__mutex); | |
| 393 } | |
| 394 | |
| 395 #endif /* _LIBOBJC */ | |
| 396 | |
| 397 #endif /* not GCC_GTHR_NKS_H */ |