Skip to content

Commit

Permalink
Fix a typo and missed variable declarations.
Browse files Browse the repository at this point in the history
  • Loading branch information
swblaster committed Jun 15, 2018
1 parent e644387 commit 86eeb7c
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
6 changes: 4 additions & 2 deletions src/mpi/romio/adio/ad_lustre/ad_lustre_aggregate.c
Original file line number Diff line number Diff line change
Expand Up @@ -464,7 +464,7 @@ void ADIOI_LUSTRE_Get_striping_info(ADIO_File fd, int **striping_info_ptr, int m
* striping_info[1]: stripe_count
* striping_info[2]: avail_cb_nodes
*/
int stripe_size, stripe_count, CO = 1;
int i, myrank, stripe_size, stripe_count, CO = 1;
int avail_cb_nodes, divisor, nprocs_for_coll = fd->hints->cb_nodes;

/* Get hints value */
Expand Down Expand Up @@ -533,10 +533,12 @@ void ADIOI_LUSTRE_Get_striping_info(ADIO_File fd, int **striping_info_ptr, int m

/* [Sunwoo] If avail_cb_nodes < fd->hints->cb_nodes,
* fd->is_agg should also be adjusted. */
MPI_Comm_rank(fd->comm, &myrank);

if (avail_cb_nodes < fd->hints->cb_nodes) {
fd->hints->cb_nodes = avail_cb_nodes;
fd->is_agg = 0;
for (int i = 0; i < avail_cb_nodes; i++) {
for (i = 0; i < avail_cb_nodes; i++) {
if (myrank == fd->hints->ranklist[i])
fd->is_agg = 1;
}
Expand Down
2 changes: 1 addition & 1 deletion src/mpi/romio/adio/ad_lustre/ad_lustre_wrcoll.c
Original file line number Diff line number Diff line change
Expand Up @@ -925,7 +925,7 @@ static void ADIOI_LUSTRE_W_Exchange_data(ADIO_File fd, const void *buf, char *wr
/* augment the request array for the 2nd and following iterations */
send_req_idx = num_send_reqs;
num_send_reqs += nprocs_send;
send_reqs = (MPI_Request *) ADIOI_Realloc(send_reqs, num_send_reqs * sizeof(MPI_Request))
send_reqs = (MPI_Request *) ADIOI_Realloc(send_reqs, num_send_reqs * sizeof(MPI_Request));
}
#endif

Expand Down

0 comments on commit 86eeb7c

Please sign in to comment.