send_offset, recv_offset, last_recv_cnt=0, nprocs_completed, k,
offset, tmp_mask, tree_root;
- unsigned int comm_size = smpi_comm_size(comm);
- unsigned int rank = smpi_comm_rank(comm);
+ unsigned int comm_size = comm->size();
+ unsigned int rank = comm->rank();
total_count = 0;
for (i=0; i<comm_size; i++)
for (j=0; j<dst_tree_root; j++)
recv_offset += recvcounts[j];
- smpi_mpi_sendrecv(((char *)tmp_buf + send_offset * recvtype_extent),
+ Request::sendrecv(((char *)tmp_buf + send_offset * recvtype_extent),
curr_cnt, recvtype, dst,
COLL_TAG_ALLGATHERV,
((char *)tmp_buf + recv_offset * recvtype_extent),
offset += recvcounts[j];
offset *= recvtype_extent;
- smpi_mpi_send(((char *)tmp_buf + offset),
+ Request::send(((char *)tmp_buf + offset),
last_recv_cnt,
recvtype, dst,
COLL_TAG_ALLGATHERV, comm);
for (j=0; j<(my_tree_root+mask); j++)
offset += recvcounts[j];
- smpi_mpi_recv(((char *)tmp_buf + offset * recvtype_extent),
+ Request::recv(((char *)tmp_buf + offset * recvtype_extent),
total_count - offset, recvtype,
dst, COLL_TAG_ALLGATHERV,
comm, &status);