21 #ifndef __STARPU_THREAD_H__ 22 #define __STARPU_THREAD_H__ 28 #ifdef STARPU_HAVE_XBT_SYNCHRO_H 29 #include <xbt/synchro.h> 31 #include <xbt/synchro_core.h> 33 #ifdef STARPU_HAVE_SIMGRID_MSG_H 34 #include <simgrid/msg.h> 38 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 40 #include <semaphore.h> 55 typedef msg_process_t starpu_pthread_t;
56 typedef int starpu_pthread_attr_t;
58 int starpu_pthread_equal(starpu_pthread_t t1, starpu_pthread_t t2);
59 starpu_pthread_t starpu_pthread_self(
void);
60 int starpu_pthread_create_on(
char *name, starpu_pthread_t *thread,
const starpu_pthread_attr_t *attr,
void *(*start_routine) (
void *),
void *arg, msg_host_t host);
61 int starpu_pthread_create(starpu_pthread_t *thread,
const starpu_pthread_attr_t *attr,
void *(*start_routine) (
void *),
void *arg);
68 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 70 typedef pthread_t starpu_pthread_t;
71 typedef pthread_attr_t starpu_pthread_attr_t;
73 #define starpu_pthread_equal pthread_equal 74 #define starpu_pthread_self pthread_self 75 #define starpu_pthread_create pthread_create 76 #define starpu_pthread_create_on(name, thread, attr, routine, arg, where) starpu_pthread_create(thread, attr, routine, arg) 77 #define starpu_pthread_join pthread_join 78 #define starpu_pthread_exit pthread_exit 79 #define starpu_pthread_attr_init pthread_attr_init 80 #define starpu_pthread_attr_destroy pthread_attr_destroy 81 #define starpu_pthread_attr_setdetachstate pthread_attr_setdetachstate 85 #ifdef STARPU_HAVE_PTHREAD_SETNAME_NP 86 #ifdef STARPU_HAVE_DARWIN 87 #define starpu_pthread_setname(name) pthread_setname_np(name) 89 #define starpu_pthread_setname(name) pthread_setname_np(pthread_self(), name) 92 #define starpu_pthread_setname(name) 100 typedef xbt_mutex_t starpu_pthread_mutex_t;
101 typedef int starpu_pthread_mutexattr_t;
103 #define STARPU_PTHREAD_MUTEX_INITIALIZER NULL 115 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 117 typedef pthread_mutex_t starpu_pthread_mutex_t;
118 typedef pthread_mutexattr_t starpu_pthread_mutexattr_t;
120 #define starpu_pthread_mutex_init pthread_mutex_init 121 #define starpu_pthread_mutex_destroy pthread_mutex_destroy 122 #define starpu_pthread_mutexattr_gettype pthread_mutexattr_gettype 123 #define starpu_pthread_mutexattr_settype pthread_mutexattr_settype 124 #define starpu_pthread_mutexattr_destroy pthread_mutexattr_destroy 125 #define starpu_pthread_mutexattr_init pthread_mutexattr_init 127 #ifdef STARPU_FXT_LOCK_TRACES 132 #define starpu_pthread_mutex_lock pthread_mutex_lock 133 #define starpu_pthread_mutex_unlock pthread_mutex_unlock 134 #define starpu_pthread_mutex_trylock pthread_mutex_trylock 137 #define STARPU_PTHREAD_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER 141 #if !defined(_MSC_VER) || defined(BUILDING_STARPU) 142 int starpu_pthread_mutex_lock_sched(starpu_pthread_mutex_t *mutex);
143 int starpu_pthread_mutex_unlock_sched(starpu_pthread_mutex_t *mutex);
144 int starpu_pthread_mutex_trylock_sched(starpu_pthread_mutex_t *mutex);
145 void starpu_pthread_mutex_check_sched(starpu_pthread_mutex_t *mutex,
char *file,
int line);
151 #ifdef STARPU_SIMGRID 153 typedef int starpu_pthread_key_t;
159 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 161 typedef pthread_key_t starpu_pthread_key_t;
163 #define starpu_pthread_key_create pthread_key_create 164 #define starpu_pthread_key_delete pthread_key_delete 165 #define starpu_pthread_setspecific pthread_setspecific 166 #define starpu_pthread_getspecific pthread_getspecific 174 #ifdef STARPU_SIMGRID 176 typedef xbt_cond_t starpu_pthread_cond_t;
177 typedef int starpu_pthread_condattr_t;
178 #define STARPU_PTHREAD_COND_INITIALIZER NULL 187 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 189 typedef pthread_cond_t starpu_pthread_cond_t;
190 typedef pthread_condattr_t starpu_pthread_condattr_t;
191 #define STARPU_PTHREAD_COND_INITIALIZER PTHREAD_COND_INITIALIZER 193 #define starpu_pthread_cond_init pthread_cond_init 194 #define starpu_pthread_cond_signal pthread_cond_signal 195 #define starpu_pthread_cond_broadcast pthread_cond_broadcast 197 #ifdef STARPU_FXT_LOCK_TRACES 200 #define starpu_pthread_cond_wait pthread_cond_wait 203 #define starpu_pthread_cond_timedwait pthread_cond_timedwait 204 #define starpu_pthread_cond_destroy pthread_cond_destroy 212 #ifdef STARPU_SIMGRID 214 typedef xbt_mutex_t starpu_pthread_rwlock_t;
215 typedef int starpu_pthread_rwlockattr_t;
225 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 227 typedef pthread_rwlock_t starpu_pthread_rwlock_t;
228 typedef pthread_rwlockattr_t starpu_pthread_rwlockattr_t;
230 #define starpu_pthread_rwlock_init pthread_rwlock_init 231 #define starpu_pthread_rwlock_destroy pthread_rwlock_destroy 233 #ifdef STARPU_FXT_LOCK_TRACES 240 #define starpu_pthread_rwlock_rdlock pthread_rwlock_rdlock 241 #define starpu_pthread_rwlock_tryrdlock pthread_rwlock_tryrdlock 242 #define starpu_pthread_rwlock_wrlock pthread_rwlock_wrlock 243 #define starpu_pthread_rwlock_trywrlock pthread_rwlock_trywrlock 244 #define starpu_pthread_rwlock_unlock pthread_rwlock_unlock 253 #if defined(STARPU_SIMGRID) || (!defined(STARPU_HAVE_PTHREAD_BARRIER) && (!defined(_MSC_VER) || defined(BUILDING_STARPU))) 255 #if defined(STARPU_SIMGRID) && (defined(STARPU_SIMGRID_HAVE_XBT_BARRIER_INIT) || defined(xbt_barrier_init)) 257 typedef int starpu_pthread_barrierattr_t;
258 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD XBT_BARRIER_SERIAL_PROCESS 261 starpu_pthread_mutex_t mutex;
262 starpu_pthread_cond_t cond;
263 starpu_pthread_cond_t cond_destroy;
267 } starpu_pthread_barrier_t;
268 typedef int starpu_pthread_barrierattr_t;
269 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD -1 276 #elif !defined(_MSC_VER) 278 typedef pthread_barrier_t starpu_pthread_barrier_t;
279 typedef pthread_barrierattr_t starpu_pthread_barrierattr_t;
281 #define starpu_pthread_barrier_init pthread_barrier_init 282 #define starpu_pthread_barrier_destroy pthread_barrier_destroy 284 #ifdef STARPU_FXT_LOCK_TRACES 287 #define starpu_pthread_barrier_wait pthread_barrier_wait 289 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD PTHREAD_BARRIER_SERIAL_THREAD 297 #if defined(STARPU_SIMGRID) || (defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK) 301 #ifdef STARPU_SIMGRID 303 #elif defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG) 316 #elif !defined(_MSC_VER) 319 #define starpu_pthread_spin_init pthread_spin_init 320 #define starpu_pthread_spin_destroy pthread_spin_destroy 321 #define starpu_pthread_spin_lock pthread_spin_lock 322 #define starpu_pthread_spin_trylock pthread_spin_trylock 323 #define starpu_pthread_spin_unlock pthread_spin_unlock 331 #if defined(_MSC_VER) && !defined(BUILDING_STARPU) 332 typedef void* starpu_pthread_rwlock_t;
333 typedef void* starpu_pthread_mutex_t;
334 typedef void* starpu_pthread_cond_t;
335 typedef void* starpu_pthread_barrier_t;
386 #ifdef STARPU_SIMGRID 389 starpu_pthread_mutex_t mutex;
390 starpu_pthread_cond_t cond;
396 starpu_pthread_mutex_t mutex;
420 #ifdef STARPU_SIMGRID 422 typedef msg_sem_t starpu_sem_t;
423 int starpu_sem_destroy(starpu_sem_t *);
424 int starpu_sem_getvalue(starpu_sem_t *,
int *);
425 int starpu_sem_init(starpu_sem_t *,
int,
unsigned);
426 int starpu_sem_post(starpu_sem_t *);
427 int starpu_sem_trywait(starpu_sem_t *);
428 int starpu_sem_wait(starpu_sem_t *);
430 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) 432 typedef sem_t starpu_sem_t;
433 #define starpu_sem_destroy sem_destroy 434 #define starpu_sem_getvalue sem_getvalue 435 #define starpu_sem_init sem_init 436 #define starpu_sem_post sem_post 437 int starpu_sem_trywait(starpu_sem_t *);
438 int starpu_sem_wait(starpu_sem_t *);
int starpu_pthread_spin_trylock(starpu_pthread_spinlock_t *lock)
int starpu_pthread_cond_wait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex)
int starpu_pthread_barrier_wait(starpu_pthread_barrier_t *barrier)
void * starpu_pthread_getspecific(starpu_pthread_key_t key)
int starpu_pthread_mutexattr_destroy(starpu_pthread_mutexattr_t *attr)
int starpu_pthread_spin_unlock(starpu_pthread_spinlock_t *lock)
int starpu_pthread_mutex_unlock(starpu_pthread_mutex_t *mutex)
int starpu_pthread_spin_lock(starpu_pthread_spinlock_t *lock)
int starpu_pthread_barrier_destroy(starpu_pthread_barrier_t *barrier)
int starpu_pthread_attr_destroy(starpu_pthread_attr_t *attr)
int starpu_pthread_mutexattr_init(starpu_pthread_mutexattr_t *attr)
int starpu_pthread_setspecific(starpu_pthread_key_t key, const void *pointer)
int starpu_pthread_exit(void *retval) STARPU_ATTRIBUTE_NORETURN
int starpu_pthread_spin_init(starpu_pthread_spinlock_t *lock, int pshared)
int starpu_pthread_barrier_init(starpu_pthread_barrier_t *barrier, const starpu_pthread_barrierattr_t *attr, unsigned count)
int starpu_pthread_cond_destroy(starpu_pthread_cond_t *cond)
int starpu_pthread_mutex_destroy(starpu_pthread_mutex_t *mutex)
int starpu_pthread_cond_broadcast(starpu_pthread_cond_t *cond)
int starpu_pthread_mutexattr_gettype(const starpu_pthread_mutexattr_t *attr, int *type)
int starpu_pthread_cond_timedwait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex, const struct timespec *abstime)
Definition: starpu_thread.h:299
Definition: starpu_thread.h:387
int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock)
Definition: starpu_thread.h:260
int starpu_pthread_rwlock_wrlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_mutexattr_settype(starpu_pthread_mutexattr_t *attr, int type)
Definition: starpu_thread.h:394
int starpu_pthread_rwlock_init(starpu_pthread_rwlock_t *rwlock, const starpu_pthread_rwlockattr_t *attr)
int starpu_pthread_join(starpu_pthread_t thread, void **retval)
int starpu_pthread_mutex_init(starpu_pthread_mutex_t *mutex, const starpu_pthread_mutexattr_t *mutexattr)
int starpu_pthread_key_delete(starpu_pthread_key_t key)
int starpu_pthread_rwlock_destroy(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_cond_init(starpu_pthread_cond_t *cond, starpu_pthread_condattr_t *cond_attr)
int starpu_pthread_rwlock_trywrlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_create(starpu_pthread_t *thread, const starpu_pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
int starpu_pthread_attr_init(starpu_pthread_attr_t *attr)
int starpu_pthread_attr_setdetachstate(starpu_pthread_attr_t *attr, int detachstate)
int starpu_pthread_rwlock_tryrdlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_mutex_lock(starpu_pthread_mutex_t *mutex)
int starpu_pthread_spin_destroy(starpu_pthread_spinlock_t *lock)
int starpu_pthread_cond_signal(starpu_pthread_cond_t *cond)
int starpu_pthread_mutex_trylock(starpu_pthread_mutex_t *mutex)
int starpu_pthread_key_create(starpu_pthread_key_t *key, void(*destr_function)(void *))