20#ifndef PARALLEL_WBP_CALCULATION_HPP
21#define PARALLEL_WBP_CALCULATION_HPP
23#include <opm/simulators/wells/ParallelPAvgDynamicSourceData.hpp>
25#include <opm/simulators/utils/ParallelCommunication.hpp>
27#include <opm/simulators/wells/PerforationData.hpp>
29#include <opm/input/eclipse/Schedule/Well/PAvgCalculator.hpp>
30#include <opm/input/eclipse/Schedule/Well/PAvgCalculatorCollection.hpp>
39 class ParallelWellInfo;
70 const Parallel::Communication&
gridComm);
155 const double gravity,
156 const double refDepth);
166 const PAvgCalculator::Result&
184 explicit LocalConnSet(
const std::vector<int>&
localConnIdx);
194 int localIndex(
const std::size_t
connIdx)
const;
205 std::vector<int> localConnIdx_{};
216 operator const ParallelPAvgDynamicSourceData&()
const
218 return *this->srcData_;
224 explicit SourceData(
const Parallel::Communication& comm);
233 SourceData& localIndex(GlobalToLocal localIdx);
241 SourceData& evaluator(Evaluator eval);
251 SourceData& evaluatorFactory(EvaluatorFactory evalFactory);
262 void buildStructure(
const std::vector<std::size_t>& sourceLocations);
273 void collectDynamicValues();
278 const Parallel::Communication& comm()
const
280 return this->comm_.get();
293 getLocalIndex(
const std::vector<std::size_t>& globalIndex)
const;
297 using DataPtr = std::unique_ptr<ParallelPAvgDynamicSourceData>;
300 std::reference_wrapper<const Parallel::Communication> comm_;
303 GlobalToLocal localIdx_{};
312 EvaluatorFactory evalFactory_{};
319 using WellID = std::vector<SourceData>::size_type;
322 std::reference_wrapper<const GridDims> cellIndexMap_;
325 SourceData reservoirSrc_;
329 PAvgCalculatorCollection calculators_{};
332 std::vector<SourceData> wellConnSrc_{};
335 std::vector<LocalConnSet> localConnSet_{};
339 void pruneInactiveWBPCells();
342 void pruneInactiveWBPCellsSerial();
345 void pruneInactiveWBPCellsParallel();
348 void defineReservoirCommunication();
354 void defineWellCommunication(
const std::size_t well);
363 PAvgCalculator::Sources makeEvaluationSources(
const WellID well)
const;
Definition AquiferInterface.hpp:35
std::function< void(int, SourceDataSpan< double >)> Evaluator
Collect source term contributions from local, on-rank, cell.
Definition ParallelPAvgDynamicSourceData.hpp:52
std::function< int(const std::size_t)> GlobalToLocal
Translate globally unique, linearised Cartesian cell indices to local, on-rank, cell indices.
Definition ParallelPAvgDynamicSourceData.hpp:41
Parallel facility for managing the on-rank collection and global distribution of WBPn source values a...
Definition ParallelWBPCalculation.hpp:50
ParallelPAvgDynamicSourceData::Evaluator Evaluator
Callback for evaluating WBPn source terms on the current MPI rank.
Definition ParallelWBPCalculation.hpp:57
void defineCommunication()
Set up communication patterns for both cell and connection level source terms and partial/intermediat...
Definition ParallelWBPCalculation.cpp:208
ParallelPAvgDynamicSourceData::GlobalToLocal GlobalToLocal
Callback for inferring the source locations which are active on the current MPI rank.
Definition ParallelWBPCalculation.hpp:54
ParallelWBPCalculation & localCellIndex(GlobalToLocal localCellIdx)
Assign translation function for inferring the on-rank IDs of the known source locations.
Definition ParallelWBPCalculation.cpp:160
void inferBlockAveragePressures(const std::size_t calcIndex, const PAvg &controls, const double gravity, const double refDepth)
Compute WBPn report values for a single well.
Definition ParallelWBPCalculation.cpp:233
void collectDynamicValues()
Collect all on-rank source term value and distribute those on-rank values to all other MPI ranks.
Definition ParallelWBPCalculation.cpp:222
std::size_t createCalculator(const Well &well, const ParallelWellInfo ¶llelWellInfo, const std::vector< int > &localConnIdx, EvaluatorFactory makeWellSourceEvaluator)
Create, or reassign, a WBPn calculation object for a particular well.
Definition ParallelWBPCalculation.cpp:175
ParallelWBPCalculation & evalCellSource(Evaluator evalCellSrc)
Assign evaluation function for computing the on-rank, cell level WBPn source terms.
Definition ParallelWBPCalculation.cpp:167
std::function< Evaluator()> EvaluatorFactory
Callback for constructing a source term evaluation function on the current MPI rank.
Definition ParallelWBPCalculation.hpp:62
const PAvgCalculator::Result & averagePressures(const std::size_t calcIndex) const
Retrieve results from most recent WBPn value calculation for specified well.
Definition ParallelWBPCalculation.cpp:244
Class encapsulating some information about parallel wells.
Definition ParallelWellInfo.hpp:184
This file contains a set of helper functions used by VFPProd / VFPInj.
Definition BlackoilPhases.hpp:27