X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a6842b518fd3973d810bae84ad5110c26b20953b..347996b4a10c4e8579080692afa60e0afb88b60a:/src/smpi/smpi_global.cpp diff --git a/src/smpi/smpi_global.cpp b/src/smpi/smpi_global.cpp index 2dc16b63b2..e9ef952fad 100644 --- a/src/smpi/smpi_global.cpp +++ b/src/smpi/smpi_global.cpp @@ -98,17 +98,17 @@ void smpi_process_init(int *argc, char ***argv) MPI_Comm* temp_comm_world; xbt_bar_t temp_bar; - smpi_deployment_register_process(instance_id, rank, index, &temp_comm_world ,&temp_bar); - data = smpi_process_remote_data(index); - data->comm_world = temp_comm_world; + smpi_deployment_register_process(instance_id, rank, index, &temp_comm_world, &temp_bar); + data = smpi_process_remote_data(index); + data->comm_world = temp_comm_world; if(temp_bar != NULL) data->finalization_barrier = temp_bar; - data->index = index; + data->index = index; data->instance_id = instance_id; - data->replaying = 0; + data->replaying = 0; //xbt_free(simcall_process_get_data(proc)); - simdata_process_t simdata = static_cast(simcall_process_get_data(proc)); - simdata->data = data; + simdata_process_t simdata = static_cast(simcall_process_get_data(proc)); + simdata->data = data; if (*argc > 3) { free((*argv)[1]); @@ -439,15 +439,15 @@ void smpi_global_init(void) smpi_universe_size = process_count; process_data = xbt_new0(smpi_process_data_t, process_count); for (i = 0; i < process_count; i++) { - process_data[i] = xbt_new(s_smpi_process_data_t, 1); - //process_data[i]->index = i; - process_data[i]->argc = NULL; - process_data[i]->argv = NULL; - process_data[i]->mailbox = simcall_rdv_create(get_mailbox_name(name, i)); - process_data[i]->mailbox_small = + process_data[i] = xbt_new(s_smpi_process_data_t, 1); + //process_data[i]->index = i; + process_data[i]->argc = NULL; + process_data[i]->argv = NULL; + process_data[i]->mailbox = simcall_rdv_create(get_mailbox_name(name, i)); + process_data[i]->mailbox_small = simcall_rdv_create(get_mailbox_name_small(name, i)); - process_data[i]->mailboxes_mutex = xbt_mutex_init(); - process_data[i]->timer = xbt_os_timer_new(); + process_data[i]->mailboxes_mutex = xbt_mutex_init(); + process_data[i]->timer = xbt_os_timer_new(); if (MC_is_active()) MC_ignore_heap(process_data[i]->timer, xbt_os_timer_size()); process_data[i]->comm_self = MPI_COMM_NULL;