Base class for output inter-processor communications stream (ie, parallel streams). Not to be used directly, thus contructors are protected. More...

#include <UOPstream.H>

Inheritance diagram for UOPstreamBase:

[legend]

Collaboration diagram for UOPstreamBase:

[legend]

Public Member Functions
virtual	~UOPstreamBase ()
	Destructor.
virtual std::ios_base::fmtflags	flags () const override
	Return current stream flags. Dummy for parallel stream, returns 0.
virtual std::ios_base::fmtflags	flags (std::ios_base::fmtflags) override
	Set stream flags, return old stream flags. Dummy for parallel stream, returns 0.
virtual bool	write (const token &tok) override
	Write token to stream or otherwise handle it.
virtual Ostream &	write (const char c) override
	Write single character. Whitespace is suppressed.
virtual Ostream &	writeQuoted (const char *str, std::streamsize len, const bool quoted=true) override
	Write character/string content, with/without surrounding quotes.
virtual Ostream &	write (const char *str) override
	Write the word-characters of a character string.
virtual Ostream &	write (const word &str) override
	Write word.
virtual Ostream &	write (const std::string &str) override
	Write string.
virtual Ostream &	write (const int32_t val) override
	Write int32_t.
virtual Ostream &	write (const int64_t val) override
	Write int64_t.
virtual Ostream &	write (const uint32_t val) override
	Write uint32_t.
virtual Ostream &	write (const uint64_t val) override
	Write uint64_t.
virtual Ostream &	write (const float val) override
	Write float.
virtual Ostream &	write (const double val) override
	Write double.
virtual Ostream &	write (const char *data, std::streamsize count) override
	Write binary block with 8-byte alignment.
virtual Ostream &	writeRaw (const char *data, std::streamsize count) override
	Low-level raw binary output.
virtual bool	beginRawWrite (std::streamsize count) override
	Begin marker for low-level raw binary output.
virtual bool	endRawWrite () override
	End marker for low-level raw binary output.
virtual void	indent () override
	Add indentation characters.
virtual void	flush () override
	Flush stream.
virtual void	endl () override
	Add newline and flush stream.
virtual char	fill () const override
	Get the current padding character.
virtual char	fill (const char) override
	Set padding character for formatted field up to field width.
virtual int	width () const override
	Get width of output field.
virtual int	width (const int) override
	Set width of output field.
virtual int	precision () const override
	Get precision of output field.
virtual int	precision (const int) override
	Set precision of output field.
virtual void	rewind ()
	Rewind the send buffer for overwriting.
void	print (Ostream &os) const override
	Print stream description to Ostream.
virtual Ostream &	writeQuoted (const std::string &str, const bool quoted=true)
	Inherit write methods from Ostream.
Public Member Functions inherited from UPstream
	ClassName ("UPstream")
	Declare name of the class and its debug switch.
	UPstream (const commsTypes commsType) noexcept
	Construct for given communication type.
commsTypes	commsType () const noexcept
	Get the communications type of the stream.
commsTypes	commsType (const commsTypes ct) noexcept
	Set the communications type of the stream.
Public Member Functions inherited from Ostream
	Ostream (const Ostream &)=default
	Copy construct.
virtual	~Ostream ()=default
	Destructor.
	Ostream (IOstreamOption streamOpt=IOstreamOption())
	Default construct (ASCII, uncompressed), construct with specified stream option.
	Ostream (IOstreamOption::streamFormat fmt, IOstreamOption::compressionType cmp=IOstreamOption::UNCOMPRESSED)
	Construct with format (uncompressed).
virtual Ostream &	write (const keyType &kw)
	Write keyType.
unsigned short	indentSize () const noexcept
	Return indent size (spaces per level).
unsigned short	indentSize (unsigned short val) noexcept
	Change indent size (spaces per level), return old value.
unsigned short	indentLevel () const noexcept
	Return the indent level.
unsigned short	indentLevel (unsigned short val) noexcept
	Change the indent level, return old value.
void	incrIndent () noexcept
	Increment the indent level.
void	decrIndent ()
	Decrement the indent level.
virtual Ostream &	writeKeyword (const keyType &kw)
	Write the keyword followed by an appropriate indentation.
virtual Ostream &	beginBlock (const keyType &kw)
	Write begin block group with the given name.
virtual Ostream &	beginBlock ()
	Write begin block group without a name.
virtual Ostream &	endBlock ()
	Write end block group.
virtual Ostream &	endEntry ()
	Write end entry (';') followed by newline.
template<class T>
Ostream &	writeEntry (const keyType &key, const T &value)
	Write a keyword/value entry.
template<class T>
Ostream &	writeEntryIfDifferent (const word &key, const T &value1, const T &value2)
	Write a keyword/value entry only when the two values differ.
Ostream &	operator() () const
	Return a non-const reference to const Ostream.
unsigned short &	indentLevel () noexcept
	Access to indent level.
unsigned short &	indentSize () noexcept
	Access to indent size.
Public Member Functions inherited from IOstream
	IOstream (const IOstream &)=default
	Copy construct.
virtual	~IOstream ()=default
	Destructor.
	IOstream (IOstreamOption streamOpt=IOstreamOption())
	Default construct (ASCII, uncompressed), construct with specified stream option.
	IOstream (IOstreamOption::streamFormat fmt, IOstreamOption::versionNumber ver, IOstreamOption::compressionType cmp=IOstreamOption::UNCOMPRESSED)
	Construct with format, version (compression).
virtual const fileName &	name () const
	The name of the stream.
fileName	relativeName () const
	Return the name of the stream relative to the current case.
virtual bool	check (const char *operation) const
	Check IOstream status for given operation.
bool	fatalCheck (const char *operation) const
	Check IOstream status for given operation.
bool	opened () const noexcept
	True if stream has been opened.
bool	closed () const noexcept
	True if stream is closed.
bool	good () const noexcept
	True if next operation might succeed.
bool	eof () const noexcept
	True if end of input seen.
bool	fail () const noexcept
	True if next operation will fail.
bool	bad () const noexcept
	True if stream is corrupted.
	operator bool () const noexcept
	True if the stream has not failed.
bool	operator! () const noexcept
	True if the stream has failed.
unsigned	labelByteSize () const noexcept
	The sizeof (label) in bytes associated with the stream.
unsigned	scalarByteSize () const noexcept
	The sizeof (scalar) in bytes associated with the stream.
