if (src == rank)
continue;
recv_offset = src * block_size;
- *(req_ptr++) = smpi_mpi_irecv((char *)recv_buff + recv_offset, recv_count, recv_type, src, tag,
+ *(req_ptr++) = Request::irecv((char *)recv_buff + recv_offset, recv_count, recv_type, src, tag,
comm);
}
dst = i + my_row_base;
if (dst == rank)
continue;
- smpi_mpi_send(send_buff, send_count, send_type, dst, tag, comm);
+ Request::send(send_buff, send_count, send_type, dst, tag, comm);
}
- smpi_mpi_waitall(Y - 1, req, MPI_STATUSES_IGNORE);
+ Request::waitall(Y - 1, req, MPI_STATUSES_IGNORE);
req_ptr = req;
continue;
src_row_base = (src / Y) * Y;
recv_offset = src_row_base * block_size;
- *(req_ptr++) = smpi_mpi_irecv((char *)recv_buff + recv_offset, recv_count * Y, recv_type, src, tag,
+ *(req_ptr++) = Request::irecv((char *)recv_buff + recv_offset, recv_count * Y, recv_type, src, tag,
comm);
}
if (dst == rank)
continue;
send_offset = my_row_base * block_size;
- smpi_mpi_send((char *)recv_buff + send_offset, send_count * Y, send_type, dst, tag,
+ Request::send((char *)recv_buff + send_offset, send_count * Y, send_type, dst, tag,
comm);
}
- smpi_mpi_waitall(X - 1, req, MPI_STATUSES_IGNORE);
+ Request::waitall(X - 1, req, MPI_STATUSES_IGNORE);
free(req);