37 bool Foam::UOPstream::bufferIPCsend()
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)
static bool write(const UPstream::commsTypes commsType, const int toProcNo, const char *buf, const std::streamsize bufSize, const int tag=UPstream::msgType(), const label comm=UPstream::worldComm)
Write buffer contents to given processor.
void size(const label n)
Older name for setAddressableSize.
DynamicList< MPI_Request > outstandingRequests_
Outstanding non-blocking operations.
static const Enum< commsTypes > commsTypeNames
Enumerated names for the communication types.
commsTypes
Types of communications.
error FatalError
Error stream (stdout output on all processes), with additional 'FOAM FATAL ERROR' header text and sta...
#define FatalErrorInFunction
Report an error message using Foam::FatalError.
DynamicList< MPI_Comm > MPICommunicators_
Ostream & endl(Ostream &os)
Add newline and flush stream.
void checkCommunicator(const label comm, const label toProcNo)
Fatal if comm is outside the allocated range.
static void addWaitTime()
Add time increment to wait time.
static void printStack(Ostream &os)
Helper function to print a stack.
DynamicList< char > & sendBuf_
static void addScatterTime()
Add time increment to scatter time.
static label warnComm
Debugging: warn for use of any communicator differing from warnComm.
errorManip< error > abort(error &err)
commsTypes commsType() const noexcept
Get the communications type of the stream.
static void beginTiming()
Update timer prior to measurement.
int debug
Static debugging option.
const T * cdata() const noexcept
Return pointer to the underlying array serving as data storage.
prefixOSstream Pout
OSstream wrapped stdout (std::cout) with parallel prefix.