X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fba44e13f2b2b7fb3f99030e5a59cd1eb721d558..7097ed501ac302a5f0a2b3cd37114c81ec2e9145:/src/sthread/sthread.h diff --git a/src/sthread/sthread.h b/src/sthread/sthread.h index 65279685e6..8447d9702c 100644 --- a/src/sthread/sthread.h +++ b/src/sthread/sthread.h @@ -31,15 +31,51 @@ typedef unsigned long int sthread_t; int sthread_create(sthread_t* thread, const /*pthread_attr_t*/ void* attr, void* (*start_routine)(void*), void* arg); int sthread_join(sthread_t thread, void** retval); +typedef struct { + unsigned recursive : 1; + unsigned errorcheck : 1; + unsigned robust : 1; +} sthread_mutexattr_t; + +int sthread_mutexattr_init(sthread_mutexattr_t* attr); +int sthread_mutexattr_settype(sthread_mutexattr_t* attr, int type); +int sthread_mutexattr_gettype(const sthread_mutexattr_t* attr, int* type); +int sthread_mutexattr_getrobust(const sthread_mutexattr_t* attr, int* robustness); +int sthread_mutexattr_setrobust(sthread_mutexattr_t* attr, int robustness); + typedef struct { void* mutex; } sthread_mutex_t; -int sthread_mutex_init(sthread_mutex_t* mutex, const /*pthread_mutexattr_t*/ void* attr); +int sthread_mutex_init(sthread_mutex_t* mutex, const sthread_mutexattr_t* attr); int sthread_mutex_lock(sthread_mutex_t* mutex); int sthread_mutex_trylock(sthread_mutex_t* mutex); int sthread_mutex_unlock(sthread_mutex_t* mutex); int sthread_mutex_destroy(sthread_mutex_t* mutex); +typedef struct { + unsigned unused : 1; +} sthread_barrierattr_t; + +typedef struct { + void* barrier; +} sthread_barrier_t; +int sthread_barrier_init(sthread_barrier_t* barrier, const sthread_barrierattr_t* attr, unsigned count); +int sthread_barrier_wait(sthread_barrier_t* barrier); +int sthread_barrier_destroy(sthread_barrier_t* barrier); + +typedef struct { + unsigned unused : 1; +} sthread_condattr_t; + +typedef struct { + void* cond; +} sthread_cond_t; +int sthread_cond_init(sthread_cond_t* cond, sthread_condattr_t* attr); +int sthread_cond_signal(sthread_cond_t* cond); +int sthread_cond_broadcast(sthread_cond_t* cond); +int sthread_cond_wait(sthread_cond_t* cond, sthread_mutex_t* mutex); +int sthread_cond_destroy(sthread_cond_t* cond); + typedef struct { void* sem; } sthread_sem_t; @@ -51,10 +87,11 @@ int sthread_sem_trywait(sthread_sem_t* sem); int sthread_sem_timedwait(sthread_sem_t* sem, const struct timespec* abs_timeout); int sthread_gettimeofday(struct timeval* tv); -void sthread_sleep(double seconds); +unsigned int sthread_sleep(double seconds); +int sthread_usleep(double seconds); -int sthread_access_begin(void* objaddr, const char* objname, const char* file, int line); -void sthread_access_end(void* objaddr, const char* objname, const char* file, int line); +int sthread_access_begin(void* objaddr, const char* objname, const char* file, int line, const char* function); +void sthread_access_end(void* objaddr, const char* objname, const char* file, int line, const char* function); #if defined(__cplusplus) }