X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/59a1aff0fbe12fa74b7d0b9fb46492fa7a822acc..99539cdc5c814389e373ed62f61f116d56b6ac2c:/src/xbt/context.c

diff --git a/src/xbt/context.c b/src/xbt/context.c
index 5ab348db85..b24922a20c 100644
--- a/src/xbt/context.c
+++ b/src/xbt/context.c
@@ -11,11 +11,21 @@
 
 #include "portable.h"
 #include "context_private.h"
-#include "xbt/error.h"
+#include "xbt/log.h"
 #include "xbt/dynar.h"
-#include "gras_config.h"
+#include "xbt/xbt_thread.h"
+/*#include <pthread.h>*/ /* I need pthread_join that is not yet available in xbt_thread.*/
+
+#ifdef CONTEXT_THREADS
+ /* This file (context.c) is only loaded in libsimgrid, not libgras.
+  * xbt_thread is only loaded in libgras explicitly, and we need it in 
+  *    libsimgrid, but only when it is the backend used to implement the 
+  *    xbt_context. So, do load it on need.
+  */
+#include "xbt/xbt_thread.c"
+#endif
 
-XBT_LOG_NEW_DEFAULT_SUBCATEGORY(context, xbt, "Context");
+XBT_LOG_NEW_DEFAULT_SUBCATEGORY(xbt_ctx, xbt, "Context");
 
 #define VOIRP(expr) DEBUG1("  {" #expr " = %p }", expr)
 
@@ -23,120 +33,200 @@ static xbt_context_t current_context = NULL;
 static xbt_context_t init_context = NULL;
 static xbt_swag_t context_to_destroy = NULL;
 static xbt_swag_t context_living = NULL;
-
-#ifndef USE_PTHREADS /* USE_PTHREADS and USE_CONTEXT are exclusive */
-# ifndef USE_UCONTEXT
-/* don't want to play with conditional compilation in automake tonight, sorry.
-   include directly the c file from here when needed. */
-#  include "context_win32.c" 
-# endif
+#ifdef CONTEXT_THREADS
+static xbt_mutex_t creation_mutex;
+static xbt_thcond_t creation_cond;
 #endif
 
