1
1
This commit was SVN r24193.
Этот коммит содержится в:
Mike Dubman 2010-12-28 07:11:46 +00:00
родитель b339a7a07b
Коммит 3d517c0285
3 изменённых файлов: 40 добавлений и 18 удалений

Просмотреть файл

@ -11,12 +11,33 @@
#include <fca_api.h>
#ifndef FCA_API
#define OMPI_FCA_VERSION 12
#else
#define OMPI_FCA_VERSION FCA_API
#endif
/*
* FCA API compatibility layer.
* MPI build must define an FCA version macro.
*/
#ifdef OMPI_FCA_VERSION_1_2
#define OMPI_FCA_BARRIER 1
#define OMPI_FCA_BCAST 1
#define OMPI_FCA_REDUCE 1
#define OMPI_FCA_ALLREDUCE 1
#define OMPI_FCA_REDUCE_SCATTER 0
#define OMPI_FCA_GATHER 0
#define OMPI_FCA_GATHERV 0
#define OMPI_FCA_ALLTOALL 0
#define OMPI_FCA_ALLTOALLV 0
#define OMPI_FCA_ALLTOALLW 0
#if OMPI_FCA_VERSION == 12
#define OMPI_FCA_ALLGATHER 0
#define FCA_API_ABI_MAJOR 1
#define FCA_API_ABI_MINOR 2
@ -92,11 +113,12 @@ static inline void mca_coll_fca_get_reduce_root(int root_rank, int my_rank,
spec->is_root = root_rank == my_rank;
}
#elif OMPI_FCA_VERSION_2_0
#elif OMPI_FCA_VERSION == 20
#define OMPI_FCA_ALLGATHER 1
#define FCA_API_ABI_MAJOR 2
#define FCA_API_ABI_MINOR 0
#define OMPI_FCA_ALLGATHER 1
#define OMPI_FCA_PROGRESS 1

Просмотреть файл

@ -170,7 +170,7 @@ int mca_coll_fca_get_fca_lib(struct ompi_communicator_t *comm)
GET_FCA_SYM(do_all_reduce);
GET_FCA_SYM(do_bcast);
GET_FCA_SYM(do_barrier);
#ifdef OMPI_FCA_ALLGATHER
#if OMPI_FCA_ALLGATHER == 1
GET_FCA_SYM(do_allgather);
GET_FCA_SYM(do_allgatherv);
#endif
@ -260,74 +260,74 @@ static int fca_register(void)
mca_base_param_reg_int(c, "enable_barrier",
"[1|0|] Enable/Disable FCA Barrier support",
false, false,
1,
OMPI_FCA_BCAST,
&mca_coll_fca_component.fca_enable_barrier);
mca_base_param_reg_int(c, "enable_bcast",
"[1|0|] Enable/Disable FCA Bcast support",
false, false,
1,
OMPI_FCA_BCAST,
&mca_coll_fca_component.fca_enable_bcast);
mca_base_param_reg_int(c, "enable_reduce",
"[1|0|] Enable/Disable FCA Reduce support",
false, false,
1,
OMPI_FCA_REDUCE,
&mca_coll_fca_component.fca_enable_reduce);
mca_base_param_reg_int(c, "enable_reduce_scatter",
"[1|0|] Enable/Disable FCA Reduce support",
false, false,
0,
OMPI_FCA_REDUCE_SCATTER,
&mca_coll_fca_component.fca_enable_reduce_scatter);
mca_base_param_reg_int(c, "enable_allreduce",
"[1|0|] Enable/Disable FCA Allreduce support",
false, false,
1,
OMPI_FCA_ALLREDUCE,
&mca_coll_fca_component.fca_enable_allreduce);
mca_base_param_reg_int(c, "enable_allgather",
"[1|0|] Enable/Disable FCA Allgather support",
false, false,
1,
OMPI_FCA_ALLGATHER,
&mca_coll_fca_component.fca_enable_allgather);
mca_base_param_reg_int(c, "enable_allgatherv",
"[1|0|] Enable/Disable FCA Allgatherv support",
false, false,
1,
OMPI_FCA_ALLGATHER,
&mca_coll_fca_component.fca_enable_allgatherv);
mca_base_param_reg_int(c, "enable_gather",
"[1|0|] Enable/Disable FCA Gather support",
false, false,
0,
OMPI_FCA_GATHER,
&mca_coll_fca_component.fca_enable_gather);
mca_base_param_reg_int(c, "enable_gatherv",
"[1|0|] Enable/Disable FCA Gatherv support",
false, false,
0,
OMPI_FCA_GATHER,
&mca_coll_fca_component.fca_enable_gatherv);
mca_base_param_reg_int(c, "enable_alltoall",
"[1|0|] Enable/Disable FCA AlltoAll support",
false, false,
0,
OMPI_FCA_ALLTOALL,
&mca_coll_fca_component.fca_enable_alltoall);
mca_base_param_reg_int(c, "enable_alltoallv",
"[1|0|] Enable/Disable FCA AlltoAllv support",
false, false,
0,
OMPI_FCA_ALLTOALLV,
&mca_coll_fca_component.fca_enable_alltoallv);
mca_base_param_reg_int(c, "enable_alltoallw",
"[1|0|] Enable/Disable FCA AlltoAllw support",
false, false,
0,
OMPI_FCA_ALLTOALLW,
&mca_coll_fca_component.fca_enable_alltoallw);

Просмотреть файл

@ -293,7 +293,7 @@ int mca_coll_fca_allgather(void *sbuf, int scount, struct ompi_datatype_t *sdtyp
mca_coll_base_module_t *module)
{
mca_coll_fca_module_t *fca_module = (mca_coll_fca_module_t*)module;
#ifdef OMPI_FCA_ALLGATHER
#if OMPI_FCA_ALLGATHER == 1
fca_gather_spec_t spec = {0,};
int ret;
@ -344,7 +344,7 @@ int mca_coll_fca_allgatherv(void *sbuf, int scount,
mca_coll_base_module_t *module)
{
mca_coll_fca_module_t *fca_module = (mca_coll_fca_module_t*)module;
#ifdef OMPI_FCA_ALLGATHER
#if OMPI_FCA_ALLGATHER == 1
fca_gatherv_spec_t spec;
int relemsize;
int comm_size;