- while (MTestGetIntercomm( &comm, &leftGroup, 4 )) {
- if (comm == MPI_COMM_NULL) continue;
- for (count = 1; count < 66000; count = 2 * count) {
- /* Get an intercommunicator */
- MPI_Comm_remote_size( comm, &rsize );
- MPI_Comm_rank( comm, &rrank );
- sendbuf = (int *)malloc( rsize * count * sizeof(int) );
- recvbuf = (int *)malloc( rsize * count * sizeof(int) );
- for (i=0; i<rsize*count; i++) recvbuf[i] = -1;
- if (leftGroup) {
- idx = 0;
- for (j=0; j<rsize; j++) {
- for (i=0; i<count; i++) {
- sendbuf[idx++] = i + rrank;
- }
- }
- err = MPI_Alltoall( sendbuf, count, datatype,
- NULL, 0, datatype, comm );
- if (err) {
- errs++;
- MTestPrintError( err );
- }
- }
- else {
- int rank, size;
+ while (MTestGetIntercomm(&comm, &leftGroup, 4)) {
+ if (comm == MPI_COMM_NULL)
+ continue;
+ for (count = 1; count < 66000; count = 2 * count) {
+ /* Get an intercommunicator */
+ MPI_Comm_remote_size(comm, &rsize);
+ MPI_Comm_rank(comm, &rrank);
+ sendbuf = (int *) malloc(rsize * count * sizeof(int));
+ recvbuf = (int *) malloc(rsize * count * sizeof(int));
+ for (i = 0; i < rsize * count; i++)
+ recvbuf[i] = -1;
+ if (leftGroup) {
+ idx = 0;
+ for (j = 0; j < rsize; j++) {
+ for (i = 0; i < count; i++) {
+ sendbuf[idx++] = i + rrank;
+ }
+ }
+ err = MTest_Alltoall(sendbuf, count, datatype, NULL, 0, datatype, comm);
+ if (err) {
+ errs++;
+ MTestPrintError(err);
+ }
+ }
+ else {
+ int rank, size;