X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/504b4d20dd2db9ea1eaa9c4b390b2a412d7c9779..dec242c057a35631bad2c2464580873b0c1200f3:/src/simix/smx_process.c diff --git a/src/simix/smx_process.c b/src/simix/smx_process.c index 52dc6c2218..0e31c2e84c 100644 --- a/src/simix/smx_process.c +++ b/src/simix/smx_process.c @@ -9,6 +9,7 @@ #include "xbt/sysdep.h" #include "xbt/log.h" #include "xbt/dict.h" +#include "msg/mailbox.h" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_process, simix, "Logging specific to SIMIX (process)"); @@ -55,13 +56,15 @@ void SIMIX_process_cleanup(void *arg) smx_process_t SIMIX_process_create(const char *name, xbt_main_func_t code, void *data, const char *hostname, int argc, - char **argv, /*props*/xbt_dict_t properties) + char **argv, xbt_dict_t properties) { smx_simdata_process_t simdata = xbt_new0(s_smx_simdata_process_t, 1); smx_process_t process = xbt_new0(s_smx_process_t, 1); smx_process_t self = NULL; smx_host_t host = SIMIX_host_get_by_name(hostname); - + /*char alias[MAX_ALIAS_NAME + 1] = {0}; + msg_mailbox_t mailbox;*/ + xbt_assert0(((code != NULL) && (host != NULL)), "Invalid parameters"); /* Simulator Data */ @@ -93,6 +96,11 @@ smx_process_t SIMIX_process_create(const char *name, 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); + + /*sprintf(alias,"%s:%s",hostname,process->name); + + mailbox = MSG_mailbox_new(alias); + MSG_mailbox_set_hostname(mailbox, hostname);*/ return process; } @@ -135,23 +143,24 @@ void SIMIX_jprocess_create(const char *name, smx_host_t host, simdata->argc = 0; simdata->argv = NULL; - simdata->context = xbt_context_new(name,NULL, NULL, NULL, + + simdata->context = xbt_context_new(name,NULL, NULL, jprocess, simix_global-> cleanup_process_function, process, /* argc/argv */ 0, NULL); - + /* Process structure */ process->name = xbt_strdup(name); process->simdata = simdata; process->data = data; - SIMIX_process_set_jprocess(process, jprocess); - SIMIX_process_set_jenv(process, jenv); xbt_swag_insert(process, host->simdata->process_list); /* fix current_process, about which xbt_context_start mocks around */ self = simix_global->current_process; + xbt_context_start(process->simdata->context); + simix_global->current_process = self; xbt_swag_insert(process, simix_global->process_list); @@ -388,25 +397,3 @@ int SIMIX_process_is_suspended(smx_process_t process) } -/* Helper functions for jMSG: manipulate the context data without breaking the module separation */ -#include "xbt/context.h" /* to pass java objects from MSG to the context */ - -void SIMIX_process_set_jprocess(smx_process_t process, void *jp) -{ - xbt_context_set_jprocess(process->simdata->context, jp); -} - -void *SIMIX_process_get_jprocess(smx_process_t process) -{ - return xbt_context_get_jprocess(process->simdata->context); -} - -void SIMIX_process_set_jenv(smx_process_t process, void *je) -{ - xbt_context_set_jenv(process->simdata->context, je); -} - -void *SIMIX_process_get_jenv(smx_process_t process) -{ - return xbt_context_get_jenv(process->simdata->context); -}