+xbt_context_t xbt_context_new(const char *name,xbt_main_func_t code,
+ void_f_pvoid_t startup_func,
+ void *startup_arg,
+ 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;
+ res->name = xbt_strdup(name);
+#ifdef CONTEXT_THREADS
+ res->mutex = xbt_os_mutex_init();
+ res->cond = xbt_os_cond_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);
+
+ res->exception = xbt_new(ex_ctx_t, 1);
+ XBT_CTX_INITIALIZE(res->exception);
+#endif /* CONTEXT_THREADS or not */
+
+ res->iwannadie = 0; /* useless but makes valgrind happy */
+
+ 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;
+}
+
+static void xbt_context_free(xbt_context_t context) {
+ if (!context)
+ return;
+ DEBUG1("Freeing %p", context);
+ free(context->name);
+#ifdef CONTEXT_THREADS
+ /*DEBUG1("\t joining %p",(void *)context->thread->t); */
+ DEBUG1("\t joining %p", (void *) context->thread);
+
+ xbt_os_thread_join(context->thread, NULL);
+
+ DEBUG1("\t mutex_destroy %p", (void *) context->mutex);
+ xbt_os_mutex_destroy(context->mutex);
+ DEBUG1("\t cond_destroy %p", (void *) context->cond);
+ xbt_os_cond_destroy(context->cond);
+
+ context->thread = NULL;
+ context->mutex = NULL;
+ context->cond = NULL;
+#else
+ if (context->exception)
+ free(context->exception);
+#endif
+
+ free(context);
+ return;
+}
+
+/************************/
+/* Start/stop a context */
+/************************/
+static void xbt_context_stop(xbt_context_t context, int value);
+
+static void *__context_wrapper(void *c)
+{
+ xbt_context_t context = current_context;
+
+#ifdef CONTEXT_THREADS
+ context = (xbt_context_t) c;
+ context->thread = xbt_os_thread_self();
+
+ DEBUG3("**[ctx:%p;self:%p]** Lock creation_mutex %p ****", context,
+ (void *) xbt_os_thread_self(), creation_mutex);
+ xbt_os_mutex_lock(creation_mutex);
+ xbt_os_mutex_lock(context->mutex);
+
+ DEBUG4
+ ("**[ctx:%p;self:%p]** Releasing the creator (creation_cond %p,%p) ****",
+ context, (void *) xbt_os_thread_self(), creation_cond,
+ creation_mutex);
+ xbt_os_cond_signal(creation_cond);
+ xbt_os_mutex_unlock(creation_mutex);
+
+ DEBUG4("**[ctx:%p;self:%p]** Going to Jail on lock %p and cond %p ****",
+ context, (void *) xbt_os_thread_self(), context->mutex,
+ context->cond);
+ xbt_os_cond_wait(context->cond, context->mutex);
+
+ DEBUG3("**[ctx:%p;self:%p]** Unlocking individual %p ****",
+ context, (void *) xbt_os_thread_self(), context->mutex);
+ xbt_os_mutex_unlock(context->mutex);
+
+#endif
+
+ if (context->startup_func)
+ context->startup_func(context->startup_arg);
+
+ DEBUG0("Calling the main function");
+
+ xbt_context_stop(context, (context->code) (context->argc, context->argv));
+ return NULL;
+}
+/**
+ * \param context the context to start
+ *
+ * Calling this function prepares \a context to be run. It will
+ however run effectively only when calling #xbt_context_schedule
+ */
+void xbt_context_start(xbt_context_t context)
+{
+#ifdef CONTEXT_THREADS
+ /* Launch the thread */
+
+ DEBUG3("**[ctx:%p;self:%p]** Locking creation_mutex %p ****", context,
+ xbt_os_thread_self(), creation_mutex);
+ xbt_os_mutex_lock(creation_mutex);
+
+ DEBUG2("**[ctx:%p;self:%p]** Thread create ****", context,
+ xbt_os_thread_self());
+ context->thread = xbt_os_thread_create(context->name,__context_wrapper, context);
+ DEBUG3("**[ctx:%p;self:%p]** Thread created : %p ****", context,
+ xbt_os_thread_self(), context->thread);
+
+ DEBUG4
+ ("**[ctx:%p;self:%p]** Going to jail on creation_cond/mutex (%p,%p) ****",
+ context, xbt_os_thread_self(), creation_cond, creation_mutex);
+ xbt_os_cond_wait(creation_cond, creation_mutex);
+ DEBUG3("**[ctx:%p;self:%p]** Unlocking creation %p ****", context,
+ xbt_os_thread_self(), creation_mutex);
+ xbt_os_mutex_unlock(creation_mutex);
+#else
+ makecontext(&(context->uc), (void (*)(void)) __context_wrapper, 1,
+ context);
+#endif
+ return;
+}
+
+static void xbt_context_stop(xbt_context_t context, int value)