X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d43bb524e880bb9c42023f0f563578dfe17e404a..5d16106918532e9d25163cd0271c8cb6fd1f5e64:/src/smpi/smpi_mpi.c diff --git a/src/smpi/smpi_mpi.c b/src/smpi/smpi_mpi.c index 37518f91c1..674a1ed9ae 100644 --- a/src/smpi/smpi_mpi.c +++ b/src/smpi/smpi_mpi.c @@ -8,22 +8,53 @@ #include "smpi_coll_private.h" #include "smpi_mpi_dt_private.h" +#define MPI_CALL_IMPLEM(type,name,args) \ + type name args __attribute__((weak,alias("P"#name))); \ + type P##name args + XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_mpi, smpi, "Logging specific to SMPI (mpi)"); +#ifdef HAVE_TRACING +//this function need to be here because of the calls to smpi_bench +int TRACE_smpi_set_category(const char *category) +{ + //need to end bench otherwise categories for execution tasks are wrong + smpi_bench_end(); + int ret; + if (!IS_TRACING){ + ret = 1; + }else{ + if (category != NULL) { + ret = TRACE_category(category); + TRACE_category_set(SIMIX_process_self(), category); + }else{ + //if category is NULL, trace of platform is disabled for this process + TRACE_category_unset(SIMIX_process_self()); + ret = 0; + } + } + //begin bench after changing process's category + smpi_bench_begin(); + return ret; +} +#endif + /* MPI User level calls */ -int MPI_Init(int* argc, char*** argv) { +MPI_CALL_IMPLEM(int, MPI_Init, (int *argc, char ***argv)) +{ smpi_process_init(argc, argv); #ifdef HAVE_TRACING TRACE_smpi_init(smpi_process_index()); #endif - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return MPI_SUCCESS; } -int MPI_Finalize(void) { - smpi_bench_end(-1, NULL); +MPI_CALL_IMPLEM(int, MPI_Finalize, (void)) +{ + smpi_bench_end(); #ifdef HAVE_TRACING TRACE_smpi_finalize(smpi_process_index()); #endif @@ -31,303 +62,329 @@ int MPI_Finalize(void) { return MPI_SUCCESS; } -int MPI_Init_thread(int* argc, char*** argv, int required, int* provided) { - if(provided != NULL) { +MPI_CALL_IMPLEM(int, MPI_Init_thread, (int *argc, char ***argv, int required, int *provided)) +{ + if (provided != NULL) { *provided = MPI_THREAD_MULTIPLE; } return MPI_Init(argc, argv); } -int MPI_Query_thread(int* provided) { +MPI_CALL_IMPLEM(int, MPI_Query_thread, (int *provided)) +{ int retval; - smpi_bench_end(-1, NULL); - if(provided == NULL) { + smpi_bench_end(); + if (provided == NULL) { retval = MPI_ERR_ARG; } else { *provided = MPI_THREAD_MULTIPLE; retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Is_thread_main(int* flag) { +MPI_CALL_IMPLEM(int, MPI_Is_thread_main, (int *flag)) +{ int retval; - smpi_bench_end(-1, NULL); - if(flag == NULL) { + smpi_bench_end(); + if (flag == NULL) { retval = MPI_ERR_ARG; } else { *flag = smpi_process_index() == 0; retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Abort(MPI_Comm comm, int errorcode) { - smpi_bench_end(-1, NULL); +MPI_CALL_IMPLEM(int, MPI_Abort, (MPI_Comm comm, int errorcode)) +{ + smpi_bench_end(); smpi_process_destroy(); // FIXME: should kill all processes in comm instead SIMIX_process_kill(SIMIX_process_self()); return MPI_SUCCESS; } -double MPI_Wtime(void) { +double MPI_Wtime(void) +{ double time; - smpi_bench_end(-1, NULL); + smpi_bench_end(); time = SIMIX_get_clock(); - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return time; } -int MPI_Address(void *location, MPI_Aint *address) { +MPI_CALL_IMPLEM(int, MPI_Address, (void *location, MPI_Aint * address)) +{ int retval; - smpi_bench_end(-1, NULL); - if(!address) { + smpi_bench_end(); + if (!address) { retval = MPI_ERR_ARG; } else { - *address = (MPI_Aint)location; + *address = (MPI_Aint) location; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Type_free(MPI_Datatype* datatype) { +MPI_CALL_IMPLEM(int, MPI_Type_free, (MPI_Datatype * datatype)) +{ int retval; - smpi_bench_end(-1, NULL); - if(!datatype) { + smpi_bench_end(); + if (!datatype) { retval = MPI_ERR_ARG; } else { // FIXME: always fail for now retval = MPI_ERR_TYPE; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Type_size(MPI_Datatype datatype, int* size) { +MPI_CALL_IMPLEM(int, MPI_Type_size, (MPI_Datatype datatype, int *size)) +{ int retval; - smpi_bench_end(-1, NULL); - if(datatype == MPI_DATATYPE_NULL) { + smpi_bench_end(); + if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(size == NULL) { + } else if (size == NULL) { retval = MPI_ERR_ARG; } else { - *size = (int)smpi_datatype_size(datatype); + *size = (int) smpi_datatype_size(datatype); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Type_get_extent(MPI_Datatype datatype, MPI_Aint* lb, MPI_Aint* extent) { +MPI_CALL_IMPLEM(int, MPI_Type_get_extent, + (MPI_Datatype datatype, MPI_Aint * lb, + MPI_Aint * extent)) +{ int retval; - smpi_bench_end(-1, NULL); - if(datatype == MPI_DATATYPE_NULL) { + smpi_bench_end(); + if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(lb == NULL || extent == NULL) { + } else if (lb == NULL || extent == NULL) { retval = MPI_ERR_ARG; } else { retval = smpi_datatype_extent(datatype, lb, extent); } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Type_extent(MPI_Datatype datatype, MPI_Aint* extent) { +MPI_CALL_IMPLEM(int, MPI_Type_extent, (MPI_Datatype datatype, MPI_Aint * extent)) +{ int retval; MPI_Aint dummy; - smpi_bench_end(-1, NULL); - if(datatype == MPI_DATATYPE_NULL) { + smpi_bench_end(); + if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(extent == NULL) { + } else if (extent == NULL) { retval = MPI_ERR_ARG; } else { retval = smpi_datatype_extent(datatype, &dummy, extent); } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Type_lb(MPI_Datatype datatype, MPI_Aint* disp) { +MPI_CALL_IMPLEM(int, MPI_Type_lb, (MPI_Datatype datatype, MPI_Aint * disp)) +{ int retval; - smpi_bench_end(-1, NULL); - if(datatype == MPI_DATATYPE_NULL) { + smpi_bench_end(); + if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(disp == NULL) { + } else if (disp == NULL) { retval = MPI_ERR_ARG; } else { *disp = smpi_datatype_lb(datatype); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Type_ub(MPI_Datatype datatype, MPI_Aint* disp) { +MPI_CALL_IMPLEM(int, MPI_Type_ub, (MPI_Datatype datatype, MPI_Aint * disp)) +{ int retval; - smpi_bench_end(-1, NULL); - if(datatype == MPI_DATATYPE_NULL) { + smpi_bench_end(); + if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(disp == NULL) { + } else if (disp == NULL) { retval = MPI_ERR_ARG; } else { *disp = smpi_datatype_ub(datatype); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Op_create(MPI_User_function* function, int commute, MPI_Op* op) { +MPI_CALL_IMPLEM(int, MPI_Op_create, (MPI_User_function * function, int commute, MPI_Op * op)) +{ int retval; - smpi_bench_end(-1, NULL); - if(function == NULL || op == NULL) { + smpi_bench_end(); + if (function == NULL || op == NULL) { retval = MPI_ERR_ARG; } else { *op = smpi_op_new(function, commute); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Op_free(MPI_Op* op) { +MPI_CALL_IMPLEM(int, MPI_Op_free, (MPI_Op * op)) +{ int retval; - smpi_bench_end(-1, NULL); - if(op == NULL) { + smpi_bench_end(); + if (op == NULL) { retval = MPI_ERR_ARG; - } else if(*op == MPI_OP_NULL) { + } else if (*op == MPI_OP_NULL) { retval = MPI_ERR_OP; } else { smpi_op_destroy(*op); *op = MPI_OP_NULL; retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_free(MPI_Group *group) { +MPI_CALL_IMPLEM(int, MPI_Group_free, (MPI_Group * group)) +{ int retval; - smpi_bench_end(-1, NULL); - if(group == NULL) { + smpi_bench_end(); + if (group == NULL) { retval = MPI_ERR_ARG; } else { smpi_group_destroy(*group); *group = MPI_GROUP_NULL; retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_size(MPI_Group group, int* size) { +MPI_CALL_IMPLEM(int, MPI_Group_size, (MPI_Group group, int *size)) +{ int retval; - smpi_bench_end(-1, NULL); - if(group == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(size == NULL) { + } else if (size == NULL) { retval = MPI_ERR_ARG; } else { *size = smpi_group_size(group); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_rank(MPI_Group group, int* rank) { +MPI_CALL_IMPLEM(int, MPI_Group_rank, (MPI_Group group, int *rank)) +{ int retval; - smpi_bench_end(-1, NULL); - if(group == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(rank == NULL) { + } else if (rank == NULL) { retval = MPI_ERR_ARG; } else { *rank = smpi_group_rank(group, smpi_process_index()); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_translate_ranks (MPI_Group group1, int n, int* ranks1, MPI_Group group2, int* ranks2) { +MPI_CALL_IMPLEM(int, MPI_Group_translate_ranks, + (MPI_Group group1, int n, int *ranks1, + MPI_Group group2, int *ranks2)) +{ int retval, i, index; - smpi_bench_end(-1, NULL); - if(group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; } else { - for(i = 0; i < n; i++) { + for (i = 0; i < n; i++) { index = smpi_group_index(group1, ranks1[i]); ranks2[i] = smpi_group_rank(group2, index); } retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_compare(MPI_Group group1, MPI_Group group2, int* result) { +MPI_CALL_IMPLEM(int, MPI_Group_compare, (MPI_Group group1, MPI_Group group2, int *result)) +{ int retval; - smpi_bench_end(-1, NULL); - if(group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(result == NULL) { + } else if (result == NULL) { retval = MPI_ERR_ARG; } else { *result = smpi_group_compare(group1, group2); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_union(MPI_Group group1, MPI_Group group2, MPI_Group* newgroup) { +MPI_CALL_IMPLEM(int, MPI_Group_union, + (MPI_Group group1, MPI_Group group2, + MPI_Group * newgroup)) +{ int retval, i, proc1, proc2, size, size2; - smpi_bench_end(-1, NULL); - if(group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { size = smpi_group_size(group1); size2 = smpi_group_size(group2); - for(i = 0; i < size2; i++) { + for (i = 0; i < size2; i++) { proc2 = smpi_group_index(group2, i); proc1 = smpi_group_rank(group1, proc2); - if(proc1 == MPI_UNDEFINED) { + if (proc1 == MPI_UNDEFINED) { size++; } } - if(size == 0) { + if (size == 0) { *newgroup = MPI_GROUP_EMPTY; } else { *newgroup = smpi_group_new(size); size2 = smpi_group_size(group1); - for(i = 0; i < size2; i++) { + for (i = 0; i < size2; i++) { proc1 = smpi_group_index(group1, i); smpi_group_set_mapping(*newgroup, proc1, i); } - for(i = size2; i < size; i++) { + for (i = size2; i < size; i++) { proc2 = smpi_group_index(group2, i - size2); smpi_group_set_mapping(*newgroup, proc2, i); } @@ -335,37 +392,40 @@ int MPI_Group_union(MPI_Group group1, MPI_Group group2, MPI_Group* newgroup) { smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_intersection(MPI_Group group1, MPI_Group group2, MPI_Group* newgroup) { - int retval, i, proc1, proc2, size, size2; +MPI_CALL_IMPLEM(int, MPI_Group_intersection, + (MPI_Group group1, MPI_Group group2, + MPI_Group * newgroup)) +{ + int retval, i, proc1, proc2, size, size2; - smpi_bench_end(-1, NULL); - if(group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { size = smpi_group_size(group1); size2 = smpi_group_size(group2); - for(i = 0; i < size2; i++) { + for (i = 0; i < size2; i++) { proc2 = smpi_group_index(group2, i); proc1 = smpi_group_rank(group1, proc2); - if(proc1 == MPI_UNDEFINED) { + if (proc1 == MPI_UNDEFINED) { size--; } } - if(size == 0) { + if (size == 0) { *newgroup = MPI_GROUP_EMPTY; } else { *newgroup = smpi_group_new(size); size2 = smpi_group_size(group1); - for(i = 0; i < size2; i++) { + for (i = 0; i < size2; i++) { proc1 = smpi_group_index(group1, i); proc2 = smpi_group_rank(group2, proc1); - if(proc2 != MPI_UNDEFINED) { + if (proc2 != MPI_UNDEFINED) { smpi_group_set_mapping(*newgroup, proc1, i); } } @@ -373,35 +433,38 @@ int MPI_Group_intersection(MPI_Group group1, MPI_Group group2, MPI_Group* newgro smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_difference(MPI_Group group1, MPI_Group group2, MPI_Group* newgroup) { +MPI_CALL_IMPLEM(int, MPI_Group_difference, + (MPI_Group group1, MPI_Group group2, + MPI_Group * newgroup)) +{ int retval, i, proc1, proc2, size, size2; - smpi_bench_end(-1, NULL); - if(group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group1 == MPI_GROUP_NULL || group2 == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { size = size2 = smpi_group_size(group1); - for(i = 0; i < size2; i++) { + for (i = 0; i < size2; i++) { proc1 = smpi_group_index(group1, i); proc2 = smpi_group_rank(group2, proc1); - if(proc2 != MPI_UNDEFINED) { + if (proc2 != MPI_UNDEFINED) { size--; } } - if(size == 0) { + if (size == 0) { *newgroup = MPI_GROUP_EMPTY; } else { *newgroup = smpi_group_new(size); - for(i = 0; i < size2; i++) { + for (i = 0; i < size2; i++) { proc1 = smpi_group_index(group1, i); proc2 = smpi_group_rank(group2, proc1); - if(proc2 == MPI_UNDEFINED) { + if (proc2 == MPI_UNDEFINED) { smpi_group_set_mapping(*newgroup, proc1, i); } } @@ -409,26 +472,29 @@ int MPI_Group_difference(MPI_Group group1, MPI_Group group2, MPI_Group* newgroup smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_incl(MPI_Group group, int n, int* ranks, MPI_Group* newgroup) { +MPI_CALL_IMPLEM(int, MPI_Group_incl, + (MPI_Group group, int n, int *ranks, + MPI_Group * newgroup)) +{ int retval, i, index; - smpi_bench_end(-1, NULL); - if(group == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { - if(n == 0) { + if (n == 0) { *newgroup = MPI_GROUP_EMPTY; - } else if(n == smpi_group_size(group)) { + } else if (n == smpi_group_size(group)) { *newgroup = group; } else { *newgroup = smpi_group_new(n); - for(i = 0; i < n; i++) { + for (i = 0; i < n; i++) { index = smpi_group_index(group, ranks[i]); smpi_group_set_mapping(*newgroup, index, i); } @@ -436,34 +502,37 @@ int MPI_Group_incl(MPI_Group group, int n, int* ranks, MPI_Group* newgroup) { smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_excl(MPI_Group group, int n, int* ranks, MPI_Group* newgroup) { +MPI_CALL_IMPLEM(int, MPI_Group_excl, + (MPI_Group group, int n, int *ranks, + MPI_Group * newgroup)) +{ int retval, i, size, rank, index; - smpi_bench_end(-1, NULL); - if(group == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { - if(n == 0) { + if (n == 0) { *newgroup = group; - } else if(n == smpi_group_size(group)) { + } else if (n == smpi_group_size(group)) { *newgroup = MPI_GROUP_EMPTY; } else { size = smpi_group_size(group) - n; *newgroup = smpi_group_new(size); rank = 0; - while(rank < size) { - for(i = 0; i < n; i++) { - if(ranks[i] == rank) { + while (rank < size) { + for (i = 0; i < n; i++) { + if (ranks[i] == rank) { break; } } - if(i >= n) { + if (i >= n) { index = smpi_group_index(group, rank); smpi_group_set_mapping(*newgroup, index, rank); rank++; @@ -473,39 +542,42 @@ int MPI_Group_excl(MPI_Group group, int n, int* ranks, MPI_Group* newgroup) { smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_range_incl(MPI_Group group, int n, int ranges[][3], MPI_Group* newgroup) { +MPI_CALL_IMPLEM(int, MPI_Group_range_incl, + (MPI_Group group, int n, int ranges[][3], + MPI_Group * newgroup)) +{ int retval, i, j, rank, size, index; - smpi_bench_end(-1, NULL); - if(group == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { - if(n == 0) { + if (n == 0) { *newgroup = MPI_GROUP_EMPTY; } else { size = 0; - for(i = 0; i < n; i++) { - for(rank = ranges[i][0]; /* First */ - rank >= 0 && rank <= ranges[i][1]; /* Last */ - rank += ranges[i][2] /* Stride */) { + for (i = 0; i < n; i++) { + for (rank = ranges[i][0]; /* First */ + rank >= 0 && rank <= ranges[i][1]; /* Last */ + rank += ranges[i][2] /* Stride */ ) { size++; } } - if(size == smpi_group_size(group)) { + if (size == smpi_group_size(group)) { *newgroup = group; } else { *newgroup = smpi_group_new(size); j = 0; - for(i = 0; i < n; i++) { - for(rank = ranges[i][0]; /* First */ - rank >= 0 && rank <= ranges[i][1]; /* Last */ - rank += ranges[i][2] /* Stride */) { + for (i = 0; i < n; i++) { + for (rank = ranges[i][0]; /* First */ + rank >= 0 && rank <= ranges[i][1]; /* Last */ + rank += ranges[i][2] /* Stride */ ) { index = smpi_group_index(group, rank); smpi_group_set_mapping(*newgroup, index, j); j++; @@ -516,47 +588,50 @@ int MPI_Group_range_incl(MPI_Group group, int n, int ranges[][3], MPI_Group* new smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Group_range_excl(MPI_Group group, int n, int ranges[][3], MPI_Group* newgroup) { +MPI_CALL_IMPLEM(int, MPI_Group_range_excl, + (MPI_Group group, int n, int ranges[][3], + MPI_Group * newgroup)) +{ int retval, i, newrank, rank, size, index, add; - smpi_bench_end(-1, NULL); - if(group == MPI_GROUP_NULL) { + smpi_bench_end(); + if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newgroup == NULL) { + } else if (newgroup == NULL) { retval = MPI_ERR_ARG; } else { - if(n == 0) { + if (n == 0) { *newgroup = group; } else { size = smpi_group_size(group); - for(i = 0; i < n; i++) { - for(rank = ranges[i][0]; /* First */ - rank >= 0 && rank <= ranges[i][1]; /* Last */ - rank += ranges[i][2] /* Stride */) { + for (i = 0; i < n; i++) { + for (rank = ranges[i][0]; /* First */ + rank >= 0 && rank <= ranges[i][1]; /* Last */ + rank += ranges[i][2] /* Stride */ ) { size--; } } - if(size == 0) { + if (size == 0) { *newgroup = MPI_GROUP_EMPTY; } else { *newgroup = smpi_group_new(size); newrank = 0; - while(newrank < size) { - for(i = 0; i < n; i++) { + while (newrank < size) { + for (i = 0; i < n; i++) { add = 1; - for(rank = ranges[i][0]; /* First */ - rank >= 0 && rank <= ranges[i][1]; /* Last */ - rank += ranges[i][2] /* Stride */) { - if(rank == newrank) { + for (rank = ranges[i][0]; /* First */ + rank >= 0 && rank <= ranges[i][1]; /* Last */ + rank += ranges[i][2] /* Stride */ ) { + if (rank == newrank) { add = 0; break; } } - if(add == 1) { + if (add == 1) { index = smpi_group_index(group, newrank); smpi_group_set_mapping(*newgroup, index, newrank); } @@ -567,136 +642,164 @@ int MPI_Group_range_excl(MPI_Group group, int n, int ranges[][3], MPI_Group* new smpi_group_use(*newgroup); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_rank(MPI_Comm comm, int* rank) { +MPI_CALL_IMPLEM(int, MPI_Comm_rank, (MPI_Comm comm, int *rank)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm == MPI_COMM_NULL) { + smpi_bench_end(); + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; } else { *rank = smpi_comm_rank(comm); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_size(MPI_Comm comm, int* size) { +MPI_CALL_IMPLEM(int, MPI_Comm_size, (MPI_Comm comm, int *size)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm == MPI_COMM_NULL) { + smpi_bench_end(); + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(size == NULL) { + } else if (size == NULL) { retval = MPI_ERR_ARG; } else { *size = smpi_comm_size(comm); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_group(MPI_Comm comm, MPI_Group* group) { +MPI_CALL_IMPLEM(int, MPI_Comm_group, (MPI_Comm comm, MPI_Group * group)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm == MPI_COMM_NULL) { + smpi_bench_end(); + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(group == NULL) { + } else if (group == NULL) { retval = MPI_ERR_ARG; } else { *group = smpi_comm_group(comm); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_compare(MPI_Comm comm1, MPI_Comm comm2, int* result) { +MPI_CALL_IMPLEM(int, MPI_Comm_compare, (MPI_Comm comm1, MPI_Comm comm2, int *result)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm1 == MPI_COMM_NULL || comm2 == MPI_COMM_NULL) { + smpi_bench_end(); + if (comm1 == MPI_COMM_NULL || comm2 == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(result == NULL) { + } else if (result == NULL) { retval = MPI_ERR_ARG; } else { - if(comm1 == comm2) { /* Same communicators means same groups */ + if (comm1 == comm2) { /* Same communicators means same groups */ *result = MPI_IDENT; } else { - *result = smpi_group_compare(smpi_comm_group(comm1), smpi_comm_group(comm2)); - if(*result == MPI_IDENT) { + *result = + smpi_group_compare(smpi_comm_group(comm1), + smpi_comm_group(comm2)); + if (*result == MPI_IDENT) { *result = MPI_CONGRUENT; } } retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_dup(MPI_Comm comm, MPI_Comm* newcomm) { +MPI_CALL_IMPLEM(int, MPI_Comm_dup, (MPI_Comm comm, MPI_Comm * newcomm)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm == MPI_COMM_NULL) { + smpi_bench_end(); + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(newcomm == NULL) { + } else if (newcomm == NULL) { retval = MPI_ERR_ARG; } else { *newcomm = smpi_comm_new(smpi_comm_group(comm)); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_create(MPI_Comm comm, MPI_Group group, MPI_Comm* newcomm) { +MPI_CALL_IMPLEM(int, MPI_Comm_create, (MPI_Comm comm, MPI_Group group, MPI_Comm * newcomm)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm == MPI_COMM_NULL) { + smpi_bench_end(); + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(group == MPI_GROUP_NULL) { + } else if (group == MPI_GROUP_NULL) { retval = MPI_ERR_GROUP; - } else if(newcomm == NULL) { + } else if (newcomm == NULL) { retval = MPI_ERR_ARG; } else { *newcomm = smpi_comm_new(group); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Comm_free(MPI_Comm* comm) { +MPI_CALL_IMPLEM(int, MPI_Comm_free, (MPI_Comm * comm)) +{ int retval; - smpi_bench_end(-1, NULL); - if(comm == NULL) { + smpi_bench_end(); + if (comm == NULL) { retval = MPI_ERR_ARG; - } else if(*comm == MPI_COMM_NULL) { + } else if (*comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; } else { smpi_comm_destroy(*comm); *comm = MPI_COMM_NULL; retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Send_init(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm, MPI_Request* request) { +MPI_CALL_IMPLEM(int, MPI_Comm_split, (MPI_Comm comm, int color, int key, MPI_Comm* comm_out)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Send_init"); - if(request == NULL) { + smpi_bench_end(); + if (comm_out == NULL) { + retval = MPI_ERR_ARG; + } else if (comm == MPI_COMM_NULL) { + retval = MPI_ERR_COMM; + } else { + *comm_out = smpi_comm_split(comm, color, key); + retval = MPI_SUCCESS; + } + smpi_bench_begin(); + return retval; +} + +MPI_CALL_IMPLEM(int, MPI_Send_init, + (void *buf, int count, MPI_Datatype datatype, int dst, + int tag, MPI_Comm comm, MPI_Request * request)) +{ + int retval; + + smpi_bench_end(); + if (request == NULL) { retval = MPI_ERR_ARG; } else if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; @@ -704,16 +807,18 @@ int MPI_Send_init(void* buf, int count, MPI_Datatype datatype, int dst, int tag, *request = smpi_mpi_send_init(buf, count, datatype, dst, tag, comm); retval = MPI_SUCCESS; } - smpi_bench_begin(rank, "Send_init"); + smpi_bench_begin(); return retval; } -int MPI_Recv_init(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm, MPI_Request* request) { +MPI_CALL_IMPLEM(int, MPI_Recv_init, + (void *buf, int count, MPI_Datatype datatype, int src, + int tag, MPI_Comm comm, MPI_Request * request)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Recv_init"); - if(request == NULL) { + smpi_bench_end(); + if (request == NULL) { retval = MPI_ERR_ARG; } else if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; @@ -721,68 +826,68 @@ int MPI_Recv_init(void* buf, int count, MPI_Datatype datatype, int src, int tag, *request = smpi_mpi_recv_init(buf, count, datatype, src, tag, comm); retval = MPI_SUCCESS; } - smpi_bench_begin(rank, "Recv_init"); + smpi_bench_begin(); return retval; } -int MPI_Start(MPI_Request* request) { +MPI_CALL_IMPLEM(int, MPI_Start, (MPI_Request * request)) +{ int retval; - MPI_Comm comm = (*request)->comm; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Start"); - if(request == NULL) { + smpi_bench_end(); + if (request == NULL) { retval = MPI_ERR_ARG; } else { smpi_mpi_start(*request); retval = MPI_SUCCESS; } - smpi_bench_begin(rank, "Start"); + smpi_bench_begin(); return retval; } -int MPI_Startall(int count, MPI_Request* requests) { +MPI_CALL_IMPLEM(int, MPI_Startall, (int count, MPI_Request * requests)) +{ int retval; - MPI_Comm comm = count > 0 && requests ? requests[0]->comm : MPI_COMM_NULL; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Startall"); - if(requests == NULL) { + smpi_bench_end(); + if (requests == NULL) { retval = MPI_ERR_ARG; } else { smpi_mpi_startall(count, requests); retval = MPI_SUCCESS; } - smpi_bench_begin(rank, "Startall"); + smpi_bench_begin(); return retval; } -int MPI_Request_free(MPI_Request* request) { +MPI_CALL_IMPLEM(int, MPI_Request_free, (MPI_Request * request)) +{ int retval; - MPI_Comm comm = (*request)->comm; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Request_free"); - if(request == NULL) { + smpi_bench_end(); + if (request == NULL) { retval = MPI_ERR_ARG; } else { smpi_mpi_request_free(request); retval = MPI_SUCCESS; } - smpi_bench_begin(rank, "Request_free"); + smpi_bench_begin(); return retval; } -int MPI_Irecv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm, MPI_Request* request) { +MPI_CALL_IMPLEM(int, MPI_Irecv, + (void *buf, int count, MPI_Datatype datatype, int src, + int tag, MPI_Comm comm, MPI_Request * request)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Irecv"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int src_traced = smpi_group_rank(smpi_comm_group(comm), src); - TRACE_smpi_ptp_in (rank, src_traced, rank, __FUNCTION__); + TRACE_smpi_ptp_in(rank, src_traced, rank, __FUNCTION__); #endif - if(request == NULL) { + if (request == NULL) { retval = MPI_ERR_ARG; } else if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; @@ -791,24 +896,27 @@ int MPI_Irecv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_ptp_out (rank, src_traced, rank, __FUNCTION__); + TRACE_smpi_ptp_out(rank, src_traced, rank, __FUNCTION__); (*request)->recv = 1; #endif - smpi_bench_begin(rank, "Irecv"); + smpi_bench_begin(); return retval; } -int MPI_Isend(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm, MPI_Request* request) { +MPI_CALL_IMPLEM(int, MPI_Isend, + (void *buf, int count, MPI_Datatype datatype, int dst, + int tag, MPI_Comm comm, MPI_Request * request)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Isend"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int dst_traced = smpi_group_rank(smpi_comm_group(comm), dst); - TRACE_smpi_ptp_in (rank, rank, dst_traced, __FUNCTION__); - TRACE_smpi_send (rank, rank, dst_traced); + TRACE_smpi_ptp_in(rank, rank, dst_traced, __FUNCTION__); + TRACE_smpi_send(rank, rank, dst_traced); #endif - if(request == NULL) { + if (request == NULL) { retval = MPI_ERR_ARG; } else if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; @@ -817,21 +925,24 @@ int MPI_Isend(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_ptp_out (rank, rank, dst_traced, __FUNCTION__); + TRACE_smpi_ptp_out(rank, rank, dst_traced, __FUNCTION__); (*request)->send = 1; #endif - smpi_bench_begin(rank, "Isend"); + smpi_bench_begin(); return retval; } -int MPI_Recv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Recv, + (void *buf, int count, MPI_Datatype datatype, int src, int tag, + MPI_Comm comm, MPI_Status * status)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Recv"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int src_traced = smpi_group_rank(smpi_comm_group(comm), src); - TRACE_smpi_ptp_in (rank, src_traced, rank, __FUNCTION__); + TRACE_smpi_ptp_in(rank, src_traced, rank, __FUNCTION__); #endif if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; @@ -840,22 +951,25 @@ int MPI_Recv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_ retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_ptp_out (rank, src_traced, rank, __FUNCTION__); - TRACE_smpi_recv (rank, src_traced, rank); + TRACE_smpi_ptp_out(rank, src_traced, rank, __FUNCTION__); + TRACE_smpi_recv(rank, src_traced, rank); #endif - smpi_bench_begin(rank, "Recv"); + smpi_bench_begin(); return retval; } -int MPI_Send(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Send, + (void *buf, int count, MPI_Datatype datatype, int dst, int tag, + MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Send"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int dst_traced = smpi_group_rank(smpi_comm_group(comm), dst); - TRACE_smpi_ptp_in (rank, rank, dst_traced, __FUNCTION__); - TRACE_smpi_send (rank, rank, dst_traced); + TRACE_smpi_ptp_in(rank, rank, dst_traced, __FUNCTION__); + TRACE_smpi_send(rank, rank, dst_traced); #endif if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; @@ -864,159 +978,170 @@ int MPI_Send(void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_ retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_ptp_out (rank, rank, dst_traced, __FUNCTION__); + TRACE_smpi_ptp_out(rank, rank, dst_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Send"); + smpi_bench_begin(); return retval; } -int MPI_Sendrecv(void* sendbuf, int sendcount, MPI_Datatype sendtype, int dst, int sendtag, void* recvbuf, int recvcount, MPI_Datatype recvtype, int src, int recvtag, MPI_Comm comm, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Sendrecv, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + int dst, int sendtag, void *recvbuf, int recvcount, + MPI_Datatype recvtype, int src, int recvtag, + MPI_Comm comm, MPI_Status * status)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Sendrecv"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int dst_traced = smpi_group_rank(smpi_comm_group(comm), dst); int src_traced = smpi_group_rank(smpi_comm_group(comm), src); - TRACE_smpi_ptp_in (rank, src_traced, dst_traced, __FUNCTION__); - TRACE_smpi_send (rank, rank, dst_traced); - TRACE_smpi_send (rank, src_traced, rank); + TRACE_smpi_ptp_in(rank, src_traced, dst_traced, __FUNCTION__); + TRACE_smpi_send(rank, rank, dst_traced); + TRACE_smpi_send(rank, src_traced, rank); #endif if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if (sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; } else { - smpi_mpi_sendrecv(sendbuf, sendcount, sendtype, dst, sendtag, recvbuf, recvcount, recvtype, src, recvtag, comm, status); + smpi_mpi_sendrecv(sendbuf, sendcount, sendtype, dst, sendtag, recvbuf, + recvcount, recvtype, src, recvtag, comm, status); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_ptp_out (rank, src_traced, dst_traced, __FUNCTION__); - TRACE_smpi_recv (rank, rank, dst_traced); - TRACE_smpi_recv (rank, src_traced, rank); + TRACE_smpi_ptp_out(rank, src_traced, dst_traced, __FUNCTION__); + TRACE_smpi_recv(rank, rank, dst_traced); + TRACE_smpi_recv(rank, src_traced, rank); #endif - smpi_bench_begin(rank, "Sendrecv"); + smpi_bench_begin(); return retval; } -int MPI_Sendrecv_replace(void* buf, int count, MPI_Datatype datatype, int dst, int sendtag, int src, int recvtag, MPI_Comm comm, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Sendrecv_replace, + (void *buf, int count, MPI_Datatype datatype, + int dst, int sendtag, int src, int recvtag, + MPI_Comm comm, MPI_Status * status)) +{ //TODO: suboptimal implementation - void* recvbuf; + void *recvbuf; int retval, size; size = smpi_datatype_size(datatype) * count; recvbuf = xbt_new(char, size); - retval = MPI_Sendrecv(buf, count, datatype, dst, sendtag, recvbuf, count, datatype, src, recvtag, comm, status); + retval = + MPI_Sendrecv(buf, count, datatype, dst, sendtag, recvbuf, count, + datatype, src, recvtag, comm, status); memcpy(buf, recvbuf, size * sizeof(char)); xbt_free(recvbuf); return retval; } -int MPI_Test(MPI_Request* request, int* flag, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Test, (MPI_Request * request, int *flag, MPI_Status * status)) +{ int retval; - int rank = request && (*request)->comm != MPI_COMM_NULL - ? smpi_comm_rank((*request)->comm) - : -1; - smpi_bench_end(rank, "Test"); - if(request == NULL || flag == NULL) { + smpi_bench_end(); + if (request == NULL || flag == NULL) { retval = MPI_ERR_ARG; - } else if(*request == MPI_REQUEST_NULL) { + } else if (*request == MPI_REQUEST_NULL) { retval = MPI_ERR_REQUEST; } else { *flag = smpi_mpi_test(request, status); retval = MPI_SUCCESS; } - smpi_bench_begin(rank, "Test"); + smpi_bench_begin(); return retval; } -int MPI_Testany(int count, MPI_Request requests[], int* index, int* flag, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Testany, + (int count, MPI_Request requests[], int *index, int *flag, + MPI_Status * status)) +{ int retval; - smpi_bench_end(-1, NULL); //FIXME - if(index == NULL || flag == NULL) { + smpi_bench_end(); + if (index == NULL || flag == NULL) { retval = MPI_ERR_ARG; } else { *flag = smpi_mpi_testany(count, requests, index, status); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Wait(MPI_Request* request, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Wait, (MPI_Request * request, MPI_Status * status)) +{ int retval; - int rank = request && (*request)->comm != MPI_COMM_NULL - ? smpi_comm_rank((*request)->comm) - : -1; - smpi_bench_end(rank, "Wait"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = request && (*request)->comm != MPI_COMM_NULL + ? smpi_comm_rank((*request)->comm) + : -1; MPI_Group group = smpi_comm_group((*request)->comm); - int src_traced = smpi_group_rank (group , (*request)->src); - int dst_traced = smpi_group_rank (group , (*request)->dst); + int src_traced = smpi_group_rank(group, (*request)->src); + int dst_traced = smpi_group_rank(group, (*request)->dst); int is_wait_for_receive = (*request)->recv; - TRACE_smpi_ptp_in (rank, src_traced, dst_traced, __FUNCTION__); + TRACE_smpi_ptp_in(rank, src_traced, dst_traced, __FUNCTION__); #endif - if(request == NULL) { + if (request == NULL) { retval = MPI_ERR_ARG; - } else if(*request == MPI_REQUEST_NULL) { + } else if (*request == MPI_REQUEST_NULL) { retval = MPI_ERR_REQUEST; } else { smpi_mpi_wait(request, status); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_ptp_out (rank, src_traced, dst_traced, __FUNCTION__); - if (is_wait_for_receive){ - TRACE_smpi_recv (rank, src_traced, dst_traced); + TRACE_smpi_ptp_out(rank, src_traced, dst_traced, __FUNCTION__); + if (is_wait_for_receive) { + TRACE_smpi_recv(rank, src_traced, dst_traced); } #endif - smpi_bench_begin(rank, "Wait"); + smpi_bench_begin(); return retval; } -int MPI_Waitany(int count, MPI_Request requests[], int* index, MPI_Status* status) { +MPI_CALL_IMPLEM(int, MPI_Waitany, + (int count, MPI_Request requests[], int *index, + MPI_Status * status)) +{ int retval; - smpi_bench_end(-1, NULL); //FIXME + smpi_bench_end(); #ifdef HAVE_TRACING //save requests information for tracing int i; - xbt_dynar_t srcs = xbt_dynar_new (sizeof(int), xbt_free); - xbt_dynar_t dsts = xbt_dynar_new (sizeof(int), xbt_free); - xbt_dynar_t recvs = xbt_dynar_new (sizeof(int), xbt_free); - for (i = 0; i < count; i++){ - MPI_Request req = requests[i]; //already received requests are no longer valid - if (req){ + xbt_dynar_t srcs = xbt_dynar_new(sizeof(int), xbt_free); + xbt_dynar_t dsts = xbt_dynar_new(sizeof(int), xbt_free); + xbt_dynar_t recvs = xbt_dynar_new(sizeof(int), xbt_free); + for (i = 0; i < count; i++) { + MPI_Request req = requests[i]; //already received requests are no longer valid + if (req) { int *asrc = xbt_new(int, 1); int *adst = xbt_new(int, 1); int *arecv = xbt_new(int, 1); *asrc = req->src; *adst = req->dst; *arecv = req->recv; - xbt_dynar_insert_at (srcs, i, asrc); - xbt_dynar_insert_at (dsts, i, adst); - xbt_dynar_insert_at (recvs, i, arecv); - }else{ + xbt_dynar_insert_at(srcs, i, asrc); + xbt_dynar_insert_at(dsts, i, adst); + xbt_dynar_insert_at(recvs, i, arecv); + } else { int *t = xbt_new(int, 1); - xbt_dynar_insert_at (srcs, i, t); - xbt_dynar_insert_at (dsts, i, t); - xbt_dynar_insert_at (recvs, i, t); + xbt_dynar_insert_at(srcs, i, t); + xbt_dynar_insert_at(dsts, i, t); + xbt_dynar_insert_at(recvs, i, t); } } - - //search for a suitable request to give the rank of current mpi proc - MPI_Request req = NULL; - for (i = 0; i < count && req == NULL; i++) { - req = requests[i]; - } - MPI_Comm comm = (req)->comm; - int rank_traced = smpi_comm_rank(comm); - TRACE_smpi_ptp_in (rank_traced, -1, -1, __FUNCTION__); + int rank_traced = smpi_comm_rank(MPI_COMM_WORLD); + TRACE_smpi_ptp_in(rank_traced, -1, -1, __FUNCTION__); #endif - if(index == NULL) { + if (index == NULL) { retval = MPI_ERR_ARG; } else { *index = smpi_mpi_waitany(count, requests, status); @@ -1024,369 +1149,418 @@ int MPI_Waitany(int count, MPI_Request requests[], int* index, MPI_Status* statu } #ifdef HAVE_TRACING int src_traced, dst_traced, is_wait_for_receive; - xbt_dynar_get_cpy (srcs, *index, &src_traced); - xbt_dynar_get_cpy (dsts, *index, &dst_traced); - xbt_dynar_get_cpy (recvs, *index, &is_wait_for_receive); - if (is_wait_for_receive){ - TRACE_smpi_recv (rank_traced, src_traced, dst_traced); + xbt_dynar_get_cpy(srcs, *index, &src_traced); + xbt_dynar_get_cpy(dsts, *index, &dst_traced); + xbt_dynar_get_cpy(recvs, *index, &is_wait_for_receive); + if (is_wait_for_receive) { + TRACE_smpi_recv(rank_traced, src_traced, dst_traced); } - TRACE_smpi_ptp_out (rank_traced, src_traced, dst_traced, __FUNCTION__); + TRACE_smpi_ptp_out(rank_traced, src_traced, dst_traced, __FUNCTION__); //clean-up of dynars - xbt_free (srcs); - xbt_free (dsts); - xbt_free (recvs); + xbt_free(srcs); + xbt_free(dsts); + xbt_free(recvs); #endif - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Waitall(int count, MPI_Request requests[], MPI_Status status[]) { +MPI_CALL_IMPLEM(int, MPI_Waitall, (int count, MPI_Request requests[], MPI_Status status[])) +{ - smpi_bench_end(-1, NULL); //FIXME + smpi_bench_end(); #ifdef HAVE_TRACING //save information from requests int i; - xbt_dynar_t srcs = xbt_dynar_new (sizeof(int), xbt_free); - xbt_dynar_t dsts = xbt_dynar_new (sizeof(int), xbt_free); - xbt_dynar_t recvs = xbt_dynar_new (sizeof(int), xbt_free); - for (i = 0; i < count; i++){ - MPI_Request req = requests[i]; //all req should be valid in Waitall + xbt_dynar_t srcs = xbt_dynar_new(sizeof(int), xbt_free); + xbt_dynar_t dsts = xbt_dynar_new(sizeof(int), xbt_free); + xbt_dynar_t recvs = xbt_dynar_new(sizeof(int), xbt_free); + for (i = 0; i < count; i++) { + MPI_Request req = requests[i]; //all req should be valid in Waitall int *asrc = xbt_new(int, 1); int *adst = xbt_new(int, 1); int *arecv = xbt_new(int, 1); *asrc = req->src; *adst = req->dst; *arecv = req->recv; - xbt_dynar_insert_at (srcs, i, asrc); - xbt_dynar_insert_at (dsts, i, adst); - xbt_dynar_insert_at (recvs, i, arecv); - } - -// find my rank inside one of MPI_Comm's of the requests - MPI_Request req = NULL; - for (i = 0; i < count && req == NULL; i++) { - req = requests[i]; + xbt_dynar_insert_at(srcs, i, asrc); + xbt_dynar_insert_at(dsts, i, adst); + xbt_dynar_insert_at(recvs, i, arecv); } - MPI_Comm comm = (req)->comm; - int rank_traced = smpi_comm_rank(comm); - TRACE_smpi_ptp_in (rank_traced, -1, -1, __FUNCTION__); + int rank_traced = smpi_comm_rank (MPI_COMM_WORLD); + TRACE_smpi_ptp_in(rank_traced, -1, -1, __FUNCTION__); #endif smpi_mpi_waitall(count, requests, status); #ifdef HAVE_TRACING - for (i = 0; i < count; i++){ + for (i = 0; i < count; i++) { int src_traced, dst_traced, is_wait_for_receive; - xbt_dynar_get_cpy (srcs, i, &src_traced); - xbt_dynar_get_cpy (dsts, i, &dst_traced); - xbt_dynar_get_cpy (recvs, i, &is_wait_for_receive); - if (is_wait_for_receive){ - TRACE_smpi_recv (rank_traced, src_traced, dst_traced); + xbt_dynar_get_cpy(srcs, i, &src_traced); + xbt_dynar_get_cpy(dsts, i, &dst_traced); + xbt_dynar_get_cpy(recvs, i, &is_wait_for_receive); + if (is_wait_for_receive) { + TRACE_smpi_recv(rank_traced, src_traced, dst_traced); } } - TRACE_smpi_ptp_out (rank_traced, -1, -1, __FUNCTION__); + TRACE_smpi_ptp_out(rank_traced, -1, -1, __FUNCTION__); //clean-up of dynars - xbt_free (srcs); - xbt_free (dsts); - xbt_free (recvs); + xbt_free(srcs); + xbt_free(dsts); + xbt_free(recvs); #endif - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return MPI_SUCCESS; } -int MPI_Waitsome(int incount, MPI_Request requests[], int* outcount, int* indices, MPI_Status status[]) { +MPI_CALL_IMPLEM(int, MPI_Waitsome, + (int incount, MPI_Request requests[], int *outcount, + int *indices, MPI_Status status[])) +{ int retval; - smpi_bench_end(-1, NULL); //FIXME - if(outcount == NULL || indices == NULL) { + smpi_bench_end(); + if (outcount == NULL || indices == NULL) { retval = MPI_ERR_ARG; } else { *outcount = smpi_mpi_waitsome(incount, requests, indices, status); retval = MPI_SUCCESS; } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Bcast(void* buf, int count, MPI_Datatype datatype, int root, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Bcast, + (void *buf, int count, MPI_Datatype datatype, int root, + MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Bcast"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int root_traced = smpi_group_rank(smpi_comm_group(comm), root); - TRACE_smpi_collective_in (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; } else { smpi_mpi_bcast(buf, count, datatype, root, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_out(rank, root_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Bcast"); + smpi_bench_begin(); return retval; } -int MPI_Barrier(MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Barrier, (MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Barrier"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; } else { smpi_mpi_barrier(comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Barrier"); + smpi_bench_begin(); return retval; } -int MPI_Gather(void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Gather, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + void *recvbuf, int recvcount, MPI_Datatype recvtype, + int root, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Gather"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int root_traced = smpi_group_rank(smpi_comm_group(comm), root); - TRACE_smpi_collective_in (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; } else { - smpi_mpi_gather(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, root, comm); + smpi_mpi_gather(sendbuf, sendcount, sendtype, recvbuf, recvcount, + recvtype, root, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_out(rank, root_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Gather"); + smpi_bench_begin(); return retval; } -int MPI_Gatherv(void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int* recvcounts, int* displs, MPI_Datatype recvtype, int root, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Gatherv, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + void *recvbuf, int *recvcounts, int *displs, + MPI_Datatype recvtype, int root, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Gatherv"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int root_traced = smpi_group_rank(smpi_comm_group(comm), root); - TRACE_smpi_collective_in (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(recvcounts == NULL || displs == NULL) { + } else if (recvcounts == NULL || displs == NULL) { retval = MPI_ERR_ARG; } else { - smpi_mpi_gatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, displs, recvtype, root, comm); + smpi_mpi_gatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, + displs, recvtype, root, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_out(rank, root_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Gatherv"); + smpi_bench_begin(); return retval; } -int MPI_Allgather(void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Allgather, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + void *recvbuf, int recvcount, MPI_Datatype recvtype, + MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Allgather"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; } else { - smpi_mpi_allgather(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm); + smpi_mpi_allgather(sendbuf, sendcount, sendtype, recvbuf, recvcount, + recvtype, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Allgather"); + smpi_bench_begin(); return retval; } -int MPI_Allgatherv(void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int* recvcounts, int* displs, MPI_Datatype recvtype, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Allgatherv, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + void *recvbuf, int *recvcounts, int *displs, + MPI_Datatype recvtype, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Allgatherv"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(recvcounts == NULL || displs == NULL) { + } else if (recvcounts == NULL || displs == NULL) { retval = MPI_ERR_ARG; } else { - smpi_mpi_allgatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, displs, recvtype, comm); + smpi_mpi_allgatherv(sendbuf, sendcount, sendtype, recvbuf, recvcounts, + displs, recvtype, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Allgatherv"); + smpi_bench_begin(); return retval; } -int MPI_Scatter(void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Scatter, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + void *recvbuf, int recvcount, MPI_Datatype recvtype, + int root, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Scatter"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int root_traced = smpi_group_rank(smpi_comm_group(comm), root); - TRACE_smpi_collective_in (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; } else { - smpi_mpi_scatter(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, root, comm); + smpi_mpi_scatter(sendbuf, sendcount, sendtype, recvbuf, recvcount, + recvtype, root, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_out(rank, root_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Scatter"); + smpi_bench_begin(); return retval; } -int MPI_Scatterv(void* sendbuf, int* sendcounts, int* displs, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, int root, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Scatterv, + (void *sendbuf, int *sendcounts, int *displs, + MPI_Datatype sendtype, void *recvbuf, int recvcount, + MPI_Datatype recvtype, int root, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Scatterv"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int root_traced = smpi_group_rank(smpi_comm_group(comm), root); - TRACE_smpi_collective_in (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(sendcounts == NULL || displs == NULL) { + } else if (sendcounts == NULL || displs == NULL) { retval = MPI_ERR_ARG; } else { - smpi_mpi_scatterv(sendbuf, sendcounts, displs, sendtype, recvbuf, recvcount, recvtype, root, comm); + smpi_mpi_scatterv(sendbuf, sendcounts, displs, sendtype, recvbuf, + recvcount, recvtype, root, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_out(rank, root_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Scatterv"); + smpi_bench_begin(); return retval; } -int MPI_Reduce(void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Reduce, + (void *sendbuf, void *recvbuf, int count, + MPI_Datatype datatype, MPI_Op op, int root, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Reduce"); + smpi_bench_end(); #ifdef HAVE_TRACING + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; int root_traced = smpi_group_rank(smpi_comm_group(comm), root); - TRACE_smpi_collective_in (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(datatype == MPI_DATATYPE_NULL || op == MPI_OP_NULL) { + } else if (datatype == MPI_DATATYPE_NULL || op == MPI_OP_NULL) { retval = MPI_ERR_ARG; } else { smpi_mpi_reduce(sendbuf, recvbuf, count, datatype, op, root, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, root_traced, __FUNCTION__); + TRACE_smpi_collective_out(rank, root_traced, __FUNCTION__); #endif - smpi_bench_begin(rank, "Reduce"); + smpi_bench_begin(); return retval; } -int MPI_Allreduce(void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Allreduce, + (void *sendbuf, void *recvbuf, int count, + MPI_Datatype datatype, MPI_Op op, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Allreduce"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(datatype == MPI_DATATYPE_NULL) { + } else if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(op == MPI_OP_NULL) { + } else if (op == MPI_OP_NULL) { retval = MPI_ERR_OP; } else { smpi_mpi_allreduce(sendbuf, recvbuf, count, datatype, op, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Allreduce"); + smpi_bench_begin(); return retval; } -int MPI_Scan(void* sendbuf, void* recvbuf, int count, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Scan, + (void *sendbuf, void *recvbuf, int count, + MPI_Datatype datatype, MPI_Op op, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Scan"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(datatype == MPI_DATATYPE_NULL) { + } else if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(op == MPI_OP_NULL) { + } else if (op == MPI_OP_NULL) { retval = MPI_ERR_OP; } else { smpi_mpi_scan(sendbuf, recvbuf, count, datatype, op, comm); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Scan"); + smpi_bench_begin(); return retval; } -int MPI_Reduce_scatter(void* sendbuf, void* recvbuf, int* recvcounts, MPI_Datatype datatype, MPI_Op op, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Reduce_scatter, + (void *sendbuf, void *recvbuf, int *recvcounts, + MPI_Datatype datatype, MPI_Op op, MPI_Comm comm)) +{ int retval, i, size, count; - int* displs; + int *displs; int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Reduce_scatter"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(datatype == MPI_DATATYPE_NULL) { + } else if (datatype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(op == MPI_OP_NULL) { + } else if (op == MPI_OP_NULL) { retval = MPI_ERR_OP; - } else if(recvcounts == NULL) { + } else if (recvcounts == NULL) { retval = MPI_ERR_ARG; } else { /* arbitrarily choose root as rank 0 */ @@ -1394,93 +1568,122 @@ int MPI_Reduce_scatter(void* sendbuf, void* recvbuf, int* recvcounts, MPI_Dataty size = smpi_comm_size(comm); count = 0; displs = xbt_new(int, size); - for(i = 0; i < size; i++) { + for (i = 0; i < size; i++) { count += recvcounts[i]; displs[i] = 0; } smpi_mpi_reduce(sendbuf, recvbuf, count, datatype, op, 0, comm); - smpi_mpi_scatterv(recvbuf, recvcounts, displs, datatype, recvbuf, recvcounts[rank], datatype, 0, comm); + smpi_mpi_scatterv(recvbuf, recvcounts, displs, datatype, recvbuf, + recvcounts[rank], datatype, 0, comm); xbt_free(displs); retval = MPI_SUCCESS; } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Reduce_scatter"); + smpi_bench_begin(); return retval; } -int MPI_Alltoall(void* sendbuf, int sendcount, MPI_Datatype sendtype, void* recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Alltoall, + (void *sendbuf, int sendcount, MPI_Datatype sendtype, + void *recvbuf, int recvcount, MPI_Datatype recvtype, + MPI_Comm comm)) +{ int retval, size, sendsize; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Alltoall"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; } else { size = smpi_comm_size(comm); sendsize = smpi_datatype_size(sendtype) * sendcount; - if(sendsize < 200 && size > 12) { - retval = smpi_coll_tuned_alltoall_bruck(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm); - } else if(sendsize < 3000) { - retval = smpi_coll_tuned_alltoall_basic_linear(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm); + if (sendsize < 200 && size > 12) { + retval = + smpi_coll_tuned_alltoall_bruck(sendbuf, sendcount, sendtype, + recvbuf, recvcount, recvtype, + comm); + } else if (sendsize < 3000) { + retval = + smpi_coll_tuned_alltoall_basic_linear(sendbuf, sendcount, + sendtype, recvbuf, + recvcount, recvtype, comm); } else { - retval = smpi_coll_tuned_alltoall_pairwise(sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm); + retval = + smpi_coll_tuned_alltoall_pairwise(sendbuf, sendcount, sendtype, + recvbuf, recvcount, recvtype, + comm); } } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Alltoall"); + smpi_bench_begin(); return retval; } -int MPI_Alltoallv(void* sendbuf, int* sendcounts, int* senddisps, MPI_Datatype sendtype, void* recvbuf, int *recvcounts, int* recvdisps, MPI_Datatype recvtype, MPI_Comm comm) { +MPI_CALL_IMPLEM(int, MPI_Alltoallv, + (void *sendbuf, int *sendcounts, int *senddisps, + MPI_Datatype sendtype, void *recvbuf, int *recvcounts, + int *recvdisps, MPI_Datatype recvtype, MPI_Comm comm)) +{ int retval; - int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; - smpi_bench_end(rank, "Alltoallv"); + smpi_bench_end(); #ifdef HAVE_TRACING - TRACE_smpi_collective_in (rank, -1, __FUNCTION__); + int rank = comm != MPI_COMM_NULL ? smpi_comm_rank(comm) : -1; + TRACE_smpi_collective_in(rank, -1, __FUNCTION__); #endif - if(comm == MPI_COMM_NULL) { + if (comm == MPI_COMM_NULL) { retval = MPI_ERR_COMM; - } else if(sendtype == MPI_DATATYPE_NULL || recvtype == MPI_DATATYPE_NULL) { + } else if (sendtype == MPI_DATATYPE_NULL + || recvtype == MPI_DATATYPE_NULL) { retval = MPI_ERR_TYPE; - } else if(sendcounts == NULL || senddisps == NULL || recvcounts == NULL || recvdisps == NULL) { + } else if (sendcounts == NULL || senddisps == NULL || recvcounts == NULL + || recvdisps == NULL) { retval = MPI_ERR_ARG; } else { - retval = smpi_coll_basic_alltoallv(sendbuf, sendcounts, senddisps, sendtype, recvbuf, recvcounts, recvdisps, recvtype, comm); + retval = + smpi_coll_basic_alltoallv(sendbuf, sendcounts, senddisps, sendtype, + recvbuf, recvcounts, recvdisps, recvtype, + comm); } #ifdef HAVE_TRACING - TRACE_smpi_collective_out (rank, -1, __FUNCTION__); + TRACE_smpi_collective_out(rank, -1, __FUNCTION__); #endif - smpi_bench_begin(rank, "Alltoallv"); + smpi_bench_begin(); return retval; } -int MPI_Get_processor_name(char* name, int* resultlen) { +MPI_CALL_IMPLEM(int, MPI_Get_processor_name, (char *name, int *resultlen)) +{ int retval = MPI_SUCCESS; - smpi_bench_end(-1, NULL); - strncpy( name , SIMIX_host_get_name(SIMIX_host_self()), MPI_MAX_PROCESSOR_NAME-1); - *resultlen= strlen(name) > MPI_MAX_PROCESSOR_NAME ? MPI_MAX_PROCESSOR_NAME : strlen(name); + smpi_bench_end(); + strncpy(name, SIMIX_host_get_name(SIMIX_host_self()), + MPI_MAX_PROCESSOR_NAME - 1); + *resultlen = + strlen(name) > + MPI_MAX_PROCESSOR_NAME ? MPI_MAX_PROCESSOR_NAME : strlen(name); - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } -int MPI_Get_count(MPI_Status* status, MPI_Datatype datatype, int* count) { +MPI_CALL_IMPLEM(int, MPI_Get_count, (MPI_Status * status, MPI_Datatype datatype, int *count)) +{ int retval = MPI_SUCCESS; size_t size; - smpi_bench_end(-1, NULL); + smpi_bench_end(); if (status == NULL || count == NULL) { retval = MPI_ERR_ARG; } else if (datatype == MPI_DATATYPE_NULL) { @@ -1488,13 +1691,265 @@ int MPI_Get_count(MPI_Status* status, MPI_Datatype datatype, int* count) { } else { size = smpi_datatype_size(datatype); if (size == 0) { - *count = 0; + *count = 0; } else if (status->count % size != 0) { - retval = MPI_UNDEFINED; + retval = MPI_UNDEFINED; } else { - *count = smpi_mpi_get_count(status, datatype); + *count = smpi_mpi_get_count(status, datatype); } } - smpi_bench_begin(-1, NULL); + smpi_bench_begin(); return retval; } + +/* The following calls are not yet implemented and will fail at runtime. */ +/* Once implemented, please move them above this notice. */ + +static int not_yet_implemented(void) { + xbt_die("Not yet implemented"); + return MPI_ERR_OTHER; +} + +MPI_CALL_IMPLEM(int, MPI_Pack_size, (int incount, MPI_Datatype datatype, MPI_Comm comm, int* size)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_coords, (MPI_Comm comm, int rank, int maxdims, int* coords)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_create, (MPI_Comm comm_old, int ndims, int* dims, int* periods, int reorder, MPI_Comm* comm_cart)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_get, (MPI_Comm comm, int maxdims, int* dims, int* periods, int* coords)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_map, (MPI_Comm comm_old, int ndims, int* dims, int* periods, int* newrank)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_rank, (MPI_Comm comm, int* coords, int* rank)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_shift, (MPI_Comm comm, int direction, int displ, int* source, int* dest)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cart_sub, (MPI_Comm comm, int* remain_dims, MPI_Comm* comm_new)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cartdim_get, (MPI_Comm comm, int* ndims)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Graph_create, (MPI_Comm comm_old, int nnodes, int* index, int* edges, int reorder, MPI_Comm* comm_graph)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Graph_get, (MPI_Comm comm, int maxindex, int maxedges, int* index, int* edges)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Graph_map, (MPI_Comm comm_old, int nnodes, int* index, int* edges, int* newrank)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Graph_neighbors, (MPI_Comm comm, int rank, int maxneighbors, int* neighbors)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Graph_neighbors_count, (MPI_Comm comm, int rank, int* nneighbors)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Graphdims_get, (MPI_Comm comm, int* nnodes, int* nedges)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Topo_test, (MPI_Comm comm, int* top_type)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Error_class, (int errorcode, int* errorclass)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Errhandler_create, (MPI_Handler_function* function, MPI_Errhandler* errhandler)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Errhandler_free, (MPI_Errhandler* errhandler)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Errhandler_get, (MPI_Comm comm, MPI_Errhandler* errhandler)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Error_string, (int errorcode, char* string, int* resultlen)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Errhandler_set, (MPI_Comm comm, MPI_Errhandler errhandler)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_contiguous, (int count, MPI_Datatype old_type, MPI_Datatype* newtype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Cancel, (MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Buffer_attach, (void* buffer, int size)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Buffer_detach, (void* buffer, int* size)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Testsome, (int incount, MPI_Request* requests, int* outcount, int* indices, MPI_Status* statuses)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Comm_test_inter, (MPI_Comm comm, int* flag)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Unpack, (void* inbuf, int insize, int* position, void* outbuf, int outcount, MPI_Datatype type, MPI_Comm comm)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_commit, (MPI_Datatype* datatype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_hindexed, (int count, int* blocklens, MPI_Aint* indices, MPI_Datatype old_type, MPI_Datatype* newtype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_hvector, (int count, int blocklen, MPI_Aint stride, MPI_Datatype old_type, MPI_Datatype* newtype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_indexed, (int count, int* blocklens, int* indices, MPI_Datatype old_type, MPI_Datatype* newtype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_struct, (int count, int* blocklens, MPI_Aint* indices, MPI_Datatype* old_types, MPI_Datatype* newtype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Type_vector, (int count, int blocklen, int stride, MPI_Datatype old_type, MPI_Datatype* newtype)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Ssend, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Ssend_init, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Intercomm_create, (MPI_Comm local_comm, int local_leader, MPI_Comm peer_comm, int remote_leader, int tag, MPI_Comm* comm_out)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Intercomm_merge, (MPI_Comm comm, int high, MPI_Comm* comm_out)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Bsend, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Bsend_init, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Ibsend, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Comm_remote_group, (MPI_Comm comm, MPI_Group* group)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Comm_remote_size, (MPI_Comm comm, int* size)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Issend, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Probe, (int source, int tag, MPI_Comm comm, MPI_Status* status)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Attr_delete, (MPI_Comm comm, int keyval)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Attr_get, (MPI_Comm comm, int keyval, void* attr_value, int* flag)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Attr_put, (MPI_Comm comm, int keyval, void* attr_value)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Rsend, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Rsend_init, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Irsend, (void* buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request* request)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Keyval_create, (MPI_Copy_function* copy_fn, MPI_Delete_function* delete_fn, int* keyval, void* extra_state)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Keyval_free, (int* keyval)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Test_cancelled, (MPI_Status* status, int* flag)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Pack, (void* inbuf, int incount, MPI_Datatype type, void* outbuf, int outcount, int* position, MPI_Comm comm)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Testall, (int count, MPI_Request* requests, int* flag, MPI_Status* statuses)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Get_elements, (MPI_Status* status, MPI_Datatype datatype, int* elements)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Dims_create, (int nnodes, int ndims, int* dims)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Iprobe, (int source, int tag, MPI_Comm comm, int* flag, MPI_Status* status)) { + return not_yet_implemented(); +} + +MPI_CALL_IMPLEM(int, MPI_Initialized, (int* flag)) { + return not_yet_implemented(); +}