@@ -825,21 +825,24 @@ static void ADIOI_R_Exchange_data(ADIO_File fd, void *buf, ADIOI_Flatlist_node
825
825
else {
826
826
/* allocate memory for recv_buf and post receives */
827
827
recv_buf = (char * * ) ADIOI_Malloc (nprocs * sizeof (char * ));
828
- for (i = 0 ; i < nprocs ; i ++ )
829
- if (recv_size [i ]) recv_buf [i ] =
830
- (char * ) ADIOI_Malloc (recv_size [i ]);
831
-
832
- j = 0 ;
833
- for (i = 0 ; i < nprocs ; i ++ )
834
- if (recv_size [i ]) {
835
- MPI_Irecv (recv_buf [i ], recv_size [i ], MPI_BYTE , i ,
836
- myrank + i + 100 * iter , fd -> comm , requests + j );
837
- j ++ ;
828
+ for (i = 0 ; i < nprocs ; i ++ ) {
829
+ if (recv_size [i ]) {
830
+ recv_buf [i ] = (char * ) ADIOI_Malloc (recv_size [i ]);
831
+ }
832
+ }
833
+
834
+ j = 0 ;
835
+ for (i = 0 ; i < nprocs ; i ++ ) {
836
+ if (recv_size [i ]) {
837
+ MPI_Irecv (recv_buf [i ], recv_size [i ], MPI_BYTE , i ,
838
+ myrank + i + 100 * iter , fd -> comm , requests + j );
839
+ j ++ ;
838
840
#ifdef RDCOLL_DEBUG
839
- DBG_FPRINTF (stderr , "node %d, recv_size %d, tag %d \n" ,
840
- myrank , recv_size [i ], myrank + i + 100 * iter );
841
+ DBG_FPRINTF (stderr , "node %d, recv_size %d, tag %d \n" ,
842
+ myrank , recv_size [i ], myrank + i + 100 * iter );
841
843
#endif
842
- }
844
+ }
845
+ }
843
846
}
844
847
845
848
/* create derived datatypes and send data */
0 commit comments