Skip to content

Commit

Permalink
fixup! coll: replace MPIR_ERR_COLL_CHECKANDCONT
Browse files Browse the repository at this point in the history
  • Loading branch information
hzhou committed Jun 28, 2024
1 parent 0bda938 commit 75fc557
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions src/mpid/ch4/shm/posix/release_gather/nb_reduce_release_gather.h
Original file line number Diff line number Diff line change
Expand Up @@ -449,38 +449,38 @@ MPL_STATIC_INLINE_PREFIX int MPIDI_POSIX_nb_release_gather_ireduce_impl(void *se
mpi_errno =
MPIR_TSP_sched_generic(reserve_buf_type_id, data, sched, n_incoming, &prev_vtx_id,
&first_vtx_id);
MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

mpi_errno =
MPIR_TSP_sched_generic(propagate_release_flag_type_id, data, sched, 1, &first_vtx_id,
&second_vtx_id);
MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

mpi_errno =
MPIR_TSP_sched_cb(&MPIDI_POSIX_NB_RG_all_datacopy_cb, data, sched, 1, &second_vtx_id,
&third_vtx_id);

MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

mpi_errno =
MPIR_TSP_sched_generic(gather_type_id, data, sched, 1, &third_vtx_id, &fourth_vtx_id);
MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

mpi_errno =
MPIR_TSP_sched_cb(&MPIDI_POSIX_NB_RG_reduce_data_cb, data, sched, 1, &fourth_vtx_id,
&fifth_vtx_id);

MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

mpi_errno =
MPIR_TSP_sched_generic(start_sendrecv_type_id, data, sched, 1, &fifth_vtx_id,
&sixth_vtx_id);
MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

mpi_errno =
MPIR_TSP_sched_generic(finish_sendrecv_type_id, data, sched, 1, &sixth_vtx_id,
&seventh_vtx_id);
MPI_ERR_CHECK(mpi_errno);
MPIR_ERR_CHECK(mpi_errno);

offset += chunk_count;
}
Expand Down

0 comments on commit 75fc557

Please sign in to comment.