src/smpi/smpi_coll.hpp

   1 /*High level handling of collective algorithms*/
   2 /* Copyright (c) 2009-2010, 2012-2014. The SimGrid Team.
   3  * All rights reserved.                                                     */
   4
   5 /* This program is free software; you can redistribute it and/or modify it
   6  * under the terms of the license (GNU LGPL) which comes with this package. */
   7
   8 #ifndef SMPI_COLL_HPP
   9 #define SMPI_COLL_HPP
  10
  11 #include <xbt/base.h>
  12
  13 #include "private.h"
  14
  15 /** \brief MPI collective description */
  16
  17 struct mpi_coll_description {
  18   const char *name;
  19   const char *description;
  20   void *coll;
  21 };
  22 typedef struct mpi_coll_description  s_mpi_coll_description_t;
  23 typedef struct mpi_coll_description* mpi_coll_description_t;
  24
  25
  26 namespace simgrid{
  27 namespace smpi{
  28
  29
  30 class Colls{
  31   private:
  32   public:
  33     static void set_gather(const char* name);
  34     static void set_allgather(const char* name);
  35     static void set_allgatherv(const char* name);
  36     static void set_alltoall(const char* name);
  37     static void set_alltoallv(const char* name);
  38     static void set_allreduce(const char* name);
  39     static void set_reduce(const char* name);
  40     static void set_reduce_scatter(const char* name);
  41     static void set_scatter(const char* name);
  42     static void set_barrier(const char* name);
  43     static void set_bcast(const char* name);
  44
  45     static s_mpi_coll_description_t mpi_coll_gather_description[];
  46     static s_mpi_coll_description_t mpi_coll_allgather_description[];
  47     static s_mpi_coll_description_t mpi_coll_allgatherv_description[];
  48     static s_mpi_coll_description_t mpi_coll_allreduce_description[];
  49     static s_mpi_coll_description_t mpi_coll_alltoall_description[];
  50     static s_mpi_coll_description_t mpi_coll_alltoallv_description[];
  51     static s_mpi_coll_description_t mpi_coll_bcast_description[];
  52     static s_mpi_coll_description_t mpi_coll_reduce_description[];
  53     static s_mpi_coll_description_t mpi_coll_reduce_scatter_description[];
  54     static s_mpi_coll_description_t mpi_coll_scatter_description[];
  55     static s_mpi_coll_description_t mpi_coll_barrier_description[];
  56
  57
  58     static XBT_PUBLIC(void) coll_help(const char *category, s_mpi_coll_description_t * table);
  59     static XBT_PUBLIC(int) find_coll_description(s_mpi_coll_description_t * table, const char *name, const char *desc);
  60     static void set_collectives();
  61
  62     static int (*gather)(void *, int, MPI_Datatype, void*, int, MPI_Datatype, int root, MPI_Comm);
  63     static int (*allgather)(void *, int, MPI_Datatype, void*, int, MPI_Datatype, MPI_Comm);
  64     static int (*allgatherv)(void *, int, MPI_Datatype, void*, int*, int*, MPI_Datatype, MPI_Comm);
  65     static int (*allreduce)(void *sbuf, void *rbuf, int rcount, MPI_Datatype dtype, MPI_Op op, MPI_Comm comm);
  66     static int (*alltoall)(void *, int, MPI_Datatype, void*, int, MPI_Datatype, MPI_Comm);
  67     static int (*alltoallv)(void *, int*, int*, MPI_Datatype, void*, int*, int*, MPI_Datatype, MPI_Comm);
  68     static int (*bcast)(void *buf, int count, MPI_Datatype datatype, int root, MPI_Comm com);
  69     static int (*reduce)(void *buf, void *rbuf, int count, MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm);
  70     static int (*reduce_scatter)(void *sbuf, void *rbuf, int *rcounts,MPI_Datatype dtype,MPI_Op  op,MPI_Comm  comm);
  71     static int (*scatter)(void *sendbuf, int sendcount, MPI_Datatype sendtype,void *recvbuf, int recvcount, MPI_Datatype recvtype,int root, MPI_Comm comm);
  72     static int (*barrier)(MPI_Comm comm);
  73
  74 //These fairly unused collectives only have one implementation in SMPI
  75
  76     static int gatherv(void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf, int *recvcounts, int *displs, MPI_Datatype recvtype, int root, MPI_Comm comm);
  77     static int scatterv(void *sendbuf, int *sendcounts, int *displs, MPI_Datatype sendtype, void *recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm);
  78     static int scan(void *sendbuf, void *recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm);
  79     static int exscan(void *sendbuf, void *recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm);
  80
  81     static void (*smpi_coll_cleanup_callback)();
  82 };
  83
  84 class Coll_algo{
  85   private:
  86     char* description_;
  87   public:
  88     char* description();
  89 };
  90
  91 class Coll_gather : public Coll_algo {
  92   private:
  93   public:
  94     static int gather (void *, int, MPI_Datatype, void*, int, MPI_Datatype, int root, MPI_Comm);
  95 };
  96
  97 class Coll_allgather : public Coll_algo {
  98   private:
  99   public:
 100     static int allgather (void *, int, MPI_Datatype, void*, int, MPI_Datatype, MPI_Comm);
 101 };
 102
 103 class Coll_allgatherv : public Coll_algo {
 104   private:
 105   public:
 106     static int allgatherv (void *, int, MPI_Datatype, void*, int*, int*, MPI_Datatype, MPI_Comm);
 107 };
 108
 109 class Coll_allreduce : public Coll_algo {
 110   private:
 111   public:
 112     static int allreduce (void *sbuf, void *rbuf, int rcount, MPI_Datatype dtype, MPI_Op op, MPI_Comm comm);
 113 };
 114
 115 class Coll_alltoall : public Coll_algo {
 116   private:
 117   public:
 118     static int alltoall (void *, int, MPI_Datatype, void*, int, MPI_Datatype, MPI_Comm);
 119 };
 120
 121 class Coll_alltoallv : public Coll_algo {
 122   private:
 123   public:
 124     static int alltoallv (void *, int*, int*, MPI_Datatype, void*, int*, int*, MPI_Datatype, MPI_Comm);
 125 };
 126
 127 class Coll_bcast : public Coll_algo {
 128   private:
 129   public:
 130     static int bcast (void *buf, int count, MPI_Datatype datatype, int root, MPI_Comm com);
 131 };
 132
 133 class Coll_reduce : public Coll_algo {
 134   private:
 135   public:
 136     static int reduce (void *buf, void *rbuf, int count, MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm);
 137 };
 138
 139 class Coll_reduce_scatter : public Coll_algo {
 140   private:
 141   public:
 142     static int reduce_scatter (void *sbuf, void *rbuf, int *rcounts,MPI_Datatype dtype,MPI_Op  op,MPI_Comm  comm);
 143 };
 144
 145 class Coll_scatter : public Coll_algo {
 146   private:
 147   public:
 148     static int scatter (void *sendbuf, int sendcount, MPI_Datatype sendtype,void *recvbuf, int recvcount, MPI_Datatype recvtype,int root, MPI_Comm comm);
 149 };
 150
 151 class Coll_barrier : public Coll_algo {
 152   private:
 153   public:
 154     static int barrier (MPI_Comm);
 155 };
 156
 157
 158
 159 #define COLL_DESCRIPTION(cat, ret, args, name) \
 160   {# name,\
 161    # cat " " # name " collective",\
 162    (void*) Coll_ ## cat ## _ ## name::cat }
 163
 164 #define COLL_PROTO(cat, ret, args, name) \
 165 class Coll_ ## cat ## _ ## name : public Coll_ ## cat { \
 166 public: \
 167 static ret cat  (COLL_UNPAREN args); \
 168 };
 169
 170 #define COLL_UNPAREN(...)  __VA_ARGS__
 171
 172 #define COLL_APPLY(action, sig, name) action(sig, name)
 173 #define COLL_COMMA ,
 174 #define COLL_NOsep
 175 #define COLL_NOTHING(...)
 176
 177 /*************
 178  * GATHER *
 179  *************/
 180
 181 #define COLL_GATHER_SIG gather, int, \
 182                           (void *send_buff, int send_count, MPI_Datatype send_type, \
 183                            void *recv_buff, int recv_count, MPI_Datatype recv_type, \
 184                            int root, MPI_Comm comm)
 185
 186 #define COLL_GATHERS(action, COLL_sep) \
 187 COLL_APPLY(action, COLL_GATHER_SIG, default) COLL_sep \
 188 COLL_APPLY(action, COLL_GATHER_SIG, ompi) COLL_sep \
 189 COLL_APPLY(action, COLL_GATHER_SIG, ompi_basic_linear) COLL_sep \
 190 COLL_APPLY(action, COLL_GATHER_SIG, ompi_binomial) COLL_sep \
 191 COLL_APPLY(action, COLL_GATHER_SIG, ompi_linear_sync) COLL_sep \
 192 COLL_APPLY(action, COLL_GATHER_SIG, mpich) COLL_sep \
 193 COLL_APPLY(action, COLL_GATHER_SIG, mvapich2) COLL_sep \
 194 COLL_APPLY(action, COLL_GATHER_SIG, mvapich2_two_level) COLL_sep \
 195 COLL_APPLY(action, COLL_GATHER_SIG, impi) COLL_sep \
 196 COLL_APPLY(action, COLL_GATHER_SIG, automatic)
 197
 198 COLL_GATHERS(COLL_PROTO, COLL_NOsep)
 199
 200 /*************
 201  * ALLGATHER *
 202  *************/
 203 #define COLL_ALLGATHER_SIG allgather, int, \
 204                           (void *send_buff, int send_count, MPI_Datatype send_type, \
 205                            void *recv_buff, int recv_count, MPI_Datatype recv_type, \
 206                            MPI_Comm comm)
 207
 208 #define COLL_ALLGATHERS(action, COLL_sep) \
 209 COLL_APPLY(action, COLL_ALLGATHER_SIG, default) COLL_sep \
 210 COLL_APPLY(action, COLL_ALLGATHER_SIG, 2dmesh) COLL_sep \
 211 COLL_APPLY(action, COLL_ALLGATHER_SIG, 3dmesh) COLL_sep \
 212 COLL_APPLY(action, COLL_ALLGATHER_SIG, bruck) COLL_sep \
 213 COLL_APPLY(action, COLL_ALLGATHER_SIG, GB) COLL_sep \
 214 COLL_APPLY(action, COLL_ALLGATHER_SIG, loosely_lr) COLL_sep \
 215 COLL_APPLY(action, COLL_ALLGATHER_SIG, NTSLR) COLL_sep \
 216 COLL_APPLY(action, COLL_ALLGATHER_SIG, NTSLR_NB) COLL_sep \
 217 COLL_APPLY(action, COLL_ALLGATHER_SIG, pair) COLL_sep \
 218 COLL_APPLY(action, COLL_ALLGATHER_SIG, rdb) COLL_sep \
 219 COLL_APPLY(action, COLL_ALLGATHER_SIG, rhv) COLL_sep \
 220 COLL_APPLY(action, COLL_ALLGATHER_SIG, ring) COLL_sep \
 221 COLL_APPLY(action, COLL_ALLGATHER_SIG, SMP_NTS) COLL_sep \
 222 COLL_APPLY(action, COLL_ALLGATHER_SIG, smp_simple) COLL_sep \
 223 COLL_APPLY(action, COLL_ALLGATHER_SIG, spreading_simple) COLL_sep \
 224 COLL_APPLY(action, COLL_ALLGATHER_SIG, ompi) COLL_sep \
 225 COLL_APPLY(action, COLL_ALLGATHER_SIG, ompi_neighborexchange) COLL_sep \
 226 COLL_APPLY(action, COLL_ALLGATHER_SIG, mvapich2) COLL_sep \
 227 COLL_APPLY(action, COLL_ALLGATHER_SIG, mvapich2_smp) COLL_sep \
 228 COLL_APPLY(action, COLL_ALLGATHER_SIG, mpich) COLL_sep \
 229 COLL_APPLY(action, COLL_ALLGATHER_SIG, impi) COLL_sep \
 230 COLL_APPLY(action, COLL_ALLGATHER_SIG, automatic)
 231
 232 COLL_ALLGATHERS(COLL_PROTO, COLL_NOsep)
 233
 234 /**************
 235  * ALLGATHERV *
 236  **************/
 237 #define COLL_ALLGATHERV_SIG allgatherv, int, \
 238                           (void *send_buff, int send_count, MPI_Datatype send_type, \
 239                            void *recv_buff, int *recv_count, int *recv_disps, \
 240                            MPI_Datatype recv_type, MPI_Comm comm)
 241
 242 #define COLL_ALLGATHERVS(action, COLL_sep) \
 243 COLL_APPLY(action, COLL_ALLGATHERV_SIG, default) COLL_sep \
 244 COLL_APPLY(action, COLL_ALLGATHERV_SIG, GB) COLL_sep \
 245 COLL_APPLY(action, COLL_ALLGATHERV_SIG, pair) COLL_sep \
 246 COLL_APPLY(action, COLL_ALLGATHERV_SIG, ring) COLL_sep \
 247 COLL_APPLY(action, COLL_ALLGATHERV_SIG, ompi) COLL_sep \
 248 COLL_APPLY(action, COLL_ALLGATHERV_SIG, ompi_neighborexchange) COLL_sep \
 249 COLL_APPLY(action, COLL_ALLGATHERV_SIG, ompi_bruck) COLL_sep \
 250 COLL_APPLY(action, COLL_ALLGATHERV_SIG, mpich) COLL_sep \
 251 COLL_APPLY(action, COLL_ALLGATHERV_SIG, mpich_rdb) COLL_sep \
 252 COLL_APPLY(action, COLL_ALLGATHERV_SIG, mpich_ring) COLL_sep \
 253 COLL_APPLY(action, COLL_ALLGATHERV_SIG, mvapich2) COLL_sep \
 254 COLL_APPLY(action, COLL_ALLGATHERV_SIG, impi) COLL_sep \
 255 COLL_APPLY(action, COLL_ALLGATHERV_SIG, automatic)
 256
 257 COLL_ALLGATHERVS(COLL_PROTO, COLL_NOsep)
 258
 259 /*************
 260  * ALLREDUCE *
 261  *************/
 262 #define COLL_ALLREDUCE_SIG allreduce, int, \
 263                           (void *sbuf, void *rbuf, int rcount, \
 264                            MPI_Datatype dtype, MPI_Op op, MPI_Comm comm)
 265
 266 #define COLL_ALLREDUCES(action, COLL_sep) \
 267 COLL_APPLY(action, COLL_ALLREDUCE_SIG, default) COLL_sep \
 268 COLL_APPLY(action, COLL_ALLREDUCE_SIG, lr) COLL_sep \
 269 COLL_APPLY(action, COLL_ALLREDUCE_SIG, rab1) COLL_sep \
 270 COLL_APPLY(action, COLL_ALLREDUCE_SIG, rab2) COLL_sep \
 271 COLL_APPLY(action, COLL_ALLREDUCE_SIG, rab_rdb) COLL_sep \
 272 COLL_APPLY(action, COLL_ALLREDUCE_SIG, rdb) COLL_sep \
 273 COLL_APPLY(action, COLL_ALLREDUCE_SIG, smp_binomial) COLL_sep \
 274 COLL_APPLY(action, COLL_ALLREDUCE_SIG, smp_binomial_pipeline) COLL_sep \
 275 COLL_APPLY(action, COLL_ALLREDUCE_SIG, smp_rdb) COLL_sep \
 276 COLL_APPLY(action, COLL_ALLREDUCE_SIG, smp_rsag) COLL_sep \
 277 COLL_APPLY(action, COLL_ALLREDUCE_SIG, smp_rsag_lr) COLL_sep \
 278 COLL_APPLY(action, COLL_ALLREDUCE_SIG, smp_rsag_rab) COLL_sep \
 279 COLL_APPLY(action, COLL_ALLREDUCE_SIG, redbcast) COLL_sep \
 280 COLL_APPLY(action, COLL_ALLREDUCE_SIG, ompi) COLL_sep \
 281 COLL_APPLY(action, COLL_ALLREDUCE_SIG, ompi_ring_segmented) COLL_sep \
 282 COLL_APPLY(action, COLL_ALLREDUCE_SIG, mpich) COLL_sep \
 283 COLL_APPLY(action, COLL_ALLREDUCE_SIG, mvapich2) COLL_sep \
 284 COLL_APPLY(action, COLL_ALLREDUCE_SIG, mvapich2_rs) COLL_sep \
 285 COLL_APPLY(action, COLL_ALLREDUCE_SIG, mvapich2_two_level) COLL_sep \
 286 COLL_APPLY(action, COLL_ALLREDUCE_SIG, impi) COLL_sep \
 287 COLL_APPLY(action, COLL_ALLREDUCE_SIG, rab) COLL_sep \
 288 COLL_APPLY(action, COLL_ALLREDUCE_SIG, automatic)
 289
 290 COLL_ALLREDUCES(COLL_PROTO, COLL_NOsep)
 291
 292 /************
 293  * ALLTOALL *
 294  ************/
 295 #define COLL_ALLTOALL_SIG alltoall, int, \
 296                          (void *send_buff, int send_count, MPI_Datatype send_type, \
 297                           void *recv_buff, int recv_count, MPI_Datatype recv_type, \
 298                           MPI_Comm comm)
 299
 300 #define COLL_ALLTOALLS(action, COLL_sep) \
 301 COLL_APPLY(action, COLL_ALLTOALL_SIG, default) COLL_sep \
 302 COLL_APPLY(action, COLL_ALLTOALL_SIG, 2dmesh) COLL_sep \
 303 COLL_APPLY(action, COLL_ALLTOALL_SIG, 3dmesh) COLL_sep \
 304 COLL_APPLY(action, COLL_ALLTOALL_SIG, basic_linear) COLL_sep \
 305 COLL_APPLY(action, COLL_ALLTOALL_SIG, bruck) COLL_sep \
 306 COLL_APPLY(action, COLL_ALLTOALL_SIG, pair) COLL_sep \
 307 COLL_APPLY(action, COLL_ALLTOALL_SIG, pair_rma) COLL_sep \
 308 COLL_APPLY(action, COLL_ALLTOALL_SIG, pair_light_barrier) COLL_sep \
 309 COLL_APPLY(action, COLL_ALLTOALL_SIG, pair_mpi_barrier) COLL_sep \
 310 COLL_APPLY(action, COLL_ALLTOALL_SIG, pair_one_barrier) COLL_sep \
 311 COLL_APPLY(action, COLL_ALLTOALL_SIG, rdb) COLL_sep \
 312 COLL_APPLY(action, COLL_ALLTOALL_SIG, ring) COLL_sep \
 313 COLL_APPLY(action, COLL_ALLTOALL_SIG, ring_light_barrier) COLL_sep \
 314 COLL_APPLY(action, COLL_ALLTOALL_SIG, ring_mpi_barrier) COLL_sep \
 315 COLL_APPLY(action, COLL_ALLTOALL_SIG, ring_one_barrier) COLL_sep \
 316 COLL_APPLY(action, COLL_ALLTOALL_SIG, mvapich2) COLL_sep \
 317 COLL_APPLY(action, COLL_ALLTOALL_SIG, mvapich2_scatter_dest) COLL_sep \
 318 COLL_APPLY(action, COLL_ALLTOALL_SIG, ompi) COLL_sep \
 319 COLL_APPLY(action, COLL_ALLTOALL_SIG, mpich) COLL_sep \
 320 COLL_APPLY(action, COLL_ALLTOALL_SIG, impi) COLL_sep \
 321 COLL_APPLY(action, COLL_ALLTOALL_SIG, automatic)
 322
 323 COLL_ALLTOALLS(COLL_PROTO, COLL_NOsep)
 324
 325 /*************
 326  * ALLTOALLV *
 327  *************/
 328 #define COLL_ALLTOALLV_SIG alltoallv, int, \
 329                          (void *send_buff, int *send_counts, int *send_disps, MPI_Datatype send_type, \
 330                           void *recv_buff, int *recv_counts, int *recv_disps, MPI_Datatype recv_type, \
 331                           MPI_Comm comm)
 332
 333 #define COLL_ALLTOALLVS(action, COLL_sep) \
 334 COLL_APPLY(action, COLL_ALLTOALLV_SIG, default) COLL_sep \
 335 COLL_APPLY(action, COLL_ALLTOALLV_SIG, bruck) COLL_sep \
 336 COLL_APPLY(action, COLL_ALLTOALLV_SIG, pair) COLL_sep \
 337 COLL_APPLY(action, COLL_ALLTOALLV_SIG, pair_light_barrier) COLL_sep \
 338 COLL_APPLY(action, COLL_ALLTOALLV_SIG, pair_mpi_barrier) COLL_sep \
 339 COLL_APPLY(action, COLL_ALLTOALLV_SIG, pair_one_barrier) COLL_sep \
 340 COLL_APPLY(action, COLL_ALLTOALLV_SIG, ring) COLL_sep \
 341 COLL_APPLY(action, COLL_ALLTOALLV_SIG, ring_light_barrier) COLL_sep \
 342 COLL_APPLY(action, COLL_ALLTOALLV_SIG, ring_mpi_barrier) COLL_sep \
 343 COLL_APPLY(action, COLL_ALLTOALLV_SIG, ring_one_barrier) COLL_sep \
 344 COLL_APPLY(action, COLL_ALLTOALLV_SIG, ompi) COLL_sep \
 345 COLL_APPLY(action, COLL_ALLTOALLV_SIG, mpich) COLL_sep \
 346 COLL_APPLY(action, COLL_ALLTOALLV_SIG, ompi_basic_linear) COLL_sep \
 347 COLL_APPLY(action, COLL_ALLTOALLV_SIG, mvapich2) COLL_sep \
 348 COLL_APPLY(action, COLL_ALLTOALLV_SIG, impi) COLL_sep \
 349 COLL_APPLY(action, COLL_ALLTOALLV_SIG, automatic)
 350
 351 COLL_ALLTOALLVS(COLL_PROTO, COLL_NOsep)
 352
 353 /*********
 354  * BCAST *
 355  *********/
 356 #define COLL_BCAST_SIG bcast, int, \
 357                       (void *buf, int count, MPI_Datatype datatype, \
 358                        int root, MPI_Comm comm)
 359
 360 #define COLL_BCASTS(action, COLL_sep) \
 361 COLL_APPLY(action, COLL_BCAST_SIG, default) COLL_sep \
 362 COLL_APPLY(action, COLL_BCAST_SIG, arrival_pattern_aware) COLL_sep \
 363 COLL_APPLY(action, COLL_BCAST_SIG, arrival_pattern_aware_wait) COLL_sep \
 364 COLL_APPLY(action, COLL_BCAST_SIG, arrival_scatter) COLL_sep \
 365 COLL_APPLY(action, COLL_BCAST_SIG, binomial_tree) COLL_sep \
 366 COLL_APPLY(action, COLL_BCAST_SIG, flattree) COLL_sep \
 367 COLL_APPLY(action, COLL_BCAST_SIG, flattree_pipeline) COLL_sep \
 368 COLL_APPLY(action, COLL_BCAST_SIG, NTSB) COLL_sep \
 369 COLL_APPLY(action, COLL_BCAST_SIG, NTSL) COLL_sep \
 370 COLL_APPLY(action, COLL_BCAST_SIG, NTSL_Isend) COLL_sep \
 371 COLL_APPLY(action, COLL_BCAST_SIG, scatter_LR_allgather) COLL_sep \
 372 COLL_APPLY(action, COLL_BCAST_SIG, scatter_rdb_allgather) COLL_sep \
 373 COLL_APPLY(action, COLL_BCAST_SIG, SMP_binary) COLL_sep \
 374 COLL_APPLY(action, COLL_BCAST_SIG, SMP_binomial) COLL_sep \
 375 COLL_APPLY(action, COLL_BCAST_SIG, SMP_linear) COLL_sep \
 376 COLL_APPLY(action, COLL_BCAST_SIG, ompi) COLL_sep \
 377 COLL_APPLY(action, COLL_BCAST_SIG, ompi_split_bintree) COLL_sep \
 378 COLL_APPLY(action, COLL_BCAST_SIG, ompi_pipeline) COLL_sep \
 379 COLL_APPLY(action, COLL_BCAST_SIG, mpich) COLL_sep \
 380 COLL_APPLY(action, COLL_BCAST_SIG, mvapich2)   COLL_sep \
 381 COLL_APPLY(action, COLL_BCAST_SIG, mvapich2_inter_node)   COLL_sep \
 382 COLL_APPLY(action, COLL_BCAST_SIG, mvapich2_intra_node)   COLL_sep \
 383 COLL_APPLY(action, COLL_BCAST_SIG, mvapich2_knomial_intra_node)   COLL_sep \
 384 COLL_APPLY(action, COLL_BCAST_SIG, impi)   COLL_sep \
 385 COLL_APPLY(action, COLL_BCAST_SIG, automatic)
 386
 387 COLL_BCASTS(COLL_PROTO, COLL_NOsep)
 388
 389
 390 /**********
 391  * REDUCE *
 392  **********/
 393 #define COLL_REDUCE_SIG reduce, int, \
 394                        (void *buf, void *rbuf, int count, MPI_Datatype datatype, \
 395                         MPI_Op op, int root, MPI_Comm comm)
 396
 397 #define COLL_REDUCES(action, COLL_sep) \
 398 COLL_APPLY(action, COLL_REDUCE_SIG, default) COLL_sep \
 399 COLL_APPLY(action, COLL_REDUCE_SIG, arrival_pattern_aware) COLL_sep \
 400 COLL_APPLY(action, COLL_REDUCE_SIG, binomial) COLL_sep \
 401 COLL_APPLY(action, COLL_REDUCE_SIG, flat_tree) COLL_sep \
 402 COLL_APPLY(action, COLL_REDUCE_SIG, NTSL) COLL_sep \
 403 COLL_APPLY(action, COLL_REDUCE_SIG, scatter_gather) COLL_sep \
 404 COLL_APPLY(action, COLL_REDUCE_SIG, ompi) COLL_sep \
 405 COLL_APPLY(action, COLL_REDUCE_SIG, ompi_chain) COLL_sep \
 406 COLL_APPLY(action, COLL_REDUCE_SIG, ompi_pipeline) COLL_sep \
 407 COLL_APPLY(action, COLL_REDUCE_SIG, ompi_basic_linear) COLL_sep \
 408 COLL_APPLY(action, COLL_REDUCE_SIG, ompi_in_order_binary) COLL_sep \
 409 COLL_APPLY(action, COLL_REDUCE_SIG, ompi_binary) COLL_sep \
 410 COLL_APPLY(action, COLL_REDUCE_SIG, ompi_binomial) COLL_sep \
 411 COLL_APPLY(action, COLL_REDUCE_SIG, mpich) COLL_sep \
 412 COLL_APPLY(action, COLL_REDUCE_SIG, mvapich2) COLL_sep \
 413 COLL_APPLY(action, COLL_REDUCE_SIG, mvapich2_knomial) COLL_sep \
 414 COLL_APPLY(action, COLL_REDUCE_SIG, mvapich2_two_level) COLL_sep \
 415 COLL_APPLY(action, COLL_REDUCE_SIG, impi) COLL_sep \
 416 COLL_APPLY(action, COLL_REDUCE_SIG, rab) COLL_sep \
 417 COLL_APPLY(action, COLL_REDUCE_SIG, automatic)
 418
 419 COLL_REDUCES(COLL_PROTO, COLL_NOsep)
 420
 421 /*************
 422  * REDUCE_SCATTER *
 423  *************/
 424 #define COLL_REDUCE_SCATTER_SIG reduce_scatter, int, \
 425                           (void *sbuf, void *rbuf, int *rcounts,\
 426                     MPI_Datatype dtype,MPI_Op  op,MPI_Comm  comm)
 427
 428 #define COLL_REDUCE_SCATTERS(action, COLL_sep) \
 429 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, default) COLL_sep \
 430 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, ompi) COLL_sep \
 431 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, ompi_basic_recursivehalving) COLL_sep \
 432 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, ompi_ring)  COLL_sep \
 433 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, mpich) COLL_sep \
 434 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, mpich_pair) COLL_sep \
 435 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, mpich_rdb) COLL_sep \
 436 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, mpich_noncomm) COLL_sep \
 437 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, mvapich2) COLL_sep \
 438 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, impi) COLL_sep \
 439 COLL_APPLY(action, COLL_REDUCE_SCATTER_SIG, automatic)
 440
 441
 442
 443 COLL_REDUCE_SCATTERS(COLL_PROTO, COLL_NOsep)
 444
 445
 446 /*************
 447  * SCATTER *
 448  *************/
 449 #define COLL_SCATTER_SIG scatter, int, \
 450                 (void *sendbuf, int sendcount, MPI_Datatype sendtype,\
 451                 void *recvbuf, int recvcount, MPI_Datatype recvtype,\
 452                 int root, MPI_Comm comm)
 453
 454 #define COLL_SCATTERS(action, COLL_sep) \
 455 COLL_APPLY(action, COLL_SCATTER_SIG, default) COLL_sep \
 456 COLL_APPLY(action, COLL_SCATTER_SIG, ompi) COLL_sep \
 457 COLL_APPLY(action, COLL_SCATTER_SIG, ompi_basic_linear) COLL_sep \
 458 COLL_APPLY(action, COLL_SCATTER_SIG, ompi_binomial)  COLL_sep \
 459 COLL_APPLY(action, COLL_SCATTER_SIG, mpich)   COLL_sep \
 460 COLL_APPLY(action, COLL_SCATTER_SIG, mvapich2)   COLL_sep \
 461 COLL_APPLY(action, COLL_SCATTER_SIG, mvapich2_two_level_binomial)   COLL_sep \
 462 COLL_APPLY(action, COLL_SCATTER_SIG, mvapich2_two_level_direct)   COLL_sep \
 463 COLL_APPLY(action, COLL_SCATTER_SIG, impi)   COLL_sep \
 464 COLL_APPLY(action, COLL_SCATTER_SIG, automatic)
 465
 466 COLL_SCATTERS(COLL_PROTO, COLL_NOsep)
 467
 468 /*************
 469  * SCATTER *
 470  *************/
 471 #define COLL_BARRIER_SIG barrier, int, \
 472                 (MPI_Comm comm)
 473
 474 #define COLL_BARRIERS(action, COLL_sep) \
 475 COLL_APPLY(action, COLL_BARRIER_SIG, default) COLL_sep \
 476 COLL_APPLY(action, COLL_BARRIER_SIG, ompi) COLL_sep \
 477 COLL_APPLY(action, COLL_BARRIER_SIG, ompi_basic_linear) COLL_sep \
 478 COLL_APPLY(action, COLL_BARRIER_SIG, ompi_two_procs)  COLL_sep \
 479 COLL_APPLY(action, COLL_BARRIER_SIG, ompi_tree)  COLL_sep \
 480 COLL_APPLY(action, COLL_BARRIER_SIG, ompi_bruck)  COLL_sep \
 481 COLL_APPLY(action, COLL_BARRIER_SIG, ompi_recursivedoubling) COLL_sep \
 482 COLL_APPLY(action, COLL_BARRIER_SIG, ompi_doublering) COLL_sep \
 483 COLL_APPLY(action, COLL_BARRIER_SIG, mpich)   COLL_sep \
 484 COLL_APPLY(action, COLL_BARRIER_SIG, mvapich2_pair)   COLL_sep \
 485 COLL_APPLY(action, COLL_BARRIER_SIG, mvapich2)   COLL_sep \
 486 COLL_APPLY(action, COLL_BARRIER_SIG, impi)   COLL_sep \
 487 COLL_APPLY(action, COLL_BARRIER_SIG, automatic)
 488
 489 COLL_BARRIERS(COLL_PROTO, COLL_NOsep)
 490
 491
 492 }
 493 }
 494
 495 #endif