X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dccf1b41e9c7b5a696f01abceaa2779fe65f154f..61fc507b7dde640d3bd7d4818d15674436c34f97:/teshsuite/smpi/coll-reduce/coll-reduce.c diff --git a/teshsuite/smpi/coll-reduce/coll-reduce.c b/teshsuite/smpi/coll-reduce/coll-reduce.c index 9543c53bee..bd6ff17866 100644 --- a/teshsuite/smpi/coll-reduce/coll-reduce.c +++ b/teshsuite/smpi/coll-reduce/coll-reduce.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2010, 2013-2014. 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,25 +10,20 @@ #include #include "mpi.h" -#ifndef EXIT_SUCCESS -#define EXIT_SUCCESS 0 -#define EXIT_FAILURE 1 -#endif - int main(int argc, char *argv[]) { - int rank, size; + int rank; + int size; int i; - long int *sb; - long int *rb; int status; MPI_Init(&argc, &argv); MPI_Comm_rank(MPI_COMM_WORLD, &rank); MPI_Comm_size(MPI_COMM_WORLD, &size); + MPI_Comm_set_errhandler(MPI_COMM_WORLD, MPI_ERRORS_RETURN); - sb = (long int *) xbt_malloc(size * sizeof(long int)); - rb = (long int *) xbt_malloc(size * sizeof(long int)); + unsigned long long* sb = (unsigned long long *) xbt_malloc(size * sizeof(unsigned long long)); + unsigned long long* rb = (unsigned long long *) xbt_malloc(size * sizeof(unsigned long long)); for (i = 0; i < size; ++i) { sb[i] = rank*size + i; @@ -36,17 +31,39 @@ int main(int argc, char *argv[]) } printf("[%d] sndbuf=[", rank); for (i = 0; i < size; i++) - printf("%ld ", sb[i]); + printf("%llu ", sb[i]); printf("]\n"); - int root=0; - status = MPI_Reduce(sb, rb, size, MPI_LONG, MPI_SUM, root, MPI_COMM_WORLD); + + status = MPI_Reduce(NULL, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, root, MPI_COMM_WORLD); + if(status!=MPI_ERR_BUFFER) + printf("MPI_Reduce did not return MPI_ERR_BUFFER for empty sendbuf\n"); + status = MPI_Reduce(sb, rb, -1, MPI_UNSIGNED_LONG_LONG, MPI_SUM, root, MPI_COMM_WORLD); + if(status!=MPI_ERR_COUNT) + printf("MPI_Reduce did not return MPI_ERR_COUNT for -1 count\n"); + status = MPI_Reduce(sb, rb, size, MPI_DATATYPE_NULL, MPI_SUM, root, MPI_COMM_WORLD); + if(status!=MPI_ERR_TYPE) + printf("MPI_Reduce did not return MPI_ERR_TYPE for MPI_DATATYPE_NULL type\n"); + status = MPI_Reduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_OP_NULL, root, MPI_COMM_WORLD); + if(status!=MPI_ERR_OP) + printf("MPI_Reduce did not return MPI_ERR_COMM for MPI_OP_NULL op\n"); + status = MPI_Reduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, -1, MPI_COMM_WORLD); + if(status!=MPI_ERR_ROOT) + printf("MPI_Reduce did not return MPI_ERR_ROOT for root -1\n"); + status = MPI_Reduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, size+1, MPI_COMM_WORLD); + if(status!=MPI_ERR_ROOT) + printf("MPI_Reduce did not return MPI_ERR_ROOT for root > size\n"); + status = MPI_Reduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, root, MPI_COMM_NULL); + if(status!=MPI_ERR_COMM) + printf("MPI_Reduce did not return MPI_ERR_COMM for MPI_COMM_NULL comm\n"); + + status = MPI_Reduce(sb, rb, size, MPI_UNSIGNED_LONG_LONG, MPI_SUM, root, MPI_COMM_WORLD); MPI_Barrier(MPI_COMM_WORLD); if (rank == root) { printf("[%d] rcvbuf=[", rank); for (i = 0; i < size; i++) - printf("%ld ", rb[i]); + printf("%llu ", rb[i]); printf("]\n"); if (status != MPI_SUCCESS) { printf("all_to_all returned %d\n", status); @@ -56,17 +73,17 @@ int main(int argc, char *argv[]) printf("[%d] second sndbuf=[", rank); for (i = 0; i < 1; i++) - printf("%ld ", sb[i]); + printf("%llu ", sb[i]); printf("]\n"); root=size-1; - status = MPI_Reduce(sb, rb, 1, MPI_LONG, MPI_PROD, root, MPI_COMM_WORLD); + status = MPI_Reduce(sb, rb, 1, MPI_UNSIGNED_LONG_LONG, MPI_PROD, root, MPI_COMM_WORLD); MPI_Barrier(MPI_COMM_WORLD); if (rank == root) { printf("[%d] rcvbuf=[", rank); for (i = 0; i < 1; i++) - printf("%ld ", rb[i]); + printf("%llu ", rb[i]); printf("]\n"); if (status != MPI_SUCCESS) { printf("all_to_all returned %d\n", status);