X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9f21f35eadfc5d1f43d3e7a4b591711fd7fb9616..6ac51c40fd30b90107eadda2a0d808a5210bcc28:/src/smpi/smpi_deployment.cpp diff --git a/src/smpi/smpi_deployment.cpp b/src/smpi/smpi_deployment.cpp index d9ad5ac1ff..bfb684b12e 100644 --- a/src/smpi/smpi_deployment.cpp +++ b/src/smpi/smpi_deployment.cpp @@ -69,12 +69,12 @@ void smpi_deployment_register_process(const char* instance_id, int rank, int ind xbt_assert(instance, "Error, unknown instance %s", instance_id); if(instance->comm_world == MPI_COMM_NULL){ - MPI_Group group = smpi_group_new(instance->size); - instance->comm_world = smpi_comm_new(group, nullptr); + MPI_Group group = new simgrid::smpi::Group(instance->size); + instance->comm_world = new simgrid::smpi::Comm(group, nullptr); } instance->present_processes++; index_to_process_data[index]=instance->index+rank; - smpi_group_set_mapping(smpi_comm_group(instance->comm_world), index, rank); + instance->comm_world->group()->set_mapping(index, rank); *bar = instance->finalization_barrier; *comm = &instance->comm_world; } @@ -85,8 +85,8 @@ void smpi_deployment_cleanup_instances(){ char *name = nullptr; xbt_dict_foreach(smpi_instances, cursor, name, instance) { if(instance->comm_world!=MPI_COMM_NULL) - while (smpi_group_unuse(smpi_comm_group(instance->comm_world)) > 0); - xbt_free(instance->comm_world); + while (instance->comm_world->group()->unuse() > 0); + delete instance->comm_world; MSG_barrier_destroy(instance->finalization_barrier); } xbt_dict_free(&smpi_instances);