Inter-processor communications stream. More...
Classes | |
class | commsStruct |
Structure for communicating between processors. More... | |
class | communicator |
Helper class for allocating/freeing communicators. More... | |
class | listEq |
combineReduce operator for lists. Used for counting. More... | |
Public Types | |
enum | commsTypes { blocking, scheduled, nonBlocking } |
Types of communications. More... | |
Public Member Functions | |
ClassName ("UPstream") | |
UPstream (const commsTypes commsType) | |
Construct given optional buffer size. More... | |
commsTypes | commsType () const |
Get the communications type of the stream. More... | |
commsTypes | commsType (const commsTypes ct) |
Set the communications type of the stream. More... | |
Static Public Member Functions | |
static label | allocateCommunicator (const label parent, const labelList &subRanks, const bool doPstream=true) |
Allocate a new communicator. More... | |
static void | freeCommunicator (const label communicator, const bool doPstream=true) |
Free a previously allocated communicator. More... | |
static void | freeCommunicators (const bool doPstream) |
Free all communicators. More... | |
static int | baseProcNo (const label myComm, const int procID) |
Return physical processor number (i.e. processor number in. More... | |
static label | procNo (const label comm, const int baseProcID) |
Return processor number in communicator (given physical processor. More... | |
static label | procNo (const label myComm, const label currentComm, const int currentProcID) |
Return processor number in communicator (given processor number. More... | |
static void | addValidParOptions (HashTable< string > &validParOptions) |
Add the valid option this type of communications library. More... | |
static bool | init (int &argc, char **&argv) |
Initialisation function called from main. More... | |
static label | nRequests () |
Get number of outstanding requests. More... | |
static void | resetRequests (const label sz) |
Truncate number of outstanding requests. More... | |
static void | waitRequests (const label start=0) |
Wait until all requests (from start onwards) have finished. More... | |
static void | waitRequest (const label i) |
Wait until request i has finished. More... | |
static bool | finishedRequest (const label i) |
Non-blocking comms: has request i finished? More... | |
static int | allocateTag (const char *) |
static int | allocateTag (const word &) |
static void | freeTag (const char *, const int tag) |
static void | freeTag (const word &, const int tag) |
static bool & | parRun () |
Is this a parallel run? More... | |
static label | nProcs (const label communicator=0) |
Number of processes in parallel run. More... | |
static int | masterNo () |
Process index of the master. More... | |
static bool | master (const label communicator=0) |
Am I the master process. More... | |
static int | myProcNo (const label communicator=0) |
Number of this process (starting from masterNo() = 0) More... | |
static label | parent (const label communicator) |
static List< int > & | procID (label communicator) |
Process ID of given process index. More... | |
static int | firstSlave () |
Process index of first slave. More... | |
static int | lastSlave (const label communicator=0) |
Process index of last slave. More... | |
static const List< commsStruct > & | linearCommunication (const label communicator=0) |
Communication schedule for linear all-to-master (proc 0) More... | |
static const List< commsStruct > & | treeCommunication (const label communicator=0) |
Communication schedule for tree all-to-master (proc 0) More... | |
static int & | msgType () |
Message tag of standard messages. More... | |
static void | exit (int errnum=1) |
Exit program. More... | |
static void | abort () |
Abort program. More... | |
static void | allToAll (const labelUList &sendData, labelUList &recvData, const label communicator=0) |
Exchange label with all processors (in the communicator). More... | |
Static Public Attributes | |
static const NamedEnum< commsTypes, 3 > | commsTypeNames |
static bool | floatTransfer |
Should compact transfer be used in which floats replace doubles. More... | |
static int | nProcsSimpleSum |
Number of processors at which the sum algorithm changes from linear. More... | |
static commsTypes | defaultCommsType |
Default commsType. More... | |
static int | nPollProcInterfaces |
Number of polling cycles in processor updates. More... | |
static label | worldComm |
Default communicator (all processors) More... | |
static label | warnComm |
Debugging: warn for use of any communicator differing from warnComm. More... | |
Protected Attributes | |
commsTypes | commsType_ |
Communications type of this stream. More... | |
|
strong |
Types of communications.
Enumerator | |
---|---|
blocking | |
scheduled | |
nonBlocking |
Definition at line 64 of file UPstream.H.
|
inline |
Construct given optional buffer size.
Definition at line 284 of file UPstream.H.
References UPstream::allocateCommunicator(), UPstream::freeCommunicator(), UPstream::freeCommunicators(), and UPstream::parent().
ClassName | ( | "UPstream" | ) |
|
static |
Allocate a new communicator.
Definition at line 250 of file UPstream.C.
References Foam::abort(), Foam::endl(), Foam::FatalError, FatalErrorInFunction, forAll, UPstream::freeCommunicator(), Foam::Pout, and List< T >::size().
Referenced by masterCoarsestGAMGProcAgglomeration::agglomerate(), eagerGAMGProcAgglomeration::agglomerate(), procFacesGAMGProcAgglomeration::agglomerate(), manualGAMGProcAgglomeration::agglomerate(), NamedEnum< directionType, 3 >::names(), globalMeshData::updateMesh(), and UPstream::UPstream().
|
static |
Free a previously allocated communicator.
Definition at line 316 of file UPstream.C.
References Foam::endl(), and Foam::Pout.
Referenced by UPstream::allocateCommunicator(), globalMeshData::updateMesh(), UPstream::UPstream(), UPstream::communicator::~communicator(), eagerGAMGProcAgglomeration::~eagerGAMGProcAgglomeration(), manualGAMGProcAgglomeration::~manualGAMGProcAgglomeration(), masterCoarsestGAMGProcAgglomeration::~masterCoarsestGAMGProcAgglomeration(), OFstreamCollator::~OFstreamCollator(), and procFacesGAMGProcAgglomeration::~procFacesGAMGProcAgglomeration().
|
static |
Free all communicators.
Definition at line 343 of file UPstream.C.
References forAll.
Referenced by UPstream::UPstream().
|
static |
Return physical processor number (i.e. processor number in.
worldComm) given communicator and procssor
Definition at line 355 of file UPstream.C.
References UPstream::parent(), and UPstream::procID().
Referenced by UPstream::communicator::operator label(), and UPstream::procNo().
|
static |
Return processor number in communicator (given physical processor.
number) (= reverse of baseProcNo)
Definition at line 371 of file UPstream.C.
References Foam::findIndex().
Referenced by UPstream::communicator::operator label().
|
static |
Return processor number in communicator (given processor number.
and communicator)
Definition at line 389 of file UPstream.C.
References UPstream::baseProcNo(), UPstream::defaultCommsType, UPstream::floatTransfer, dictionary::lookup(), UPstream::nProcsSimpleSum, Foam::debug::optimisationSwitch(), Foam::debug::optimisationSwitches(), registerOptSwitch(), and serialComm.
Add the valid option this type of communications library.
adds/requires on the command line
Definition at line 31 of file UPstream.C.
Referenced by UPstream::communicator::operator label().
|
static |
Initialisation function called from main.
Spawns slave processes and initialises inter-communication
Definition at line 35 of file UPstream.C.
References Foam::exit(), Foam::FatalError, FatalErrorInFunction, and Foam::nl.
Referenced by UPstream::communicator::operator label(), and ParRunControl::runPar().
|
static |
Get number of outstanding requests.
Definition at line 107 of file UPstream.C.
Referenced by mapDistributeBase::compact(), GeometricField< Type, PatchField, GeoMesh >::Boundary::evaluate(), Foam::evaluateConstraintTypes(), processorFvPatchField< Type >::initInterfaceMatrixUpdate(), processorGAMGInterfaceField::initInterfaceMatrixUpdate(), UPstream::communicator::operator label(), processorFvPatchField< Type >::updateInterfaceMatrix(), processorGAMGInterfaceField::updateInterfaceMatrix(), and decomposedBlockData::writeBlocks().
|
static |
Truncate number of outstanding requests.
Definition at line 113 of file UPstream.C.
Referenced by UPstream::communicator::operator label(), and decomposedBlockData::writeBlocks().
|
static |
Wait until all requests (from start onwards) have finished.
Definition at line 117 of file UPstream.C.
Referenced by mapDistributeBase::compact(), GeometricField< Type, PatchField, GeoMesh >::Boundary::evaluate(), Foam::evaluateConstraintTypes(), GAMGProcAgglomeration::globalCellCells(), UPstream::communicator::operator label(), and decomposedBlockData::writeBlocks().
|
static |
Wait until request i has finished.
Definition at line 121 of file UPstream.C.
Referenced by UPstream::communicator::operator label(), processorFvPatchField< Type >::updateInterfaceMatrix(), and processorGAMGInterfaceField::updateInterfaceMatrix().
|
static |
Non-blocking comms: has request i finished?
Definition at line 125 of file UPstream.C.
References NotImplemented.
Referenced by UPstream::communicator::operator label(), and decomposedBlockData::writeBlocks().
|
static |
Definition at line 614 of file UPstream.C.
References Foam::endl(), Foam::PstreamGlobals::freedTags_, Foam::PstreamGlobals::nTags_, Foam::Pout, and DynamicList< T, SizeInc, SizeMult, SizeDiv >::remove().
Referenced by UPstream::communicator::operator label().
|
static |
Definition at line 643 of file UPstream.C.
References Foam::endl(), Foam::PstreamGlobals::freedTags_, Foam::PstreamGlobals::nTags_, Foam::Pout, and DynamicList< T, SizeInc, SizeMult, SizeDiv >::remove().
|
static |
Definition at line 672 of file UPstream.C.
References DynamicList< T, SizeInc, SizeMult, SizeDiv >::append(), Foam::endl(), Foam::PstreamGlobals::freedTags_, and Foam::Pout.
Referenced by UPstream::communicator::operator label().
|
static |
Definition at line 688 of file UPstream.C.
References DynamicList< T, SizeInc, SizeMult, SizeDiv >::append(), Foam::endl(), Foam::PstreamGlobals::freedTags_, and Foam::Pout.
|
inlinestatic |
Is this a parallel run?
Definition at line 394 of file UPstream.H.
Referenced by error::abort(), IOerror::abort(), snappyLayerDriver::addLayers(), unwatchedIOdictionary::addWatch(), regIOobject::addWatch(), meshRefinement::balance(), writeFile::baseFileDir(), boundBox::boundBox(), processorCyclicPolyPatch::calcGeometry(), processorPolyPatch::calcGeometry(), FaceCellWave< Type, TrackingData >::cellToFace(), polyBoundaryMesh::checkParallelSync(), CloudFunctionObject< CloudType >::CloudFunctionObject(), mapDistributeBase::compact(), processorFvPatch::coupled(), processorPointPatchField< Type >::coupled(), processorCyclicPointPatchField< Type >::coupled(), processorFvsPatchField< Type >::coupled(), processorCyclicFvsPatchField< Type >::coupled(), cyclicAMIFvPatch::coupled(), cyclicACMIFvPatch::coupled(), processorFvPatchField< Type >::coupled(), processorPolyPatch::coupled(), simpleGeomDecomp::decompose(), decompositionMethod::decompose(), conformalVoronoiMesh::decomposition(), processorFvPatch::delta(), fvMeshDistribute::distribute(), refinementHistory::distribute(), distributedTriSurfaceMesh::distributedTriSurfaceMesh(), snappyLayerDriver::doLayers(), snappyRefineDriver::doRefine(), PointEdgeWave< Type, TrackingData >::edgeToPoint(), GeometricField< Type, PatchField, GeoMesh >::Boundary::evaluate(), Foam::evaluateConstraintTypes(), error::exit(), IOerror::exit(), sampledSurfaces::expire(), polyMesh::findCell(), distributedTriSurfaceMesh::findNearest(), Pstream::gather(), Pstream::gatherList(), distributedTriSurfaceMesh::getField(), distributedTriSurfaceMesh::getNormal(), distributedTriSurfaceMesh::getRegion(), GAMGProcAgglomeration::globalCellCells(), InflationInjection< CloudType >::InflationInjection(), processorPolyPatch::initGeometry(), processorPolyPatch::initOrder(), processorPolyPatch::initUpdateMesh(), PointEdgeWave< Type, TrackingData >::iterate(), FaceCellWave< Type, TrackingData >::iterate(), LUscalarMatrix::LUscalarMatrix(), patchMeanVelocityForce::magUbarAve(), processorFvPatch::makeWeights(), NamedEnum< directionType, 3 >::names(), polyBoundaryMesh::neighbourEdges(), masterUncollatedFileOperation::NewIFstream(), minEqOp< labelPair >::operator()(), messageStream::operator()(), processorPolyPatch::order(), InflationInjection< CloudType >::parcelsToInject(), probes::prepare(), sampledSurfaces::read(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), Time::readModifiedObjects(), masterUncollatedFileOperation::readStream(), sampledSets::sampledSets(), sampledSurfaces::sampledSurfaces(), Pstream::scatter(), Pstream::scatterList(), Time::setControls(), fvMeshSubset::setLargeCellSubset(), syncTools::syncEdgeMap(), syncTools::syncEdgePositions(), syncTools::syncPointMap(), externalCoupledTemperatureMixedFvPatchScalarField::transferData(), sampledSurfaces::update(), processorPolyPatch::updateMesh(), fileOperation::updateStates(), streamLine::write(), meshToMeshMethod::writeConnectivity(), fieldMinMax::writeFileHeader(), collatedFileOperation::writeObject(), and masterOFstream::~masterOFstream().
Number of processes in parallel run.
Definition at line 400 of file UPstream.H.
References List< T >::size().
Referenced by surfaceZonesInfo::addCellZonesToMesh(), surfaceZonesInfo::addFaceZonesToMesh(), masterCoarsestGAMGProcAgglomeration::agglomerate(), eagerGAMGProcAgglomeration::agglomerate(), procFacesGAMGProcAgglomeration::agglomerate(), manualGAMGProcAgglomeration::agglomerate(), meshRefinement::balanceAndRefine(), mapDistributeBase::calcCompactAddressing(), meshRefinement::checkCoupledFaceZones(), polyBoundaryMesh::checkParallelSync(), mappedPatchBase::collectSamples(), fieldValue::combineFields(), Foam::combineReduce(), mapDistributeBase::compact(), GAMGAgglomeration::continueAgglomerating(), fvMeshDistribute::countCells(), simpleGeomDecomp::decompose(), fvMeshDistribute::distribute(), refinementHistory::distribute(), distributedTriSurfaceMesh::distribute(), distributedTriSurfaceMesh::distributedTriSurfaceMesh(), mapDistributeBase::exchangeAddressing(), extendedUpwindCellToFaceStencil::extendedUpwindCellToFaceStencil(), distributedTriSurfaceMesh::findNearest(), Pstream::gather(), Pstream::gatherList(), globalIndex::globalIndex(), UPstream::lastSlave(), LUscalarMatrix::LUscalarMatrix(), mapDistributeBase::mapDistributeBase(), NamedEnum< directionType, 3 >::names(), masterUncollatedFileOperation::NewIFstream(), minEqOp< labelPair >::operator()(), lessProcPatches::operator()(), UPstream::listEq::operator()(), InflationInjection< CloudType >::parcelsToInject(), argList::parse(), fvMeshDistribute::printCoupleInfo(), mapDistributeBase::printLayout(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), decomposedBlockData::readBlocks(), masterUncollatedFileOperation::readHeader(), masterUncollatedFileOperation::readStream(), mapDistributeBase::receive(), Foam::reduce(), meshRefinement::refineAndBalance(), meshRefinement::refineCandidates(), Foam::returnReduce(), Pstream::scatter(), Pstream::scatterList(), mapDistributeBase::schedule(), mapDistributeBase::send(), Time::setControls(), fvMeshSubset::setLargeCellSubset(), ParSortableList< Type >::sort(), externalCoupledTemperatureMixedFvPatchScalarField::transferData(), globalMeshData::updateMesh(), streamLine::write(), decomposedBlockData::writeBlocks(), and masterOFstream::~masterOFstream().
|
inlinestatic |
Process index of the master.
Definition at line 406 of file UPstream.H.
Referenced by simpleGeomDecomp::decompose(), LUscalarMatrix::LUscalarMatrix(), UPstream::master(), masterUncollatedFileOperation::NewIFstream(), minEqOp< labelPair >::operator()(), argList::parse(), decomposedBlockData::readBlocks(), masterUncollatedFileOperation::readStream(), mapDistributeBase::schedule(), globalMeshData::sharedPoints(), syncTools::syncEdgeMap(), syncTools::syncPointMap(), decomposedBlockData::writeBlocks(), and masterOFstream::~masterOFstream().
|
inlinestatic |
Am I the master process.
Definition at line 412 of file UPstream.H.
References UPstream::masterNo().
Referenced by effectivenessHeatExchangerSource::addSup(), regIOobject::addWatch(), masterUncollatedFileOperation::addWatch(), mappedPatchBase::calcMapping(), viewFactor::calculate(), argList::check(), polyBoundaryMesh::checkParallelSync(), argList::checkRootCase(), Foam::chMod(), fieldValue::combineFields(), commSchedule::commSchedule(), Foam::cp(), logFiles::createFiles(), simpleGeomDecomp::decompose(), masterUncollatedFileOperation::dirPath(), Foam::exists(), logFiles::file(), masterUncollatedFileOperation::filePath(), logFiles::files(), Foam::fileSize(), probes::findElements(), masterUncollatedFileOperation::findTimes(), masterUncollatedFileOperation::findWatch(), masterUncollatedFileOperation::getFile(), masterUncollatedFileOperation::getState(), cachedRandom::globalGaussNormal(), cachedRandom::globalPosition(), cachedRandom::globalRandomise01(), cachedRandom::globalSample01(), Foam::highResLastModified(), Foam::isDir(), Foam::isFile(), JobInfo::JobInfo(), Foam::lastModified(), Foam::ln(), LUscalarMatrix::LUscalarMatrix(), messageStream::masterStream(), Foam::mkDir(), Foam::mv(), Foam::mvBak(), NamedEnum< directionType, 3 >::names(), masterUncollatedFileOperation::NewIFstream(), isNotEqOp< T >::operator()(), minEqOp< labelPair >::operator()(), ListPlusEqOp< T, Size >::operator()(), messageStream::operator()(), InflationInjection< CloudType >::parcelsToInject(), argList::parse(), porosityModel::porosityModel(), probes::prepare(), decomposedBlockData::read(), sampledSurfaces::read(), uncollatedFileOperation::read(), sampledSets::read(), masterUncollatedFileOperation::read(), decomposedBlockData::readBlocks(), baseIOdictionary::readData(), Foam::readDir(), masterUncollatedFileOperation::readHeader(), masterUncollatedFileOperation::readObjects(), masterUncollatedFileOperation::readStream(), masterUncollatedFileOperation::removeWatch(), logFiles::resetName(), logFiles::resetNames(), Foam::rm(), Foam::rmDir(), mapDistributeBase::schedule(), masterUncollatedFileOperation::setUnmodified(), globalMeshData::sharedPoints(), JobInfo::signalEnd(), rigidBodyMeshMotionSolver::solve(), rigidBodyMeshMotion::solve(), rigidBodyMotion::solve(), ParSortableList< Type >::sort(), syncTools::syncEdgeMap(), syncTools::syncPointMap(), externalCoupledTemperatureMixedFvPatchScalarField::transferData(), Foam::type(), IOobject::typeHeaderOk(), sampledSurfaces::update(), sixDoFRigidBodyMotion::update(), fileMonitor::updateStates(), masterUncollatedFileOperation::updateStates(), solution::upgradeSolverDict(), JobInfo::write(), residuals::write(), yPlus::write(), cloudInfo::write(), wallHeatFlux::write(), histogram::write(), wallShearStress::write(), fieldValueDelta::write(), fieldMinMax::write(), sampledSurfaces::write(), forceCoeffs::write(), sampledSets::write(), streamLine::write(), regionSizeDistribution::write(), volFieldValue::write(), forces::write(), surfaceFieldValue::write(), decomposedBlockData::writeBlocks(), decomposedBlockData::writeData(), residuals::writeFileHeader(), collatedFileOperation::writeObject(), decomposedBlockData::writeObject(), JobInfo::~JobInfo(), and masterOFstream::~masterOFstream().
|
inlinestatic |
Number of this process (starting from masterNo() = 0)
Definition at line 418 of file UPstream.H.
Referenced by surfaceZonesInfo::addCellZonesToMesh(), surfaceZonesInfo::addFaceZonesToMesh(), GAMGProcAgglomeration::agglomerate(), masterCoarsestGAMGProcAgglomeration::agglomerate(), eagerGAMGProcAgglomeration::agglomerate(), manualGAMGProcAgglomeration::agglomerate(), mapDistributeBase::calcCompactAddressing(), viewFactor::calculate(), GAMGAgglomeration::calculateRegionMaster(), meshRefinement::checkCoupledFaceZones(), polyBoundaryMesh::checkParallelSync(), mappedPatchBase::collectSamples(), fieldValue::combineFields(), mapDistributeBase::compact(), noDecomp::decompose(), fvMeshDistribute::distribute(), distributedTriSurfaceMesh::distribute(), distributedTriSurfaceMesh::distributedTriSurfaceMesh(), mapDistributeBase::exchangeAddressing(), processorField::execute(), InjectionModel< CloudType >::findCellAtPosition(), probes::findElements(), patchProbes::findElements(), distributedTriSurfaceMesh::findNearest(), mappedPatchBase::findSamples(), Pstream::gather(), lduPrimitiveMesh::gather(), Pstream::gatherList(), GAMGProcAgglomeration::globalCellCells(), globalIndex::globalIndex(), globalIndex::isLocal(), lduPrimitiveMesh::lduPrimitiveMesh(), globalIndex::localSize(), meshToMesh::mapAndOpTgtToSrc(), mapDistribute::mapDistribute(), mapDistributeBase::mapDistributeBase(), conformalVoronoiMesh::maxSurfaceProtrusion(), meshRefinement::mergeBaffles(), NamedEnum< directionType, 3 >::names(), masterUncollatedFileOperation::NewIFstream(), regionSplit::nLocalRegions(), minEqOp< labelPair >::operator()(), ListPlusEqOp< T, Size >::operator()(), lessProcPatches::operator()(), InflationInjection< CloudType >::parcelsToInject(), argList::parse(), UOPstream::print(), fvMeshDistribute::printCoupleInfo(), mapDistributeBase::printLayout(), backgroundMeshDecomposition::procBounds(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), masterUncollatedFileOperation::readHeader(), masterUncollatedFileOperation::readStream(), indexedVertex< Gt, Vb >::referred(), Pstream::scatter(), Pstream::scatterList(), mapDistributeBase::schedule(), Time::setControls(), fvMeshSubset::setLargeCellSubset(), patchInjectionBase::setPositionAndCell(), ParSortableList< Type >::sort(), ThermoSurfaceFilm< CloudType >::splashInteraction(), refinementHistory::subset(), globalIndex::toGlobal(), globalIndex::toLocal(), externalCoupledTemperatureMixedFvPatchScalarField::transferData(), patchInjectionBase::updateMesh(), decomposedBlockData::writeBlocks(), meshToMeshMethod::writeConnectivity(), extendedCellToFaceStencil::writeStencilStats(), and masterOFstream::~masterOFstream().
Definition at line 423 of file UPstream.H.
Referenced by UPstream::baseProcNo(), and UPstream::UPstream().
Process ID of given process index.
Definition at line 429 of file UPstream.H.
Referenced by UPstream::baseProcNo(), and UPstream::listEq::operator()().
|
inlinestatic |
Process index of first slave.
Definition at line 435 of file UPstream.H.
Referenced by LUscalarMatrix::LUscalarMatrix(), minEqOp< labelPair >::operator()(), argList::parse(), mapDistributeBase::schedule(), globalMeshData::sharedPoints(), syncTools::syncEdgeMap(), and syncTools::syncPointMap().
|
inlinestatic |
Process index of last slave.
Definition at line 441 of file UPstream.H.
References UPstream::linearCommunication(), and UPstream::nProcs().
Referenced by LUscalarMatrix::LUscalarMatrix(), minEqOp< labelPair >::operator()(), argList::parse(), mapDistributeBase::schedule(), globalMeshData::sharedPoints(), syncTools::syncEdgeMap(), and syncTools::syncPointMap().
|
inlinestatic |
Communication schedule for linear all-to-master (proc 0)
Definition at line 448 of file UPstream.H.
References UPstream::treeCommunication().
Referenced by Foam::combineReduce(), Pstream::gather(), Pstream::gatherList(), UPstream::lastSlave(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), Foam::reduce(), Foam::returnReduce(), Pstream::scatter(), and Pstream::scatterList().
|
inlinestatic |
Communication schedule for tree all-to-master (proc 0)
Definition at line 457 of file UPstream.H.
Referenced by Foam::combineReduce(), Pstream::gather(), Pstream::gatherList(), UPstream::linearCommunication(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), Foam::reduce(), Foam::returnReduce(), Pstream::scatter(), and Pstream::scatterList().
|
inlinestatic |
Message tag of standard messages.
Definition at line 465 of file UPstream.H.
Referenced by decompositionMethod::calcCellCells(), extendedCentredCellToFaceStencil::compact(), extendedCentredFaceToCellStencil::compact(), extendedCentredCellToCellStencil::compact(), mapDistributeBase::constructHasFlip(), UOPstream::flags(), UIPstream::flags(), globalIndex::gather(), lduPrimitiveMesh::gather(), Foam::gAverage(), GAMGProcAgglomeration::globalCellCells(), globalIndex::globalIndex(), Foam::gSumCmptProd(), Foam::gSumProd(), regionModel::interRegionAMI(), lduPrimitiveMesh::lduPrimitiveMesh(), LUscalarMatrix::LUscalarMatrix(), mappedPatchFieldBase< Type >::mappedField(), mapDistribute::transformPosition::operator()(), Pstream::Pstream(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), decomposedBlockData::readBlocks(), Foam::reduce(), fvMatrix< Type >::relax(), mapDistributeBase::schedule(), processorFvPatch::tag(), processorCyclicPolyPatch::tag(), processorPolyPatch::tag(), externalCoupledTemperatureMixedFvPatchScalarField::transferData(), mapDistribute::transformStart(), mappedVelocityFluxFixedValueFvPatchField::updateCoeffs(), filmPyrolysisTemperatureCoupledFvPatchScalarField::updateCoeffs(), wideBandDiffusiveRadiationMixedFvPatchScalarField::updateCoeffs(), filmPyrolysisVelocityCoupledFvPatchVectorField::updateCoeffs(), mappedFlowRateFvPatchVectorField::updateCoeffs(), greyDiffusiveRadiationMixedFvPatchScalarField::updateCoeffs(), MarshakRadiationFvPatchScalarField::updateCoeffs(), MarshakRadiationFixedTemperatureFvPatchScalarField::updateCoeffs(), alphatFilmWallFunctionFvPatchScalarField::updateCoeffs(), turbulentTemperatureCoupledBaffleMixedFvPatchScalarField::updateCoeffs(), turbulentTemperatureRadCoupledMixedFvPatchScalarField::updateCoeffs(), thermalBaffle1DFvPatchScalarField< solidType >::updateCoeffs(), globalMeshData::updateMesh(), and decomposedBlockData::writeBlocks().
|
inline |
Get the communications type of the stream.
Definition at line 472 of file UPstream.H.
References UPstream::commsType_.
|
inline |
Set the communications type of the stream.
Definition at line 478 of file UPstream.H.
References UPstream::abort(), UPstream::allToAll(), UPstream::commsType_, UPstream::exit(), and Foam::operator<<().
|
static |
Exit program.
Definition at line 46 of file UPstream.C.
References NotImplemented.
Referenced by UPstream::commsType(), error::exit(), IOerror::exit(), ParRunControl::runPar(), and ParRunControl::~ParRunControl().
|
static |
Abort program.
Definition at line 52 of file UPstream.C.
References NotImplemented.
Referenced by error::abort(), IOerror::abort(), and UPstream::commsType().
|
static |
Exchange label with all processors (in the communicator).
sendData[proci] is the label to send to proci. After return recvData contains the data from the other processors.
Definition at line 85 of file UPstream.C.
References UList< T >::deepCopy().
Referenced by UPstream::commsType(), and Foam::reduce().
|
static |
Definition at line 71 of file UPstream.H.
Referenced by GeometricField< Type, PatchField, GeoMesh >::Boundary::evaluate(), PstreamBuffers::finishedSends(), NamedEnum< directionType, 3 >::names(), argList::parse(), decomposedBlockData::readBlocks(), addcommsTypeToOpt::readData(), decomposedBlockData::writeBlocks(), and addcommsTypeToOpt::writeData().
|
protected |
Communications type of this stream.
Definition at line 249 of file UPstream.H.
Referenced by UPstream::commsType(), and UOPstream::~UOPstream().
|
static |
Should compact transfer be used in which floats replace doubles.
reducing the bandwidth requirement at the expense of some loss in accuracy
Definition at line 262 of file UPstream.H.
Referenced by processorFvPatchField< Type >::initInterfaceMatrixUpdate(), processorGAMGInterfaceField::initInterfaceMatrixUpdate(), argList::parse(), UPstream::procNo(), processorFvPatchField< Type >::updateInterfaceMatrix(), and processorGAMGInterfaceField::updateInterfaceMatrix().
|
static |
Number of processors at which the sum algorithm changes from linear.
to tree
Definition at line 266 of file UPstream.H.
Referenced by Foam::combineReduce(), Pstream::gather(), Pstream::gatherList(), argList::parse(), UPstream::procNo(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), Foam::reduce(), Foam::returnReduce(), Pstream::scatter(), and Pstream::scatterList().
|
static |
Default commsType.
Definition at line 269 of file UPstream.H.
Referenced by polyBoundaryMesh::clearAddressing(), mapDistributeBase::distribute(), mappedPatchBase::distribute(), GeometricField< Type, PatchField, GeoMesh >::Boundary::evaluate(), Foam::evaluateConstraintTypes(), pointBoundaryMesh::findIndices(), pointBoundaryMesh::movePoints(), polyBoundaryMesh::movePoints(), argList::parse(), UPstream::procNo(), addcommsTypeToOpt::readData(), mapDistributeBase::reverseDistribute(), mappedPatchBase::reverseDistribute(), pointBoundaryMesh::updateMesh(), polyBoundaryMesh::updateMesh(), and addcommsTypeToOpt::writeData().
|
static |
Number of polling cycles in processor updates.
Definition at line 272 of file UPstream.H.
Referenced by argList::parse(), and addcommsTypeToOpt::writeData().
|
static |
Default communicator (all processors)
Definition at line 275 of file UPstream.H.
Referenced by decompositionMethod::calcCellCells(), mapDistributeBase::exchangeAddressing(), messageStream::masterStream(), NamedEnum< directionType, 3 >::names(), Pstream::Pstream(), uncollatedFileOperation::read(), masterUncollatedFileOperation::read(), masterUncollatedFileOperation::readStream(), Foam::reduce(), globalMeshData::updateMesh(), and addcommsTypeToOpt::writeData().
|
static |
Debugging: warn for use of any communicator differing from warnComm.
Definition at line 278 of file UPstream.H.
Referenced by GAMGSolver::GAMGSolver(), processorGAMGInterfaceField::initInterfaceMatrixUpdate(), processorGAMGInterface::initInternalFieldTransfer(), processorGAMGInterface::internalFieldTransfer(), messageStream::masterStream(), Foam::reduce(), GAMGSolver::solve(), processorGAMGInterfaceField::updateInterfaceMatrix(), and addcommsTypeToOpt::writeData().