X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dfe761f4bc8d35a74c3da5fabe99630c0788001f..c2112799ca0f893d65f2f30a9a9a05f57f451ed0:/src/include/xbt/xbt_os_thread.h diff --git a/src/include/xbt/xbt_os_thread.h b/src/include/xbt/xbt_os_thread.h index b39fcec63e..22d56bb172 100644 --- a/src/include/xbt/xbt_os_thread.h +++ b/src/include/xbt/xbt_os_thread.h @@ -1,8 +1,7 @@ -/* $Id$ */ - /* xbt/xbt_thread.h -- Thread portability layer */ -/* Copyright (c) 2007 Martin Quinson. All rights reserved. */ +/* Copyright (c) 2007, 2009, 2010. The SimGrid Team. + * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -11,14 +10,9 @@ #ifndef _XBT_OS_THREAD_H #define _XBT_OS_THREAD_H -#include "xbt/misc.h" /* SG_BEGIN_DECL */ +#include "xbt/misc.h" /* SG_BEGIN_DECL */ #include "xbt/function_types.h" -#ifndef WIN32 /* HAVE_SEMAPHOR_H */ -#include -#endif - - SG_BEGIN_DECL() /** @addtogroup XBT_thread @@ -29,59 +23,85 @@ SG_BEGIN_DECL() * * @{ */ - /** \brief Thread data type (opaque structure) */ - typedef struct xbt_os_thread_ *xbt_os_thread_t; +typedef struct xbt_os_thread_ *xbt_os_thread_t; - XBT_PUBLIC(xbt_os_thread_t) xbt_os_thread_create(const char *name,pvoid_f_pvoid_t start_routine,void* param); - XBT_PUBLIC(void) xbt_os_thread_exit(int *retcode); - XBT_PUBLIC(xbt_os_thread_t) xbt_os_thread_self(void); - XBT_PUBLIC(const char*) xbt_os_thread_self_name(void); - XBT_PUBLIC(const char*) xbt_os_thread_name(xbt_os_thread_t); +typedef unsigned int xbt_os_thread_key_t; + +/* Calls pthread_atfork() if present, and else does nothing. + * The only known user of this wrapper is mmalloc_preinit(). + */ +XBT_PUBLIC(int) xbt_os_thread_atfork(void (*prepare)(void), + void (*parent)(void), + void (*child)(void)); + + +XBT_PUBLIC(xbt_os_thread_t) xbt_os_thread_create(const char *name, + pvoid_f_pvoid_t start_routine, + void *param, + void *data); + +XBT_PUBLIC(void) xbt_os_thread_exit(int *retcode); +XBT_PUBLIC(void) xbt_os_thread_detach(xbt_os_thread_t thread); +XBT_PUBLIC(xbt_os_thread_t) xbt_os_thread_self(void); +XBT_PUBLIC(const char *) xbt_os_thread_self_name(void); +XBT_PUBLIC(const char *) xbt_os_thread_name(xbt_os_thread_t); +XBT_PUBLIC(void) xbt_os_thread_set_extra_data(void *data); +XBT_PUBLIC(void *) xbt_os_thread_get_extra_data(void); +XBT_PUBLIC(void) xbt_os_thread_key_create(xbt_os_thread_key_t* key); +XBT_PUBLIC(void) xbt_os_thread_set_specific(xbt_os_thread_key_t key, void* value); +XBT_PUBLIC(void*) xbt_os_thread_get_specific(xbt_os_thread_key_t key); /* xbt_os_thread_join frees the joined thread (ie the XBT wrapper around it, the OS frees the rest) */ - XBT_PUBLIC(void) xbt_os_thread_join(xbt_os_thread_t thread,void ** thread_return); - XBT_PUBLIC(void) xbt_os_thread_yield(void); - XBT_PUBLIC(void) xbt_os_thread_cancel(xbt_os_thread_t thread); - XBT_PUBLIC(void*) xbt_os_thread_getparam(void); +XBT_PUBLIC(void) xbt_os_thread_join(xbt_os_thread_t thread, + void **thread_return); +XBT_PUBLIC(void) xbt_os_thread_yield(void); +XBT_PUBLIC(void) xbt_os_thread_cancel(xbt_os_thread_t thread); +XBT_PUBLIC(void *) xbt_os_thread_getparam(void); /** \brief Thread mutex data type (opaque structure) */ - typedef struct xbt_os_mutex_ *xbt_os_mutex_t; +typedef struct xbt_os_mutex_ *xbt_os_mutex_t; + +XBT_PUBLIC(xbt_os_mutex_t) xbt_os_mutex_init(void); +XBT_PUBLIC(void) xbt_os_mutex_acquire(xbt_os_mutex_t mutex); +XBT_PUBLIC(void) xbt_os_mutex_timedacquire(xbt_os_mutex_t mutex, + double delay); +XBT_PUBLIC(void) xbt_os_mutex_release(xbt_os_mutex_t mutex); +XBT_PUBLIC(void) xbt_os_mutex_destroy(xbt_os_mutex_t mutex); - XBT_PUBLIC(xbt_os_mutex_t) xbt_os_mutex_init(void); - XBT_PUBLIC(void) xbt_os_mutex_lock(xbt_os_mutex_t mutex); - XBT_PUBLIC(void) xbt_os_mutex_unlock(xbt_os_mutex_t mutex); - XBT_PUBLIC(void) xbt_os_mutex_destroy(xbt_os_mutex_t mutex); +/** \brief Thread reentrant mutex data type (opaque structure) */ +typedef struct xbt_os_rmutex_ *xbt_os_rmutex_t; + +XBT_PUBLIC(xbt_os_rmutex_t) xbt_os_rmutex_init(void); +XBT_PUBLIC(void) xbt_os_rmutex_acquire(xbt_os_rmutex_t rmutex); +XBT_PUBLIC(void) xbt_os_rmutex_release(xbt_os_rmutex_t rmutex); +XBT_PUBLIC(void) xbt_os_rmutex_destroy(xbt_os_rmutex_t rmutex); /** \brief Thread condition data type (opaque structure) */ - typedef struct xbt_os_cond_ *xbt_os_cond_t; - - XBT_PUBLIC(xbt_os_cond_t) xbt_os_cond_init(void); - XBT_PUBLIC(void) xbt_os_cond_wait(xbt_os_cond_t cond, - xbt_os_mutex_t mutex); - XBT_PUBLIC(void) xbt_os_cond_timedwait(xbt_os_cond_t cond, - xbt_os_mutex_t mutex, - double delay); - XBT_PUBLIC(void) xbt_os_cond_signal(xbt_os_cond_t cond); - XBT_PUBLIC(void) xbt_os_cond_broadcast(xbt_os_cond_t cond); - XBT_PUBLIC(void) xbt_os_cond_destroy(xbt_os_cond_t cond); - +typedef struct xbt_os_cond_ *xbt_os_cond_t; + +XBT_PUBLIC(xbt_os_cond_t) xbt_os_cond_init(void); +XBT_PUBLIC(void) xbt_os_cond_wait(xbt_os_cond_t cond, + xbt_os_mutex_t mutex); +XBT_PUBLIC(void) xbt_os_cond_timedwait(xbt_os_cond_t cond, + xbt_os_mutex_t mutex, double delay); +XBT_PUBLIC(void) xbt_os_cond_signal(xbt_os_cond_t cond); +XBT_PUBLIC(void) xbt_os_cond_broadcast(xbt_os_cond_t cond); +XBT_PUBLIC(void) xbt_os_cond_destroy(xbt_os_cond_t cond); + /** \brief Semaphore data type (opaque structure) */ - typedef struct xbt_os_sem_* xbt_os_sem_t; - - XBT_PUBLIC(xbt_os_sem_t) xbt_os_sem_init(int pshared, unsigned int value); - XBT_PUBLIC(xbt_os_sem_t) xbt_os_sem_open(const char *name, int oflag, mode_t mode, unsigned int value); - XBT_PUBLIC(void) xbt_os_sem_wait(xbt_os_sem_t sem); - XBT_PUBLIC(void) xbt_os_sem_timedwait(xbt_os_sem_t sem,const struct timespec* abs_timeout); - XBT_PUBLIC(void) xbt_os_sem_post(xbt_os_sem_t sem); - XBT_PUBLIC(void) xbt_os_sem_close(xbt_os_sem_t sem); - XBT_PUBLIC(void) xbt_os_sem_destroy(xbt_os_sem_t sem); - XBT_PUBLIC(void) xbt_os_sem_get_value(xbt_os_sem_t sem, int* svalue); - +typedef struct xbt_os_sem_ *xbt_os_sem_t; + +XBT_PUBLIC(xbt_os_sem_t) xbt_os_sem_init(unsigned int value); +XBT_PUBLIC(void) xbt_os_sem_acquire(xbt_os_sem_t sem); +XBT_PUBLIC(void) xbt_os_sem_timedacquire(xbt_os_sem_t sem, double timeout); +XBT_PUBLIC(void) xbt_os_sem_release(xbt_os_sem_t sem); +XBT_PUBLIC(void) xbt_os_sem_destroy(xbt_os_sem_t sem); +XBT_PUBLIC(void) xbt_os_sem_get_value(xbt_os_sem_t sem, int *svalue); + /** @} */ SG_END_DECL() - -#endif /* _XBT_OS_THREAD_H */ +#endif /* _XBT_OS_THREAD_H */