X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/325a6bb78259a0e6835f69ca6fc2341dc620418d..1bf13b42c09009ec33fd1928b8bffd2ded6bb931:/src/smpi/internals/smpi_deployment.cpp diff --git a/src/smpi/internals/smpi_deployment.cpp b/src/smpi/internals/smpi_deployment.cpp index 5e74b69313..7bbf7475a8 100644 --- a/src/smpi/internals/smpi_deployment.cpp +++ b/src/smpi/internals/smpi_deployment.cpp @@ -34,7 +34,6 @@ public: const std::string name_; unsigned int size_; - std::vector present_processes_; unsigned int finalized_ranks_ = 0; MPI_Comm comm_world_; }; @@ -66,10 +65,9 @@ void SMPI_app_instance_register(const char *name, xbt_main_func_t code, int num_ smpi_instances.insert(std::pair(name, instance)); } -void smpi_deployment_register_process(const std::string& instance_id, int rank, simgrid::s4u::ActorPtr actor) +void smpi_deployment_register_process(const std::string& instance_id, int rank, simgrid::s4u::Actor* actor) { - Instance& instance = smpi_instances.at(instance_id); - instance.present_processes_.push_back(actor); + const Instance& instance = smpi_instances.at(instance_id); instance.comm_world_->group()->set_mapping(actor, rank); } @@ -79,7 +77,6 @@ void smpi_deployment_unregister_process(const std::string& instance_id) instance.finalized_ranks_++; if (instance.finalized_ranks_ == instance.size_) { - instance.present_processes_.clear(); simgrid::smpi::Comm::destroy(instance.comm_world_); smpi_instances.erase(instance_id); } @@ -99,7 +96,6 @@ void smpi_deployment_cleanup_instances(){ for (auto const& item : smpi_instances) { XBT_CINFO(smpi, "Stalling SMPI instance: %s. Do all your MPI ranks call MPI_Finalize()?", item.first.c_str()); Instance instance = item.second; - instance.present_processes_.clear(); simgrid::smpi::Comm::destroy(instance.comm_world_); } smpi_instances.clear();