- recv_chunk *= recv_count;
-
- MPI_Barrier(comm);
- for (i = 0; i < num_procs; i++)
- {
- src = dst = rank ^ i;
- MPI_Sendrecv(send_ptr + dst * send_chunk, send_count, send_type, dst,
- tag, recv_ptr + src * recv_chunk, recv_count, recv_type,
- src, tag, comm, &s);
- }
-
- return success;
+ recv_chunk *= recv_count;
+
+ mpi_coll_barrier_fun(comm);
+ for (i = 0; i < num_procs; i++) {
+ src = dst = rank ^ i;
+ smpi_mpi_sendrecv(send_ptr + dst * send_chunk, send_count, send_type, dst,
+ tag, recv_ptr + src * recv_chunk, recv_count, recv_type,
+ src, tag, comm, &s);
+ }
+
+ return MPI_SUCCESS;