1 /* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
3 * (C) 2015 by Argonne National Laboratory.
4 * See COPYRIGHT in top-level directory.
15 int main(int argc, char **argv)
19 int rank, size, rsize;
20 int in[ITERS], out[ITERS], sol[ITERS], cnt;
22 MPI_Comm newcomm[ITERS], testcomm;
25 MTest_Init(&argc, &argv);
26 MPI_Comm_rank(MPI_COMM_WORLD, &rank);
27 MPI_Comm_size(MPI_COMM_WORLD, &size);
29 printf("this test requires at least 2 processes\n");
30 MPI_Abort(MPI_COMM_WORLD, 1);
33 sreq = (MPI_Request *) malloc(sizeof(MPI_Request) * (size + 1) * ITERS);
35 while (MTestGetIntracommGeneral(&testcomm, 1, 1)) {
36 if (testcomm == MPI_COMM_NULL)
39 MPI_Comm_rank(testcomm, &rank);
40 MPI_Comm_size(testcomm, &size);
42 for (j = 0; j < ITERS; j++) {
47 for (i = 1; i < size; i++)
48 MPI_Isend(&out[j], 1, MPI_INT, i, 0, testcomm, &sreq[cnt++]);
49 MPI_Comm_idup(testcomm, &newcomm[j], &sreq[cnt++]);
55 MPI_Comm_idup(testcomm, &newcomm[j], &sreq[cnt++]);
56 MPI_Irecv(&in[j], 1, MPI_INT, 0, 0, testcomm, &sreq[cnt++]);
59 MPI_Waitall(cnt, sreq, MPI_STATUS_IGNORE);
61 for (j = 0; j < ITERS; j++) {
64 errs += MTestTestComm(newcomm[j]);
65 MPI_Comm_free(&newcomm[j]);
67 MTestFreeComm(&testcomm);
69 while (MTestGetIntercomm(&testcomm, &isLeft, 1)) {
70 if (testcomm == MPI_COMM_NULL)
73 MPI_Comm_rank(testcomm, &rank);
74 MPI_Comm_size(testcomm, &size);
75 MPI_Comm_remote_size(testcomm, &rsize);
77 for (j = 0; j < ITERS; j++) {
82 for (i = 1; i < rsize; i++)
83 MPI_Isend(&out[j], 1, MPI_INT, i, 0, testcomm, &sreq[cnt++]);
84 MPI_Comm_idup(testcomm, &newcomm[j], &sreq[cnt++]);
90 MPI_Comm_idup(testcomm, &newcomm[j], &sreq[cnt++]);
91 MPI_Irecv(&in[j], 1, MPI_INT, 0, 0, testcomm, &sreq[cnt++]);
94 MPI_Waitall(cnt, sreq, MPI_STATUS_IGNORE);
96 for (j = 0; j < ITERS; j++) {
99 errs += MTestTestComm(newcomm[j]);
100 MPI_Comm_free(&newcomm[j]);
102 MTestFreeComm(&testcomm);
106 MTest_Finalize(errs);