+static void __context_exit(xbt_context_t context ,int value);
 static void __xbt_context_yield(xbt_context_t context)
 {
-  int return_value = 0;
-
-  xbt_assert0(current_context,"You have to call context_init() first.");
-  
-  DEBUG2("--------- current_context (%p) is yielding to context(%p) ---------",
-	 current_context,context);
-
-#ifdef USE_PTHREADS
-  if (context) {
-    xbt_context_t self = current_context;
-    DEBUG0("**** Locking ****");
-    pthread_mutex_lock(&(context->mutex));
-    DEBUG0("**** Updating current_context ****");
-    current_context = context;
-    DEBUG0("**** Releasing the prisonner ****");
-    pthread_cond_signal(&(context->cond));
-    DEBUG0("**** Going to jail ****");
-    pthread_cond_wait(&(context->cond), &(context->mutex));
-    DEBUG0("**** Unlocking ****");
-    pthread_mutex_unlock(&(context->mutex));
-    DEBUG0("**** Updating current_context ****");
-    current_context = self;
-  }
-#else
-  if(current_context)
-    VOIRP(current_context->save);
-
-  VOIRP(context);
-  if(context) VOIRP(context->save);
-  if (context) {
-    if(context->save==NULL) {
-      DEBUG0("**** Yielding to somebody else ****");
-      DEBUG2("Saving current_context value (%p) to context(%p)->save",current_context,context);
-      context->save = current_context ;
-      DEBUG1("current_context becomes  context(%p) ",context);
-      current_context = context ;
-      DEBUG1("Current position memorized (context->save). Jumping to context (%p)",context);
-      return_value = swapcontext (&(context->save->uc), &(context->uc));
-      xbt_assert0((return_value==0),"Context swapping failure");
-      DEBUG1("I am (%p). Coming back\n",context);
-    } else {
-      xbt_context_t old_context = context->save ;
-      DEBUG0("**** Back ! ****");
-      DEBUG2("Setting current_context (%p) to context(%p)->save",current_context,context);
-      current_context = context->save ;
-      DEBUG1("Setting context(%p)->save to NULL",context);
-      context->save = NULL ;
-      DEBUG2("Current position memorized (%p). Jumping to context (%p)",context,old_context);
-      return_value = swapcontext (&(context->uc), &(old_context->uc));
-      xbt_assert0((return_value==0),"Context swapping failure");
-      DEBUG1("I am (%p). Coming back\n",context);
-    }
-  }
-#endif
-  return;
+	xbt_assert0(current_context,"You have to call context_init() first.");
+
+	DEBUG2("--------- current_context (%p) is yielding to context(%p) ---------",current_context,context);
+   
+	#ifdef CONTEXT_THREADS
+	if (context){
+		xbt_context_t self = current_context;
+		DEBUG1("[%p] **** Locking ****", self);
+		xbt_mutex_lock(context->mutex);
+		DEBUG1("[%p] **** Updating current_context ****", self);
+		current_context = context;
+		DEBUG1("[%p] **** Releasing the prisonner ****", self);
+		xbt_thcond_signal(context->cond);
+		DEBUG1("[%p] **** Going to jail ****", self);
+		xbt_thcond_wait(context->cond, context->mutex);
+		DEBUG1("[%p] **** Unlocking ****", self);
+		xbt_mutex_unlock(context->mutex);
+		DEBUG1("[%p] **** Updating current_context ****", self);
+		current_context = self;
+	}
+	#else /* use SUSv2 contexts */
+	if(current_context)
+		VOIRP(current_context->save);
+	
+	VOIRP(context);
+	
+	if(context) 
+		VOIRP(context->save);
+	
+	if (context){
+	
+		int return_value = 0;
+		
+		if(context->save==NULL){
+		
+		  DEBUG1("[%p] **** Yielding to somebody else ****", current_context);
+			DEBUG2("Saving current_context value (%p) to context(%p)->save",current_context,context);
+			context->save = current_context ;
+			DEBUG1("current_context becomes  context(%p) ",context);
+			current_context = context ;
+			DEBUG1("Current position memorized (context->save). Jumping to context (%p)",context);
+			return_value = swapcontext (&(context->save->uc), &(context->uc));
+			xbt_assert0((return_value==0),"Context swapping failure");
+			DEBUG1("I am (%p). Coming back\n",context);
+		} else {
+			xbt_context_t old_context = context->save ;
+			DEBUG1("[%p] **** Back ! ****", context);
+			DEBUG2("Setting current_context (%p) to context(%p)->save",current_context,context);
+			current_context = context->save ;
+			DEBUG1("Setting context(%p)->save to NULL",context);
+			context->save = NULL ;
+			DEBUG2("Current position memorized (%p). Jumping to context (%p)",context,old_context);
+			return_value = swapcontext (&(context->uc), &(old_context->uc));
+			xbt_assert0((return_value==0),"Context swapping failure");
+			DEBUG1("I am (%p). Coming back\n",context);
+		
+		}
+	}
+	#endif
+	if(current_context->iwannadie)
+	  __context_exit(current_context, 1);
+
+	return;
 }
 
-static void xbt_context_destroy(xbt_context_t context)
+static void xbt_context_free(xbt_context_t context)
 {
-#ifdef USE_PTHREADS
-  xbt_free(context->thread);
-  pthread_mutex_destroy(&(context->mutex));
-  pthread_cond_destroy(&(context->cond));
+	if (!context) return;
+	DEBUG1("Freeing %p",context);
+#ifdef CONTEXT_THREADS
+	/*DEBUG1("\t joining %p",(void *)context->thread->t);*/
+	DEBUG1("\t joining %p",(void *)context->thread);
+	/*pthread_join(context->thread->t,NULL);*/
+	xbt_thread_join(context->thread,NULL);
+	DEBUG1("\t xbt_free %p",(void *)context->thread);
+	xbt_free(context->thread);
+	DEBUG1("\t mutex_destroy %p",(void *)context->mutex);
+	xbt_mutex_destroy(context->mutex);
+	DEBUG1("\t cond_destroy %p",(void *)context->cond);
+	xbt_thcond_destroy(context->cond);
+
+	context->thread = NULL;
+	context->mutex = NULL;
+   	context->cond = NULL;
 #endif
-  free(context);
-  return;
+	
+	if(context->exception) 
+		free(context->exception);
+		
+	free(context);
+	return;
 }
