void *recv_buff, int recv_count,
MPI_Datatype recv_type, MPI_Comm comm)
{
- int i, rank, size, nreqs, src, dst, tag = 101;
+ int i, rank, size, nreqs, src, dst, tag = COLL_TAG_ALLTOALL;
char *psnd;
char *prcv;
MPI_Aint sndinc;
smpi_mpi_waitall(nreqs, req, statuses);
- for (i = 0, preq = req; i < nreqs; ++i, ++preq) {
- smpi_mpi_request_free(preq);
- }
/* All done */
-
+ for(i= 0;i<nreqs;i++)if(req[i])smpi_mpi_request_free(&req[i]);
if (req)
- free((char *) req);
+ xbt_free((char *) req);
if (statuses)
- free(statuses);
+ xbt_free(statuses);
return MPI_SUCCESS;
}