Go to the documentation of this file.
41 <<
"The dummy Pstream library cannot be used in parallel mode"
51 <<
"The dummy Pstream library cannot be used in parallel mode"
112 const char* sendData,
121 memmove(recvData, sendData, sendSize);
127 const char* sendData,
136 memmove(recvData, sendData, recvSize);
140 void Foam::UPstream::allocatePstreamCommunicator
148 void Foam::UPstream::freePstreamCommunicator(
const label)
static void resetRequests(const label sz)
Truncate number of outstanding requests.
static void exit(int errnum=1)
Exit program.
static void waitRequests(const label start=0)
Wait until all requests (from start onwards) have finished.
static void abort()
Abort program.
Ostream & endl(Ostream &os)
Add newline and flush stream.
void deepCopy(const UList< T > &list)
Copy elements of the given UList.
static void allToAll(const labelUList &sendData, labelUList &recvData, const label communicator=0)
Exchange label with all processors (in the communicator).
static void gather(const char *sendData, int sendSize, char *recvData, const UList< int > &recvSizes, const UList< int > &recvOffsets, const label communicator=0)
Receive data from all processors on the master.
#define NotImplemented
Issue a FatalErrorIn for a function not currently implemented.
void reduce(const List< UPstream::commsStruct > &comms, T &Value, const BinaryOp &bop, const int tag, const label comm)
intWM_LABEL_SIZE_t label
A label is an int32_t or int64_t as specified by the pre-processor macro WM_LABEL_SIZE.
static void waitRequest(const label i)
Wait until request i has finished.
static void addValidParOptions(HashTable< string > &validParOptions)
static void scatter(const char *sendData, const UList< int > &sendSizes, const UList< int > &sendOffsets, char *recvData, int recvSize, const label communicator=0)
Send data to all processors from the root of the communicator.
errorManip< error > abort(error &err)
Inter-processor communication reduction functions.
errorManipArg< error, int > exit(error &err, const int errNo=1)
A HashTable similar to std::unordered_map.
#define FatalErrorInFunction
Report an error message using Foam::FatalError.
static label nRequests()
Get number of outstanding requests.
static bool initNull()
Special purpose initialisation function.
label ListType::const_reference const label start
static bool finishedRequest(const label i)
Non-blocking comms: has request i finished?
void sumReduce(T &Value, label &Count, const int tag=Pstream::msgType(), const label comm=UPstream::worldComm)
Helper class for allocating/freeing communicators.
static bool init(int &argc, char **&argv, const bool needsThread)
Initialisation function called from main.
#define WarningInFunction
Report a warning using Foam::Warning.