void	setLabelByteSize (unsigned nbytes) noexcept
	Set the sizeof (label) in bytes associated with the stream.
void	setScalarByteSize (unsigned nbytes) noexcept
	Set the sizeof (scalar) in bytes associated with the stream.
template<class T, class = std::enable_if_t<std::is_integral_v<T>>>
bool	checkLabelSize () const noexcept
	Test if the label byte-size associated with the stream is the same as the given type.
template<class T, class = std::enable_if_t<std::is_floating_point_v<T>>>
bool	checkScalarSize () const noexcept
	Test if the scalar byte-size associated with the stream is the same as the given type.
bool	checkNativeSizes () const noexcept
	Test if the label/scalar byte-size associated with the stream are the native label/scalar sizes.
bool	fatalCheckNativeSizes (const char *operation) const
	Assert that the label/scalar byte-size associated with the stream are the native label/scalar sizes.
label	lineNumber () const noexcept
	Const access to the current stream line number.
label &	lineNumber () noexcept
	Non-const access to the current stream line number.
label	lineNumber (const label num) noexcept
	Set the stream line number.
void	setEof () noexcept
	Set stream state as reached 'eof'.
void	setFail () noexcept
	Set stream state as 'failed'.
void	setBad () noexcept
	Set stream state to be 'bad'.
std::ios_base::fmtflags	setf (std::ios_base::fmtflags f)
	Set stream flag(s), return old stream flags.
std::ios_base::fmtflags	setf (const std::ios_base::fmtflags f, const std::ios_base::fmtflags mask)
	Set stream flag(s) with mask, return old stream flags.
std::ios_base::fmtflags	unsetf (std::ios_base::fmtflags f)
	Unset stream flags, return old stream flags.
void	print (Ostream &os, const int streamState) const
	Print information about the stream state bits.
InfoProxy< IOstream >	info () const noexcept
	Return info proxy, used to print IOstream information to a stream.
Public Member Functions inherited from IOstreamOption
constexpr	IOstreamOption (streamFormat fmt=streamFormat::ASCII, compressionType comp=compressionType::UNCOMPRESSED) noexcept
	Default construct (ASCII, UNCOMPRESSED, currentVersion) or construct with format, compression.
constexpr	IOstreamOption (streamFormat fmt, compressionType comp, versionNumber ver) noexcept
	Construct from components (format, compression, version).
constexpr	IOstreamOption (streamFormat fmt, versionNumber ver, compressionType comp=compressionType::UNCOMPRESSED) noexcept
	Construct from components (format, version, compression).
	IOstreamOption (const IOstreamOption &opt, streamFormat fmt) noexcept
	Copy construct with change of format.
streamFormat	format () const noexcept
	Get the current stream format.
streamFormat	format (const streamFormat fmt) noexcept
	Set the stream format.
streamFormat	format (const word &formatName)
	Set the stream format from string value.
compressionType	compression () const noexcept
	Get the stream compression.
compressionType	compression (const compressionType comp) noexcept
	Set the stream compression.
compressionType	compression (const word &compName)
	Set the stream compression from string value.
versionNumber	version () const noexcept
	Get the stream version.
versionNumber	version (const versionNumber ver) noexcept
	Set the stream version.
versionNumber	version (const token &tok)
	Set the stream version from token.

Protected Member Functions
	UOPstreamBase (const UPstream::commsTypes commsType, const int toProcNo, DynamicList< char > &sendBuf, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm, const bool sendAtDestruct=true, IOstreamOption::streamFormat fmt=IOstreamOption::BINARY)
	Construct given process index to write to using the given attached send buffer, optional communication characteristics and IO format.
	UOPstreamBase (const int toProcNo, PstreamBuffers &buffers)
	Construct given buffers.
	UOPstreamBase (DynamicList< char > &sendBuf, IOstreamOption::streamFormat fmt)
	Construct for externally obtained buffers.
Protected Member Functions inherited from IOstream
void	setOpened () noexcept
	Set stream opened.
void	setClosed () noexcept
	Set stream closed.
void	setState (std::ios_base::iostate state) noexcept
	Set stream state.
void	setGood () noexcept
	Set stream state to be good.

Protected Attributes
const int	toProcNo_
	Destination rank for the data.
const int	tag_
	Message tag for communication.
const int	comm_
	The communicator index.
bool	sendAtDestruct_
	Call bufferIPCsend on termination (in the destructor).
DynamicList< char > &	sendBuf_
	Reference to the send buffer data.
Protected Attributes inherited from Ostream
unsigned short	indentSize_ = 4
	Number of spaces per indent level.
unsigned short	indentLevel_ = 0
	Current indent level.
Protected Attributes inherited from IOstream
std::ios_base::iostate	ioState_
	Mirror of internal stream io state.
streamAccess	openClosed_
	The stream open/closed state.
unsigned char	sizeofLabel_
	The sizeof (label), possibly read from the header.
unsigned char	sizeofScalar_
	The sizeof (scalar), possibly read from the header.
label	lineNumber_
	The file line.

Additional Inherited Members
Public Types inherited from UPstream
enum class	commsTypes : char { buffered , scheduled , nonBlocking , blocking = buffered }
	Communications types. More...
enum class	sendModes : char { normal , sync }
	Different MPI-send modes (ignored for commsTypes::buffered). More...
enum class	dataTypes : char { Basic_begin , type_byte = Basic_begin , type_int16 , type_int32 , type_int64 , type_uint16 , type_uint32 , type_uint64 , type_float , type_double , type_long_double , Basic_end , User_begin = Basic_end , type_3float = User_begin , type_3double , type_6float , type_6double , type_9float , type_9double , invalid , User_end = invalid , DataTypes_end = invalid }
	Mapping of some fundamental and aggregate types to MPI data types. More...
enum class	opCodes : char { Basic_begin , op_min = Basic_begin , op_max , op_sum , op_prod , op_bool_and , op_bool_or , op_bool_xor , op_bit_and , op_bit_or , op_bit_xor , Basic_end , Extra_begin = Basic_end , op_replace = Extra_begin , op_no_op , invalid , Extra_end = invalid , OpCodes_end = invalid }
	Mapping of some MPI op codes. More...
enum class	topoControls : int { broadcast = 1 , reduce = 2 , gather = 4 , combine = 16 , mapGather = 32 , gatherList = 64 }
	Some bit masks corresponding to topology controls. More...
