OilfieldToolsNet/opm-simulators
4
0
Fork 0
mirror of https://github.com/OPM/opm-simulators.git synced 2025-02-25 18:55:30 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2919 from blattms/do-not-filter-distributed

Browse Source 
Do not filter connections on the schedule of the loadbalanced grid.
This commit is contained in:
Atgeirr Flø Rasmussen 2020-11-26 16:43:09 +01:00 committed by GitHub
commit 5617a2ef5c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 28 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
ebos/eclcpgridvanguard.hh
View File

@ -35,6 +35,7 @@
#include <opm/grid/cpgrid/GridHelpers.hpp>
#include <opm/simulators/utils/ParallelEclipseState.hpp>
#include <opm/simulators/utils/PropsCentroidsDataHandle.hpp>
#include <opm/simulators/utils/ParallelSerialization.hpp>
#include <dune/grid/common/mcmgmapper.hh>
@ -234,15 +235,10 @@ public:
cartesianIndexMapper_.reset();
if ( ! equilGrid_ )
{
// for processes that do not hold the global grid we filter here using the local grid.
// If we would filter in filterConnection_ our partition would be empty and the connections of all
// wells would be removed.
ActiveGridCells activeCells(grid().logicalCartesianSize(),
grid().globalCell().data(), grid().size(0));
this->schedule().filterConnections(activeCells);
}
// Calling Schedule::filterConnections would remove any perforated
// cells that exist only on other ranks even in the case of distributed wells
// But we need all connections to figure out the first cell of a well (e.g. for
// pressure). Hence this is now skipped. Rank 0 had everything even before.
}
#endif
@ -351,6 +347,21 @@ protected:
equilGrid().size(0));
this->schedule().filterConnections(activeCells);
}
#if HAVE_MPI
try
{
// Broadcast another time to remove inactive peforations on
// slave processors.
Opm::eclScheduleBroadcast(this->schedule());
}
catch(const std::exception& broadcast_error)
{
OpmLog::error(fmt::format("Distributing properties to all processes failed\n"
"Internal error message: {}", broadcast_error.what()));
MPI_Finalize();
std::exit(EXIT_FAILURE);
}
#endif
}
std::unique_ptr<Grid> grid_;

5
opm/simulators/utils/ParallelSerialization.cpp
View File

@ -49,4 +49,9 @@ void eclStateBroadcast(EclipseState& eclState, Schedule& schedule,
ser.broadcast(summaryConfig);
}
void eclScheduleBroadcast(Schedule& schedule)
{
Opm::EclMpiSerializer ser(Dune::MPIHelper::getCollectiveCommunication());
ser.broadcast(schedule);
}
}

3
opm/simulators/utils/ParallelSerialization.hpp
View File

@ -33,6 +33,9 @@ class SummaryConfig;
void eclStateBroadcast(EclipseState& eclState, Schedule& schedule,
SummaryConfig& summaryConfig);
/// \brief Broadcasts an schedule from root node in parallel runs.
void eclScheduleBroadcast(Schedule& schedule);
} // end namespace Opm
#endif // PARALLEL_SERIALIZATION_HPP