X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a3d08dd00246eb26ced68c5b0e046096706bbe23..5ed37babb2fa9097abe82df299c0aa259ed84d5a:/teshsuite/smpi/coll-allgatherv/coll-allgatherv.c diff --git a/teshsuite/smpi/coll-allgatherv/coll-allgatherv.c b/teshsuite/smpi/coll-allgatherv/coll-allgatherv.c index 30734f17d5..c2358fd3f0 100644 --- a/teshsuite/smpi/coll-allgatherv/coll-allgatherv.c +++ b/teshsuite/smpi/coll-allgatherv/coll-allgatherv.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2009-2010, 2013-2014. The SimGrid Team. +/* Copyright (c) 2009-2023. 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 i; @@ -25,6 +20,7 @@ int main(int argc, char *argv[]) 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); int* recv_counts = (int *) xbt_malloc(size * sizeof(int)); int* recv_disps = (int *) xbt_malloc(size * sizeof(int)); @@ -39,6 +35,31 @@ int main(int argc, char *argv[]) int* sb = (int *) xbt_malloc(recv_counts[rank] * sizeof(int)); int* rb = (int *) xbt_malloc(recv_sb_size * sizeof(int)); + status = MPI_Allgatherv(NULL, recv_counts[rank], MPI_INT, rb, recv_counts, recv_disps, MPI_INT, MPI_COMM_WORLD); + if(status!=MPI_ERR_BUFFER) + printf("MPI_Allgatherv did not return MPI_ERR_BUFFER for empty sendbuf\n"); + status = MPI_Allgatherv(sb, -1, MPI_INT, rb, recv_counts, recv_disps, MPI_INT, MPI_COMM_WORLD); + if(status!=MPI_ERR_COUNT) + printf("MPI_Allgatherv did not return MPI_ERR_COUNT for -1 sendcount\n"); + status = MPI_Allgatherv(sb, recv_counts[rank], MPI_DATATYPE_NULL, rb, recv_counts, recv_disps, MPI_INT, MPI_COMM_WORLD); + if(status!=MPI_ERR_TYPE) + printf("MPI_Allgatherv did not return MPI_ERR_TYPE for MPI_DATATYPE_NULL sendtype\n"); + status = MPI_Allgatherv(sb, recv_counts[rank], MPI_INT, NULL, recv_counts, recv_disps, MPI_INT, MPI_COMM_WORLD); + if(status!=MPI_ERR_BUFFER) + printf("MPI_Allgatherv did not return MPI_ERR_BUFFER for empty recvbuf\n"); + status = MPI_Allgatherv(sb, recv_counts[rank], MPI_INT, rb, NULL, recv_disps, MPI_INT, MPI_COMM_WORLD); + if(status!=MPI_ERR_COUNT) + printf("MPI_Allgatherv did not return MPI_ERR_COUNT for NULL recvcounts\n"); + status = MPI_Allgatherv(sb, recv_counts[rank], MPI_INT, rb, recv_counts, NULL, MPI_INT, MPI_COMM_WORLD); + if(status!=MPI_ERR_ARG) + printf("MPI_Allgatherv did not return MPI_ERR_ARG for NULL recvdisps\n"); + status = MPI_Allgatherv(sb, recv_counts[rank], MPI_INT, rb, recv_counts, recv_disps, MPI_DATATYPE_NULL, MPI_COMM_WORLD); + if(status!=MPI_ERR_TYPE) + printf("MPI_Allgatherv did not return MPI_ERR_TYPE for MPI_DATATYPE_NULL recvtype\n"); + status = MPI_Allgatherv(sb, recv_counts[rank], MPI_INT, rb, recv_counts, recv_disps, MPI_INT, MPI_COMM_NULL); + if(status!=MPI_ERR_COMM) + printf("MPI_Allgatherv did not return MPI_ERR_COMM for MPI_COMM_NULL comm\n"); + printf("[%d] sndbuf=[", rank); for (i = 0; i < recv_counts[rank]; i++){ sb[i] = recv_disps[rank] + i; @@ -56,16 +77,14 @@ int main(int argc, char *argv[]) printf("%d ", rb[i]); printf("]\n"); - if (rank == 0) { - if (status != MPI_SUCCESS) { - printf("allgatherv returned %d\n", status); - fflush(stdout); - } + if (rank == 0 && status != MPI_SUCCESS) { + printf("allgatherv returned %d\n", status); + fflush(stdout); } xbt_free(sb); xbt_free(rb); xbt_free(recv_counts); xbt_free(recv_disps); MPI_Finalize(); - return (EXIT_SUCCESS); + return EXIT_SUCCESS; }