minor fix in scatterv_inter. We should now pass all ibm inter-collective tests.
This commit was SVN r5302.
Этот коммит содержится в:
родитель
a2b1f98444
Коммит
4ef292717e
@ -131,8 +131,8 @@ int mca_coll_basic_scatterv_inter(void *sbuf, int *scounts,
|
|||||||
else if ( MPI_ROOT != root ) {
|
else if ( MPI_ROOT != root ) {
|
||||||
/* If not root, receive data. */
|
/* If not root, receive data. */
|
||||||
err = MCA_PML_CALL(recv(rbuf, rcount, rdtype,
|
err = MCA_PML_CALL(recv(rbuf, rcount, rdtype,
|
||||||
root, MCA_COLL_BASE_TAG_SCATTERV,
|
root, MCA_COLL_BASE_TAG_SCATTERV,
|
||||||
comm, MPI_STATUS_IGNORE));
|
comm, MPI_STATUS_IGNORE));
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
/* I am the root, loop sending data. */
|
/* I am the root, loop sending data. */
|
||||||
@ -142,15 +142,12 @@ int mca_coll_basic_scatterv_inter(void *sbuf, int *scounts,
|
|||||||
}
|
}
|
||||||
|
|
||||||
for (i = 0; i < size; ++i) {
|
for (i = 0; i < size; ++i) {
|
||||||
if (0 == scounts[i]) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
ptmp = ((char *) sbuf) + (extent * disps[i]);
|
ptmp = ((char *) sbuf) + (extent * disps[i]);
|
||||||
err = MCA_PML_CALL(isend(ptmp, scounts[i], sdtype, i,
|
err = MCA_PML_CALL(isend(ptmp, scounts[i], sdtype, i,
|
||||||
MCA_COLL_BASE_TAG_SCATTERV,
|
MCA_COLL_BASE_TAG_SCATTERV,
|
||||||
MCA_PML_BASE_SEND_STANDARD, comm, reqs++));
|
MCA_PML_BASE_SEND_STANDARD, comm,
|
||||||
if (MPI_SUCCESS != err) {
|
&(reqs[i])));
|
||||||
|
if (OMPI_SUCCESS != err) {
|
||||||
return err;
|
return err;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user