- recv_chunk *= recv_count;
-
- for (i = 0; i < num_procs; i++)
- {
- src = (rank - i + num_procs) % num_procs;
- dst = (rank + i) % num_procs;
-
- MPI_Barrier(comm);
- 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;
+
+ for (i = 0; i < num_procs; i++) {
+ src = (rank - i + num_procs) % num_procs;
+ dst = (rank + i) % num_procs;
+
+ mpi_coll_barrier_fun(comm);
+ 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;