X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9e2e32849ed01a869c9c70e78014e6938f098be5..80ce6e44e60fc872257d4e9fc5100e419d0ae376:/teshsuite/smpi/coll-allreduce/coll-allreduce.c diff --git a/teshsuite/smpi/coll-allreduce/coll-allreduce.c b/teshsuite/smpi/coll-allreduce/coll-allreduce.c index c35732fce6..6d4264890f 100644 --- a/teshsuite/smpi/coll-allreduce/coll-allreduce.c +++ b/teshsuite/smpi/coll-allreduce/coll-allreduce.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2010, 2013-2017. The SimGrid Team. +/* Copyright (c) 2009-2019. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -10,11 +10,6 @@ #include #include "mpi.h" -#ifndef EXIT_SUCCESS -#define EXIT_SUCCESS 0 -#define EXIT_FAILURE 1 -#endif - int main(int argc, char *argv[]) { int rank; @@ -30,19 +25,37 @@ int main(int argc, char *argv[]) MPI_Comm_size(MPI_COMM_WORLD, &size); if (maxlen > 1) mult = maxlen > size ? size : maxlen; - int* sb = (int *) xbt_malloc(size *maxlen * sizeof(int)); - int* rb = (int *) xbt_malloc(size *maxlen * sizeof(int)); + int* sb = xbt_new0(int, size * maxlen); + int* rb = xbt_new0(int, size * maxlen); for (i = 0; i < size *maxlen; ++i) { sb[i] = rank*size + i; rb[i] = 0; } + status = MPI_Allreduce(NULL, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, MPI_COMM_WORLD); + if(status!=MPI_ERR_BUFFER) + printf("MPI_Allreduce did not return MPI_ERR_BUFFER for empty sendbuf\n"); + status = MPI_Allreduce(sb, NULL, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, MPI_COMM_WORLD); + if(status!=MPI_ERR_BUFFER) + printf("MPI_Allreduce did not return MPI_ERR_BUFFER for empty recvbuf\n"); + status = MPI_Allreduce(sb, rb, -1, MPI_UNSIGNED_LONG_LONG, MPI_SUM, MPI_COMM_WORLD); + if(status!=MPI_ERR_COUNT) + printf("MPI_Allreduce did not return MPI_ERR_COUNT for -1 count\n"); + status = MPI_Allreduce(sb, rb, size, MPI_DATATYPE_NULL, MPI_SUM, MPI_COMM_WORLD); + if(status!=MPI_ERR_TYPE) + printf("MPI_Allreduce did not return MPI_ERR_TYPE for MPI_DATATYPE_NULL type\n"); + status = MPI_Allreduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_OP_NULL, MPI_COMM_WORLD); + if(status!=MPI_ERR_OP) + printf("MPI_Allreduce did not return MPI_ERR_COMM for MPI_OP_NULL op\n"); + status = MPI_Allreduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, MPI_COMM_NULL); + if(status!=MPI_ERR_COMM) + printf("MPI_Allreduce did not return MPI_ERR_COMM for MPI_COMM_NULL comm\n"); + printf("[%d] sndbuf=[", rank); for (i = 0; i < size *mult; i++) printf("%d ", sb[i]); printf("]\n"); - status = MPI_Allreduce(sb, rb, size *maxlen, MPI_INT, MPI_SUM, MPI_COMM_WORLD); printf("[%d] rcvbuf=[", rank);