typedef IntRange< int >	rangeType
	Int ranges are used for MPI ranks (processes).
Public Types inherited from IOstream
enum	streamAccess : char { CLOSED = 0 , OPENED }
	Enumeration for stream open/closed state. More...
Public Types inherited from IOstreamOption
enum	streamFormat : char { ASCII = 0 , BINARY , COHERENT , UNKNOWN_FORMAT }
	Data format (ascii \| binary \| coherent). More...
enum	compressionType : char { UNCOMPRESSED = 0 , COMPRESSED }
	Compression treatment (UNCOMPRESSED \| COMPRESSED). More...
enum	appendType : char { NO_APPEND = 0 , APPEND_APP , APPEND_ATE , NON_APPEND = NO_APPEND , APPEND = APPEND_APP }
	File appending (NO_APPEND \| APPEND_APP \| APPEND_ATE). More...
enum	atomicType : char { NON_ATOMIC = 0 , ATOMIC }
	Atomic operations (output). More...
enum class	floatFormat : unsigned { general = unsigned(0) , fixed = unsigned(std::ios_base::fixed) , scientific = unsigned(std::ios_base::scientific) }
	Float formats (eg, time directory name formats). More...
Static Public Member Functions inherited from UPstream
static bool	usingTopoControl (UPstream::topoControls ctrl) noexcept
	Test for selection of given topology-aware routine.
static constexpr int	commGlobal () noexcept
	Communicator for all ranks, irrespective of any local worlds.
static constexpr int	commSelf () noexcept
	Communicator within the current rank only.
static int	commConstWorld () noexcept
	Communicator for all ranks (respecting any local worlds).
static label	commWorld () noexcept
	Communicator for all ranks (respecting any local worlds).
static label	commWorld (const label communicator) noexcept
	Set world communicator. Negative values are a no-op.
static label	commWarn (const label communicator) noexcept
	Alter communicator debugging setting. Warns for use of any communicator differing from specified. Negative values disable.
static label	nComms () noexcept
	Number of currently defined communicators.
static void	printCommTree (int communicator, bool linear=false)
	Debugging: print the communication tree.
static int	commInterNode () noexcept
	Communicator between nodes/hosts (respects any local worlds).
static int	commLocalNode () noexcept
	Communicator within the node/host (respects any local worlds).
static bool	hasNodeCommunicators () noexcept
	Both inter-node and local-node communicators have been created.
static bool	usingNodeComms (const int communicator)
	True if node topology-aware routines have been enabled, it is running in parallel, the starting point is the world-communicator and it is not an odd corner case (ie, all processes on one node, all processes on different nodes).
static label	newCommunicator (const label parent, const labelRange &subRanks, const bool withComponents=true)
	Create new communicator with sub-ranks on the parent communicator.
static label	newCommunicator (const label parent, const labelUList &subRanks, const bool withComponents=true)
	Create new communicator with sub-ranks on the parent communicator.
static label	dupCommunicator (const label parent)
	Duplicate the parent communicator.
static label	splitCommunicator (const label parent, const int colour, const bool two_step=true)
	Allocate a new communicator by splitting the parent communicator on the given colour.
static void	freeCommunicator (const label communicator, const bool withComponents=true)
	Free a previously allocated communicator.
static int	baseProcNo (label comm, int procID)
	Return physical processor number (i.e. processor number in worldComm) given communicator and processor.
static label	procNo (const label comm, const int baseProcID)
	Return processor number in communicator (given physical processor number) (= reverse of baseProcNo).
static label	procNo (const label comm, const label currentComm, const int currentProcID)
	Return processor number in communicator (given processor number and communicator).
static void	addValidParOptions (HashTable< string > &validParOptions)
	Add the valid option this type of communications library adds/requires on the command line.
static bool	init (int &argc, char **&argv, const bool needsThread)
	Initialisation function called from main.
static bool	initNull ()
	Special purpose initialisation function.
static void	barrier (const int communicator, UPstream::Request *req=nullptr)
	Impose a synchronisation barrier (optionally non-blocking).
static void	send_done (const int toProcNo, const int communicator, const int tag=UPstream::msgType()+1970)
	Impose a point-to-point synchronisation barrier by sending a zero-byte "done" message to given rank.
static int	wait_done (const int fromProcNo, const int communicator, const int tag=UPstream::msgType()+1970)
	Impose a point-to-point synchronisation barrier by receiving a zero-byte "done" message from given rank.
static std::pair< int, int64_t >	probeMessage (const UPstream::commsTypes commsType, const int fromProcNo, const int tag=UPstream::msgType(), const int communicator=worldComm)
	Probe for an incoming message.
static void	printNodeCommsControl (Ostream &os)
	Report the node-communication settings.
static void	printTopoControl (Ostream &os)
	Report the topology routines settings.
static label	nRequests () noexcept
	Number of outstanding requests (on the internal list of requests).
static void	resetRequests (const label n)
	Truncate outstanding requests to given length, which is expected to be in the range [0 to nRequests()].
static void	addRequest (UPstream::Request &req)
	Transfer the (wrapped) MPI request to the internal global list and invalidate the parameter (ignores null requests).
static void	cancelRequest (const label i)
	Non-blocking comms: cancel and free outstanding request. Corresponds to MPI_Cancel() + MPI_Request_free().
static void	cancelRequest (UPstream::Request &req)
	Non-blocking comms: cancel and free outstanding request. Corresponds to MPI_Cancel() + MPI_Request_free().
static void	cancelRequests (UList< UPstream::Request > &requests)
	Non-blocking comms: cancel and free outstanding requests. Corresponds to MPI_Cancel() + MPI_Request_free().
static void	removeRequests (label pos, label len=-1)
	Non-blocking comms: cancel/free outstanding requests (from position onwards) and remove from internal list of requests. Corresponds to MPI_Cancel() + MPI_Request_free().
static void	freeRequest (UPstream::Request &req)
	Non-blocking comms: free outstanding request. Corresponds to MPI_Request_free().
static void	freeRequests (UList< UPstream::Request > &requests)
	Non-blocking comms: free outstanding requests. Corresponds to MPI_Request_free().
static void	waitRequests (label pos, label len=-1)
	Wait until all requests (from position onwards) have finished. Corresponds to MPI_Waitall().
