Skip to content
This repository was archived by the owner on Sep 30, 2022. It is now read-only.

Commit 564f3c0

Browse files
committed
fcoll/two_phase: use PMPI_* insted of MPI_*
(cherry picked from commit open-mpi/ompi@002c7b8)
1 parent 32e4695 commit 564f3c0

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -677,8 +677,8 @@ static int two_phase_read_and_exch(mca_io_ompio_file_t *fh,
677677
}
678678
if (req_off < real_off + real_size) {
679679
count[i]++;
680-
MPI_Address(read_buf+req_off-real_off,
681-
&(others_req[i].mem_ptrs[j]));
680+
PMPI_Address(read_buf+req_off-real_off,
681+
&(others_req[i].mem_ptrs[j]));
682682

683683
send_size[i] += (int)(OMPIO_MIN(real_off + real_size - req_off,
684684
(OMPI_MPI_OFFSET_TYPE)req_len));

ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -766,8 +766,8 @@ static int two_phase_exch_and_write(mca_io_ompio_file_t *fh,
766766
size,i,
767767
count[i]);
768768
#endif
769-
MPI_Address(write_buf+req_off-off,
770-
&(others_req[i].mem_ptrs[j]));
769+
PMPI_Address(write_buf+req_off-off,
770+
&(others_req[i].mem_ptrs[j]));
771771
#if DEBUG_ON
772772
printf("%d : mem_ptrs : %ld\n", fh->f_rank,
773773
others_req[i].mem_ptrs[j]);

ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ int mca_fcoll_two_phase_calc_aggregator(mca_io_ompio_file_t *fh,
173173
fprintf(stderr,
174174
"rank_index(%d) >= num_aggregators(%d)fd_size=%lld off=%lld\n",
175175
rank_index,num_aggregators,fd_size,off);
176-
MPI_Abort(MPI_COMM_WORLD, 1);
176+
PMPI_Abort(MPI_COMM_WORLD, 1);
177177
}
178178

179179

0 commit comments

Comments
 (0)