Test if having futex.h.

[simgrid.git] / src / xbt / xbt_os_thread.c

diff --git a/src/xbt/xbt_os_thread.c b/src/xbt/xbt_os_thread.c
index 1ecd247..c3f5688 100644 (file)
--- a/src/xbt/xbt_os_thread.c
+++ b/src/xbt/xbt_os_thread.c
@@ -8,6 +8,7 @@
 /* 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. */
 
+#include "gras_config.h"
 #include "xbt/sysdep.h"
 #include "xbt/ex.h"
 #include "xbt/ex_interface.h"   /* We play crude games with exceptions */
@@ -43,7 +44,8 @@ typedef struct xbt_os_thread_ {
   char *name;
   void *param;
   pvoid_f_pvoid_t start_routine;
-  ex_ctx_t *exception;
+  xbt_running_ctx_t *running_ctx;
+  void *extra_data;
 } s_xbt_os_thread_t;
 static xbt_os_thread_t main_thread = NULL;
 
@@ -58,9 +60,9 @@ static void xbt_os_thread_free_thread_data(void *d)
 }
 
 /* callback: context fetching */
-static ex_ctx_t *_os_thread_ex_ctx(void)
+static xbt_running_ctx_t *_os_thread_get_running_ctx(void)
 {
-  return xbt_os_thread_self()->exception;
+  return xbt_os_thread_self()->running_ctx;
 }
 
 /* callback: termination */
@@ -82,20 +84,25 @@ void xbt_os_thread_mod_preinit(void)
   if ((errcode = pthread_key_create(&xbt_self_thread_key, NULL)))
     THROW0(system_error, errcode,
            "pthread_key_create failed for xbt_self_thread_key");
-
+  
   main_thread = xbt_new(s_xbt_os_thread_t, 1);
   main_thread->name = (char *) "main";
   main_thread->start_routine = NULL;
   main_thread->param = NULL;
-  main_thread->exception = xbt_new(ex_ctx_t, 1);
-  XBT_CTX_INITIALIZE(main_thread->exception);
+  main_thread->running_ctx = xbt_new(xbt_running_ctx_t, 1);
+  XBT_RUNNING_CTX_INITIALIZE(main_thread->running_ctx);
+
+  if ((errcode = pthread_setspecific(xbt_self_thread_key, main_thread)))
+    THROW0(system_error, errcode,
+           "pthread_setspecific failed for xbt_self_thread_key");
 
-  __xbt_ex_ctx = _os_thread_ex_ctx;
+  
+  __xbt_running_ctx_fetch = _os_thread_get_running_ctx;
   __xbt_ex_terminate = _os_thread_ex_terminate;
 
   thread_mod_inited = 1;
 
-#ifndef HAVE_SEM_WAIT
+#ifndef HAVE_SEM_INIT
   next_sem_ID_lock = xbt_os_mutex_init();
 #endif
 
@@ -109,19 +116,25 @@ void xbt_os_thread_mod_postexit(void)
 
   //   if ((errcode=pthread_key_delete(xbt_self_thread_key)))
   //     THROW0(system_error,errcode,"pthread_key_delete failed for xbt_self_thread_key");
-  free(main_thread->exception);
+  free(main_thread->running_ctx);
   free(main_thread);
   main_thread = NULL;
   thread_mod_inited = 0;
-#ifndef HAVE_SEM_WAIT
+#ifndef HAVE_SEM_INIT
   xbt_os_mutex_destroy(next_sem_ID_lock);
 #endif
 
   /* Restore the default exception setup */
-  __xbt_ex_ctx = &__xbt_ex_ctx_default;
+  __xbt_running_ctx_fetch = &__xbt_ex_ctx_default;
   __xbt_ex_terminate = &__xbt_ex_terminate_default;
 }
 