static void	waitRequests (UList< UPstream::Request > &requests)
	Wait until all requests have finished. Corresponds to MPI_Waitall().
static bool	waitAnyRequest (label pos, label len=-1)
	Wait until any request (from position onwards) has finished. Corresponds to MPI_Waitany().
static bool	waitSomeRequests (label pos, label len=-1, DynamicList< int > *indices=nullptr)
	Wait until some requests (from position onwards) have finished. Corresponds to MPI_Waitsome().
static bool	waitSomeRequests (UList< UPstream::Request > &requests, DynamicList< int > *indices=nullptr)
	Wait until some requests have finished. Corresponds to MPI_Waitsome().
static int	waitAnyRequest (UList< UPstream::Request > &requests)
	Wait until any request has finished and return its index. Corresponds to MPI_Waitany().
static void	waitRequest (const label i)
	Wait until request i has finished. Corresponds to MPI_Wait().
static void	waitRequest (UPstream::Request &req)
	Wait until specified request has finished. Corresponds to MPI_Wait().
static bool	activeRequest (const label i)
	Is request `i` active (!= MPI_REQUEST_NULL)?
static bool	activeRequest (const UPstream::Request &req)
	Is request active (!= MPI_REQUEST_NULL)?
static bool	finishedRequest (const label i)
	Non-blocking comms: has request i finished? Corresponds to MPI_Test().
static bool	finishedRequest (UPstream::Request &req)
	Non-blocking comms: has request finished? Corresponds to MPI_Test().
static bool	finishedRequests (label pos, label len=-1)
	Non-blocking comms: have all requests (from position onwards) finished? Corresponds to MPI_Testall().
static bool	finishedRequests (UList< UPstream::Request > &requests)
	Non-blocking comms: have all requests finished? Corresponds to MPI_Testall().
static bool	finishedRequestPair (label &req0, label &req1)
	Non-blocking comms: have both requests finished? Corresponds to pair of MPI_Test().
static void	waitRequestPair (label &req0, label &req1)
	Non-blocking comms: wait for both requests to finish. Corresponds to pair of MPI_Wait().
static bool	parRun (const bool on) noexcept
	Set as parallel run on/off.
static bool &	parRun () noexcept
	Test if this a parallel run.
static bool	haveThreads () noexcept
	Have support for threads.
static constexpr int	masterNo () noexcept
	Relative rank for the master process - is always 0.
static label	nProcs (const label communicator=worldComm)
	Number of ranks in parallel run (for given communicator). It is 1 for serial run.
static int	myProcNo (const label communicator=worldComm)
	Rank of this process in the communicator (starting from masterNo()). Negative if the process is not a rank in the communicator.
static bool	master (const label communicator=worldComm)
	True if process corresponds to the master rank in the communicator.
static bool	is_rank (const label communicator=worldComm)
	True if process corresponds to any rank (master or sub-rank) in the given communicator.
static bool	is_subrank (const label communicator=worldComm)
	True if process corresponds to a sub-rank in the given communicator.
static bool	is_parallel (const label communicator=worldComm)
	True if parallel algorithm or exchange is required.
static int	numNodes () noexcept
	The number of shared/host nodes in the (const) world communicator.
static label	parent (int communicator)
	The parent communicator.
static List< int > &	procID (int communicator)
	The list of ranks within a given communicator.
static bool	sameProcs (int communicator1, int communicator2)
	Test for communicator equality.
template<typename T1, typename = std::void_t <std::enable_if_t<std::is_integral_v<T1>>>>
static bool	sameProcs (int communicator, const UList< T1 > &procs)
	Test equality of communicator procs with the given list of ranks. Includes a guard for the communicator index.
template<typename T1, typename T2, typename = std::void_t < std::enable_if_t<std::is_integral_v<T1>>, std::enable_if_t<std::is_integral_v<T2>> >>
static bool	sameProcs (const UList< T1 > &procs1, const UList< T2 > &procs2)
	Test the equality of two lists of ranks.
static const wordList &	allWorlds () noexcept
	All worlds.
static const labelList &	worldIDs () noexcept
	The indices into allWorlds for all processes.
static label	myWorldID ()
	My worldID.
static const word &	myWorld ()
	My world.
static rangeType	allProcs (const label communicator=worldComm)
	Range of process indices for all processes.
static rangeType	subProcs (const label communicator=worldComm)
	Range of process indices for sub-processes.
static const List< int > &	interNode_offsets ()
	Processor offsets corresponding to the inter-node communicator.
static const rangeType &	localNode_parentProcs ()
	The range (start/size) of the commLocalNode ranks in terms of the (const) world communicator processors.
static const commsStructList &	linearCommunication (int communicator)
	Linear communication schedule (special case) for given communicator.
static const commsStructList &	treeCommunication (int communicator)
	Tree communication schedule (standard case) for given communicator.
static const commsStructList &	whichCommunication (const int communicator, bool linear=false)
	Communication schedule for all-to-master (proc 0) as linear/tree/none with switching based on UPstream::nProcsSimpleSum, the is_parallel() state and the optional `linear` parameter.
static int &	msgType () noexcept
	Message tag of standard messages.
static int	msgType (int val) noexcept
	Set the message tag for standard messages.
static int	incrMsgType (int val=1) noexcept
	Increment the message tag for standard messages.
static void	shutdown (int errNo=0)
	Shutdown (finalize) MPI as required.
static void	abort (int errNo=1)
	Call MPI_Abort with no other checks or cleanup.
static void	exit (int errNo=1)
	Shutdown (finalize) MPI as required and exit program with errNo.
static void	allToAll (const UList< int32_t > &sendData, UList< int32_t > &recvData, const int communicator=UPstream::worldComm)
	Exchange `int32_t` data with all ranks in communicator.
static void	allToAllConsensus (const UList< int32_t > &sendData, UList< int32_t > &recvData, const int tag, const int communicator=UPstream::worldComm)
	Exchange non-zero `int32_t` data between ranks [NBX].
static void	allToAllConsensus (const Map< int32_t > &sendData, Map< int32_t > &recvData, const int tag, const int communicator=UPstream::worldComm)
	Exchange `int32_t` data between ranks [NBX].
static Map< int32_t >	allToAllConsensus (const Map< int32_t > &sendData, const int tag, const int communicator=UPstream::worldComm)
	Exchange `int32_t` data between ranks [NBX].
