attach errhandlers to some forgotten calls

[simgrid.git] / src / smpi / include / smpi_coll.hpp

diff --git a/src/smpi/include/smpi_coll.hpp b/src/smpi/include/smpi_coll.hpp
index 3e73854..537510b 100644 (file)
--- a/src/smpi/include/smpi_coll.hpp
+++ b/src/smpi/include/smpi_coll.hpp
@@ -14,24 +14,24 @@
 /** @brief MPI collective description */
 
 #define COLL_DEFS(cat, ret, args, args2)                                                                               \
-  static void set_##cat(const std::string& name);                                                                      \
-  static s_mpi_coll_description_t mpi_coll_##cat##_description[];                                                      \
+  static void _XBT_CONCAT(set_, cat)(const std::string& name);                                                         \
+  static s_mpi_coll_description_t _XBT_CONCAT3(mpi_coll_, cat, _description)[];                                        \
   static int(*cat) args;
 
 #define COLL_SIG(cat, ret, args, args2)\
     static int cat args;
 
+#define COLL_DESCRIPTION(cat, ret, args, name)                                                                         \
+  {                                                                                                                    \
+    _XBT_STRINGIFY(name)                                                                                               \
+    , _XBT_STRINGIFY(cat) " " _XBT_STRINGIFY(name) " collective", (void*)_XBT_CONCAT4(Coll_, cat, _, name)::cat        \
+  }
 
-#define COLL_DESCRIPTION(cat, ret, args, name) \
-  {# name,\
-   # cat " " # name " collective",\
-   (void*) Coll_ ## cat ## _ ## name::cat }
-
-#define COLL_PROTO(cat, ret, args, name) \
-class Coll_ ## cat ## _ ## name : public Coll { \
-public: \
-static ret cat  (COLL_UNPAREN args); \
-};
+#define COLL_PROTO(cat, ret, args, name)                                                                               \
+  class _XBT_CONCAT4(Coll_, cat, _, name) : public Coll {                                                              \
+  public:                                                                                                              \
+    static ret cat(COLL_UNPAREN args);                                                                                 \
+  };
 
 #define COLL_UNPAREN(...)  __VA_ARGS__
 
@@ -96,17 +96,17 @@ public:
   static void set_collectives();
 
   // for each collective type, create the set_* prototype, the description array and the function pointer
-  COLL_APPLY(COLL_DEFS, COLL_GATHER_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_ALLGATHER_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_ALLGATHERV_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_REDUCE_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_ALLREDUCE_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_REDUCE_SCATTER_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_SCATTER_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_BARRIER_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_BCAST_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_ALLTOALL_SIG, "");
-  COLL_APPLY(COLL_DEFS, COLL_ALLTOALLV_SIG, "");
+  COLL_APPLY(COLL_DEFS, COLL_GATHER_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_ALLGATHER_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_ALLGATHERV_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_REDUCE_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_ALLREDUCE_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_REDUCE_SCATTER_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_SCATTER_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_BARRIER_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_BCAST_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_ALLTOALL_SIG, "")
+  COLL_APPLY(COLL_DEFS, COLL_ALLTOALLV_SIG, "")
 
   // These fairly unused collectives only have one implementation in SMPI
   static int gatherv(const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, const int* recvcounts, const int* displs,
@@ -120,41 +120,41 @@ public:
           const int* recvdisps, const MPI_Datatype* recvtypes, MPI_Comm comm);
 
   //async collectives
-  static int ibarrier(MPI_Comm comm, MPI_Request* request);
+  static int ibarrier(MPI_Comm comm, MPI_Request* request, int external=1);
   static int ibcast(void *buf, int count, MPI_Datatype datatype, 
-                   int root, MPI_Comm comm, MPI_Request* request);
+                   int root, MPI_Comm comm, MPI_Request* request, int external=1);
   static int igather (const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount,
-                                      MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request);
+                                      MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external=1);
   static int igatherv (const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf,
-                                       const int* recvcounts, const int* displs, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request);
+                                       const int* recvcounts, const int* displs, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iallgather (const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf,
-                                         int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request);
+                                         int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iallgatherv (const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf,
-                                          const int* recvcounts, const int* displs, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request);
+                                          const int* recvcounts, const int* displs, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iscatter (const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf,
-                                       int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request);
+                                       int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iscatterv (const void* sendbuf, const int* sendcounts, const int* displs, MPI_Datatype sendtype,
-                                        void* recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request);
+                                        void* recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm, MPI_Request *request, int external=1);
   static int ireduce
-         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm, MPI_Request *request);
+         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iallreduce
-         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request);
+         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iscan
-         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request);
+         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request, int external=1);
   static int iexscan
-         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request);
+         (const void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request, int external=1);
   static int ireduce_scatter
-         (const void* sendbuf, void* recvbuf, const int* recvcounts, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request);
+         (const void* sendbuf, void* recvbuf, const int* recvcounts, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request, int external=1);
   static int ireduce_scatter_block
-         (const void* sendbuf, void* recvbuf, int recvcount, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request);
+         (const void* sendbuf, void* recvbuf, int recvcount, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm, MPI_Request *request, int external=1);
   static int ialltoall (const void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf,
-                                        int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request);
+                                        int recvcount, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request, int external=1);
   static int ialltoallv
          (const void* sendbuf, const int* sendcounts, const int* senddisps, MPI_Datatype sendtype, void* recvbuf, const int* recvcounts,
-          const int* recvdisps, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request);
+          const int* recvdisps, MPI_Datatype recvtype, MPI_Comm comm, MPI_Request *request, int external=1);
   static int ialltoallw
          (const void* sendbuf, const int* sendcounts, const int* senddisps, const MPI_Datatype* sendtypes, void* recvbuf, const int* recvcounts,
-          const int* recvdisps, const MPI_Datatype* recvtypes, MPI_Comm comm, MPI_Request *request);
+          const int* recvdisps, const MPI_Datatype* recvtypes, MPI_Comm comm, MPI_Request *request, int external=1);
 
 
   static void (*smpi_coll_cleanup_callback)();
@@ -163,17 +163,17 @@ public:
 class Coll {
 public:
   // for each collective type, create a function member
-  COLL_APPLY(COLL_SIG, COLL_GATHER_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_ALLGATHER_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_ALLGATHERV_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_REDUCE_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_ALLREDUCE_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_REDUCE_SCATTER_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_SCATTER_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_BARRIER_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_BCAST_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_ALLTOALL_SIG, "");
-  COLL_APPLY(COLL_SIG, COLL_ALLTOALLV_SIG, "");
+  COLL_APPLY(COLL_SIG, COLL_GATHER_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_ALLGATHER_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_ALLGATHERV_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_REDUCE_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_ALLREDUCE_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_REDUCE_SCATTER_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_SCATTER_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_BARRIER_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_BCAST_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_ALLTOALL_SIG, "")
+  COLL_APPLY(COLL_SIG, COLL_ALLTOALLV_SIG, "")
 };
 
 /*************