X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d4f3a012fbbb4484ed74c6cec7b5444ffb15f27f..fe84e0ac0aeb2988a5625c87e4688735de44d480:/src/smpi/smpi_comm.hpp diff --git a/src/smpi/smpi_comm.hpp b/src/smpi/smpi_comm.hpp index aedf39e845..a2a2a60c1e 100644 --- a/src/smpi/smpi_comm.hpp +++ b/src/smpi/smpi_comm.hpp @@ -8,13 +8,7 @@ #define SMPI_COMM_HPP_INCLUDED #include "private.h" - - -typedef struct s_smpi_mpi_comm_key_elem { - MPI_Comm_copy_attr_function* copy_fn; - MPI_Comm_delete_attr_function* delete_fn; -} s_smpi_mpi_comm_key_elem_t; -typedef struct s_smpi_mpi_comm_key_elem *smpi_comm_key_elem; +#include namespace simgrid{ namespace smpi{ @@ -34,13 +28,14 @@ class Comm : public F2C, public Keyval{ int* non_uniform_map_; //set if smp nodes have a different number of processes allocated int is_blocked_;// are ranks allocated on the same smp node contiguous ? + std::list rma_wins_; // attached windows for synchronization. + public: static std::unordered_map keyvals_; static int keyval_id_; Comm() = default; Comm(MPI_Group group, MPI_Topology topo); - int dup(MPI_Comm* newcomm); MPI_Group group(); MPI_Topology topo(); @@ -56,7 +51,6 @@ class Comm : public F2C, public Keyval{ int is_uniform(); int is_blocked(); MPI_Comm split(int color, int key); - void cleanup_attributes(); void cleanup_smp(); void ref(); static void unref(MPI_Comm comm); @@ -71,6 +65,10 @@ class Comm : public F2C, public Keyval{ static int keyval_free(int* keyval); static void keyval_cleanup(); + void add_rma_win(MPI_Win win); + void remove_rma_win(MPI_Win win); + void finish_rma_calls(); + }; }