-
-static void *__context_wrapper(void *c)
+	
+static void __context_exit(xbt_context_t context ,int value)
 {
-  xbt_context_t context = c;
-  int i;
-
-#ifdef USE_PTHREADS
-  DEBUG0("**** Lock ****");
-  pthread_mutex_lock(&(context->mutex));
-  DEBUG0("**** Releasing the prisonner ****");
-  pthread_cond_signal(&(context->cond));
-  DEBUG0("**** Going to Jail ****");
-  pthread_cond_wait(&(context->cond), &(context->mutex));
-  DEBUG0("**** Unlocking ****");
-  pthread_mutex_unlock(&(context->mutex));
-#endif
-
-  if(context->startup_func)
-    context->startup_func(context->startup_arg);
-
-   DEBUG0("Calling the main function");
-  (context->code) (context->argc,context->argv);
-
-  for(i=0;i<context->argc; i++) 
-    if(context->argv[i]) free(context->argv[i]);
-  if(context->argv) free(context->argv);
+	int i;
+
+	DEBUG1("--------- %p is exiting ---------",context);
+
+	DEBUG0("Calling cleanup functions");
+	if(context->cleanup_func){
+		DEBUG0("Calling cleanup function");
+		context->cleanup_func(context->cleanup_arg);
+	}
+
+	DEBUG0("Freeing arguments");
+	for(i=0;i<context->argc; i++) 
+		if(context->argv[i]) 
+			free(context->argv[i]);
+	
+	if(context->argv) 
+		free(context->argv);
+		
+	DEBUG0("Putting context in the to_destroy set");
+	xbt_swag_remove(context, context_living);
+	xbt_swag_insert(context, context_to_destroy);
+	DEBUG0("Context put in the to_destroy set");
+
+	DEBUG0("Yielding");
+	
+	#ifdef CONTEXT_THREADS
+	DEBUG1("[%p] **** Locking ****", context);
+	xbt_mutex_lock(context->mutex);
+/* 	DEBUG1("[%p] **** Updating current_context ****"); */
+/* 	current_context = context; */
+	DEBUG1("[%p] **** Releasing the prisonner ****", context);
+	xbt_thcond_signal(context->cond);
+	DEBUG1("[%p] **** Unlocking ****", context);
+	xbt_mutex_unlock(context->mutex);
+	DEBUG1("[%p] **** Exiting ****", context);
+	xbt_thread_exit(NULL); // We should provide return value in case other wants it
+	#else
+	__xbt_context_yield(context);
+	#endif
+	xbt_assert0(0,"You can't be here!");
+}
 
-  if(context->cleanup_func)
-    context->cleanup_func(context->cleanup_arg);
+static void *
+__context_wrapper(void* c) {
+	xbt_context_t context = (xbt_context_t)c;
+	
+	#ifdef CONTEXT_THREADS
+	context->thread = xbt_thread_self();
+        
+	DEBUG2("**[%p:%p]** Lock ****",context,(void*)xbt_thread_self());
+	xbt_mutex_lock(creation_mutex);
+	
+	DEBUG2("**[%p:%p]** Releasing the creator ****",context,(void*)xbt_thread_self());
+	xbt_thcond_signal(creation_cond);
+	xbt_mutex_unlock(creation_mutex);
+	
+	DEBUG2("**[%p:%p]** Going to Jail ****",context,(void*)xbt_thread_self());
+	xbt_mutex_lock(context->mutex);
+	xbt_thcond_wait(context->cond, context->mutex);
+	
+	DEBUG2("**[%p:%p]** Unlocking ****",context,(void*)xbt_thread_self());
+	xbt_mutex_unlock(context->mutex);
+	
+	#endif
+	
+	if(context->startup_func)
+		context->startup_func(context->startup_arg);
+	
+	DEBUG0("Calling the main function");
+	
+	__context_exit(context, (context->code) (context->argc,context->argv));
+	return NULL;
+}
 
-  xbt_swag_remove(context, context_living);
-  xbt_swag_insert(context, context_to_destroy);
+/* callback: context fetching */
+static ex_ctx_t *__context_ex_ctx(void)
+{
+ 	return current_context->exception;
+}
 
