xfygogo/phasicFlow
1
0
Fork 0
mirror of https://github.com/PhasicFlow/phasicFlow.git synced 2025-06-12 16:26:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Code recovery MPI part

Browse Source
This commit is contained in:
HRN
2024-10-18 23:10:42 +03:30
parent f317cef0ef
commit ba8f307c56
4 changed files with 10 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/Integration/AdamsBashforth2/processorAB2BoundaryIntegration.cpp
View File

@ -50,16 +50,16 @@ bool pFlow::processorAB2BoundaryIntegration::correctPStruct(real dt, const realx
#ifndef BoundaryModel1 #ifndef BoundaryModel1
if(this->isBoundaryMaster()) if(this->isBoundaryMaster())
{ {
const uint32 thisIndex = thisBoundaryIndex(); const uint32 thisIndex = thisBoundaryIndex();
const auto& AB2 = static_cast<const AdamsBashforth2&>(Integration()); const auto& AB2 = static_cast<const AdamsBashforth2&>(Integration());
const auto& dy1View = AB2.BoundaryField(thisIndex).neighborProcField().deviceView(); const auto& dy1View = AB2.BoundaryField(thisIndex).neighborProcField().deviceView();
const auto& velView = vel.BoundaryField(thisIndex).neighborProcField().deviceView(); const auto& velView = vel.BoundaryField(thisIndex).neighborProcField().deviceView();
const auto& xposView = boundary().neighborProcPoints().deviceView(); const auto& xposView = boundary().neighborProcPoints().deviceView();
const rangeU32 aRange(0u, dy1View.size()); const rangeU32 aRange(0u, dy1View.size());
return AB2Kernels::intAllActive( return AB2Kernels::intAllActive(
"AB2Integration::correctPStruct."+this->boundaryName(), "AB2Integration::correctPStruct."+this->boundaryName(),
dt, dt,
aRange, aRange,
xposView, xposView,
velView, velView,
dy1View dy1View

12
src/phasicFlow/MPIParallelization/domain/MPISimulationDomain.cpp
View File

@ -36,16 +36,9 @@ pFlow::MPI::MPISimulationDomain::MPISimulationDomain(systemControl& control)
bool pFlow::MPI::MPISimulationDomain::createBoundaryDicts() bool pFlow::MPI::MPISimulationDomain::createBoundaryDicts()
{ {
if(!prepareBoundaryDicts()) dictionary& boundaries = this->subDict("boundaries");
{
return false;
}
auto& boundaries = this->subDict("boundaries");
auto& thisBoundaries = this->subDict(thisBoundariesDictName());
dictionary& thisBoundaries = this->subDict(thisBoundariesDictName());
auto neighbors = findPlaneNeighbors(); auto neighbors = findPlaneNeighbors();
@ -134,7 +127,6 @@ bool pFlow::MPI::MPISimulationDomain::setThisDomain()
return false; return false;
} }
return true; return true;
} }

5
src/phasicFlow/MPIParallelization/pointStructure/boundaries/boundaryProcessor.cpp
View File

@ -291,7 +291,7 @@ bool pFlow::MPI::boundaryProcessor::transferData(
callAgain = false; callAgain = false;
return false; return false;
} }
callAgain = true;
return true; return true;
} }
else if(step == 3) // to recieve data else if(step == 3) // to recieve data
@ -367,10 +367,7 @@ bool pFlow::MPI::boundaryProcessor::transferData(
callAgain = false; callAgain = false;
return true; return true;
} }
callAgain = false;
return true; return true;
} }
bool bool

1
src/phasicFlow/MPIParallelization/pointStructure/boundaries/boundaryProcessor.hpp
View File

@ -22,6 +22,7 @@ Licence:
#define __boundaryProcessor_hpp__ #define __boundaryProcessor_hpp__
#include "boundaryBase.hpp" #include "boundaryBase.hpp"
#include "timeInfo.hpp"
#include "mpiTypes.hpp" #include "mpiTypes.hpp"
#include "dataSender.hpp" #include "dataSender.hpp"
#include "dataReciever.hpp" #include "dataReciever.hpp"