From 900d572a6ead2c27b10bc4d69b4fbb2c6f264fc5 Mon Sep 17 00:00:00 2001 From: mattijs Date: Thu, 2 May 2013 15:53:07 +0100 Subject: [PATCH] ENH: Pstream: shortcut on single processor --- .../db/IOstreams/Pstreams/combineGatherScatter.C | 12 ++++++------ src/OpenFOAM/db/IOstreams/Pstreams/exchange.C | 2 +- src/OpenFOAM/db/IOstreams/Pstreams/gatherScatter.C | 4 ++-- .../db/IOstreams/Pstreams/gatherScatterList.C | 4 ++-- 4 files changed, 11 insertions(+), 11 deletions(-) diff --git a/src/OpenFOAM/db/IOstreams/Pstreams/combineGatherScatter.C b/src/OpenFOAM/db/IOstreams/Pstreams/combineGatherScatter.C index 72dc870ff0..48036e7c52 100644 --- a/src/OpenFOAM/db/IOstreams/Pstreams/combineGatherScatter.C +++ b/src/OpenFOAM/db/IOstreams/Pstreams/combineGatherScatter.C @@ -55,7 +55,7 @@ void Pstream::combineGather const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const commsStruct& myComm = comms[UPstream::myProcNo(comm)]; @@ -182,7 +182,7 @@ void Pstream::combineScatter const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const UPstream::commsStruct& myComm = comms[UPstream::myProcNo(comm)]; @@ -287,7 +287,7 @@ void Pstream::listCombineGather const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const commsStruct& myComm = comms[UPstream::myProcNo(comm)]; @@ -421,7 +421,7 @@ void Pstream::listCombineScatter const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const UPstream::commsStruct& myComm = comms[UPstream::myProcNo(comm)]; @@ -540,7 +540,7 @@ void Pstream::mapCombineGather const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const commsStruct& myComm = comms[UPstream::myProcNo(comm)]; @@ -640,7 +640,7 @@ void Pstream::mapCombineScatter const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const UPstream::commsStruct& myComm = comms[UPstream::myProcNo(comm)]; diff --git a/src/OpenFOAM/db/IOstreams/Pstreams/exchange.C b/src/OpenFOAM/db/IOstreams/Pstreams/exchange.C index 9116b567fc..62cce15f7d 100644 --- a/src/OpenFOAM/db/IOstreams/Pstreams/exchange.C +++ b/src/OpenFOAM/db/IOstreams/Pstreams/exchange.C @@ -81,7 +81,7 @@ void Pstream::exchange // Send sizes across. Note: blocks. combineReduce(sizes, UPstream::listEq(), tag, comm); - if (Pstream::parRun()) + if (UPstream::nProcs(comm) > 1) { label startOfRequests = Pstream::nRequests(); diff --git a/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatter.C b/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatter.C index a606a6a5f7..477dbe35f5 100644 --- a/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatter.C +++ b/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatter.C @@ -52,7 +52,7 @@ void Pstream::gather const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const commsStruct& myComm = comms[UPstream::myProcNo(comm)]; @@ -151,7 +151,7 @@ void Pstream::scatter const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { // Get my communication order const commsStruct& myComm = comms[UPstream::myProcNo(comm)]; diff --git a/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatterList.C b/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatterList.C index d518027175..3b3133b495 100644 --- a/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatterList.C +++ b/src/OpenFOAM/db/IOstreams/Pstreams/gatherScatterList.C @@ -53,7 +53,7 @@ void Pstream::gatherList const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { if (Values.size() != UPstream::nProcs(comm)) { @@ -212,7 +212,7 @@ void Pstream::scatterList const label comm ) { - if (UPstream::parRun()) + if (UPstream::nProcs(comm) > 1) { if (Values.size() != UPstream::nProcs(comm)) {