-  __xbt_context_yield(context);
-  xbt_assert0(0,"You're cannot be here!");
-  return NULL;
+/* callback: termination */
+static void __context_ex_terminate(xbt_ex_t *e) {
+  xbt_ex_display(e);
+
+  abort();
+   /* FIXME: there should be a configuration variable to choose this
+  if(current_context!=init_context) 
+    __context_exit(current_context, e->value);
+  else
+    abort();
+    */
 }
 
 /** \name Functions 
@@ -149,12 +239,22 @@ static void *__context_wrapper(void *c)
  */
 void xbt_context_init(void)
 {
-  if(!current_context) {
-    current_context = init_context = xbt_new0(s_xbt_context_t,1);
-    context_to_destroy = xbt_swag_new(xbt_swag_offset(*current_context,hookup));
-    context_living = xbt_swag_new(xbt_swag_offset(*current_context,hookup));
-    xbt_swag_insert(init_context, context_living);
-  }
+	if(!current_context){
+		current_context = init_context = xbt_new0(s_xbt_context_t,1);
+		DEBUG1("Init Context (%p)",init_context);
+		
+		init_context->exception = xbt_new(ex_ctx_t,1);
+		XBT_CTX_INITIALIZE(init_context->exception);
+		__xbt_ex_ctx       = __context_ex_ctx;
+		__xbt_ex_terminate = __context_ex_terminate;
+		context_to_destroy = xbt_swag_new(xbt_swag_offset(*current_context,hookup));
+		context_living = xbt_swag_new(xbt_swag_offset(*current_context,hookup));
+		xbt_swag_insert(init_context, context_living);
+#ifdef CONTEXT_THREADS	   
+	        creation_mutex = xbt_mutex_init();
+	        creation_cond = xbt_thcond_init();
+#endif	   
+	}
 }
 
 /** Garbage collection
@@ -164,10 +264,11 @@ void xbt_context_init(void)
  */
 void xbt_context_empty_trash(void)
 {
-  xbt_context_t context=NULL;
-
-  while((context=xbt_swag_extract(context_to_destroy)))
-    xbt_context_destroy(context);
+	xbt_context_t context=NULL;
+	DEBUG1("Emptying trashbin (%d contexts to free)",
+	       xbt_swag_size(context_to_destroy));
+	while((context=xbt_swag_extract(context_to_destroy)))
+		xbt_context_free(context);
 }
 
 /** 
@@ -178,22 +279,23 @@ void xbt_context_empty_trash(void)
  */
 void xbt_context_start(xbt_context_t context) 
 {
-#ifdef USE_PTHREADS
-  /* Launch the thread */
-  DEBUG0("**** Locking ****");
-  pthread_mutex_lock(&(context->mutex));
-  DEBUG0("**** Pthread create ****");
-  xbt_assert0(!pthread_create(context->thread, NULL, __context_wrapper, context),
-	      "Unable to create a thread.");
-  DEBUG0("**** Going to jail ****");
-  pthread_cond_wait(&(context->cond), &(context->mutex));
-  DEBUG0("**** Unlocking ****");
-  pthread_mutex_unlock(&(context->mutex));  
-#else
-  makecontext (&(context->uc), (void (*) (void)) __context_wrapper,
-	       1, context);
-#endif
-  return;
+	#ifdef CONTEXT_THREADS
+	/* Launch the thread */
+	DEBUG1("**[%p]** Locking ****",context);
+	xbt_mutex_lock(creation_mutex);
+   
+	DEBUG1("**[%p]** Thread create ****",context);
+        context->thread = xbt_thread_create(__context_wrapper, context);   
+	DEBUG2("**[%p]** Thread created : %p ****",context,context->thread);
+   
+	DEBUG1("**[%p]** Going to jail ****",context);
+	xbt_thcond_wait(creation_cond, creation_mutex);
+	DEBUG1("**[%p]** Unlocking ****",context);
+	xbt_mutex_unlock(creation_mutex);
+	#else
+	makecontext (&(context->uc), (void (*) (void)) __context_wrapper,1, context);
+	#endif
+	return;
 }
 
 /** 
@@ -212,36 +314,38 @@ xbt_context_t xbt_context_new(xbt_context_function_t code,
 			      void_f_pvoid_t cleanup_func, void *cleanup_arg,
 			      int argc, char *argv[])
 {
-  xbt_context_t res = NULL;
-
-  res = xbt_new0(s_xbt_context_t,1);
-
-  res->code = code;
-#ifdef USE_PTHREADS
-  res->thread = xbt_new0(pthread_t,1);
-  xbt_assert0(!pthread_mutex_init(&(res->mutex), NULL), "Mutex initialization error");
-  xbt_assert0(!pthread_cond_init(&(res->cond), NULL), "Condition initialization error");
-#else
-  /* FIXME: strerror is not thread safe */
-  xbt_assert2(getcontext(&(res->uc))==0,"Error in context saving: %d (%s)", errno, strerror(errno));
-  res->uc.uc_link = NULL;
-  /*   res->uc.uc_link = &(current_context->uc); */
-  /* WARNING : when this context is over, the current_context (i.e. the 
-     father), is awaken... Theorically, the wrapper should prevent using 
-     this feature. */
-  res->uc.uc_stack.ss_sp = res->stack;
-  res->uc.uc_stack.ss_size = STACK_SIZE;
-#endif
-  res->argc = argc;
-  res->argv = argv;
-  res->startup_func = startup_func;
-  res->startup_arg = startup_arg;
-  res->cleanup_func = cleanup_func;
-  res->cleanup_arg = cleanup_arg;
-
-  xbt_swag_insert(res, context_living);
-
-  return res;
+	xbt_context_t res = NULL;
+	
+	res = xbt_new0(s_xbt_context_t,1);
+	
+	res->code = code;
+	#ifdef CONTEXT_THREADS
+	res->mutex = xbt_mutex_init();
+        res->cond = xbt_thcond_init();
+	#else 
+
+	xbt_assert2(getcontext(&(res->uc))==0,"Error in context saving: %d (%s)", errno, strerror(errno));
+	res->uc.uc_link = NULL;
+	/*   res->uc.uc_link = &(current_context->uc); */
+	/* WARNING : when this context is over, the current_context (i.e. the 
+	father), is awaken... Theorically, the wrapper should prevent using 
+	this feature. */
+	res->uc.uc_stack.ss_sp = pth_skaddr_makecontext(res->stack,STACK_SIZE);
+	res->uc.uc_stack.ss_size = pth_sksize_makecontext(res->stack,STACK_SIZE);
+	#endif /* CONTEXT_THREADS or not */
+	
+	res->argc = argc;
+	res->argv = argv;
+	res->startup_func = startup_func;
+	res->startup_arg = startup_arg;
+	res->cleanup_func = cleanup_func;
+	res->cleanup_arg = cleanup_arg;
+	res->exception = xbt_new(ex_ctx_t,1);
+	XBT_CTX_INITIALIZE(res->exception);
+	
+	xbt_swag_insert(res, context_living);
+	
+	return res;
 }
 
 /** 
@@ -251,7 +355,7 @@ xbt_context_t xbt_context_new(xbt_context_function_t code,
  */
 void xbt_context_yield(void)
 {
-  __xbt_context_yield(current_context);
+	__xbt_context_yield(current_context);
 }
 
 /** 
@@ -263,9 +367,9 @@ void xbt_context_yield(void)
  */
 void xbt_context_schedule(xbt_context_t context)
 {
-  xbt_assert0((current_context==init_context),
-	      "You are not supposed to run this function here!");
-  __xbt_context_yield(context);
+	DEBUG1("Scheduling %p",context);
+	xbt_assert0((current_context==init_context),"You are not supposed to run this function here!");
+	__xbt_context_yield(context);
 }
 
 /** 
@@ -273,17 +377,26 @@ void xbt_context_schedule(xbt_context_t context)
  * that has been allocated in this module.
  */
 void xbt_context_exit(void) {
-  xbt_context_t context=NULL;
-
-  xbt_context_empty_trash();
-  xbt_swag_free(context_to_destroy);
-
-  while((context=xbt_swag_extract(context_living)))
-    xbt_context_free(context);
-
-  xbt_swag_free(context_living);
-
-  init_context = current_context = NULL ;
+	xbt_context_t context=NULL;
+	
+	xbt_context_empty_trash();
+	while((context=xbt_swag_extract(context_living))) {
+	  if(context!=init_context) {
+	    xbt_context_kill(context);
+	  }
+	}
+	free(init_context->exception);   
+	free(init_context);   
+	init_context = current_context = NULL ;
+
+	xbt_context_empty_trash();
+	xbt_swag_free(context_to_destroy);
+	xbt_swag_free(context_living);
+	
+#ifdef CONTEXT_THREADS	   
+	xbt_mutex_destroy(creation_mutex);
+	xbt_thcond_destroy(creation_cond);
+#endif   
 }
 
 /** 
@@ -291,19 +404,15 @@ void xbt_context_exit(void) {
  *
  * This function simply kills \a context... scarry isn't it ?
  */
-void xbt_context_free(xbt_context_t context)
+void xbt_context_kill(xbt_context_t context)
 {
-  int i ;
-
-  xbt_swag_remove(context, context_living);  
-  for(i=0;i<context->argc; i++) 
-    if(context->argv[i]) free(context->argv[i]);
-  if(context->argv) free(context->argv);
-  
-  if(context->cleanup_func)
-    context->cleanup_func(context->cleanup_arg);
-  xbt_context_destroy(context);
-
-  return;
+	DEBUG1("Killing %p", context);
+
+	context->iwannadie=1;
+	DEBUG1("Scheduling %p",context);
+	__xbt_context_yield(context);
+	DEBUG1("End of Scheduling %p",context);
+	
+	return;
 }
 /* @} */