MPI implementation of the IPstreamImpl abstract base class. More...
#include <mpiPstream/mpiIPstreamImpl.H>
MPI implementation of the IPstreamImpl abstract base class.
Definition at line 55 of file mpiIPstreamImpl.H.
Public Member Functions | |
TypeName ("mpiIPstreamImpl") | |
mpiIPstreamImpl () | |
Construct null.
| |
virtual void | init (const PstreamImpl::commsTypes commsType, const label bufSize, int &fromProcNo, label &messageSize, List< char > &buf) |
Initialization.
| |
virtual label | read (const PstreamImpl::commsTypes commsType, const int fromProcNo, char *buf, const std::streamsize bufSize) |
Read into given buffer from given processor and return the.
| |
virtual void | waitRequests () |
Non-blocking receives: wait until all have finished.
| |
virtual bool | finishedRequest (const label i) |
Non-blocking receives: has request i finished?
|
mpiIPstreamImpl | ( | ) | [inline]
|
Construct null.
Definition at line 75 of file mpiIPstreamImpl.H.
TypeName | ( | "mpiIPstreamImpl" | ) |
void init | ( | const PstreamImpl::commsTypes | commsType, |
const label | bufSize, | ||
int & | fromProcNo, | ||
label & | messageSize, | ||
List< char > & | buf | ||
) | [virtual]
|
Initialization.
Implements IPstreamImpl.
Definition at line 53 of file mpiIPstreamImpl.C.
References Foam::abort(), UList< T >::begin(), Foam::FatalError, FatalErrorIn, List< T >::setSize(), and List< T >::size().
Foam::label read | ( | const PstreamImpl::commsTypes | commsType, |
const int | fromProcNo, | ||
char * | buf, | ||
const std::streamsize | bufSize | ||
) | [virtual]
|
Read into given buffer from given processor and return the.
message size
Implements IPstreamImpl.
Definition at line 88 of file mpiIPstreamImpl.C.
References Foam::abort(), Foam::FatalError, FatalErrorIn, and Foam::PstreamGlobals::IPstream_outstandingRequests_.
void waitRequests | ( | ) | [virtual]
|
Non-blocking receives: wait until all have finished.
Implements IPstreamImpl.
Definition at line 189 of file mpiIPstreamImpl.C.
References Foam::endl(), FatalErrorIn, and Foam::PstreamGlobals::IPstream_outstandingRequests_.
bool finishedRequest | ( | const label | i ) | [virtual]
|
Non-blocking receives: has request i finished?
Implements IPstreamImpl.
Definition at line 214 of file mpiIPstreamImpl.C.
References Foam::abort(), Foam::FatalError, FatalErrorIn, Foam::PstreamGlobals::IPstream_outstandingRequests_, and Foam::nl.