static void	allToAll (const UList< int64_t > &sendData, UList< int64_t > &recvData, const int communicator=UPstream::worldComm)
	Exchange `int64_t` data with all ranks in communicator.
static void	allToAllConsensus (const UList< int64_t > &sendData, UList< int64_t > &recvData, const int tag, const int communicator=UPstream::worldComm)
	Exchange non-zero `int64_t` data between ranks [NBX].
static void	allToAllConsensus (const Map< int64_t > &sendData, Map< int64_t > &recvData, const int tag, const int communicator=UPstream::worldComm)
	Exchange `int64_t` data between ranks [NBX].
static Map< int64_t >	allToAllConsensus (const Map< int64_t > &sendData, const int tag, const int communicator=UPstream::worldComm)
	Exchange `int64_t` data between ranks [NBX].
template<class Type>
static void	mpiGather (const Type sendData, Type recvData, int count, const int communicator=UPstream::worldComm)
	Receive identically-sized (contiguous) data from all ranks.
template<class Type>
static void	mpiScatter (const Type sendData, Type recvData, int count, const int communicator=UPstream::worldComm)
	Send identically-sized (contiguous) data to all ranks.
template<class Type>
static void	mpiAllGather (Type *allData, int count, const int communicator=UPstream::worldComm)
	Gather/scatter identically-sized data.
template<class Type>
static void	mpiGatherv (const Type sendData, int sendCount, Type recvData, const UList< int > &recvCounts, const UList< int > &recvOffsets, const int communicator=UPstream::worldComm)
	Receive variable length data from all ranks.
template<class Type>
static void	mpiScatterv (const Type sendData, const UList< int > &sendCounts, const UList< int > &sendOffsets, Type recvData, int recvCount, const int communicator=UPstream::worldComm)
	Send variable length data to all ranks.
template<class T>
static List< T >	allGatherValues (const T &localValue, const int communicator=UPstream::worldComm)
	Allgather individual values into list locations.
template<class T>
static List< T >	listGatherValues (const T &localValue, const int communicator=UPstream::worldComm)
	Gather individual values into list locations.
template<class T>
static T	listScatterValues (const UList< T > &allValues, const int communicator=UPstream::worldComm)
	Scatter individual values from list locations.
template<class Type>
static bool	broadcast (Type *buffer, std::streamsize count, const int communicator, const int root=UPstream::masterNo())
	Broadcast buffer contents (contiguous types) to all ranks (default: from rank=0). The sizes must match on all processes.
template<class Type, unsigned N>
static bool	broadcast (FixedList< Type, N > &list, const int communicator, const int root=UPstream::masterNo())
	Broadcast fixed-list content (contiguous types) to all ranks (default: from rank=0). The sizes must match on all processes.
template<class T>
static void	mpiReduce (T values[], int count, const UPstream::opCodes opCodeId, const int communicator)
	MPI_Reduce (blocking) for known operators.
template<UPstream::opCodes opCode, class T>
static void	mpiReduce (T values[], int count, const int communicator)
	MPI_Reduce (blocking) for known operators.
template<class T>
static void	mpiAllReduce (T values[], int count, const UPstream::opCodes opCodeId, const int communicator)
	MPI_Allreduce (blocking) for known operators.
template<UPstream::opCodes opCode, class T>
static void	mpiAllReduce (T values[], int count, const int communicator)
	MPI_Allreduce (blocking) for known operators.
template<class T>
static void	mpiAllReduce (T values[], int count, const UPstream::opCodes opCodeId, const int communicator, UPstream::Request &req)
	MPI_Iallreduce (non-blocking) for known operators.
template<UPstream::opCodes opCode, class T>
static void	mpiAllReduce (T values[], int count, const int communicator, UPstream::Request &req)
	MPI_Iallreduce (non-blocking) for known operators.
template<Foam::UPstream::opCodes opCode, class T>
static void	mpiScan (T values[], int count, const int communicator, const bool exclusive=false)
	Inclusive/exclusive scan (in-place).
template<Foam::UPstream::opCodes opCode, class T>
static T	mpiScan (const T &localValue, const int communicator, const bool exclusive=false)
	Inclusive/exclusive scan returning the result. In exclusive mode, the degenerate value on rank=0 has no meaning but is treated like non-exclusive mode (ie, original values).
template<class T>
static void	mpiScan_min (T values[], int count, const int communicator, const bool exclusive=false)
	Inclusive/exclusive `min` scan (in-place).
template<class T>
static void	mpiExscan_min (T values[], int count, const int communicator)
	Exclusive `min` scan (in-place).
template<class T>
static T	mpiScan_min (const T &value, const int communicator, const bool exclusive=false)
	Inclusive/exclusive `min` scan returning result.
template<class T>
static T	mpiExscan_min (const T &value, const int communicator)
	Exclusive `min` scan returning result.
template<class T>
static void	mpiScan_max (T values[], int count, const int communicator, const bool exclusive=false)
	Inclusive/exclusive `max` scan (in-place).
template<class T>
static void	mpiExscan_max (T values[], int count, const int communicator)
	Exclusive `max` scan (in-place).
template<class T>
static T	mpiScan_max (const T &value, const int communicator, const bool exclusive=false)
	Inclusive/exclusive `max` scan returning result.
template<class T>
static T	mpiExscan_max (const T &value, const int communicator)
	Exclusive `max` scan returning result.
template<class T>
static void	mpiScan_sum (T values[], int count, const int communicator, const bool exclusive=false)
	Inclusive/exclusive `sum` scan (in-place).
template<class T>
static void	mpiExscan_sum (T values[], int count, const int communicator)
	Exclusive `sum` scan (in-place).
template<class T>
static T	mpiScan_sum (const T &value, const int communicator, const bool exclusive=false)
	Inclusive/exclusive `sum` scan returning result.
template<class T>
static T	mpiExscan_sum (const T &value, const int communicator)
	Exclusive `sum` scan returning result.
static void	reduceAnd (bool &value, const int communicator=worldComm)
	Logical (and) reduction (MPI_AllReduce).
static void	reduceOr (bool &value, const int communicator=worldComm)
	Logical (or) reduction (MPI_AllReduce).
static int	find_first (bool condition, int communicator)
	Locate the first rank for which the `condition` is true, or -1 if no ranks satisfy the condition.
static int	find_last (bool condition, int communicator)
	Locate the last rank for which the `condition` is true, or -1 if no ranks satisfy the condition.
