zhyang-dev/openfoam
1
0
Fork 0
mirror of https://develop.openfoam.com/Development/openfoam.git synced 2025-11-28 03:28:01 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

ignore status

Browse Source
This commit is contained in:
mattijs
2008-11-14 13:42:28 +00:00
parent 4d2284c99d
commit 80c19974f1
3 changed files with 8 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/Pstream/mpi/IPread.C
View File

@ -193,15 +193,13 @@ void Foam::IPstream::waitRequests()
{ {
if (IPstream_outstandingRequests_.size() > 0) if (IPstream_outstandingRequests_.size() > 0)
{ {
List<MPI_Status> status(IPstream_outstandingRequests_.size());
if if
( (
MPI_Waitall MPI_Waitall
( (
IPstream_outstandingRequests_.size(), IPstream_outstandingRequests_.size(),
IPstream_outstandingRequests_.begin(), IPstream_outstandingRequests_.begin(),
status.begin() MPI_STATUSES_IGNORE
) )
) )
{ {
@ -231,9 +229,7 @@ bool Foam::IPstream::finishedRequest(const label i)
} }
int flag; int flag;
MPI_Status status; MPI_Test(&IPstream_outstandingRequests_[i], &flag, MPI_STATUS_IGNORE);
MPI_Test(&IPstream_outstandingRequests_[i], &flag, &status);
return flag != 0; return flag != 0;
} }

8
src/Pstream/mpi/OPwrite.C
View File

@ -131,15 +131,13 @@ void Foam::OPstream::waitRequests()
{ {
if (OPstream_outstandingRequests_.size() > 0) if (OPstream_outstandingRequests_.size() > 0)
{ {
List<MPI_Status> status(OPstream_outstandingRequests_.size());
if if
( (
MPI_Waitall MPI_Waitall
( (
OPstream_outstandingRequests_.size(), OPstream_outstandingRequests_.size(),
OPstream_outstandingRequests_.begin(), OPstream_outstandingRequests_.begin(),
status.begin() MPI_STATUSES_IGNORE
) )
) )
{ {
@ -169,9 +167,7 @@ bool Foam::OPstream::finishedRequest(const label i)
} }
int flag; int flag;
MPI_Status status; MPI_Test(&OPstream_outstandingRequests_[i], &flag, MPI_STATUS_IGNORE);
MPI_Test(&OPstream_outstandingRequests_[i], &flag, &status);
return flag != 0; return flag != 0;
} }

12
src/Pstream/mpi/Pstream.C
View File

@ -157,8 +157,6 @@ void Foam::reduce(scalar& Value, const sumOp<scalar>& bop)
if (Pstream::nProcs() <= Pstream::nProcsSimpleSum) if (Pstream::nProcs() <= Pstream::nProcsSimpleSum)
{ {
MPI_Status status;
if (Pstream::master()) if (Pstream::master())
{ {
for for
@ -180,7 +178,7 @@ void Foam::reduce(scalar& Value, const sumOp<scalar>& bop)
Pstream::procID(slave), Pstream::procID(slave),
Pstream::msgType(), Pstream::msgType(),
MPI_COMM_WORLD, MPI_COMM_WORLD,
&status MPI_STATUS_IGNORE
) )
) )
{ {
@ -260,7 +258,7 @@ void Foam::reduce(scalar& Value, const sumOp<scalar>& bop)
Pstream::procID(Pstream::masterNo()), Pstream::procID(Pstream::masterNo()),
Pstream::msgType(), Pstream::msgType(),
MPI_COMM_WORLD, MPI_COMM_WORLD,
&status MPI_STATUS_IGNORE
) )
) )
{ {
@ -279,8 +277,6 @@ void Foam::reduce(scalar& Value, const sumOp<scalar>& bop)
Value = sum; Value = sum;
/* /*
MPI_Status status;
int myProcNo = Pstream::myProcNo(); int myProcNo = Pstream::myProcNo();
int nProcs = Pstream::nProcs(); int nProcs = Pstream::nProcs();
@ -314,7 +310,7 @@ void Foam::reduce(scalar& Value, const sumOp<scalar>& bop)
Pstream::procID(childProcId), Pstream::procID(childProcId),
Pstream::msgType(), Pstream::msgType(),
MPI_COMM_WORLD, MPI_COMM_WORLD,
&status MPI_STATUS_IGNORE
) )
) )
{ {
@ -370,7 +366,7 @@ void Foam::reduce(scalar& Value, const sumOp<scalar>& bop)
Pstream::procID(parentId), Pstream::procID(parentId),
Pstream::msgType(), Pstream::msgType(),
MPI_COMM_WORLD, MPI_COMM_WORLD,
&status MPI_STATUS_IGNORE
) )
) )
{ {