37bool Foam::UOPstream::bufferIPCsend()
55 const commsTypes commsType,
58 const std::streamsize bufSize,
60 const label communicator
65 Pout<<
"UOPstream::write : starting write to:" << toProcNo
67 <<
" comm:" << communicator <<
" size:" << label(bufSize)
73 Pout<<
"UOPstream::write : starting write to:" << toProcNo
75 <<
" comm:" << communicator <<
" size:" << label(bufSize)
90 if (commsType == commsTypes::blocking)
94 const_cast<char*
>(buf),
107 Pout<<
"UOPstream::write : finished write to:" << toProcNo
108 <<
" tag:" << tag <<
" size:" << label(bufSize)
113 else if (commsType == commsTypes::scheduled)
117 const_cast<char*
>(buf),
130 Pout<<
"UOPstream::write : finished write to:" << toProcNo
131 <<
" tag:" << tag <<
" size:" << label(bufSize)
136 else if (commsType == commsTypes::nonBlocking)
142 const_cast<char*
>(buf),
155 Pout<<
"UOPstream::write : started write to:" << toProcNo
156 <<
" tag:" << tag <<
" size:" << label(bufSize)
167 <<
"Unsupported communications type " << int(commsType)
const T * cdata() const noexcept
Return pointer to the underlying array serving as data storage.
void size(const label n)
Older name for setAddressableSize.
DynamicList< char > & sendBuf_
static label warnComm
Debugging: warn for use of any communicator differing from warnComm.
static const Enum< commsTypes > commsTypeNames
Names of the communication types.
commsTypes commsType() const noexcept
Get the communications type of the stream.
static void printStack(Ostream &os)
Helper function to print a stack.
virtual bool write()
Write the output fields.
static void addScatterTime()
Add time increment to scatterTime.
static void beginTiming()
Update timer prior to measurement.
static void addWaitTime()
Add time increment to waitTime.
#define FatalErrorInFunction
Report an error message using Foam::FatalError.
DynamicList< MPI_Request > outstandingRequests_
Outstanding non-blocking operations.
void checkCommunicator(const label comm, const label toProcNo)
DynamicList< MPI_Comm > MPICommunicators_
Ostream & endl(Ostream &os)
Add newline and flush stream.
errorManip< error > abort(error &err)
prefixOSstream Pout
OSstream wrapped stdout (std::cout) with parallel prefix.