static label	allocateCommunicator (const label parent, const labelRange &subRanks, const bool withComponents=true)
static label	allocateCommunicator (const label parent, const labelUList &subRanks, const bool withComponents=true)
static label	commInterHost () noexcept
	Communicator between nodes (respects any local worlds).
static label	commIntraHost () noexcept
	Communicator within the node (respects any local worlds).
static void	waitRequests ()
	Wait for all requests to finish.
template<class Type>
static void	gather (const Type send, int count, Type recv, const UList< int > &counts, const UList< int > &offsets, const int comm=UPstream::worldComm)
template<class Type>
static void	scatter (const Type send, const UList< int > &counts, const UList< int > &offsets, Type recv, int count, const int comm=UPstream::worldComm)
Static Public Member Functions inherited from IOstream
static unsigned int	defaultPrecision () noexcept
	Return the default precision.
static unsigned int	defaultPrecision (unsigned int prec) noexcept
	Reset the default precision.
static unsigned int	minPrecision (unsigned int prec) noexcept
	Set the minimum default precision.
Static Public Member Functions inherited from IOstreamOption
static floatFormat	floatFormatEnum (const word &fmtName, const floatFormat deflt=floatFormat::general)
	Lookup floatFormat enum corresponding to the string (general \| fixed \| scientific).
static floatFormat	floatFormatEnum (const word &key, const dictionary &dict, const floatFormat deflt=floatFormat::general)
	getOrDefault floatFormat from dictionary, warn only on bad enumeration.
static streamFormat	formatEnum (const word &fmtName, const streamFormat deflt=streamFormat::ASCII)
	Lookup streamFormat enum corresponding to the string (ascii \| binary).
static streamFormat	formatEnum (const word &key, const dictionary &dict, const streamFormat deflt=streamFormat::ASCII)
	getOrDefault streamFormat from dictionary, warn only on bad enumeration.
static compressionType	compressionEnum (const word &compName, const compressionType deflt=compressionType::UNCOMPRESSED)
	The compression enum corresponding to the string.
static compressionType	compressionEnum (const word &key, const dictionary &dict, const compressionType deflt=compressionType::UNCOMPRESSED)
	getOrDefault compressionType from dictionary, warn only on bad enumeration.
Static Public Attributes inherited from UPstream
static const Enum< commsTypes >	commsTypeNames
	Enumerated names for the communication types.
static int	nodeCommsControl_
	Use of host/node topology-aware routines.
static int	nodeCommsMin_
	Minimum number of nodes before topology-aware routines are enabled.
static int	topologyControl_
	Selection of topology-aware routines as a bitmask combination of the topoControls enumerations.
static bool	floatTransfer
	Should compact transfer be used in which floats replace doubles reducing the bandwidth requirement at the expense of some loss in accuracy.
static int	nProcsSimpleSum
	Number of processors to change from linear to tree communication.
static int	nProcsNonblockingExchange
	Number of processors to change to nonBlocking consensual exchange (NBX). Ignored for zero or negative values.
static int	nPollProcInterfaces
	Number of polling cycles in processor updates.
static commsTypes	defaultCommsType
	Default commsType.
static int	maxCommsSize
	Optional maximum message size (bytes).
static int	tuning_NBX_
	Tuning parameters for non-blocking exchange (NBX).
static const int	mpiBufferSize
	MPI buffer-size (bytes).
static label	worldComm
	Communicator for all ranks. May differ from commGlobal() if local worlds are in use.
static label	warnComm
	Debugging: warn for use of any communicator differing from warnComm.
Static Public Attributes inherited from IOstream
static unsigned int	precision_
	Default precision.
Static Public Attributes inherited from IOstreamOption
static const Enum< floatFormat >	floatFormatNames
	Names for float formats (general, fixed, scientific).
static const Enum< streamFormat >	formatNames
	Stream format names (ascii, binary).
static const versionNumber	currentVersion
	The current version number (2.0).
Static Protected Member Functions inherited from UPstream
static bool	mpi_broadcast (void *buf, std::streamsize count, const UPstream::dataTypes dataTypeId, const int communicator, const int root=0)
	Broadcast buffer contents to all ranks (default: from rank=0). The sizes must match on all processes.
static void	mpi_reduce (void values, int count, const UPstream::dataTypes dataTypeId, const UPstream::opCodes opCodeId, const int communicator, UPstream::Request req=nullptr)
	In-place reduction of `values` with result on rank 0.
static void	mpi_allreduce (void values, int count, const UPstream::dataTypes dataTypeId, const UPstream::opCodes opCodeId, const int communicator, UPstream::Request req=nullptr)
	In-place reduction of `values` with same result on all ranks.
static void	mpi_scan_reduce (void *values, int count, const UPstream::dataTypes dataTypeId, const UPstream::opCodes opCodeId, const int communicator, const bool exclusive)
	In-place scan/exscan reduction of `values`.
static bool	mpi_send (const UPstream::commsTypes commsType, const void buf, std::streamsize count, const UPstream::dataTypes dataTypeId, const int toProcNo, const int tag, const int communicator, UPstream::Request req=nullptr, const UPstream::sendModes sendMode=UPstream::sendModes::normal)
	Send buffer contents of specified data type to given processor.
static std::streamsize	mpi_receive (const UPstream::commsTypes commsType, void buf, std::streamsize count, const UPstream::dataTypes dataTypeId, const int fromProcNo, const int tag, const int communicator, UPstream::Request req=nullptr)
	Receive buffer contents of specified data type from given processor.
static void	mpi_gather (const void sendData, void recvData, int count, const UPstream::dataTypes dataTypeId, const int communicator, UPstream::Request *req=nullptr)
	Receive identically-sized (contiguous) data from all ranks, placing the result on rank 0.
static void	mpi_scatter (const void sendData, void recvData, int count, const UPstream::dataTypes dataTypeId, const int communicator, UPstream::Request *req=nullptr)
	Send identically-sized (contiguous) data from rank 0 to all other ranks.
static void	mpi_allgather (void allData, int count, const UPstream::dataTypes dataTypeId, const int communicator, UPstream::Request req=nullptr)
	Gather/scatter identically-sized data.
static void	mpi_gatherv (const void sendData, int sendCount, void recvData, const UList< int > &recvCounts, const UList< int > &recvOffsets, const UPstream::dataTypes dataTypeId, const int communicator)
	Receive variable length data from all ranks, placing the result on rank 0. (caution: known to scale poorly).
