X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ed4651a70cc0b13df62042680427e4686047225b..39423c5e63cbaa7fc3c41a4af6037948c4033225:/src/smpi/smpi_op.cpp diff --git a/src/smpi/smpi_op.cpp b/src/smpi/smpi_op.cpp index 96dd94142a..805647bb61 100644 --- a/src/smpi/smpi_op.cpp +++ b/src/smpi/smpi_op.cpp @@ -18,8 +18,8 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(smpi_op, smpi, "Logging specific to SMPI (op)"); #define BAND_OP(a, b) (b) &= (a) #define BOR_OP(a, b) (b) |= (a) #define BXOR_OP(a, b) (b) ^= (a) -#define MAXLOC_OP(a, b) (b) = (a.value) < (b.value) ? (b) : (a) -#define MINLOC_OP(a, b) (b) = (a.value) < (b.value) ? (a) : (b) +#define MAXLOC_OP(a, b) (b) = (a.value) < (b.value) ? (b) : ((a.value) == (b.value) ? ((a.index) < (b.index) ? (a) : (b)) : (a)) +#define MINLOC_OP(a, b) (b) = (a.value) < (b.value) ? (a) : ((a.value) == (b.value) ? ((a.index) < (b.index) ? (a) : (b)) : (b)) #define APPLY_FUNC(a, b, length, type, func) \ { \ @@ -188,6 +188,11 @@ static void replace_func(void *a, void *b, int *length, MPI_Datatype * datatype) memcpy(b, a, *length * (*datatype)->size()); } +static void no_func(void *a, void *b, int *length, MPI_Datatype * datatype) +{ + /* obviously a no-op */ +} + #define CREATE_MPI_OP(name, func) \ static SMPI_Op mpi_##name (&(func) /* func */, true ); \ MPI_Op name = &mpi_##name; @@ -205,6 +210,7 @@ CREATE_MPI_OP(MPI_BXOR, bxor_func); CREATE_MPI_OP(MPI_MAXLOC, maxloc_func); CREATE_MPI_OP(MPI_MINLOC, minloc_func); CREATE_MPI_OP(MPI_REPLACE, replace_func); +CREATE_MPI_OP(MPI_NO_OP, no_func); namespace simgrid{ namespace smpi{ @@ -232,12 +238,12 @@ void Op::set_fortran_op() void Op::apply(void *invec, void *inoutvec, int *len, MPI_Datatype datatype) { - if(smpi_privatize_global_variables){//we need to switch as the called function may silently touch global variables + if(smpi_privatize_global_variables == SMPI_PRIVATIZE_MMAP){//we need to switch as the called function may silently touch global variables XBT_DEBUG("Applying operation, switch to the right data frame "); smpi_switch_data_segment(smpi_process()->index()); } - if(!smpi_process()->replaying()){ + if(!smpi_process()->replaying() && *len > 0){ if(! is_fortran_op_) this->func_(invec, inoutvec, len, &datatype); else{