X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0f12caebeefc7985a0586836248238e475258079..656d24a575ca26a64c94174ff3573272979e081d:/src/simix/smx_process.cpp diff --git a/src/simix/smx_process.cpp b/src/simix/smx_process.cpp index 7b93e9ccef..f696d92b30 100644 --- a/src/simix/smx_process.cpp +++ b/src/simix/smx_process.cpp @@ -136,7 +136,7 @@ void SIMIX_process_empty_trash(void) xbt_dynar_free(&process->on_exit); xbt_free(process->name); - xbt_free(process); + delete process; } } @@ -147,7 +147,7 @@ void create_maestro(std::function code) { smx_process_t maestro = NULL; /* Create maestro process and intilialize it */ - maestro = xbt_new0(s_smx_process_t, 1); + maestro = new simgrid::simix::Process(); maestro->pid = simix_process_maxpid++; maestro->ppid = -1; maestro->name = (char*) ""; @@ -156,7 +156,7 @@ void create_maestro(std::function code) XBT_RUNNING_CTX_INITIALIZE(maestro->running_ctx); if (!code) { - maestro->context = SIMIX_context_new(NULL, 0, nullptr, NULL, maestro); + maestro->context = SIMIX_context_new(std::function(), NULL, maestro); } else { if (!simix_global) xbt_die("simix is not initialized, please call MSG_init first"); @@ -219,7 +219,7 @@ smx_process_t SIMIX_process_create_from_wrapper(smx_process_arg_t args) { args->properties, args->auto_restart, NULL); - xbt_free(args); + delete args; return process; } @@ -277,7 +277,7 @@ smx_process_t SIMIX_process_create( xbt_free(argv); } else { - process = xbt_new0(s_smx_process_t, 1); + process = new simgrid::simix::Process(); xbt_assert(((code != NULL) && (host != NULL)), "Invalid parameters"); /* Process data */ @@ -315,7 +315,9 @@ smx_process_t SIMIX_process_create( XBT_VERB("Create context %s", process->name); - process->context = SIMIX_context_new(code, argc, argv, simix_global->cleanup_process_function, process); + process->context = SIMIX_context_new( + simgrid::simix::wrap_main(code, argc, argv), + simix_global->cleanup_process_function, process); process->running_ctx = (xbt_running_ctx_t*) xbt_malloc0(sizeof(xbt_running_ctx_t)); XBT_RUNNING_CTX_INITIALIZE(process->running_ctx); @@ -368,7 +370,7 @@ smx_process_t SIMIX_process_attach( return nullptr; } - smx_process_t process = xbt_new0(s_smx_process_t, 1); + smx_process_t process = new simgrid::simix::Process(); /* Process data */ process->pid = simix_process_maxpid++; process->name = xbt_strdup(name); @@ -516,7 +518,7 @@ void SIMIX_process_kill(smx_process_t process, smx_process_t issuer) { } else if (raw != nullptr) { SIMIX_synchro_stop_waiting(process, &process->simcall); - SIMIX_synchro_destroy(process->waiting_synchro); + delete process->waiting_synchro; } else if (io != nullptr) { SIMIX_io_destroy(process->waiting_synchro);