static void	mpi_scatterv (const void sendData, const UList< int > &sendCounts, const UList< int > &sendOffsets, void recvData, int recvCount, const UPstream::dataTypes dataTypeId, const int communicator)
	Send variable length data from rank 0 to all ranks. (caution: known to scale poorly).
Static Protected Attributes inherited from Ostream
static constexpr const unsigned short	entryIndentation_ = 16
	Indentation of the entry from the start of the keyword.
Static Protected Attributes inherited from IOstream
static fileName	staticName_
	Name for any generic stream - normally treat as readonly.

Detailed Description

Base class for output inter-processor communications stream (ie, parallel streams). Not to be used directly, thus contructors are protected.

Source files

Definition at line 55 of file UOPstream.H.

Constructor & Destructor Documentation

◆ UOPstreamBase() [1/3]

UOPstreamBase	(	const UPstream::commsTypes	commsType,
		const int	toProcNo,
		DynamicList< char > &	sendBuf,
		const int	tag = UPstream::msgType(),
		const int	communicator = UPstream::worldComm,
		const bool	sendAtDestruct = true,
		IOstreamOption::streamFormat	fmt = IOstreamOption::BINARY )

protected

Construct given process index to write to using the given attached send buffer, optional communication characteristics and IO format.

Definition at line 136 of file UOPstreamBase.C.

References comm_, UPstream::commsType(), Ostream::Ostream(), sendAtDestruct_, sendBuf_, IOstream::setGood(), IOstream::setOpened(), tag_, toProcNo_, and UPstream::UPstream().

Referenced by UOPBstream::UOPBstream(), UOPstream::UOPstream(), UOPstream::UOPstream(), and UOPstream::UOPstream().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ UOPstreamBase() [2/3]

UOPstreamBase	(	const int	toProcNo,
		PstreamBuffers &	buffers )

protected

Construct given buffers.

Definition at line 160 of file UOPstreamBase.C.

References comm_, UPstream::commsType(), IOstreamOption::format(), Ostream::Ostream(), sendAtDestruct_, sendBuf_, IOstream::setGood(), IOstream::setOpened(), tag_, toProcNo_, and UPstream::UPstream().

Here is the call graph for this function:

◆ UOPstreamBase() [3/3]

UOPstreamBase	(	DynamicList< char > &	sendBuf,
		IOstreamOption::streamFormat	fmt )

protected

Construct for externally obtained buffers.

Definition at line 175 of file UOPstreamBase.C.

References comm_, UPstream::commSelf(), UPstream::masterNo(), UPstream::msgType(), Ostream::Ostream(), sendAtDestruct_, sendBuf_, IOstream::setGood(), IOstream::setOpened(), tag_, toProcNo_, and UPstream::UPstream().

Here is the call graph for this function:

◆ ~UOPstreamBase()

~UOPstreamBase ( )

virtual

Destructor.

Definition at line 197 of file UOPstreamBase.C.

Member Function Documentation

◆ flags() [1/2]

virtual std::ios_base::fmtflags flags ( ) const

inlineoverridevirtual

Return current stream flags. Dummy for parallel stream, returns 0.

Implements IOstream.

Definition at line 179 of file UOPstream.H.

◆ flags() [2/2]

virtual std::ios_base::fmtflags flags ( std::ios_base::fmtflags )

inlineoverridevirtual

Set stream flags, return old stream flags. Dummy for parallel stream, returns 0.

Implements IOstream.

Definition at line 188 of file UOPstream.H.

◆ write() [1/12]

bool write ( const token & tok )

overridevirtual

Write token to stream or otherwise handle it.

Returns: false if the token type was not handled by this method

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 203 of file UOPstreamBase.C.

◆ write() [2/12]

Foam::Ostream & write ( const char c )

overridevirtual

Write single character. Whitespace is suppressed.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 248 of file UOPstreamBase.C.

References Foam::isspace().

Here is the call graph for this function:

◆ writeQuoted() [1/2]

Foam::Ostream & writeQuoted	(	const char *	str,
		std::streamsize	len,
		const bool	quoted = true )

overridevirtual

Write character/string content, with/without surrounding quotes.

Implements Ostream.

Definition at line 259 of file UOPstreamBase.C.

◆ write() [3/12]

Foam::Ostream & write ( const char * str )

overridevirtual

Write the word-characters of a character string.

Sends as a single char, or as word.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 280 of file UOPstreamBase.C.

References string::validate(), and write().

Here is the call graph for this function:

◆ write() [4/12]

Foam::Ostream & write ( const word & str )

overridevirtual

Write word.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 297 of file UOPstreamBase.C.

References token::WORD.

◆ write() [5/12]

Foam::Ostream & write ( const std::string & str )

overridevirtual

Write string.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 306 of file UOPstreamBase.C.

References token::STRING.

◆ write() [6/12]

Foam::Ostream & write ( const int32_t val )

overridevirtual

Write int32_t.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 315 of file UOPstreamBase.C.

References token::INTEGER_32.

◆ write() [7/12]

Foam::Ostream & write ( const int64_t val )

overridevirtual

Write int64_t.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 323 of file UOPstreamBase.C.

References token::INTEGER_64.

◆ write() [8/12]

Foam::Ostream & write ( const uint32_t val )

overridevirtual

Write uint32_t.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 331 of file UOPstreamBase.C.

References token::UNSIGNED_INTEGER_32.

◆ write() [9/12]

Foam::Ostream & write ( const uint64_t val )

overridevirtual

Write uint64_t.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 339 of file UOPstreamBase.C.

References token::UNSIGNED_INTEGER_64.

◆ write() [10/12]

Foam::Ostream & write ( const float val )

overridevirtual

Write float.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 347 of file UOPstreamBase.C.

References token::FLOAT.

◆ write() [11/12]

Foam::Ostream & write ( const double val )

overridevirtual

Write double.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 355 of file UOPstreamBase.C.

References token::DOUBLE.

◆ write() [12/12]

Foam::Ostream & write	(	const char *	data,
		std::streamsize	count )

overridevirtual

Write binary block with 8-byte alignment.

Implements Ostream.

Reimplemented in UOPstream.

Definition at line 363 of file UOPstreamBase.C.

