Blame test/mpi/errors/comm/manysplit.c
|
Packit |
0848f5 |
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
|
|
Packit |
0848f5 |
/*
|
|
Packit |
0848f5 |
* (C) 2007 by Argonne National Laboratory.
|
|
Packit |
0848f5 |
* See COPYRIGHT in top-level directory.
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
#include <stdio.h>
|
|
Packit |
0848f5 |
#include <stdlib.h>
|
|
Packit |
0848f5 |
#include <mpi.h>
|
|
Packit |
0848f5 |
#include "mpitest.h"
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Test that comm_split fails gracefully when the number of communicators
|
|
Packit |
0848f5 |
is exhausted. Original version submitted by Paul Sack.
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
#define MAX_COMMS 2000
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Define VERBOSE to get an output line for every communicator */
|
|
Packit |
0848f5 |
/* #define VERBOSE 1 */
|
|
Packit |
0848f5 |
int main(int argc, char *argv[])
|
|
Packit |
0848f5 |
{
|
|
Packit |
0848f5 |
int i, rank;
|
|
Packit |
0848f5 |
int rc, maxcomm;
|
|
Packit |
0848f5 |
int errs = 0;
|
|
Packit |
0848f5 |
MPI_Comm comm[MAX_COMMS];
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MTest_Init(&argc, &argv);
|
|
Packit |
0848f5 |
MPI_Comm_rank(MPI_COMM_WORLD, &rank;;
|
|
Packit |
0848f5 |
MPI_Errhandler_set(MPI_COMM_WORLD, MPI_ERRORS_RETURN);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
maxcomm = -1;
|
|
Packit |
0848f5 |
for (i = 0; i < MAX_COMMS; i++) {
|
|
Packit |
0848f5 |
#ifdef VERBOSE
|
|
Packit |
0848f5 |
if (rank == 0) {
|
|
Packit |
0848f5 |
if (i % 20 == 0) {
|
|
Packit |
0848f5 |
fprintf(stderr, "\n %d: ", i);
|
|
Packit |
0848f5 |
fflush(stdout);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
else {
|
|
Packit |
0848f5 |
fprintf(stderr, ".");
|
|
Packit |
0848f5 |
fflush(stdout);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
#endif
|
|
Packit |
0848f5 |
rc = MPI_Comm_split(MPI_COMM_WORLD, 1, rank, &comm[i]);
|
|
Packit |
0848f5 |
if (rc != MPI_SUCCESS) {
|
|
Packit |
0848f5 |
break;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
maxcomm = i;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
for (i = 0; i <= maxcomm; i++) {
|
|
Packit |
0848f5 |
MPI_Comm_free(&comm[i]);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
/* If we complete, there are no errors */
|
|
Packit |
0848f5 |
MTest_Finalize(errs);
|
|
Packit |
0848f5 |
MPI_Finalize();
|
|
Packit |
0848f5 |
return 0;
|
|
Packit |
0848f5 |
}
|