UIPstreamBase Member List

This is the complete list of members for UIPstreamBase, including all inherited members.

abort(int errNo=1)UPstreamstatic
activeRequest(const label i)UPstreamstatic
activeRequest(const UPstream::Request &req)UPstreamstatic
addRequest(UPstream::Request &req)UPstreamstatic
addValidParOptions(HashTable< string > &validParOptions)UPstreamstatic
allGatherValues(const T &localValue, const int communicator=UPstream::worldComm)UPstreamstatic
allocateCommunicator(const label parent, const labelRange &subRanks, const bool withComponents=true)UPstreaminlinestatic
allocateCommunicator(const label parent, const labelUList &subRanks, const bool withComponents=true)UPstreaminlinestatic
allProcs(const label communicator=worldComm)UPstreaminlinestatic
allToAll(const UList< int32_t > &sendData, UList< int32_t > &recvData, const int communicator=UPstream::worldComm)UPstreamstatic
allToAll(const UList< int64_t > &sendData, UList< int64_t > &recvData, const int communicator=UPstream::worldComm)UPstreamstatic
allToAllConsensus(const UList< int32_t > &sendData, UList< int32_t > &recvData, const int tag, const int communicator=UPstream::worldComm)UPstreamstatic
allToAllConsensus(const Map< int32_t > &sendData, Map< int32_t > &recvData, const int tag, const int communicator=UPstream::worldComm)UPstreamstatic
allToAllConsensus(const Map< int32_t > &sendData, const int tag, const int communicator=UPstream::worldComm)UPstreaminlinestatic
allToAllConsensus(const UList< int64_t > &sendData, UList< int64_t > &recvData, const int tag, const int communicator=UPstream::worldComm)UPstreamstatic
allToAllConsensus(const Map< int64_t > &sendData, Map< int64_t > &recvData, const int tag, const int communicator=UPstream::worldComm)UPstreamstatic
allToAllConsensus(const Map< int64_t > &sendData, const int tag, const int communicator=UPstream::worldComm)UPstreaminlinestatic
allWorlds() noexceptUPstreaminlinestatic
APPEND enum valueIOstreamOption
APPEND_APP enum valueIOstreamOption
APPEND_ATE enum valueIOstreamOption
appendType enum nameIOstreamOption
ASCII enum valueIOstreamOption
ATOMIC enum valueIOstreamOption
atomicType enum nameIOstreamOption
bad() const noexceptIOstreaminline
barrier(const int communicator, UPstream::Request *req=nullptr)UPstreamstatic
baseProcNo(label comm, int procID)UPstreamstatic
beginRawRead() overrideUIPstreamBasevirtual
BINARY enum valueIOstreamOption
broadcast(Type *buffer, std::streamsize count, const int communicator, const int root=UPstream::masterNo())UPstreaminlinestatic
broadcast(FixedList< Type, N > &list, const int communicator, const int root=UPstream::masterNo())UPstreaminlinestatic
cancelRequest(const label i)UPstreamstatic
cancelRequest(UPstream::Request &req)UPstreamstatic
cancelRequests(UList< UPstream::Request > &requests)UPstreamstatic
check(const char *operation) constIOstreamvirtual
checkLabelSize() const noexceptIOstreaminline
checkNativeSizes() const noexceptIOstreaminline
checkScalarSize() const noexceptIOstreaminline
ClassName("UPstream")UPstream
clearAtEnd_UIPstreamBaseprotected
CLOSED enum valueIOstream
closed() const noexceptIOstreaminline
COHERENT enum valueIOstreamOption
comm_UIPstreamBaseprotected
commConstWorld() noexceptUPstreaminlinestatic
commGlobal() noexceptUPstreaminlinestatic
commInterHost() noexceptUPstreaminlinestatic
commInterNode() noexceptUPstreaminlinestatic
commIntraHost() noexceptUPstreaminlinestatic
commLocalNode() noexceptUPstreaminlinestatic
commSelf() noexceptUPstreaminlinestatic
commsType() const noexceptUPstreaminline
commsType(const commsTypes ct) noexceptUPstreaminline
commsTypeNamesUPstreamstatic
commsTypes enum nameUPstream
commWarn(const label communicator) noexceptUPstreaminlinestatic
commWorld() noexceptUPstreaminlinestatic
commWorld(const label communicator) noexceptUPstreaminlinestatic
COMPRESSED enum valueIOstreamOption
compression() const noexceptIOstreamOptioninline
compression(const compressionType comp) noexceptIOstreamOptioninline
compression(const word &compName)IOstreamOptioninline
compressionEnum(const word &compName, const compressionType deflt=compressionType::UNCOMPRESSED)IOstreamOptionstatic
compressionEnum(const word &key, const dictionary &dict, const compressionType deflt=compressionType::UNCOMPRESSED)IOstreamOptionstatic
compressionType enum nameIOstreamOption
currentVersionIOstreamOptionstatic
dataTypes enum nameUPstream
defaultCommsTypeUPstreamstatic
defaultPrecision() noexceptIOstreaminlinestatic
defaultPrecision(unsigned int prec) noexceptIOstreaminlinestatic
dupCommunicator(const label parent)UPstreamstatic
endRawRead() overrideUIPstreamBaseinlinevirtual
eof() const noexceptIOstreaminline
exit(int errNo=1)UPstreamstatic
fail() const noexceptIOstreaminline
fatalCheck(const char *operation) constIOstream
fatalCheckNativeSizes(const char *operation) constIOstream
find_first(bool condition, int communicator)UPstreamstatic
find_last(bool condition, int communicator)UPstreamstatic
finishedRequest(const label i)UPstreamstatic
finishedRequest(UPstream::Request &req)UPstreamstatic
finishedRequestPair(label &req0, label &req1)UPstreamstatic
finishedRequests(label pos, label len=-1)UPstreamstatic
finishedRequests(UList< UPstream::Request > &requests)UPstreamstatic
flags() const overrideUIPstreamBaseinlinevirtual
flags(std::ios_base::fmtflags) overrideUIPstreamBaseinlinevirtual
floatFormat enum nameIOstreamOption
floatFormatEnum(const word &fmtName, const floatFormat deflt=floatFormat::general)IOstreamOptionstatic
floatFormatEnum(const word &key, const dictionary &dict, const floatFormat deflt=floatFormat::general)IOstreamOptionstatic
floatFormatNamesIOstreamOptionstatic
floatTransferUPstreamstatic
format() const noexceptIOstreamOptioninline
format(const streamFormat fmt) noexceptIOstreamOptioninline
format(const word &formatName)IOstreamOptioninline
formatEnum(const word &fmtName, const streamFormat deflt=streamFormat::ASCII)IOstreamOptionstatic
formatEnum(const word &key, const dictionary &dict, const streamFormat deflt=streamFormat::ASCII)IOstreamOptionstatic
formatNamesIOstreamOptionstatic
freeCommunicator(const label communicator, const bool withComponents=true)UPstreamstatic
freeRequest(UPstream::Request &req)UPstreamstatic
freeRequests(UList< UPstream::Request > &requests)UPstreamstatic
fromProcNo_UIPstreamBaseprotected
gather(const Type *send, int count, Type *recv, const UList< int > &counts, const UList< int > &offsets, const int comm=UPstream::worldComm)UPstreaminlinestatic
getBack(token &tok)Istream
good() const noexceptIOstreaminline
hasNodeCommunicators() noexceptUPstreaminlinestatic
hasPutback() const noexceptIstreaminlineprotected
haveThreads() noexceptUPstreaminlinestatic
incrMsgType(int val=1) noexceptUPstreaminlinestatic
info() const noexceptIOstreaminline
init(int &argc, char **&argv, const bool needsThread)UPstreamstatic
initNull()UPstreamstatic
interNode_offsets()UPstreamstatic
ioState_IOstreamprotected
IOstream(const IOstream &)=defaultIOstream
IOstream(IOstreamOption streamOpt=IOstreamOption())IOstreaminlineexplicit
IOstream(IOstreamOption::streamFormat fmt, IOstreamOption::versionNumber ver, IOstreamOption::compressionType cmp=IOstreamOption::UNCOMPRESSED)IOstreaminline
IOstreamOption(streamFormat fmt=streamFormat::ASCII, compressionType comp=compressionType::UNCOMPRESSED) noexceptIOstreamOptioninline
IOstreamOption(streamFormat fmt, compressionType comp, versionNumber ver) noexceptIOstreamOptioninline
IOstreamOption(streamFormat fmt, versionNumber ver, compressionType comp=compressionType::UNCOMPRESSED) noexceptIOstreamOptioninline
IOstreamOption(const IOstreamOption &opt, streamFormat fmt) noexceptIOstreamOptioninline
is_parallel(const label communicator=worldComm)UPstreaminlinestatic
is_rank(const label communicator=worldComm)UPstreaminlinestatic
is_subrank(const label communicator=worldComm)UPstreaminlinestatic
Istream(const Istream &)=defaultIstream
Istream(IOstreamOption streamOpt=IOstreamOption())Istreaminlineexplicit
Istream(IOstreamOption::streamFormat fmt, IOstreamOption::compressionType cmp=IOstreamOption::UNCOMPRESSED)Istreaminlineexplicit
labelByteSize() const noexceptIOstreaminline
linearCommunication(int communicator)UPstreamstatic
lineNumber() const noexceptIOstreaminline
lineNumber() noexceptIOstreaminline
lineNumber(const label num) noexceptIOstreaminline
lineNumber_IOstreamprotected
listGatherValues(const T &localValue, const int communicator=UPstream::worldComm)UPstreamstatic
listScatterValues(const UList< T > &allValues, const int communicator=UPstream::worldComm)UPstreamstatic
localNode_parentProcs()UPstreamstatic
master(const label communicator=worldComm)UPstreaminlinestatic
masterNo() noexceptUPstreaminlinestatic
maxCommsSizeUPstreamstatic
messageSize_UIPstreamBaseprotected
minPrecision(unsigned int prec) noexceptIOstreaminlinestatic
mpi_allgather(void *allData, int count, const UPstream::dataTypes dataTypeId, const int communicator, UPstream::Request *req=nullptr)UPstreamprotectedstatic
mpi_allreduce(void *values, int count, const UPstream::dataTypes dataTypeId, const UPstream::opCodes opCodeId, const int communicator, UPstream::Request *req=nullptr)UPstreamprotectedstatic
mpi_broadcast(void *buf, std::streamsize count, const UPstream::dataTypes dataTypeId, const int communicator, const int root=0)UPstreamprotectedstatic
mpi_gather(const void *sendData, void *recvData, int count, const UPstream::dataTypes dataTypeId, const int communicator, UPstream::Request *req=nullptr)UPstreamprotectedstatic
mpi_gatherv(const void *sendData, int sendCount, void *recvData, const UList< int > &recvCounts, const UList< int > &recvOffsets, const UPstream::dataTypes dataTypeId, const int communicator)UPstreamprotectedstatic
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)UPstreamprotectedstatic
mpi_reduce(void *values, int count, const UPstream::dataTypes dataTypeId, const UPstream::opCodes opCodeId, const int communicator, UPstream::Request *req=nullptr)UPstreamprotectedstatic
mpi_scan_reduce(void *values, int count, const UPstream::dataTypes dataTypeId, const UPstream::opCodes opCodeId, const int communicator, const bool exclusive)UPstreamprotectedstatic
mpi_scatter(const void *sendData, void *recvData, int count, const UPstream::dataTypes dataTypeId, const int communicator, UPstream::Request *req=nullptr)UPstreamprotectedstatic
mpi_scatterv(const void *sendData, const UList< int > &sendCounts, const UList< int > &sendOffsets, void *recvData, int recvCount, const UPstream::dataTypes dataTypeId, const int communicator)UPstreamprotectedstatic
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)UPstreamprotectedstatic
mpiAllGather(Type *allData, int count, const int communicator=UPstream::worldComm)UPstreamstatic
mpiAllReduce(T values[], int count, const UPstream::opCodes opCodeId, const int communicator)UPstreamstatic
mpiAllReduce(T values[], int count, const int communicator)UPstreamstatic
mpiAllReduce(T values[], int count, const UPstream::opCodes opCodeId, const int communicator, UPstream::Request &req)UPstreamstatic
mpiAllReduce(T values[], int count, const int communicator, UPstream::Request &req)UPstreamstatic
mpiBufferSizeUPstreamstatic
mpiExscan_max(T values[], int count, const int communicator)UPstreaminlinestatic
mpiExscan_max(const T &value, const int communicator)UPstreaminlinestatic
mpiExscan_min(T values[], int count, const int communicator)UPstreaminlinestatic
mpiExscan_min(const T &value, const int communicator)UPstreaminlinestatic
mpiExscan_sum(T values[], int count, const int communicator)UPstreaminlinestatic
mpiExscan_sum(const T &value, const int communicator)UPstreaminlinestatic
mpiGather(const Type *sendData, Type *recvData, int count, const int communicator=UPstream::worldComm)UPstreamstatic
mpiGatherv(const Type *sendData, int sendCount, Type *recvData, const UList< int > &recvCounts, const UList< int > &recvOffsets, const int communicator=UPstream::worldComm)UPstreamstatic
mpiReduce(T values[], int count, const UPstream::opCodes opCodeId, const int communicator)UPstreamstatic
mpiReduce(T values[], int count, const int communicator)UPstreamstatic
mpiScan(T values[], int count, const int communicator, const bool exclusive=false)UPstreamstatic
mpiScan(const T &localValue, const int communicator, const bool exclusive=false)UPstreamstatic
mpiScan_max(T values[], int count, const int communicator, const bool exclusive=false)UPstreaminlinestatic
mpiScan_max(const T &value, const int communicator, const bool exclusive=false)UPstreaminlinestatic
mpiScan_min(T values[], int count, const int communicator, const bool exclusive=false)UPstreaminlinestatic
mpiScan_min(const T &value, const int communicator, const bool exclusive=false)UPstreaminlinestatic
mpiScan_sum(T values[], int count, const int communicator, const bool exclusive=false)UPstreaminlinestatic
mpiScan_sum(const T &value, const int communicator, const bool exclusive=false)UPstreaminlinestatic
mpiScatter(const Type *sendData, Type *recvData, int count, const int communicator=UPstream::worldComm)UPstreamstatic
mpiScatterv(const Type *sendData, const UList< int > &sendCounts, const UList< int > &sendOffsets, Type *recvData, int recvCount, const int communicator=UPstream::worldComm)UPstreamstatic
msgType() noexceptUPstreaminlinestatic
msgType(int val) noexceptUPstreaminlinestatic
myProcNo(const label communicator=worldComm)UPstreaminlinestatic
myWorld()UPstreaminlinestatic
myWorldID()UPstreaminlinestatic
name() constIOstreamvirtual
nComms() noexceptUPstreaminlinestatic
newCommunicator(const label parent, const labelRange &subRanks, const bool withComponents=true)UPstreamstatic
newCommunicator(const label parent, const labelUList &subRanks, const bool withComponents=true)UPstreamstatic
NO_APPEND enum valueIOstreamOption
nodeCommsControl_UPstreamstatic
nodeCommsMin_UPstreamstatic
NON_APPEND enum valueIOstreamOption
NON_ATOMIC enum valueIOstreamOption
nPollProcInterfacesUPstreamstatic
nProcs(const label communicator=worldComm)UPstreaminlinestatic
nProcsNonblockingExchangeUPstreamstatic
nProcsSimpleSumUPstreamstatic
nRequests() noexceptUPstreamstatic
numNodes() noexceptUPstreaminlinestatic
opCodes enum nameUPstream
openClosed_IOstreamprotected
OPENED enum valueIOstream
opened() const noexceptIOstreaminline
operator bool() const noexceptIOstreaminlineexplicit
operator!() const noexceptIOstreaminline
operator()() constIstream
parent(int communicator)UPstreaminlinestatic
parRun(const bool on) noexceptUPstreaminlinestatic
parRun() noexceptUPstreaminlinestatic
peekBack() const noexceptIstream
precision_IOstreamstatic
print(Ostream &os) const overrideUIPstreamBasevirtual
Foam::Istream::print(Ostream &os, const int streamState) constIOstream
printCommTree(int communicator, bool linear=false)UPstreamstatic
printNodeCommsControl(Ostream &os)UPstreamstatic
printTopoControl(Ostream &os)UPstreamstatic
probeMessage(const UPstream::commsTypes commsType, const int fromProcNo, const int tag=UPstream::msgType(), const int communicator=worldComm)UPstreamstatic
procID(int communicator)UPstreaminlinestatic
procNo(const label comm, const int baseProcID)UPstreamstatic
procNo(const label comm, const label currentComm, const int currentProcID)UPstreamstatic
putBack(const token &tok)Istream
putBack(token &&tok)Istream
putBackClear()Istream
rangeType typedefUPstream
read(token &) overrideUIPstreamBasevirtual
read(char &c) overrideUIPstreamBasevirtual
read(word &str) overrideUIPstreamBasevirtual
read(string &str) overrideUIPstreamBasevirtual
read(int32_t &val) overrideUIPstreamBasevirtual
read(int64_t &val) overrideUIPstreamBasevirtual
read(uint32_t &val) overrideUIPstreamBasevirtual
read(uint64_t &val) overrideUIPstreamBasevirtual
read(float &val) overrideUIPstreamBasevirtual
read(double &val) overrideUIPstreamBasevirtual
read(char *data, std::streamsize count) overrideUIPstreamBasevirtual
readBegin(const char *funcName)Istream
readBeginList(const char *funcName)Istream
readEnd(const char *funcName)Istream
readEndList(const char *funcName)Istream
readRaw(char *data, std::streamsize count) overrideUIPstreamBasevirtual
recvBuf_UIPstreamBaseprotected
recvBufPos_UIPstreamBaseprotected
reduceAnd(bool &value, const int communicator=worldComm)UPstreamstatic
reduceOr(bool &value, const int communicator=worldComm)UPstreamstatic
relativeName() constIOstream
remaining() const noexceptUIPstreamBase
removeRequests(label pos, label len=-1)UPstreamstatic
resetRequests(const label n)UPstreamstatic
rewind() overrideUIPstreamBasevirtual
sameProcs(int communicator1, int communicator2)UPstreaminlinestatic
sameProcs(int communicator, const UList< T1 > &procs)UPstreaminlinestatic
sameProcs(const UList< T1 > &procs1, const UList< T2 > &procs2)UPstreaminlinestatic
scalarByteSize() const noexceptIOstreaminline
scatter(const Type *send, const UList< int > &counts, const UList< int > &offsets, Type *recv, int count, const int comm=UPstream::worldComm)UPstreaminlinestatic
send_done(const int toProcNo, const int communicator, const int tag=UPstream::msgType()+1970)UPstreamstatic
sendModes enum nameUPstream
setBad() noexceptIOstreaminline
setClosed() noexceptIOstreaminlineprotected
setEof() noexceptIOstreaminline
setf(std::ios_base::fmtflags f)IOstreaminline
setf(const std::ios_base::fmtflags f, const std::ios_base::fmtflags mask)IOstreaminline
setFail() noexceptIOstreaminline
setGood() noexceptIOstreaminlineprotected
setLabelByteSize(unsigned nbytes) noexceptIOstreaminline
setOpened() noexceptIOstreaminlineprotected
setScalarByteSize(unsigned nbytes) noexceptIOstreaminline
setState(std::ios_base::iostate state) noexceptIOstreaminlineprotected
shutdown(int errNo=0)UPstreamstatic
sizeofLabel_IOstreamprotected
sizeofScalar_IOstreamprotected
splitCommunicator(const label parent, const int colour, const bool two_step=true)UPstreamstatic
staticName_IOstreamprotectedstatic
storedRecvBufPos_UIPstreamBaseprotected
streamAccess enum nameIOstream
streamFormat enum nameIOstreamOption
subProcs(const label communicator=worldComm)UPstreaminlinestatic
tag_UIPstreamBaseprotected
topoControls enum nameUPstream
topologyControl_UPstreamstatic
treeCommunication(int communicator)UPstreamstatic
tuning_NBX_UPstreamstatic
UIPstreamBase(const UPstream::commsTypes commsType, const int fromProcNo, DynamicList< char > &receiveBuf, label &receiveBufPosition, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm, const bool clearAtEnd=false, IOstreamOption::streamFormat fmt=IOstreamOption::BINARY)UIPstreamBaseprotected
UIPstreamBase(const int fromProcNo, PstreamBuffers &buffers)UIPstreamBaseprotected
UIPstreamBase(const DynamicList< char > &receiveBuf, IOstreamOption::streamFormat fmt)UIPstreamBaseprotected
UNCOMPRESSED enum valueIOstreamOption
UNKNOWN_FORMAT enum valueIOstreamOption
unsetf(std::ios_base::fmtflags f)IOstreaminline
UPstream(const commsTypes commsType) noexceptUPstreaminlineexplicit
usingNodeComms(const int communicator)UPstreamstatic
usingTopoControl(UPstream::topoControls ctrl) noexceptUPstreaminlinestatic
version() const noexceptIOstreamOptioninline
version(const versionNumber ver) noexceptIOstreamOptioninline
version(const token &tok)IOstreamOptioninline
wait_done(const int fromProcNo, const int communicator, const int tag=UPstream::msgType()+1970)UPstreamstatic
waitAnyRequest(label pos, label len=-1)UPstreamstatic
waitAnyRequest(UList< UPstream::Request > &requests)UPstreamstatic
waitRequest(const label i)UPstreamstatic
waitRequest(UPstream::Request &req)UPstreamstatic
waitRequestPair(label &req0, label &req1)UPstreamstatic
waitRequests(label pos, label len=-1)UPstreamstatic
waitRequests(UList< UPstream::Request > &requests)UPstreamstatic
waitRequests()UPstreaminlinestatic
waitSomeRequests(label pos, label len=-1, DynamicList< int > *indices=nullptr)UPstreamstatic
waitSomeRequests(UList< UPstream::Request > &requests, DynamicList< int > *indices=nullptr)UPstreamstatic
warnCommUPstreamstatic
whichCommunication(const int communicator, bool linear=false)UPstreaminlinestatic
worldCommUPstreamstatic
worldIDs() noexceptUPstreaminlinestatic
~IOstream()=defaultIOstreamvirtual
~Istream()=defaultIstreamvirtual
~UIPstreamBase()UIPstreamBasevirtual