+int xbt_os_thread_atfork(void (*prepare)(void),
+                         void (*parent)(void), void (*child)(void))
+{
+  return pthread_atfork(prepare, parent, child);
+}
+
 static void *wrapper_start_routine(void *s)
 {
   xbt_os_thread_t t = s;
@@ -136,7 +149,8 @@ static void *wrapper_start_routine(void *s)
 
 xbt_os_thread_t xbt_os_thread_create(const char *name,
                                      pvoid_f_pvoid_t start_routine,
-                                     void *param)
+                                     void *param,
+                                     void *extra_data)
 {
   int errcode;
 
@@ -144,9 +158,10 @@ xbt_os_thread_t xbt_os_thread_create(const char *name,
   res_thread->name = xbt_strdup(name);
   res_thread->start_routine = start_routine;
   res_thread->param = param;
-  res_thread->exception = xbt_new(ex_ctx_t, 1);
-  XBT_CTX_INITIALIZE(res_thread->exception);
-
+  res_thread->running_ctx = xbt_new(xbt_running_ctx_t, 1);
+  XBT_RUNNING_CTX_INITIALIZE(res_thread->running_ctx);
+  res_thread->extra_data = extra_data;
+  
   if ((errcode = pthread_create(&(res_thread->t), NULL,
                                 wrapper_start_routine, res_thread)))
     THROW1(system_error, errcode,
@@ -166,6 +181,16 @@ const char *xbt_os_thread_self_name(void)
   return me ? me->name : "main";
 }
 
+void xbt_os_thread_set_extra_data(void *data)
+{
+  xbt_os_thread_self()->extra_data = data;
+}
+
+void *xbt_os_thread_get_extra_data(void)
+{
+  return xbt_os_thread_self()->extra_data;
+}
+
 void xbt_os_thread_join(xbt_os_thread_t thread, void **thread_return)
 {
 
@@ -174,8 +199,8 @@ void xbt_os_thread_join(xbt_os_thread_t thread, void **thread_return)
   if ((errcode = pthread_join(thread->t, thread_return)))
     THROW1(system_error, errcode, "pthread_join failed: %s",
            strerror(errcode));
-  if (thread->exception)
-    free(thread->exception);
+  if (thread->running_ctx)
+    free(thread->running_ctx);
 
   if (thread->name)
     free(thread->name);
@@ -199,12 +224,15 @@ xbt_os_thread_t xbt_os_thread_self(void)
     return NULL;
 
   res = pthread_getspecific(xbt_self_thread_key);
-  if (!res)
-    res = main_thread;
 
   return res;
 }
 
+void xbt_os_thread_detach(xbt_os_thread_t thread)
+{
+  pthread_detach(thread->t);
+}
+
 #include <sched.h>
 void xbt_os_thread_yield(void)
 {
@@ -451,7 +479,7 @@ xbt_os_sem_t xbt_os_sem_init(unsigned int value)
 #else                           /* damn, no sem_init(). Reimplement it */
 
   xbt_os_mutex_acquire(next_sem_ID_lock);
-  res->name = bprintf("/%d.%d", (*xbt_getpid) (), ++next_sem_ID);
+  res->name = bprintf("/%d", ++next_sem_ID);
   xbt_os_mutex_release(next_sem_ID_lock);
 
   res->ps = sem_open(res->name, O_CREAT, 0644, value);
@@ -618,6 +646,12 @@ void xbt_os_thread_mod_postexit(void)
            "TlsFree() failed to cleanup the thread submodule");
 }
 
+int xbt_os_thread_atfork(void (*prepare)(void),
+                         void (*parent)(void), void (*child)(void))
+{
+  return 0;
+}
+
 static DWORD WINAPI wrapper_start_routine(void *s)
 {
   xbt_os_thread_t t = (xbt_os_thread_t) s;
@@ -698,6 +732,12 @@ void xbt_os_thread_exit(int *retval)
     ExitThread(0);
 }
 
+void xbt_os_thread_detach(xbt_os_thread_t thread)
+{
+  THROW_UNIMPLEMENTED;
+}
+
+
 xbt_os_thread_t xbt_os_thread_self(void)
 {
   return TlsGetValue(xbt_self_thread_key);