References Foam::abort(), IOstreamOption::BINARY, Foam::FatalError, FatalErrorInFunction, and format().

Here is the call graph for this function:

◆ writeRaw()

Foam::Ostream & writeRaw	(	const char *	data,
		std::streamsize	count )

overridevirtual

Low-level raw binary output.

Implements Ostream.

Definition at line 383 of file UOPstreamBase.C.

◆ beginRawWrite()

bool beginRawWrite ( std::streamsize count )

overridevirtual

Begin marker for low-level raw binary output.

The count indicates the number of bytes for subsequent writeRaw calls.

Implements Ostream.

Definition at line 399 of file UOPstreamBase.C.

References Foam::abort(), IOstreamOption::BINARY, Foam::FatalError, FatalErrorInFunction, and format().

Here is the call graph for this function:

◆ endRawWrite()

virtual bool endRawWrite ( )

inlineoverridevirtual

End marker for low-level raw binary output.

Implements Ostream.

Definition at line 299 of file UOPstream.H.

◆ indent()

virtual void indent ( )

inlineoverridevirtual

Add indentation characters.

Implements Ostream.

Definition at line 307 of file UOPstream.H.

◆ flush()

virtual void flush ( )

inlineoverridevirtual

Flush stream.

Implements Ostream.

Definition at line 316 of file UOPstream.H.

◆ endl()

virtual void endl ( )

inlineoverridevirtual

Add newline and flush stream.

Implements Ostream.

Definition at line 322 of file UOPstream.H.

◆ fill() [1/2]

virtual char fill ( ) const

inlineoverridevirtual

Get the current padding character.

Returns: previous padding character

Implements Ostream.

Definition at line 330 of file UOPstream.H.

◆ fill() [2/2]

virtual char fill ( const char )

inlineoverridevirtual

Set padding character for formatted field up to field width.

Implements Ostream.

Definition at line 338 of file UOPstream.H.

◆ width() [1/2]

virtual int width ( ) const

inlineoverridevirtual

Get width of output field.

Implements Ostream.

Definition at line 346 of file UOPstream.H.

◆ width() [2/2]

virtual int width ( const int )

inlineoverridevirtual

Set width of output field.

Returns: previous width

Implements Ostream.

Definition at line 356 of file UOPstream.H.

◆ precision() [1/2]

virtual int precision ( ) const

inlineoverridevirtual

Get precision of output field.

Implements Ostream.

Definition at line 364 of file UOPstream.H.

◆ precision() [2/2]

virtual int precision ( const int )

inlineoverridevirtual

Set precision of output field.

Returns: old precision

Implements Ostream.

Definition at line 374 of file UOPstream.H.

◆ rewind()

void rewind ( )

virtual

Rewind the send buffer for overwriting.

//- The current put position (tellp) in the buffer label pos() const;

Foam::label Foam::UOPstreamBase::pos() const { return sendBuf_.size(); }

Definition at line 427 of file UOPstreamBase.C.

References sendBuf_, IOstream::setGood(), and IOstream::setOpened().

Here is the call graph for this function:

◆ print()

void print ( Ostream & os ) const

overridevirtual

Print stream description to Ostream.

Reimplemented from IOstream.

Definition at line 435 of file UOPstreamBase.C.

References comm_, Foam::endl(), UPstream::myProcNo(), os(), Ostream::Ostream(), tag_, and toProcNo_.

Here is the call graph for this function:

◆ writeQuoted() [2/2]

Foam::Ostream & writeQuoted	(	const std::string &	str,
		const bool	quoted = true )

virtual

Inherit write methods from Ostream.

Reimplemented from Ostream.

Definition at line 149 of file Ostream.C.

Member Data Documentation

◆ toProcNo_

const int toProcNo_

protected

Destination rank for the data.

Definition at line 108 of file UOPstream.H.

Referenced by print(), UOPstreamBase(), UOPstreamBase(), UOPstreamBase(), and UOPstream::~UOPstream().

◆ tag_

const int tag_

protected

Message tag for communication.

Definition at line 113 of file UOPstream.H.

Referenced by print(), UOPstreamBase(), UOPstreamBase(), and UOPstreamBase().

◆ comm_

const int comm_

protected

The communicator index.

Definition at line 118 of file UOPstream.H.

Referenced by print(), UOPstreamBase(), UOPstreamBase(), and UOPstreamBase().

◆ sendAtDestruct_

bool sendAtDestruct_

protected

Call bufferIPCsend on termination (in the destructor).

Definition at line 123 of file UOPstream.H.

Referenced by UOPstream::send(), UOPstreamBase(), UOPstreamBase(), UOPstreamBase(), UOPBstream::~UOPBstream(), and UOPstream::~UOPstream().

◆ sendBuf_

DynamicList<char>& sendBuf_

protected

Reference to the send buffer data.

Definition at line 128 of file UOPstream.H.

Referenced by rewind(), UOPstreamBase(), UOPstreamBase(), UOPstreamBase(), UOPBstream::~UOPBstream(), and UOPstream::~UOPstream().

The documentation for this class was generated from the following files:

src/OpenFOAM/db/IOstreams/Pstreams/UOPstream.H
src/OpenFOAM/db/IOstreams/Pstreams/UOPstreamBase.C

Public Member Functions

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ UOPstreamBase() [1/3]

◆ UOPstreamBase() [2/3]

◆ UOPstreamBase() [3/3]

◆ ~UOPstreamBase()

Member Function Documentation

◆ flags() [1/2]

◆ flags() [2/2]

◆ write() [1/12]

◆ write() [2/12]

◆ writeQuoted() [1/2]

◆ write() [3/12]

◆ write() [4/12]

◆ write() [5/12]

◆ write() [6/12]

◆ write() [7/12]

◆ write() [8/12]

◆ write() [9/12]

◆ write() [10/12]

◆ write() [11/12]

◆ write() [12/12]

◆ writeRaw()

◆ beginRawWrite()

◆ endRawWrite()

◆ indent()

◆ flush()

◆ endl()

◆ fill() [1/2]

◆ fill() [2/2]

◆ width() [1/2]

◆ width() [2/2]

◆ precision() [1/2]

◆ precision() [2/2]

◆ rewind()

◆ print()

◆ writeQuoted() [2/2]

Member Data Documentation

◆ toProcNo_

◆ tag_

◆ comm_

◆ sendAtDestruct_

◆ sendBuf_