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"
119 const sumOp<solveScalar>& bop,
127 const minOp<solveScalar>& bop,
134 Vector2D<solveScalar>& Value,
135 const sumOp<Vector2D<solveScalar>>& bop,
151 const sumOp<solveScalar>& bop,
161 const sumOp<solveScalar>&,
184 const char* sendData,
193 memmove(recvData, sendData, sendSize);
199 const char* sendData,
208 memmove(recvData, sendData, recvSize);
212 void Foam::UPstream::allocatePstreamCommunicator
220 void Foam::UPstream::freePstreamCommunicator(
const label)
static void resetRequests(const label sz)
Truncate number of outstanding requests.
static void waitRequests(const label start=0)
Wait until all requests (from start onwards) have finished.
static void abort()
Call MPI_Abort with no other checks or cleanup.
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)
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.
static void shutdown(int errNo=0)
Shutdown (finalize) MPI as required.
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.
static void exit(int errNo=1)
Shutdown (finalize) MPI as required and exit program with errNo.