while ((process = xbt_swag_extract(simix_global->process_to_destroy))){
SIMIX_context_free(process->context);
+
+ /* Free the exception allocated at creation time */
+ if (process->exception)
+ free(process->exception);
+
free(process->name);
process->name = NULL;
free(process);
/**
* \brief Creates and runs the maestro process
*/
-void __SIMIX_create_maestro_process()
+void SIMIX_create_maestro_process()
{
smx_process_t process = NULL;
process = xbt_new0(s_smx_process_t, 1);
/* Process data */
process->name = (char *)"";
+ process->exception = xbt_new(ex_ctx_t, 1);
+ XBT_CTX_INITIALIZE(process->exception);
+
/* Create a dummy context for maestro */
process->context = SIMIX_context_new(NULL, 0, NULL, NULL, NULL);
process->mutex = NULL;
process->cond = NULL;
process->iwannadie = 0;
-
+ process->data = data;
+
VERB1("Create context %s", process->name);
process->context = SIMIX_context_new(code, argc, argv,
simix_global->cleanup_process_function,
process);
- process->data = data;
+ process->exception = xbt_new(ex_ctx_t, 1);
+ XBT_CTX_INITIALIZE(process->exception);
/* Add properties */
process->properties = properties;
return process;
}
-/**
- * \brief Creates and runs a new #smx_process_t hosting a JAVA thread
- *
- * Warning: this should only be used in libsimgrid4java, since it create
- * a context with no code, which leads to segfaults in plain libsimgrid
- */
-void SIMIX_jprocess_create(const char *name, smx_host_t host,
- void *data,
- void *jprocess, void *jenv, smx_process_t * res)
-{
- smx_process_t process = xbt_new0(s_smx_process_t, 1);
- smx_process_t self = NULL;
-
- /* HACK: We need this trick because when we xbt_context_new() do
- syncronization stuff, the s_process field in the m_process needs
- to have a valid value, and we call xbt_context_new() before
- returning, of course, ie, before providing a right value to the
- caller (Java_simgrid_msg_Msg_processCreate) have time to store it
- in place. This way, we initialize the m_process->simdata->s_process
- field ourself ASAP.
-
- All this would be much simpler if the synchronization stuff would be done
- in the JAVA world, I think.
- */
- *res = process;
-
- DEBUG5("jprocess_create(name=%s,host=%p,data=%p,jproc=%p,jenv=%p)",
- name, host, data, jprocess, jenv);
- xbt_assert0(host, "Invalid parameters");
-
- /* Process data */
- process->name = xbt_strdup(name);
- process->smx_host = host;
- process->mutex = NULL;
- process->cond = NULL;
- process->context = SIMIX_context_new(jprocess, 0, NULL, NULL, NULL);
- process->data = data;
-
- /* Add the process to it's host process list */
- xbt_swag_insert(&process, host->process_list);
-
- /* fix current_process, about which xbt_context_start mocks around */
- self = simix_global->current_process;
- SIMIX_context_start(process->context);
- simix_global->current_process = self;
-
- /* Now insert it in the global process list and in the process to run list */
- xbt_swag_insert(process, simix_global->process_list);
- DEBUG2("Inserting %s(%s) in the to_run list", process->name, host->name);
- xbt_swag_insert(process, simix_global->process_to_run);
-}
-
/** \brief Kill a SIMIX process
*
* This function simply kills a \a process... scarry isn't it ? :).
if (process == SIMIX_process_self())
SIMIX_context_stop(process->context);
else
- __SIMIX_process_schedule(process);
+ SIMIX_process_schedule(process);
}
* Only the processes can call this function, giving back the control
* to the maestro
*/
-void __SIMIX_process_yield(void)
+void SIMIX_process_yield(void)
{
DEBUG1("Yield process '%s'", simix_global->current_process->name);
xbt_assert0((simix_global->current_process != simix_global->maestro_process),
SIMIX_context_stop(simix_global->current_process->context);
}
-void __SIMIX_process_schedule(smx_process_t new_process)
+void SIMIX_process_schedule(smx_process_t new_process)
{
DEBUG1("Scheduling context: '%s'", new_process->name);
/* restore the current process to the previously saved process */
simix_global->current_process = old_process;
}
+
+/* callback: context fetching */
+ex_ctx_t *SIMIX_process_get_exception(void)
+{
+ return simix_global->current_process->exception;
+}
+
+/* callback: termination */
+void SIMIX_process_exception_terminate(xbt_ex_t * e)
+{
+ xbt_ex_display(e);
+ abort();
+}
+
+
