Pstream Member List

This is the complete list of members for Pstream, 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
allGatherList(UList< T > &values, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
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
barrier(const int communicator, UPstream::Request *req=nullptr)UPstreamstatic
baseProcNo(label comm, int procID)UPstreamstatic
broadcast(Type &value, const int communicator=UPstream::worldComm)Pstreamstatic
broadcast(FixedList< Type, N > &list, const int communicator=UPstream::worldComm)Pstreamstatic
broadcast(Type *buffer, std::streamsize count, const int communicator, const int root=UPstream::masterNo())Pstreaminlinestatic
broadcast(FixedList< Type, N > &list, const int communicator, const int root=UPstream::masterNo())Pstreaminlinestatic
Foam::UPstream::broadcast(Type *buffer, std::streamsize count, const int communicator, const int root=UPstream::masterNo())UPstreaminlinestatic
Foam::UPstream::broadcast(FixedList< Type, N > &list, const int communicator, const int root=UPstream::masterNo())UPstreaminlinestatic
broadcastList(ListType &list, const int communicator=UPstream::worldComm)Pstreamstatic
broadcasts(const int communicator, Type &value, Args &&... values)Pstreamstatic
cancelRequest(const label i)UPstreamstatic
cancelRequest(UPstream::Request &req)UPstreamstatic
cancelRequests(UList< UPstream::Request > &requests)UPstreamstatic
ClassName("Pstream")Pstream
Foam::UPstream::ClassName("UPstream")UPstream
combineAllGather(T &value, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreaminlinestatic
combineGather(T &value, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
combineReduce(T &value, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
combineScatter(T &value, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreaminlinestatic
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
dataTypes enum nameUPstream
defaultCommsTypeUPstreamstatic
dupCommunicator(const label parent)UPstreamstatic
exchange(const UList< Container > &sendBufs, const labelUList &recvSizes, List< Container > &recvBufs, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm, const bool wait=true)Pstreamstatic
exchange(const Map< Container > &sendBufs, const Map< label > &recvSizes, Map< Container > &recvBufs, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm, const bool wait=true)Pstreamstatic
exchange(const UList< Container > &sendBufs, List< Container > &recvBufs, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm, const bool wait=true)Pstreamstatic
exchange(const Map< Container > &sendBufs, Map< Container > &recvBufs, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm, const bool wait=true)Pstreamstatic
exchangeConsensus(const UList< Container > &sendBufs, List< Container > &recvBufs, const int tag, const int comm, const bool wait=true)Pstreamstatic
exchangeConsensus(const Map< Container > &sendBufs, Map< Container > &recvBufs, const int tag, const int comm, const bool wait=true)Pstreamstatic
exchangeConsensus(const Map< Container > &sendBufs, const int tag, const int comm, const bool wait=true)Pstreamstatic
exchangeSizes(const labelUList &sendProcs, const labelUList &recvProcs, const Container &sendBufs, labelList &sizes, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreamstatic
exchangeSizes(const labelUList &neighProcs, const Container &sendBufs, labelList &sizes, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreamstatic
exchangeSizes(const Container &sendBufs, labelList &recvSizes, const int comm=UPstream::worldComm)Pstreamstatic
exchangeSizes(const Map< Container > &sendBufs, Map< label > &recvSizes, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreamstatic
exit(int errNo=1)UPstreamstatic
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
floatTransferUPstreamstatic
FOAM_DEPRECATED_FOR(2025-03, "broadcast() or broadcastList()") static void scatterList(UList< T > &valuesPstream
freeCommunicator(const label communicator, const bool withComponents=true)UPstreamstatic
freeRequest(UPstream::Request &req)UPstreamstatic
freeRequests(UList< UPstream::Request > &requests)UPstreamstatic
gather(T &value, BinaryOp bop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
Foam::UPstream::gather(const Type *send, int count, Type *recv, const UList< int > &counts, const UList< int > &offsets, const int comm=UPstream::worldComm)UPstreaminlinestatic
gather_algorithm(const UPstream::commsStructList &comms, T &value, BinaryOp bop, const int tag, const int communicator)Pstreamstatic
gather_topo_algorithm(T &value, BinaryOp bop, const int tag, const int communicator)Pstreamstatic
gatherList(UList< T > &values, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
gatherList_algorithm(const UPstream::commsStructList &comms, UList< T > &values, const int tag, const int communicator)Pstreamstatic
gatherList_topo_algorithm(UList< T > &values, const int tag, const int communicator)Pstreamstatic
hasNodeCommunicators() noexceptUPstreaminlinestatic
haveThreads() noexceptUPstreaminlinestatic
incrMsgType(int val=1) noexceptUPstreaminlinestatic
init(int &argc, char **&argv, const bool needsThread)UPstreamstatic
initNull()UPstreamstatic
interNode_offsets()UPstreamstatic
is_parallel(const label communicator=worldComm)UPstreaminlinestatic
is_rank(const label communicator=worldComm)UPstreaminlinestatic
is_subrank(const label communicator=worldComm)UPstreaminlinestatic
linearCommunication(int communicator)UPstreamstatic
listCombineAllGather(UList< T > &values, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreaminlinestatic
listCombineGather(UList< T > &values, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
listCombineReduce(UList< T > &values, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
listCombineScatter(List< T > &value, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreaminlinestatic
listGather(UList< T > &values, BinaryOp bop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
listGather_algorithm(const UPstream::commsStructList &comms, UList< T > &values, BinaryOp bop, const int tag, const int communicator)Pstreamstatic
listGather_topo_algorithm(UList< T > &values, BinaryOp bop, const int tag, const int communicator)Pstreamstatic
listGatherValues(const T &localValue, const int communicator=UPstream::worldComm, const int tag=UPstream::msgType())Pstreamstatic
Foam::UPstream::listGatherValues(const T &localValue, const int communicator=UPstream::worldComm)UPstreamstatic
listReduce(UList< T > &values, BinaryOp bop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
listScatterValues(const UList< T > &allValues, const int communicator=UPstream::worldComm, const int tag=UPstream::msgType())Pstreamstatic
Foam::UPstream::listScatterValues(const UList< T > &allValues, const int communicator=UPstream::worldComm)UPstreamstatic
localNode_parentProcs()UPstreamstatic
mapCombineAllGather(Container &values, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreaminlinestatic
mapCombineGather(Container &values, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
mapCombineReduce(Container &values, CombineOp cop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
mapCombineScatter(Container &values, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreaminlinestatic
mapGather(Container &values, BinaryOp bop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
mapGather_algorithm(const UPstream::commsStructList &comms, Container &values, BinaryOp bop, const int tag, const int communicator)Pstreamstatic
mapGather_topo_algorithm(Container &values, BinaryOp bop, const int tag, const int communicator)Pstreamstatic
mapReduce(Container &values, BinaryOp bop, const int tag=UPstream::msgType(), const int communicator=UPstream::worldComm)Pstreamstatic
master(const label communicator=worldComm)UPstreaminlinestatic
masterNo() noexceptUPstreaminlinestatic
maxCommsSizeUPstreamstatic
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
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
nodeCommsControl_UPstreamstatic
nodeCommsMin_UPstreamstatic
nPollProcInterfacesUPstreamstatic
nProcs(const label communicator=worldComm)UPstreaminlinestatic
nProcsNonblockingExchangeUPstreamstatic
nProcsSimpleSumUPstreamstatic
nRequests() noexceptUPstreamstatic
numNodes() noexceptUPstreaminlinestatic
opCodes enum nameUPstream
parent(int communicator)UPstreaminlinestatic
parRun(const bool on) noexceptUPstreaminlinestatic
parRun() noexceptUPstreaminlinestatic
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
Pstream(const UPstream::commsTypes commsType) noexceptPstreaminlineexplicit
Pstream(const UPstream::commsTypes commsType, int bufferSize)Pstreaminline
rangeType typedefUPstream
reduceAnd(bool &value, const int communicator=worldComm)UPstreamstatic
reduceOr(bool &value, const int communicator=worldComm)UPstreamstatic
removeRequests(label pos, label len=-1)UPstreamstatic
resetRequests(const label n)UPstreamstatic
sameProcs(int communicator1, int communicator2)UPstreaminlinestatic
sameProcs(int communicator, const UList< T1 > &procs)UPstreaminlinestatic
sameProcs(const UList< T1 > &procs1, const UList< T2 > &procs2)UPstreaminlinestatic
scatter(T &value, const int tag=UPstream::msgType(), const int comm=UPstream::worldComm)Pstreaminlinestatic
Foam::UPstream::scatter(const Type *send, const UList< int > &counts, const UList< int > &offsets, Type *recv, int count, const int comm=UPstream::worldComm)UPstreaminlinestatic
scatterList_algorithm(const UPstream::commsStructList &comms, UList< T > &values, const int tag, const int communicator)Pstreamstatic
send_done(const int toProcNo, const int communicator, const int tag=UPstream::msgType()+1970)UPstreamstatic
sendModes enum nameUPstream
shutdown(int errNo=0)UPstreamstatic
splitCommunicator(const label parent, const int colour, const bool two_step=true)UPstreamstatic
subProcs(const label communicator=worldComm)UPstreaminlinestatic
tagPstream
topoControls enum nameUPstream
topologyControl_UPstreamstatic
transferBuf_Pstreamprotected
treeCommunication(int communicator)UPstreamstatic
tuning_NBX_UPstreamstatic
UPstream(const commsTypes commsType) noexceptUPstreaminlineexplicit
usingNodeComms(const int communicator)UPstreamstatic
usingTopoControl(UPstream::topoControls ctrl) noexceptUPstreaminlinestatic
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