Copyright update 2021

[tools/medcoupling.git] / src / ParaMEDMEM / CommInterface.cxx

diff --git a/src/ParaMEDMEM/CommInterface.cxx b/src/ParaMEDMEM/CommInterface.cxx
index 6184d70774e5ff242bac8bec85b1ea285d1194d8..f6f33020503f7535c188dcc941c043a2ecbac031 100644 (file)
--- a/src/ParaMEDMEM/CommInterface.cxx
+++ b/src/ParaMEDMEM/CommInterface.cxx
@@ -1,4 +1,4 @@
-// Copyright (C) 2007-2020  CEA/DEN, EDF R&D
+// Copyright (C) 2007-2021  CEA/DEN, EDF R&D
 //
 // This library is free software; you can redistribute it and/or
 // modify it under the terms of the GNU Lesser General Public
@@ -21,46 +21,53 @@
 
 namespace MEDCoupling
 {
-  /*! \anchor CommInterface-det
-     \class CommInterface
+  MPI_Datatype ParaTraits<double>::MPIDataType = MPI_DOUBLE;
 
-    The class \a CommInterface is the gateway to the MPI library.
-    It is a wrapper around all MPI calls, thus trying to abstract the rest of the code from using the direct MPI API
-    (but this is not strictly respected overall in practice ...). It is used in all
-    the \ref parallel "DEC related classes".
+  MPI_Datatype ParaTraits<Int32>::MPIDataType = MPI_INT;
 
-    It is typically instantiated after the MPI_Init() call in a program and is afterwards passed as a
-    parameter to the constructors of various \ref parallel "parallel objects" so that they access the
-    MPI library via this common interface.
+  MPI_Datatype ParaTraits<Int64>::MPIDataType = MPI_LONG;
 
-    As an example, the following code excerpt initializes a processor group made of the zero processor.
-
-    \verbatim
-    #include "CommInterface.hxx"
-    #include "ProcessorGroup.hxx"
+  void CommInterface::gatherArrays(MPI_Comm comm, int root, const DataArrayIdType *array, std::vector< MCAuto<DataArrayIdType> >& arraysOut) const
+  {
+    this->gatherArraysT2<mcIdType>(comm,root,array,arraysOut);
+  }
 
-    int main(int argc, char** argv)
-    {
-    //initialization
-    MPI_Init(&argc, &argv);
-    MEDCoupling::CommInterface comm_interface;
+  /*!
+   * Generalized AllGather collective communication.
+   * This method send input \a array to all procs.
+   */
+  void CommInterface::allGatherArrays(MPI_Comm comm, const DataArrayIdType *array, std::vector< MCAuto<DataArrayIdType> >& arraysOut) const
+  {
+    this->allGatherArraysT2<mcIdType>(comm,array,arraysOut);
+  }
 
-    //setting up a processor group with proc 0
-    set<int> procs;
-    procs.insert(0);
-    MEDCoupling::ProcessorGroup group(procs, comm_interface);
+  /*!
+   * Generalized AllGather collective communication.
+   * This method send input \a array to all procs.
+   */
+  int CommInterface::allGatherArrays(MPI_Comm comm, const DataArrayIdType *array, std::unique_ptr<mcIdType[]>& result, std::unique_ptr<mcIdType[]>& resultIndex) const
+  {
+    return this->allGatherArraysT<mcIdType>(comm,array,result,resultIndex);
+  }
 
-    //cleanup
-    MPI_Finalize();
-    }
-    \endverbatim
-  */
+  void CommInterface::allToAllArrays(MPI_Comm comm, const std::vector< MCAuto<DataArrayDouble> >& arrays, std::vector< MCAuto<DataArrayDouble> >& arraysOut) const
+  {
+    this->allToAllArraysT<double>(comm,arrays,arraysOut);
+  }
 
-  CommInterface::CommInterface()
+  void CommInterface::allToAllArrays(MPI_Comm comm, const std::vector< MCAuto<DataArrayDouble> >& arrays, MCAuto<DataArrayDouble>& arraysOut) const
   {
+    std::unique_ptr<mcIdType[]> notUsed1;
+    mcIdType notUsed2;
+    this->allToAllArraysT2<double>(comm,arrays,arraysOut,notUsed1,notUsed2);
   }
 
-  CommInterface::~CommInterface()
+  /*!
+  * Generalized AllToAll collective communication.
+  */
+  void CommInterface::allToAllArrays(MPI_Comm comm, const std::vector< MCAuto<DataArrayIdType> >& arrays, std::vector< MCAuto<DataArrayIdType> >& arraysOut) const
   {
+    this->allToAllArraysT<mcIdType>(comm,arrays,arraysOut);
   }
+
 }