- /* Initialize the recv buffer */
- for (i=0; i<MAX_MSGS; i++) {
- for (j=0; j<MAX_MSGS; j++) {
- buf[i][j] = -1;
- }
- }
- for (i=0; i<MAX_MSGS; i++) {
- MPI_Irecv( buf[i], MAX_MSGS-i, MPI_INT, MPI_ANY_SOURCE,
- MPI_ANY_TAG, comm, &r[i] );
- }
- MPI_Barrier( MPI_COMM_WORLD );
- for (i=0; i<MAX_MSGS; i++) {
- MPI_Waitany( MAX_MSGS, r, &idx, &status );
- /* Message idx should have length MAX_MSGS-idx */
- MPI_Get_count( &status, MPI_INT, &count );
- if (count != MAX_MSGS-idx) {
- errs++;
- }
- else {
- /* Check for the correct answers */
- for (j=0; j < MAX_MSGS-idx; j++) {
- if (buf[idx][j] != idx * MAX_MSGS + j) {
- errs ++;
- printf( "Message %d [%d] is %d, should be %d\n",
- idx, j, buf[idx][j], idx * MAX_MSGS + j );
- }
- }
- }
- }
+ /* Initialize the recv buffer */
+ for (i = 0; i < MAX_MSGS; i++) {
+ for (j = 0; j < MAX_MSGS; j++) {
+ buf[i][j] = -1;
+ }
+ }
+ for (i = 0; i < MAX_MSGS; i++) {
+ MPI_Irecv(buf[i], MAX_MSGS - i, MPI_INT, MPI_ANY_SOURCE, MPI_ANY_TAG, comm, &r[i]);
+ }
+ MPI_Barrier(MPI_COMM_WORLD);
+ for (i = 0; i < MAX_MSGS; i++) {
+ MPI_Waitany(MAX_MSGS, r, &idx, &status);
+ /* Message idx should have length MAX_MSGS-idx */
+ MPI_Get_count(&status, MPI_INT, &count);
+ if (count != MAX_MSGS - idx) {
+ errs++;
+ }
+ else {
+ /* Check for the correct answers */
+ for (j = 0; j < MAX_MSGS - idx; j++) {
+ if (buf[idx][j] != idx * MAX_MSGS + j) {
+ errs++;
+ printf("Message %d [%d] is %d, should be %d\n",
+ idx, j, buf[idx][j], idx * MAX_MSGS + j);
+ }
+ }
+ }
+ }