X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bc81bcfcd68831933a508b3fe478eae2d76b6c1a..b9e79eec822b45eb15b2779f4fa393b07b1e8fff:/src/smpi/include/smpi_group.hpp diff --git a/src/smpi/include/smpi_group.hpp b/src/smpi/include/smpi_group.hpp index eb56ba4e4c..99be12735a 100644 --- a/src/smpi/include/smpi_group.hpp +++ b/src/smpi/include/smpi_group.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2018. The SimGrid Team. +/* Copyright (c) 2010-2021. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -16,40 +16,41 @@ namespace simgrid{ namespace smpi{ class Group : public F2C{ - private: - int size_; - /* This is actually a map from int to int. We could use - * std::map here, but looking up a value there costs O(log(n)). - * For a vector, this costs O(1). We hence go with the vector. - */ - std::vector rank_to_actor_map_; - std::map actor_to_rank_map_; - std::vector index_to_rank_map_; - - int refcount_; - public: - explicit Group(); - explicit Group(int size); - explicit Group(Group* origin); - - void set_mapping(simgrid::s4u::ActorPtr actor, int rank); - int rank(int index); - simgrid::s4u::ActorPtr actor(int rank); - int rank(const simgrid::s4u::ActorPtr process); - void ref(); - static void unref(MPI_Group group); - int size(); - int compare(MPI_Group group2); - int incl(int n, int* ranks, MPI_Group* newgroup); - int excl(int n, int *ranks, MPI_Group * newgroup); - int group_union(MPI_Group group2, MPI_Group* newgroup); - int intersection(MPI_Group group2, MPI_Group* newgroup); - int difference(MPI_Group group2, MPI_Group* newgroup); - int range_incl(int n, int ranges[][3], MPI_Group * newgroup); - int range_excl(int n, int ranges[][3], MPI_Group * newgroup); - - static Group* f2c(int id); - + /* This is actually a map from int to s4u::Actor*. We could use std::map here, but looking up a value there costs + * O(log(n)). For a vector, this costs O(1). We hence go with the vector. + */ + std::vector rank_to_actor_map_; + std::map actor_to_rank_map_; + std::vector index_to_rank_map_; + + int refcount_ = 1; /* refcount_: start > 0 so that this group never gets freed */ + + int incl(const std::vector ranks, MPI_Group* newgroup) const; + int excl(const std::vector excl_map, MPI_Group* newgroup) const; + +public: + Group() = default; + explicit Group(int size) : rank_to_actor_map_(size, nullptr), index_to_rank_map_(size, MPI_UNDEFINED) {} + explicit Group(const Group* origin); + + void set_mapping(s4u::Actor* actor, int rank); + int rank(int index) const; + s4u::Actor* actor(int rank) const; + std::string name() const override {return std::string("MPI_Group");} + int rank(s4u::Actor* process) const; + void ref(); + static void unref(MPI_Group group); + int size() const { return static_cast(rank_to_actor_map_.size()); } + int compare(MPI_Group group2) const; + int incl(int n, const int* ranks, MPI_Group* newgroup) const; + int excl(int n, const int* ranks, MPI_Group* newgroup) const; + int group_union(MPI_Group group2, MPI_Group* newgroup) const; + int intersection(MPI_Group group2, MPI_Group* newgroup) const; + int difference(MPI_Group group2, MPI_Group* newgroup) const; + int range_incl(int n, int ranges[][3], MPI_Group* newgroup) const; + int range_excl(int n, int ranges[][3], MPI_Group* newgroup) const; + + static Group* f2c(int id); }; } }