X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/15f804cfddebc4fe4b305acd1c66487f2405420d..2f3c9cf811c7c608eb49a3ee14411a887b6a99c8:/src/smpi/mpi/smpi_comm.cpp diff --git a/src/smpi/mpi/smpi_comm.cpp b/src/smpi/mpi/smpi_comm.cpp index d8ca45b523..d6ca527e3f 100644 --- a/src/smpi/mpi/smpi_comm.cpp +++ b/src/smpi/mpi/smpi_comm.cpp @@ -120,6 +120,7 @@ int Comm::dup_with_info(MPI_Info info, MPI_Comm* newcomm){ (*newcomm)->info_=MPI_INFO_NULL; } if(info != MPI_INFO_NULL){ + info->ref(); (*newcomm)->info_=info; } return ret; @@ -333,6 +334,8 @@ void Comm::unref(Comm* comm){ if(comm->refcount_==0){ comm->cleanup_smp(); comm->cleanup_attr(); + if (comm->info_ != MPI_INFO_NULL) + simgrid::smpi::Info::unref(comm->info_); delete comm->topo_; // there's no use count on topos delete comm; } @@ -537,17 +540,21 @@ void Comm::finish_rma_calls(){ } } -MPI_Info Comm::info(){ - if(info_== MPI_INFO_NULL) +MPI_Info Comm::info() +{ + if (info_ == MPI_INFO_NULL) info_ = new Info(); info_->ref(); return info_; } -void Comm::set_info(MPI_Info info){ - if(info_!= MPI_INFO_NULL) +void Comm::set_info(MPI_Info info) +{ + if (info_ != MPI_INFO_NULL) + simgrid::smpi::Info::unref(info); + info_ = info; + if (info_ != MPI_INFO_NULL) info->ref(); - info_=info; } MPI_Errhandler Comm::errhandler(){