diff --git a/applications/test/parallel-nonBlocking/Test-parallel-nonBlocking.C b/applications/test/parallel-nonBlocking/Test-parallel-nonBlocking.C index ce00f4d8cbe0f8c4da50cc7d53049b9214a44e21..e5ec8bd2b6ce3c79800936aa90265f565b9fe601 100644 --- a/applications/test/parallel-nonBlocking/Test-parallel-nonBlocking.C +++ b/applications/test/parallel-nonBlocking/Test-parallel-nonBlocking.C @@ -66,7 +66,7 @@ int main(int argc, char *argv[]) Pstream::myProcNo() ); - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; if (!Pstream::master()) { @@ -150,7 +150,7 @@ int main(int argc, char *argv[]) // Do a non-blocking send inbetween { - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; for (const int proci : Pstream::allProcs()) { diff --git a/applications/utilities/mesh/generation/foamyMesh/conformalVoronoiMesh/conformalVoronoiMesh/conformalVoronoiMeshIO.C b/applications/utilities/mesh/generation/foamyMesh/conformalVoronoiMesh/conformalVoronoiMesh/conformalVoronoiMeshIO.C index ccc5b21fe99a74fa41bf1a884c0d88efca74586b..1b6dbddb93046560755619e8f545710e561ad9d2 100644 --- a/applications/utilities/mesh/generation/foamyMesh/conformalVoronoiMesh/conformalVoronoiMesh/conformalVoronoiMeshIO.C +++ b/applications/utilities/mesh/generation/foamyMesh/conformalVoronoiMesh/conformalVoronoiMesh/conformalVoronoiMeshIO.C @@ -618,7 +618,7 @@ void Foam::conformalVoronoiMesh::reorderProcessorPatches labelList rotation(faces.size(), Zero); labelList faceMap(faces.size(), label(-1)); - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Send ordering forAll(sortMesh.boundaryMesh(), patchi) diff --git a/applications/utilities/parallelProcessing/redistributePar/parLagrangianDistributor.C b/applications/utilities/parallelProcessing/redistributePar/parLagrangianDistributor.C index de9968fbfb0110408cd650595d3fbbf0279372c7..97c5b0cc5c96d0cab932e4a6e11f7f4a68d23628 100644 --- a/applications/utilities/parallelProcessing/redistributePar/parLagrangianDistributor.C +++ b/applications/utilities/parallelProcessing/redistributePar/parLagrangianDistributor.C @@ -184,7 +184,7 @@ Foam::parLagrangianDistributor::distributeLagrangianPositions labelListList sendMap; // Transfer buffers - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; { // List of lists of particles to be transferred for all of the diff --git a/src/OpenFOAM/db/IOobjects/decomposedBlockData/decomposedBlockData.C b/src/OpenFOAM/db/IOobjects/decomposedBlockData/decomposedBlockData.C index 4139ecca421647417fb51347da903d2c34ace88e..8542952455c88a611f6ff8b68c931b0a5a5ca265 100644 --- a/src/OpenFOAM/db/IOobjects/decomposedBlockData/decomposedBlockData.C +++ b/src/OpenFOAM/db/IOobjects/decomposedBlockData/decomposedBlockData.C @@ -545,7 +545,7 @@ bool Foam::decomposedBlockData::readBlocks } else { - PstreamBuffers pBufs(comm, UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs(comm); if (UPstream::master(comm)) { @@ -667,7 +667,7 @@ Foam::autoPtr<Foam::ISstream> Foam::decomposedBlockData::readBlocks } else { - PstreamBuffers pBufs(comm, UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs(comm); if (UPstream::master(comm)) { diff --git a/src/OpenFOAM/db/IOstreams/Fstreams/masterOFstream.C b/src/OpenFOAM/db/IOstreams/Fstreams/masterOFstream.C index cc80139f0e68f4c65b2d932962718b4a84fcb231..efdb248655576f7945706c31c62be1d0e5d01086 100644 --- a/src/OpenFOAM/db/IOstreams/Fstreams/masterOFstream.C +++ b/src/OpenFOAM/db/IOstreams/Fstreams/masterOFstream.C @@ -115,7 +115,7 @@ void Foam::masterOFstream::commit() } // Different files - PstreamBuffers pBufs(comm_, UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs(comm_); if (!UPstream::master(comm_)) { diff --git a/src/OpenFOAM/db/IOstreams/Pstreams/PstreamBuffers.H b/src/OpenFOAM/db/IOstreams/Pstreams/PstreamBuffers.H index cb4cf58e3af92c17d125b426a0e96ab66f8f9dbc..ed40029c9329aef3002343c72f62477bc3adc218 100644 --- a/src/OpenFOAM/db/IOstreams/Pstreams/PstreamBuffers.H +++ b/src/OpenFOAM/db/IOstreams/Pstreams/PstreamBuffers.H @@ -38,7 +38,7 @@ Description Example usage: \code - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; for (const int proci : UPstream::allProcs()) { @@ -68,7 +68,7 @@ Description one-to-all and all-to-one communication patterns. For example, \code - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; if (UPstream::master()) { @@ -96,7 +96,7 @@ Description For example, \code - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; pBufs.initRegisterSend(); diff --git a/src/OpenFOAM/global/fileOperations/masterUncollatedFileOperation/masterUncollatedFileOperation.C b/src/OpenFOAM/global/fileOperations/masterUncollatedFileOperation/masterUncollatedFileOperation.C index 5299af8ab4bac4c71ae8173ec0c3f5dfb8fe9cc6..20c9511aa0dd13a429d00295dc786db2d12dc37c 100644 --- a/src/OpenFOAM/global/fileOperations/masterUncollatedFileOperation/masterUncollatedFileOperation.C +++ b/src/OpenFOAM/global/fileOperations/masterUncollatedFileOperation/masterUncollatedFileOperation.C @@ -452,7 +452,7 @@ Foam::fileOperations::masterUncollatedFileOperation::read { autoPtr<ISstream> isPtr; - PstreamBuffers pBufs(comm, UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs(comm); if (UPstream::master(comm)) { @@ -1834,7 +1834,7 @@ bool Foam::fileOperations::masterUncollatedFileOperation::readHeader } // Is a more efficient scatter possible? - PstreamBuffers pBufs(comm_, UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs(comm_); if (Pstream::master(comm_)) { @@ -2396,7 +2396,7 @@ Foam::fileOperations::masterUncollatedFileOperation::NewIFstream filePaths[Pstream::myProcNo(comm_)] = filePath; Pstream::gatherList(filePaths, Pstream::msgType(), comm_); - PstreamBuffers pBufs(comm_, Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs(comm_); if (Pstream::master(comm_)) { diff --git a/src/OpenFOAM/matrices/lduMatrix/solvers/GAMG/GAMGSolverAgglomerateMatrix.C b/src/OpenFOAM/matrices/lduMatrix/solvers/GAMG/GAMGSolverAgglomerateMatrix.C index a3fe33a999dff5bdf102f990f3c1812915c075c3..7225bdcaaa8b23c8bf98c8ef4819ffcbeb4df207 100644 --- a/src/OpenFOAM/matrices/lduMatrix/solvers/GAMG/GAMGSolverAgglomerateMatrix.C +++ b/src/OpenFOAM/matrices/lduMatrix/solvers/GAMG/GAMGSolverAgglomerateMatrix.C @@ -311,12 +311,7 @@ void Foam::GAMGSolver::gatherMatrices const auto& boundaryMap = agglomeration_.boundaryMap(destLevel); // Use PstreamBuffers - PstreamBuffers pBufs - ( - UPstream::commsTypes::nonBlocking, - UPstream::msgType(), - comm - ); + PstreamBuffers pBufs(comm); // Send to master if (!UPstream::master(comm)) diff --git a/src/OpenFOAM/meshes/lduMesh/lduPrimitiveMesh.C b/src/OpenFOAM/meshes/lduMesh/lduPrimitiveMesh.C index e847072e24e3c84169c18248fcbe8e97ba537e23..40a5975794e0197594d5ef65b7693747560f4a87 100644 --- a/src/OpenFOAM/meshes/lduMesh/lduPrimitiveMesh.C +++ b/src/OpenFOAM/meshes/lduMesh/lduPrimitiveMesh.C @@ -1344,12 +1344,7 @@ void Foam::lduPrimitiveMesh::gather (void)mesh.lduAddr().patchSchedule(); // Use PstreamBuffers - PstreamBuffers pBufs - ( - Pstream::commsTypes::nonBlocking, - UPstream::msgType(), - comm - ); + PstreamBuffers pBufs(comm); // Send to master if (!Pstream::master(comm)) diff --git a/src/OpenFOAM/meshes/polyMesh/mapPolyMesh/mapDistribute/mapDistributeBaseTemplates.C b/src/OpenFOAM/meshes/polyMesh/mapPolyMesh/mapDistribute/mapDistributeBaseTemplates.C index 68b9662a7789e663fe18fea59f505af99530dafd..ce75d448405bb4cb3bfee157c84a20d4f6d29e58 100644 --- a/src/OpenFOAM/meshes/polyMesh/mapPolyMesh/mapDistribute/mapDistributeBaseTemplates.C +++ b/src/OpenFOAM/meshes/polyMesh/mapPolyMesh/mapDistribute/mapDistributeBaseTemplates.C @@ -681,7 +681,7 @@ void Foam::mapDistributeBase::distribute if (!is_contiguous<T>::value) { - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking, tag, comm); + PstreamBuffers pBufs(comm, tag); // Stream data into buffer for (const int proci : UPstream::allProcs(comm)) @@ -1121,7 +1121,7 @@ void Foam::mapDistributeBase::distribute if (!is_contiguous<T>::value) { - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking, tag, comm); + PstreamBuffers pBufs(comm, tag); // Stream data into buffer for (const int proci : UPstream::allProcs(comm)) diff --git a/src/OpenFOAM/meshes/polyMesh/syncTools/syncToolsTemplates.C b/src/OpenFOAM/meshes/polyMesh/syncTools/syncToolsTemplates.C index 21b4030d2277b8b6cced828e1523e1bd2ae6e13e..b23781865970512b0ebd79cc97a82e1996eb6fd1 100644 --- a/src/OpenFOAM/meshes/polyMesh/syncTools/syncToolsTemplates.C +++ b/src/OpenFOAM/meshes/polyMesh/syncTools/syncToolsTemplates.C @@ -132,7 +132,7 @@ void Foam::syncTools::syncPointMap // Presize according to number of processor patches // (global topology information may not yet be available...) DynamicList<label> neighbProcs(patches.nProcessorPatches()); - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Reduce communication by only sending non-zero data, // but with multiply-connected processor/processor @@ -396,7 +396,7 @@ void Foam::syncTools::syncEdgeMap // Presize according to number of processor patches // (global topology information may not yet be available...) DynamicList<label> neighbProcs(patches.nProcessorPatches()); - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Reduce communication by only sending non-zero data, // but with multiply-connected processor/processor @@ -1142,7 +1142,7 @@ void Foam::syncTools::syncBoundaryFaceList else { DynamicList<label> neighbProcs; - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Send for (const polyPatch& pp : patches) diff --git a/src/OpenFOAM/parallel/globalIndex/globalIndexTemplates.C b/src/OpenFOAM/parallel/globalIndex/globalIndexTemplates.C index 9de90ba469e4b791602b680797d008dfc58b8087..4519893055dbcfd96788478c5891bbc33b631c54 100644 --- a/src/OpenFOAM/parallel/globalIndex/globalIndexTemplates.C +++ b/src/OpenFOAM/parallel/globalIndex/globalIndexTemplates.C @@ -1092,7 +1092,7 @@ void Foam::globalIndex::get ); // Send local indices to individual processors as local index - PstreamBuffers sendBufs(UPstream::commsTypes::nonBlocking, tag, comm); + PstreamBuffers sendBufs(comm, tag); for (const auto proci : validBins) { @@ -1109,7 +1109,7 @@ void Foam::globalIndex::get sendBufs.finishedSends(); - PstreamBuffers returnBufs(UPstream::commsTypes::nonBlocking, tag, comm); + PstreamBuffers returnBufs(comm, tag); for (const int proci : sendBufs.allProcs()) { diff --git a/src/dynamicMesh/fvMeshDistribute/fvMeshDistribute.C b/src/dynamicMesh/fvMeshDistribute/fvMeshDistribute.C index a3b18318a1528002513c84bdef029bc5700cfe1d..b843e387670acde2f4653310902480d009f1851c 100644 --- a/src/dynamicMesh/fvMeshDistribute/fvMeshDistribute.C +++ b/src/dynamicMesh/fvMeshDistribute/fvMeshDistribute.C @@ -2153,7 +2153,7 @@ Foam::autoPtr<Foam::mapDistributePolyMesh> Foam::fvMeshDistribute::distribute UPstream::allToAll(nSendCells, nRecvCells); // Allocate buffers - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // What to send to neighbouring domains diff --git a/src/dynamicMesh/polyTopoChange/polyTopoChange/hexRef8/refinementHistory.C b/src/dynamicMesh/polyTopoChange/polyTopoChange/hexRef8/refinementHistory.C index 7919d228e1867e88eafe0d3002ed54c4397e2a3e..c842c2a696000b406207d8338b1a101d149c9d2e 100644 --- a/src/dynamicMesh/polyTopoChange/polyTopoChange/hexRef8/refinementHistory.C +++ b/src/dynamicMesh/polyTopoChange/polyTopoChange/hexRef8/refinementHistory.C @@ -1272,7 +1272,7 @@ void Foam::refinementHistory::distribute(const mapDistributePolyMesh& map) // Create subsetted refinement tree consisting of all parents that // move in their whole to other processor. - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; for (const int proci : Pstream::allProcs()) { diff --git a/src/finiteVolume/fields/fvPatchFields/derived/turbulentDFSEMInlet/turbulentDFSEMInletFvPatchVectorField.C b/src/finiteVolume/fields/fvPatchFields/derived/turbulentDFSEMInlet/turbulentDFSEMInletFvPatchVectorField.C index c66b64247559ce6572a50cf12a3c68b34ce96429..f7e7ac5a0b7b0bb83be91bfab5283a2fc9c950a5 100644 --- a/src/finiteVolume/fields/fvPatchFields/derived/turbulentDFSEMInlet/turbulentDFSEMInletFvPatchVectorField.C +++ b/src/finiteVolume/fields/fvPatchFields/derived/turbulentDFSEMInlet/turbulentDFSEMInletFvPatchVectorField.C @@ -537,7 +537,7 @@ void Foam::turbulentDFSEMInletFvPatchVectorField::calcOverlappingProcEddies } - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; forAll(sendMap, proci) { diff --git a/src/finiteVolume/fvMesh/fvMeshSubset/fvMeshSubset.C b/src/finiteVolume/fvMesh/fvMeshSubset/fvMeshSubset.C index 54a837d7ebf5309d7ddaea6934da327e2aa4f5fb..2f10400289bc4aacfc5c0910c4de4b4dae6e65aa 100644 --- a/src/finiteVolume/fvMesh/fvMeshSubset/fvMeshSubset.C +++ b/src/finiteVolume/fvMesh/fvMeshSubset/fvMeshSubset.C @@ -174,7 +174,7 @@ void Foam::fvMeshSubset::doCoupledPatches if (syncPar && UPstream::parRun()) { - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Send face usage across processor patches if (!nCellsUsingFace.empty()) diff --git a/src/functionObjects/field/DMD/DMDModels/derived/STDMD/STDMD.C b/src/functionObjects/field/DMD/DMDModels/derived/STDMD/STDMD.C index 3678b341e58783c05404f813df88caf41f832d57..5f503d8646f6f87bfc5d58c6e9cdd566e340c818 100644 --- a/src/functionObjects/field/DMD/DMDModels/derived/STDMD/STDMD.C +++ b/src/functionObjects/field/DMD/DMDModels/derived/STDMD/STDMD.C @@ -227,7 +227,7 @@ reducedKoopmanOperator() // the final outcome of TSQR decomposition up to sign // Don't clear storage on persistent buffer - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; pBufs.allowClearRecv(false); const label myProcNo = Pstream::myProcNo(); diff --git a/src/functionObjects/field/externalCoupled/externalCoupled.C b/src/functionObjects/field/externalCoupled/externalCoupled.C index 5b69105194e7fec13d99ec660601baa6aa76a238..2602860e1262a0c427a1e0636aa1d1e1365e31e6 100644 --- a/src/functionObjects/field/externalCoupled/externalCoupled.C +++ b/src/functionObjects/field/externalCoupled/externalCoupled.C @@ -111,7 +111,7 @@ void Foam::functionObjects::externalCoupled::readColumns // Get sizes for all processors const globalIndex globalFaces(globalIndex::gatherOnly{}, nRows); - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; if (UPstream::master()) { @@ -182,7 +182,7 @@ void Foam::functionObjects::externalCoupled::readLines // Get sizes for all processors const globalIndex globalFaces(globalIndex::gatherOnly{}, nRows); - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; if (UPstream::master()) { diff --git a/src/functionObjects/randomProcesses/energySpectrum/energySpectrum.C b/src/functionObjects/randomProcesses/energySpectrum/energySpectrum.C index 0a8a159b28795ce6f27a9b5287b2e516fbc103cb..f36b4d276783382195c4154f732976dbd4b369e8 100644 --- a/src/functionObjects/randomProcesses/energySpectrum/energySpectrum.C +++ b/src/functionObjects/randomProcesses/energySpectrum/energySpectrum.C @@ -215,7 +215,7 @@ bool Foam::functionObjects::energySpectrum::write() if (Pstream::parRun()) { - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; { UOPstream toMaster(Pstream::masterNo(), pBufs); diff --git a/src/functionObjects/utilities/syncObjects/syncObjects.C b/src/functionObjects/utilities/syncObjects/syncObjects.C index cd5b2c2a64207afeae1cffb6bd6e756395b89f86..d0735699ddbec9f13137bdc586022a3f9f8ee944 100644 --- a/src/functionObjects/utilities/syncObjects/syncObjects.C +++ b/src/functionObjects/utilities/syncObjects/syncObjects.C @@ -87,11 +87,7 @@ void Foam::functionObjects::syncObjects::sync() // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ // Note provision of explicit all-world communicator - PstreamBuffers pBufs - ( - UPstream::commGlobal(), - UPstream::commsTypes::nonBlocking - ); + PstreamBuffers pBufs(UPstream::commGlobal()); for (const int proci : pBufs.allProcs()) diff --git a/src/lagrangian/basic/Cloud/Cloud.C b/src/lagrangian/basic/Cloud/Cloud.C index eb15d60699e479a38cfd59d6d636189b95df5d3a..2580c082d01f474500ea10d234b1848a7cdafa7e 100644 --- a/src/lagrangian/basic/Cloud/Cloud.C +++ b/src/lagrangian/basic/Cloud/Cloud.C @@ -182,7 +182,7 @@ void Foam::Cloud<ParticleType>::move // Allocate transfer buffers, // automatic clearStorage when UIPstream closes is disabled. - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; pBufs.allowClearRecv(false); // Cache of opened UOPstream wrappers diff --git a/src/lagrangian/basic/InteractionLists/InteractionLists.H b/src/lagrangian/basic/InteractionLists/InteractionLists.H index b71f222d36eaa01832070df0ac71d430b9e3c7d7..a575b9d5b3cedf9b0b261c48d03c627e39cffdfa 100644 --- a/src/lagrangian/basic/InteractionLists/InteractionLists.H +++ b/src/lagrangian/basic/InteractionLists/InteractionLists.H @@ -39,7 +39,7 @@ Description Simultaneous communication and computation is possible using: \verbatim - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; label startOfRequests = Pstream::nRequests(); il_.sendReferredData(cellOccupancy_, pBufs); // Do other things @@ -231,8 +231,7 @@ public: // Member Functions - //- Prepare and send referred particles and wall data, - // nonBlocking communication + //- Prepare and send referred particles and wall data (nonBlocking) void sendReferredData ( const List<DynamicList<ParticleType*>>& cellOccupancy, diff --git a/src/lagrangian/intermediate/submodels/Kinematic/CollisionModel/PairCollision/PairCollision.C b/src/lagrangian/intermediate/submodels/Kinematic/CollisionModel/PairCollision/PairCollision.C index e66c5a73a35a51f724906d665c42fc09153866fc..2dbed1a87b9dabf5f1bec28a23393a7f11f7df5f 100644 --- a/src/lagrangian/intermediate/submodels/Kinematic/CollisionModel/PairCollision/PairCollision.C +++ b/src/lagrangian/intermediate/submodels/Kinematic/CollisionModel/PairCollision/PairCollision.C @@ -58,7 +58,7 @@ void Foam::PairCollision<CloudType>::preInteraction() template<class CloudType> void Foam::PairCollision<CloudType>::parcelInteraction() { - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; label startOfRequests = Pstream::nRequests(); diff --git a/src/lagrangian/intermediate/submodels/Kinematic/PatchInteractionModel/RecycleInteraction/RecycleInteraction.C b/src/lagrangian/intermediate/submodels/Kinematic/PatchInteractionModel/RecycleInteraction/RecycleInteraction.C index 18d415733f2356047fb3ee44a8468d436e1ef573..78501a00a22a731c7101135fe8e9c966d37166e6 100644 --- a/src/lagrangian/intermediate/submodels/Kinematic/PatchInteractionModel/RecycleInteraction/RecycleInteraction.C +++ b/src/lagrangian/intermediate/submodels/Kinematic/PatchInteractionModel/RecycleInteraction/RecycleInteraction.C @@ -208,7 +208,7 @@ void Foam::RecycleInteraction<CloudType>::postEvolve() // See comments in Cloud::move() about transfer particles handling // Allocate transfer buffers - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Cache of opened UOPstream wrappers PtrList<UOPstream> UOPstreamPtrs(Pstream::nProcs()); diff --git a/src/lagrangian/molecularDynamics/molecule/moleculeCloud/moleculeCloud.C b/src/lagrangian/molecularDynamics/molecule/moleculeCloud/moleculeCloud.C index 9052b14a65f63e247a1400b46b3b36072bc39b5b..3c8670824a09b26ddcb34f371d4162e00cedb960 100644 --- a/src/lagrangian/molecularDynamics/molecule/moleculeCloud/moleculeCloud.C +++ b/src/lagrangian/molecularDynamics/molecule/moleculeCloud/moleculeCloud.C @@ -131,7 +131,7 @@ void Foam::moleculeCloud::buildCellOccupancy() void Foam::moleculeCloud::calculatePairForce() { - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Start sending referred data label startOfRequests = Pstream::nRequests(); @@ -356,7 +356,7 @@ void Foam::moleculeCloud::removeHighEnergyOverlaps() buildCellOccupancy(); - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Start sending referred data label startOfRequests = Pstream::nRequests(); diff --git a/src/meshTools/AMIInterpolation/AMIInterpolation/advancingFrontAMI/advancingFrontAMIParallelOps.C b/src/meshTools/AMIInterpolation/AMIInterpolation/advancingFrontAMI/advancingFrontAMIParallelOps.C index 2df540432b28bd4f07bb8719771e253a45497e99..7bfa4688d6bfd6e22721329c5a9ae207b4a2b091 100644 --- a/src/meshTools/AMIInterpolation/AMIInterpolation/advancingFrontAMI/advancingFrontAMIParallelOps.C +++ b/src/meshTools/AMIInterpolation/AMIInterpolation/advancingFrontAMI/advancingFrontAMIParallelOps.C @@ -78,12 +78,7 @@ void Foam::advancingFrontAMI::distributePatches points.setSize(Pstream::nProcs(comm_)); faceIDs.setSize(Pstream::nProcs(comm_)); - PstreamBuffers pBufs - ( - Pstream::commsTypes::nonBlocking, - UPstream::msgType(), - comm_ - ); + PstreamBuffers pBufs(comm_); for (const int domain : Pstream::allProcs(comm_)) { diff --git a/src/meshTools/polyTopoChange/polyTopoChange.C b/src/meshTools/polyTopoChange/polyTopoChange.C index 88b6e0359ef8d5f45bb59676cc8d9ade1f4d4106..149da72b5fef496f8cbcd22c907b1790fa9b2d65 100644 --- a/src/meshTools/polyTopoChange/polyTopoChange.C +++ b/src/meshTools/polyTopoChange/polyTopoChange.C @@ -2026,7 +2026,7 @@ void Foam::polyTopoChange::reorderCoupledFaces // Rotation on new faces. labelList rotation(faces_.size(), Zero); - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Send ordering forAll(patchMap, patchi) diff --git a/src/meshTools/processorLOD/box/box.C b/src/meshTools/processorLOD/box/box.C index dd6deffc320c5871718b0ef6ffd4d7b3603c773e..26faa28e680f82e1fae7f4c72ee9fab1d6950cc0 100644 --- a/src/meshTools/processorLOD/box/box.C +++ b/src/meshTools/processorLOD/box/box.C @@ -102,7 +102,7 @@ void Foam::processorLODs::box::setRefineFlags labelList& nElems ) const { - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Identify src boxes that can be refined and send to all remote procs for (const int proci : Pstream::allProcs()) @@ -315,7 +315,7 @@ bool Foam::processorLODs::box::doRefineBoxes List<DynamicList<treeBoundBox>>& fixedBoxes ) { - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Send refine info back for list of evolving src boxes forAll(refineFlags, proci) diff --git a/src/overset/cellCellStencil/inverseDistance/inverseDistanceCellCellStencil.C b/src/overset/cellCellStencil/inverseDistance/inverseDistanceCellCellStencil.C index b0e999c0f88855ab14d359dfafa3d54b7533974a..f606f5bdd440b046afaa3ea44e462809e7e0db25 100644 --- a/src/overset/cellCellStencil/inverseDistance/inverseDistanceCellCellStencil.C +++ b/src/overset/cellCellStencil/inverseDistance/inverseDistanceCellCellStencil.C @@ -1970,7 +1970,7 @@ bool Foam::cellCellStencils::inverseDistance::update() const globalIndex globalCells(mesh_.nCells()); - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Mark holes (in allCellTypes) for (label srcI = 0; srcI < meshParts.size()-1; srcI++) diff --git a/src/overset/cellCellStencil/trackingInverseDistance/trackingInverseDistanceCellCellStencil.C b/src/overset/cellCellStencil/trackingInverseDistance/trackingInverseDistanceCellCellStencil.C index 5aa941503500251a822e31d28ab51fae31295877..73d421c58f5d03578a4e1f5578b85adf1f65ae44 100644 --- a/src/overset/cellCellStencil/trackingInverseDistance/trackingInverseDistanceCellCellStencil.C +++ b/src/overset/cellCellStencil/trackingInverseDistance/trackingInverseDistanceCellCellStencil.C @@ -765,7 +765,7 @@ bool Foam::cellCellStencils::trackingInverseDistance::update() const globalIndex globalCells(mesh_.nCells()); - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; DebugInfo<< FUNCTION_NAME << " : Allocated donor-cell structures" << endl; diff --git a/src/parallel/distributed/distributedTriSurfaceMesh/distributedTriSurfaceMesh.C b/src/parallel/distributed/distributedTriSurfaceMesh/distributedTriSurfaceMesh.C index 647b5ce11261e038fa3cdb4a2214c181e883a878..8c32aface9d13a59d0e1510d601f641950f01d5e 100644 --- a/src/parallel/distributed/distributedTriSurfaceMesh/distributedTriSurfaceMesh.C +++ b/src/parallel/distributed/distributedTriSurfaceMesh/distributedTriSurfaceMesh.C @@ -4784,7 +4784,7 @@ void Foam::distributedTriSurfaceMesh::distribute // Send all // ~~~~~~~~ - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; forAll(faceSendMap, proci) { diff --git a/src/parallel/reconstruct/faReconstruct/faMeshReconstructor.C b/src/parallel/reconstruct/faReconstruct/faMeshReconstructor.C index 722a63e2ba57c4e4a1acd2e3b0a01da68cb3b9ea..71b7584fb4ea33384785dee018ad3c2c164c12ae 100644 --- a/src/parallel/reconstruct/faReconstruct/faMeshReconstructor.C +++ b/src/parallel/reconstruct/faReconstruct/faMeshReconstructor.C @@ -110,7 +110,7 @@ void Foam::faMeshReconstructor::calcAddressing } } - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; if (Pstream::master()) { diff --git a/src/sampling/meshToMesh/meshToMeshParallelOps.C b/src/sampling/meshToMesh/meshToMeshParallelOps.C index f1a9d756b0cb971180194c2bb58c43c81847f1ec..308409db988152e9b6422a4373fedc5db70f5314 100644 --- a/src/sampling/meshToMesh/meshToMeshParallelOps.C +++ b/src/sampling/meshToMesh/meshToMeshParallelOps.C @@ -274,7 +274,7 @@ void Foam::meshToMesh::distributeCells procLocalFaceIDs.setSize(Pstream::nProcs());; - PstreamBuffers pBufs(Pstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; for (const int domain : Pstream::allProcs()) { diff --git a/src/transportModels/geometricVoF/advectionSchemes/isoAdvection/isoAdvection.C b/src/transportModels/geometricVoF/advectionSchemes/isoAdvection/isoAdvection.C index 1b54ff2ca1a3eda72675618ba98733a1abd2c2db..a2296c3c6bf3833de1d56e73ddd3f318a9b698c4 100644 --- a/src/transportModels/geometricVoF/advectionSchemes/isoAdvection/isoAdvection.C +++ b/src/transportModels/geometricVoF/advectionSchemes/isoAdvection/isoAdvection.C @@ -497,7 +497,7 @@ Foam::DynamicList<Foam::label> Foam::isoAdvection::syncProcPatches if (Pstream::parRun()) { DynamicList<label> neighProcs; - PstreamBuffers pBufs(UPstream::commsTypes::nonBlocking); + PstreamBuffers pBufs; // Send for (const label patchi : procPatchLabels_)