Commit bf021b67 authored by Igor Ivanov's avatar Igor Ivanov Committed by Wesley Bland
Browse files

mpi/coll: Fix a bug in MPI_Scan

This issue was added in commit [54362c00

].
Signed-off-by: default avatarIgor Ivanov <Igor.Ivanov@itseez.com>
Signed-off-by: default avatarWesley Bland <wbland@anl.gov>
parent be7c17b3
......@@ -303,7 +303,7 @@ int MPIR_Scan(
{
mpi_errno = MPIC_Recv(localfulldata, count, datatype,
comm_ptr->node_comm->local_size - 1, MPIR_SCAN_TAG,
comm_ptr, &status, errflag);
comm_ptr->node_comm, &status, errflag);
if (mpi_errno) {
/* for communication errors, just record the error but continue */
*errflag = MPIR_ERR_GET_CLASS(mpi_errno);
......@@ -316,7 +316,7 @@ int MPIR_Scan(
MPIU_Get_intranode_rank(comm_ptr, rank) == comm_ptr->node_comm->local_size - 1)
{
mpi_errno = MPIC_Send(recvbuf, count, datatype,
0, MPIR_SCAN_TAG, comm_ptr, errflag);
0, MPIR_SCAN_TAG, comm_ptr->node_comm, errflag);
if (mpi_errno) {
/* for communication errors, just record the error but continue */
*errflag = MPIR_ERR_GET_CLASS(mpi_errno);
......@@ -349,7 +349,7 @@ int MPIR_Scan(
{
mpi_errno = MPIC_Send(prefulldata, count, datatype,
MPIU_Get_internode_rank(comm_ptr, rank) + 1,
MPIR_SCAN_TAG, comm_ptr, errflag);
MPIR_SCAN_TAG, comm_ptr->node_roots_comm, errflag);
if (mpi_errno) {
/* for communication errors, just record the error but continue */
*errflag = MPIR_ERR_GET_CLASS(mpi_errno);
......@@ -361,7 +361,7 @@ int MPIR_Scan(
{
mpi_errno = MPIC_Recv(tempbuf, count, datatype,
MPIU_Get_internode_rank(comm_ptr, rank) - 1,
MPIR_SCAN_TAG, comm_ptr, &status, errflag);
MPIR_SCAN_TAG, comm_ptr->node_roots_comm, &status, errflag);
noneed = 0;
if (mpi_errno) {
/* for communication errors, just record the error but continue */
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment