49 os << allValues[proci];
69template<
class Type,
class FileOp>
80 Pout<<
"masterUncollatedFileOperation::masterOp : Operation "
81 <<
typeid(FileOp).
name()
82 <<
" on " << fName <<
endl;
93 result = fop(filePaths[0]);
94 for (label i = 1; i < filePaths.
size(); i++)
96 if (filePaths[i] != filePaths[0])
98 result[i] = fop(filePaths[i]);
103 return scatterList(result, tag, comm);
112template<
class Type,
class FileOp>
124 Pout<<
"masterUncollatedFileOperation : Operation on src:" << src
125 <<
" dest:" << dest <<
endl;
140 result = fop(srcs[0], dests[0]);
141 for (label i = 1; i < srcs.
size(); i++)
143 if (srcs[i] != srcs[0])
145 result[i] = fop(srcs[i], dests[i]);
150 return scatterList(result, tag, comm);
154 return fop(src, dest);
A 1D array of objects of type <T>, where the size of the vector is known and used for subscript bound...
Buffers for inter-processor communications streams (UOPstream, UIPstream).
label nProcs() const noexcept
Number of ranks associated with PstreamBuffers.
void finishedScatters(const bool wait=true)
Mark all sends to sub-procs as done.
UPstream::rangeType subProcs() const noexcept
Range of sub-processes indices associated with PstreamBuffers.
static void gatherList(const List< commsStruct > &comms, List< T > &values, const int tag, const label comm)
A 1D vector of objects of type <T>, where the size of the vector is known and can be used for subscri...
void size(const label n)
Older name for setAddressableSize.
@ nonBlocking
"nonBlocking"
static constexpr int masterNo() noexcept
Process index of the master (always 0)
static bool & parRun() noexcept
Test if this a parallel run.
A class for handling file names.
Type masterOp(const fileName &fName, const FileOp &fop, const int tag, const label comm) const
Type scatterList(const UList< Type > &, const int, const label comm) const
int myProcNo() const noexcept
Return processor number.
splitCell * master() const
OBJstream os(runTime.globalPath()/outputName)
Ostream & endl(Ostream &os)
Add newline and flush stream.
word name(const expressions::valueTypeCode typeCode)
A word representation of a valueTypeCode. Empty for INVALID.
prefixOSstream Pout
OSstream wrapped stdout (std::cout) with parallel prefix.