[mpich2-commits] r7741 - mpich2/trunk/src/mpi/coll

balaji at mcs.anl.gov balaji at mcs.anl.gov
Tue Jan 18 14:35:44 CST 2011


Author: balaji
Date: 2011-01-18 14:35:44 -0600 (Tue, 18 Jan 2011)
New Revision: 7741

Modified:
   mpich2/trunk/src/mpi/coll/alltoallv.c
   mpich2/trunk/src/mpi/coll/alltoallw.c
Log:
Fixes to the collective tags.

Reviewed by buntinas.

Modified: mpich2/trunk/src/mpi/coll/alltoallv.c
===================================================================
--- mpich2/trunk/src/mpi/coll/alltoallv.c	2011-01-18 20:31:07 UTC (rev 7740)
+++ mpich2/trunk/src/mpi/coll/alltoallv.c	2011-01-18 20:35:44 UTC (rev 7741)
@@ -107,8 +107,8 @@
                     /* also covers the (rank == i && rank == j) case */
                     mpi_errno = MPIC_Sendrecv_replace(((char *)recvbuf + rdispls[j]*recv_extent),
                                                       recvcnts[j], recvtype,
-                                                      j, MPIR_ALLTOALL_TAG,
-                                                      j, MPIR_ALLTOALL_TAG,
+                                                      j, MPIR_ALLTOALLV_TAG,
+                                                      j, MPIR_ALLTOALLV_TAG,
                                                       comm, &status);
                     if (mpi_errno) MPIU_ERR_POP(mpi_errno);
                 }
@@ -116,8 +116,8 @@
                     /* same as above with i/j args reversed */
                     mpi_errno = MPIC_Sendrecv_replace(((char *)recvbuf + rdispls[i]*recv_extent),
                                                       recvcnts[i], recvtype,
-                                                      i, MPIR_ALLTOALL_TAG,
-                                                      i, MPIR_ALLTOALL_TAG,
+                                                      i, MPIR_ALLTOALLV_TAG,
+                                                      i, MPIR_ALLTOALLV_TAG,
                                                       comm, &status);
                     if (mpi_errno) MPIU_ERR_POP(mpi_errno);
                 }

Modified: mpich2/trunk/src/mpi/coll/alltoallw.c
===================================================================
--- mpich2/trunk/src/mpi/coll/alltoallw.c	2011-01-18 20:31:07 UTC (rev 7740)
+++ mpich2/trunk/src/mpi/coll/alltoallw.c	2011-01-18 20:35:44 UTC (rev 7741)
@@ -98,8 +98,8 @@
                     /* also covers the (rank == i && rank == j) case */
                     mpi_errno = MPIC_Sendrecv_replace(((char *)recvbuf + rdispls[j]),
                                                       recvcnts[j], recvtypes[j],
-                                                      j, MPIR_ALLTOALL_TAG,
-                                                      j, MPIR_ALLTOALL_TAG,
+                                                      j, MPIR_ALLTOALLW_TAG,
+                                                      j, MPIR_ALLTOALLW_TAG,
                                                       comm, &status);
                     if (mpi_errno) {
                         /* for communication errors, just record the error but continue */
@@ -111,8 +111,8 @@
                     /* same as above with i/j args reversed */
                     mpi_errno = MPIC_Sendrecv_replace(((char *)recvbuf + rdispls[i]),
                                                       recvcnts[i], recvtypes[i],
-                                                      i, MPIR_ALLTOALL_TAG,
-                                                      i, MPIR_ALLTOALL_TAG,
+                                                      i, MPIR_ALLTOALLW_TAG,
+                                                      i, MPIR_ALLTOALLW_TAG,
                                                       comm, &status);
                     if (mpi_errno) {
                         /* for communication errors, just record the error but continue */



More information about the mpich2-commits mailing list