Go to the documentation of this file.
46 commsType_(commsType),
51 sendBuf_(UPstream::nProcs(comm)),
52 recvBuf_(UPstream::nProcs(comm)),
53 recvBufPos_(UPstream::nProcs(comm), 0),
54 finishedSendsCalled_(
false)
65 if (recvBufPos_[proci] < recvBuf_[proci].size())
68 <<
"Message from processor " << proci
69 <<
" not fully consumed. messageSize:" << recvBuf_[proci].size()
70 <<
" bytes of which only " << recvBufPos_[proci]
82 finishedSendsCalled_ =
true;
86 Pstream::exchange<DynamicList<char>,
char>
100 finishedSendsCalled_ =
true;
106 Pstream::exchange<DynamicList<char>,
char>
119 <<
"Obtaining sizes not supported in "
121 <<
" since transfers already in progress. Use non-blocking instead."
141 finishedSendsCalled_ =
false;
Creates a single block of cells from point coordinates, numbers of cells in each direction and an exp...
~PstreamBuffers()
Destructor.
static void exchangeSizes(const Container &sendData, labelList &sizes, const label comm=UPstream::worldComm)
Helper: exchange sizes of sendData. sendData is the data per.
Ostream & endl(Ostream &os)
Add newline and flush stream.
void clear()
Clear storage and reset.
#define forAll(list, i)
Loop across all elements in list.
word format(conversionProperties.get< word >("format"))
Representation of a major/minor version number.
static const Enum< commsTypes > commsTypeNames
Names of the communication types.
void finishedSends(const bool block=true)
Mark all sends as having been done. This will start receives.
streamFormat
Data format (ascii | binary)
errorManip< error > abort(error &err)
errorManipArg< error, int > exit(error &err, const int errNo=1)
const std::string version
OpenFOAM version (name or stringified number) as a std::string.
PstreamBuffers(const UPstream::commsTypes commsType, const int tag=UPstream::msgType(), const label comm=UPstream::worldComm, IOstream::streamFormat format=IOstream::BINARY, IOstream::versionNumber version=IOstream::currentVersion)
Construct given comms type,.
commsTypes
Types of communications.
#define FatalErrorInFunction
Report an error message using Foam::FatalError.
static DynamicList< char > nullBuf