@@ -825,21 +825,24 @@ static void ADIOI_R_Exchange_data(ADIO_File fd, void *buf, ADIOI_Flatlist_node
825825 else {
826826/* allocate memory for recv_buf and post receives */
827827 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 ++ ;
838840#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 );
841843#endif
842- }
844+ }
845+ }
843846 }
844847
845848/* create derived datatypes and send data */
0 commit comments