34 void Foam::UIPBstream::bufferIPCrecv()
49 reinterpret_cast<char*>(&bufSize),
57 <<
"MPI_Bcast failure receiving buffer size" <<
nl 63 Pout<<
"UOPBstream IPC read buffer :" 66 <<
" probed size:" << bufSize
97 <<
"MPI_Bcast failure receiving buffer data:" << bufSize <<
nl 116 const int rootProcNo,
118 const std::streamsize bufSize,
128 <<
"MPI_Bcast failure receiving data:" << label(bufSize) <<
nl 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.
static label read(const int rootProcNo, char *buf, const std::streamsize bufSize, const label comm=UPstream::worldComm)
Wrapped version of UPstream::broadcast.
constexpr char nl
The newline '\n' character (0x0a)
T * data() noexcept
Return pointer to the underlying array serving as data storage.
void resize(const label len)
Alter addressable list size, allocating new space if required while recovering old content...
Ostream & endl(Ostream &os)
Add newline and flush stream.
const int fromProcNo_
Source rank for the data.
int messageSize_
The message size, read on bufferIPCrecv or set directly.
label capacity() const noexcept
Size of the underlying storage.
Useful combination of include files which define Sin, Sout and Serr and the use of IO streams general...
errorManip< error > abort(error &err)
int debug
Static debugging option.
DynamicList< char > & recvBuf_
Reference to the receive buffer data.
static bool broadcast(char *buf, const std::streamsize bufSize, const label communicator, const int rootProcNo=masterNo())
Broadcast buffer contents to all processes in given communicator. The sizes must match on all process...
void setEof() noexcept
Set stream state as reached 'eof'.
const int comm_
The communicator index.
prefixOSstream Pout
OSstream wrapped stdout (std::cout) with parallel prefix.