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_ACTOR_H
34 #include <simgrid/actor.h>
36 #ifdef STARPU_HAVE_SIMGRID_SEMAPHORE_H
37 #include <simgrid/semaphore.h>
39 #ifdef STARPU_HAVE_SIMGRID_MUTEX_H
40 #include <simgrid/mutex.h>
42 #ifdef STARPU_HAVE_SIMGRID_COND_H
43 #include <simgrid/cond.h>
45 #ifdef STARPU_HAVE_SIMGRID_BARRIER_H
46 #include <simgrid/barrier.h>
48 #ifdef STARPU_HAVE_SIMGRID_MSG_H
49 #include <simgrid/msg.h>
53 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
55 #include <semaphore.h>
70 #ifdef STARPU_HAVE_SIMGRID_ACTOR_H
71 typedef sg_actor_t starpu_pthread_t;
73 typedef msg_process_t starpu_pthread_t;
75 typedef int starpu_pthread_attr_t;
77 #ifdef STARPU_HAVE_SIMGRID_ACTOR_H
78 typedef sg_host_t starpu_sg_host_t;
80 typedef msg_host_t starpu_sg_host_t;
82 int starpu_pthread_equal(starpu_pthread_t t1, starpu_pthread_t t2);
83 starpu_pthread_t starpu_pthread_self(
void);
84 int starpu_pthread_create_on(
char *name, starpu_pthread_t *thread,
const starpu_pthread_attr_t *attr,
void *(*start_routine) (
void *),
void *arg, starpu_sg_host_t host);
85 int starpu_pthread_create(starpu_pthread_t *thread,
const starpu_pthread_attr_t *attr,
void *(*start_routine) (
void *),
void *arg);
92 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
94 typedef pthread_t starpu_pthread_t;
95 typedef pthread_attr_t starpu_pthread_attr_t;
97 #define starpu_pthread_equal pthread_equal
98 #define starpu_pthread_self pthread_self
99 #define starpu_pthread_create pthread_create
100 #define starpu_pthread_create_on(name, thread, attr, routine, arg, where) starpu_pthread_create(thread, attr, routine, arg)
101 #define starpu_pthread_join pthread_join
102 #define starpu_pthread_exit pthread_exit
103 #define starpu_pthread_attr_init pthread_attr_init
104 #define starpu_pthread_attr_destroy pthread_attr_destroy
105 #define starpu_pthread_attr_setdetachstate pthread_attr_setdetachstate
109 #ifdef STARPU_HAVE_PTHREAD_SETNAME_NP
110 #ifdef STARPU_HAVE_DARWIN
111 #define starpu_pthread_setname(name) pthread_setname_np(name)
113 #define starpu_pthread_setname(name) pthread_setname_np(pthread_self(), name)
116 #define starpu_pthread_setname(name)
123 #ifdef STARPU_SIMGRID
124 #ifdef STARPU_HAVE_SIMGRID_MUTEX_H
125 typedef sg_mutex_t starpu_pthread_mutex_t;
127 typedef xbt_mutex_t starpu_pthread_mutex_t;
129 typedef int starpu_pthread_mutexattr_t;
131 #define STARPU_PTHREAD_MUTEX_INITIALIZER NULL
143 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
145 typedef pthread_mutex_t starpu_pthread_mutex_t;
146 typedef pthread_mutexattr_t starpu_pthread_mutexattr_t;
148 #define starpu_pthread_mutex_init pthread_mutex_init
149 #define starpu_pthread_mutex_destroy pthread_mutex_destroy
150 #define starpu_pthread_mutexattr_gettype pthread_mutexattr_gettype
151 #define starpu_pthread_mutexattr_settype pthread_mutexattr_settype
152 #define starpu_pthread_mutexattr_destroy pthread_mutexattr_destroy
153 #define starpu_pthread_mutexattr_init pthread_mutexattr_init
155 #ifdef STARPU_FXT_LOCK_TRACES
160 #define starpu_pthread_mutex_lock pthread_mutex_lock
161 #define starpu_pthread_mutex_unlock pthread_mutex_unlock
162 #define starpu_pthread_mutex_trylock pthread_mutex_trylock
165 #define STARPU_PTHREAD_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
169 #if !defined(_MSC_VER) || defined(BUILDING_STARPU)
170 int starpu_pthread_mutex_lock_sched(starpu_pthread_mutex_t *mutex);
171 int starpu_pthread_mutex_unlock_sched(starpu_pthread_mutex_t *mutex);
172 int starpu_pthread_mutex_trylock_sched(starpu_pthread_mutex_t *mutex);
173 void starpu_pthread_mutex_check_sched(starpu_pthread_mutex_t *mutex,
char *file,
int line);
179 #ifdef STARPU_SIMGRID
181 typedef int starpu_pthread_key_t;
187 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
189 typedef pthread_key_t starpu_pthread_key_t;
191 #define starpu_pthread_key_create pthread_key_create
192 #define starpu_pthread_key_delete pthread_key_delete
193 #define starpu_pthread_setspecific pthread_setspecific
194 #define starpu_pthread_getspecific pthread_getspecific
202 #ifdef STARPU_SIMGRID
204 #ifdef STARPU_HAVE_SIMGRID_COND_H
205 typedef sg_cond_t starpu_pthread_cond_t;
207 typedef xbt_cond_t starpu_pthread_cond_t;
209 typedef int starpu_pthread_condattr_t;
210 #define STARPU_PTHREAD_COND_INITIALIZER NULL
219 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
221 typedef pthread_cond_t starpu_pthread_cond_t;
222 typedef pthread_condattr_t starpu_pthread_condattr_t;
223 #define STARPU_PTHREAD_COND_INITIALIZER PTHREAD_COND_INITIALIZER
225 #define starpu_pthread_cond_init pthread_cond_init
226 #define starpu_pthread_cond_signal pthread_cond_signal
227 #define starpu_pthread_cond_broadcast pthread_cond_broadcast
229 #ifdef STARPU_FXT_LOCK_TRACES
232 #define starpu_pthread_cond_wait pthread_cond_wait
235 #define starpu_pthread_cond_timedwait pthread_cond_timedwait
236 #define starpu_pthread_cond_destroy pthread_cond_destroy
244 #ifdef STARPU_SIMGRID
246 #ifdef STARPU_HAVE_SIMGRID_MUTEX_H
247 typedef sg_mutex_t starpu_pthread_rwlock_t;
249 typedef xbt_mutex_t starpu_pthread_rwlock_t;
251 typedef int starpu_pthread_rwlockattr_t;
261 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
263 typedef pthread_rwlock_t starpu_pthread_rwlock_t;
264 typedef pthread_rwlockattr_t starpu_pthread_rwlockattr_t;
266 #define starpu_pthread_rwlock_init pthread_rwlock_init
267 #define starpu_pthread_rwlock_destroy pthread_rwlock_destroy
269 #ifdef STARPU_FXT_LOCK_TRACES
276 #define starpu_pthread_rwlock_rdlock pthread_rwlock_rdlock
277 #define starpu_pthread_rwlock_tryrdlock pthread_rwlock_tryrdlock
278 #define starpu_pthread_rwlock_wrlock pthread_rwlock_wrlock
279 #define starpu_pthread_rwlock_trywrlock pthread_rwlock_trywrlock
280 #define starpu_pthread_rwlock_unlock pthread_rwlock_unlock
289 #if defined(STARPU_SIMGRID) || (!defined(STARPU_HAVE_PTHREAD_BARRIER) && (!defined(_MSC_VER) || defined(BUILDING_STARPU)))
291 #if defined(STARPU_SIMGRID) && (defined(STARPU_HAVE_SIMGRID_BARRIER_H) || defined(STARPU_SIMGRID_HAVE_XBT_BARRIER_INIT) || defined(xbt_barrier_init))
292 #ifdef STARPU_HAVE_SIMGRID_BARRIER_H
297 typedef int starpu_pthread_barrierattr_t;
298 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD -1
301 starpu_pthread_mutex_t mutex;
302 starpu_pthread_cond_t cond;
303 starpu_pthread_cond_t cond_destroy;
308 typedef int starpu_pthread_barrierattr_t;
309 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD -1
316 #elif !defined(_MSC_VER)
319 typedef pthread_barrierattr_t starpu_pthread_barrierattr_t;
321 #define starpu_pthread_barrier_init pthread_barrier_init
322 #define starpu_pthread_barrier_destroy pthread_barrier_destroy
324 #ifdef STARPU_FXT_LOCK_TRACES
327 #define starpu_pthread_barrier_wait pthread_barrier_wait
329 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD PTHREAD_BARRIER_SERIAL_THREAD
337 #if defined(STARPU_SIMGRID) || (defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)
341 #ifdef STARPU_SIMGRID
343 #elif defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)
356 #elif !defined(_MSC_VER)
359 #define starpu_pthread_spin_init pthread_spin_init
360 #define starpu_pthread_spin_destroy pthread_spin_destroy
361 #define starpu_pthread_spin_lock pthread_spin_lock
362 #define starpu_pthread_spin_trylock pthread_spin_trylock
363 #define starpu_pthread_spin_unlock pthread_spin_unlock
371 #if defined(_MSC_VER) && !defined(BUILDING_STARPU)
372 typedef void* starpu_pthread_rwlock_t;
373 typedef void* starpu_pthread_mutex_t;
374 typedef void* starpu_pthread_cond_t;
426 #ifdef STARPU_SIMGRID
429 starpu_pthread_mutex_t mutex;
430 starpu_pthread_cond_t cond;
436 starpu_pthread_mutex_t mutex;
460 #ifdef STARPU_SIMGRID
462 #ifdef STARPU_HAVE_SIMGRID_SEMAPHORE_H
463 typedef sg_sem_t starpu_sem_t;
465 typedef msg_sem_t starpu_sem_t;
467 int starpu_sem_destroy(starpu_sem_t *);
468 int starpu_sem_getvalue(starpu_sem_t *,
int *);
469 int starpu_sem_init(starpu_sem_t *,
int,
unsigned);
470 int starpu_sem_post(starpu_sem_t *);
471 int starpu_sem_trywait(starpu_sem_t *);
472 int starpu_sem_wait(starpu_sem_t *);
474 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
476 typedef sem_t starpu_sem_t;
477 #define starpu_sem_destroy sem_destroy
478 #define starpu_sem_getvalue sem_getvalue
479 #define starpu_sem_init sem_init
480 #define starpu_sem_post sem_post
481 int starpu_sem_trywait(starpu_sem_t *);
482 int starpu_sem_wait(starpu_sem_t *);