Copyright update 2021

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

diff --git a/src/ParaMEDMEM/CommInterface.cxx b/src/ParaMEDMEM/CommInterface.cxx
index 948f099d88a77ce5254c3d40825da44f4f66ff8d..f6f33020503f7535c188dcc941c043a2ecbac031 100644 (file)
--- a/src/ParaMEDMEM/CommInterface.cxx
+++ b/src/ParaMEDMEM/CommInterface.cxx
@@ -1,4 +1,4 @@
-// Copyright (C) 2007-2015  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
@@ -19,48 +19,55 @@
 
 #include "CommInterface.hxx"
 
-namespace ParaMEDMEM
+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.
+  MPI_Datatype ParaTraits<Int32>::MPIDataType = MPI_INT;
 
-    It is a helper class that gathers the calls to the MPI
-    library that are made in the %ParaMEDMEM library. This gathering
-    allows easier gathering of information about the communication
-    in the library.
+  MPI_Datatype ParaTraits<Int64>::MPIDataType = MPI_LONG;
 
-    It is typically called after the MPI_Init() call in a program. It is afterwards passed as a parameter to the constructors of %ParaMEDMEM objects so that they access the MPI library via the CommInterface.
-
-    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);
-    ParaMEDMEM::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);
-    ParaMEDMEM::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);
   }
+
 }