- int i;
- MPI_Request *rr = (MPI_Request *)malloc(size * sizeof(MPI_Request));
- for (i=0; i<size; i++) {
- MPI_Irecv( rbuf, 10, MPI_INT, i, tag, MPI_COMM_WORLD, &rr[i] );
- }
- MPI_Start( &r );
- MPI_Wait( &r, &s );
- MPI_Waitall( size, rr, MPI_STATUSES_IGNORE );
+ int i;
+ MPI_Request *rr = (MPI_Request *) malloc(size * sizeof(MPI_Request));
+ for (i = 0; i < size; i++) {
+ MPI_Irecv(rbuf, 10, MPI_INT, i, tag, MPI_COMM_WORLD, &rr[i]);
+ }
+ MPI_Start(&r);
+ MPI_Wait(&r, &s);
+ MPI_Waitall(size, rr, MPI_STATUSES_IGNORE);
+ free(rr);