- while (MTestGetIntracommGeneral( &comm, minsize, 1 )) {
- if (comm == MPI_COMM_NULL) continue;
- /* Determine the sender and receiver */
- MPI_Comm_rank( comm, &rank );
- MPI_Comm_size( comm, &size );
-
- for (count = 1; count < 130000; count = count * 2) {
- sendbuf = (int *)malloc( count * sizeof(int) );
- recvbuf = (int *)malloc( count * sizeof(int) );
- for (root = 0; root < size; root ++) {
- for (i=0; i<count; i++) sendbuf[i] = i;
- for (i=0; i<count; i++) recvbuf[i] = -1;
- MPI_Reduce( sendbuf, recvbuf, count, MPI_INT, MPI_SUM,
- root, comm );
- if (rank == root) {
- for (i=0; i<count; i++) {
- if (recvbuf[i] != i * size) {
- errs++;
- }
- }
- }
- }
- free( sendbuf );
- free( recvbuf );
- }
+ while (MTestGetIntracommGeneral(&comm, minsize, 1)) {
+ if (comm == MPI_COMM_NULL)
+ continue;
+ /* Determine the sender and receiver */
+ MPI_Comm_rank(comm, &rank);
+ MPI_Comm_size(comm, &size);