BlackoilWellModel_impl.hpp

Go to the documentation of this file.

/*
  Copyright 2016 - 2019 SINTEF Digital, Mathematics & Cybernetics.
  Copyright 2016 - 2018 Equinor ASA.
  Copyright 2017 Dr. Blatt - HPC-Simulation-Software & Services
  Copyright 2016 - 2018 Norce AS
 
  This file is part of the Open Porous Media project (OPM).
 
  OPM is free software: you can redistribute it and/or modify
  it under the terms of the GNU General Public License as published by
  the Free Software Foundation, either version 3 of the License, or
  (at your option) any later version.
 
  OPM is distributed in the hope that it will be useful,
  but WITHOUT ANY WARRANTY; without even the implied warranty of
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  GNU General Public License for more details.
 
  You should have received a copy of the GNU General Public License
  along with OPM.  If not, see <http://www.gnu.org/licenses/>.
*/
 
#ifndef OPM_BLACKOILWELLMODEL_IMPL_HEADER_INCLUDED
#define OPM_BLACKOILWELLMODEL_IMPL_HEADER_INCLUDED
 
// Improve IDE experience
#ifndef OPM_BLACKOILWELLMODEL_HEADER_INCLUDED
#include <config.h>
#include <opm/simulators/wells/BlackoilWellModel.hpp>
#endif
 
#include <opm/grid/utility/cartesianToCompressed.hpp>
 
#include <opm/input/eclipse/Schedule/Network/Balance.hpp>
#include <opm/input/eclipse/Schedule/Network/ExtNetwork.hpp>
#include <opm/input/eclipse/Schedule/Well/PAvgDynamicSourceData.hpp>
#include <opm/input/eclipse/Schedule/Well/WellMatcher.hpp>
#include <opm/input/eclipse/Schedule/Well/WellTestConfig.hpp>
#include <opm/input/eclipse/Schedule/Well/WellEconProductionLimits.hpp>
 
#include <opm/input/eclipse/Units/UnitSystem.hpp>
 
#include <opm/simulators/wells/BlackoilWellModelConstraints.hpp>
#include <opm/simulators/wells/BlackoilWellModelNldd.hpp>
#include <opm/simulators/wells/GuideRateHandler.hpp>
#include <opm/simulators/wells/ParallelPAvgDynamicSourceData.hpp>
#include <opm/simulators/wells/ParallelWBPCalculation.hpp>
#include <opm/simulators/wells/VFPProperties.hpp>
#include <opm/simulators/wells/GroupStateHelper.hpp>
 
#include <opm/simulators/utils/DeferredLoggingErrorHelpers.hpp>
#if HAVE_MPI
#include <opm/simulators/utils/MPIPacker.hpp>
#endif
 
#if COMPILE_GPU_BRIDGE
#include <opm/simulators/linalg/gpubridge/WellContributions.hpp>
#endif
 
#include <algorithm>
#include <cassert>
#include <cstddef>
#include <iomanip>
#include <optional>
#include <utility>
 
#include <fmt/format.h>
 
namespace Opm {
    template<typename TypeTag>
    BlackoilWellModel<TypeTag>::
    BlackoilWellModel(Simulator& simulator, const NewtonIterationContext& iter_ctx)
        : WellConnectionModule(*this, simulator.gridView().comm())
        , BlackoilWellModelGeneric<Scalar, IndexTraits>(simulator.vanguard().schedule(),
                                                        gaslift_,
                                                        network_,
                                                        simulator.vanguard().summaryState(),
                                                        simulator.vanguard().eclState(),
                                                        FluidSystem::phaseUsage(),
                                                        simulator.gridView().comm(),
                                                        iter_ctx)
        , simulator_(simulator)
        , guide_rate_handler_{
            *this,
            simulator.vanguard().schedule(),
            simulator.vanguard().summaryState(),
            simulator.vanguard().grid().comm()
        }
        , gaslift_(this->terminal_output_)
        , network_(*this)
#ifdef RESERVOIR_COUPLING_ENABLED
        , rescoupHelper_(*this)
#endif
    {
        local_num_cells_ = simulator_.gridView().size(0);
 
        // Number of cells the global grid view
        global_num_cells_ = simulator_.vanguard().globalNumCells();
 
        {
            auto& parallel_wells = simulator.vanguard().parallelWells();
 
            this->parallel_well_info_.reserve(parallel_wells.size());
            for( const auto& name_bool : parallel_wells) {
                this->parallel_well_info_.push_back
                    (std::make_unique<ParallelWellInfo<Scalar>>
                     (name_bool, grid().comm()));
            }
        }
 
        this->alternative_well_rate_init_ =
            Parameters::Get<Parameters::AlternativeWellRateInit>();
 
        using SourceDataSpan =
            typename PAvgDynamicSourceData<Scalar>::template SourceDataSpan<Scalar>;
 
        this->wbp_.initializeSources(
            [this](const std::size_t globalIndex)
            { return this->compressedIndexForInterior(globalIndex); },
            [this](const int localCell, SourceDataSpan sourceTerms)
            {
                using Item = typename SourceDataSpan::Item;
 
                const auto* intQuants = this->simulator_.model()
                    .cachedIntensiveQuantities(localCell, /*timeIndex = */0);
                const auto& fs = intQuants->fluidState();
 
                sourceTerms
                    .set(Item::PoreVol, intQuants->porosity().value() *
                         this->simulator_.model().dofTotalVolume(localCell))
                    .set(Item::Depth, this->depth_[localCell]);
 
                constexpr auto io = FluidSystem::oilPhaseIdx;
                constexpr auto ig = FluidSystem::gasPhaseIdx;
                constexpr auto iw = FluidSystem::waterPhaseIdx;
 
                // Ideally, these would be 'constexpr'.
                const auto haveOil = FluidSystem::phaseIsActive(io);
                const auto haveGas = FluidSystem::phaseIsActive(ig);
                const auto haveWat = FluidSystem::phaseIsActive(iw);
 
                auto weightedPhaseDensity = [&fs](const auto ip)
                {
                    return fs.saturation(ip).value() * fs.density(ip).value();
                };
 
                if (haveOil)      { sourceTerms.set(Item::Pressure, fs.pressure(io).value()); }
                else if (haveGas) { sourceTerms.set(Item::Pressure, fs.pressure(ig).value()); }
                else              { sourceTerms.set(Item::Pressure, fs.pressure(iw).value()); }
 
                // Strictly speaking, assumes SUM(s[p]) == 1.
                auto rho = 0.0;
                if (haveOil) { rho += weightedPhaseDensity(io); }
                if (haveGas) { rho += weightedPhaseDensity(ig); }
                if (haveWat) { rho += weightedPhaseDensity(iw); }
 
                sourceTerms.set(Item::MixtureDensity, rho);
            }
        );
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    init()
    {
        extractLegacyCellPvtRegionIndex_();
        extractLegacyDepth_();
 
        gravity_ = simulator_.problem().gravity()[2];
 
        this->initial_step_ = true;
 
        // add the eWoms auxiliary module for the wells to the list
        simulator_.model().addAuxiliaryModule(this);
 
        is_cell_perforated_.resize(local_num_cells_, false);
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    initWellContainer(const int reportStepIdx)
    {
        const uint64_t effective_events_mask = ScheduleEvents::WELL_STATUS_CHANGE
                        + ScheduleEvents::NEW_WELL;
        const auto& events = this->schedule()[reportStepIdx].wellgroup_events();
        for (auto& wellPtr : this->well_container_) {
            const bool well_opened_this_step = this->report_step_starts_ &&
                                               events.hasEvent(wellPtr->name(),
                                                               effective_events_mask);
            wellPtr->init(this->depth_, this->gravity_,
                          this->B_avg_, well_opened_this_step);
        }
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    beginReportStep(const int timeStepIdx)
    {
        this->groupStateHelper().setReportStep(timeStepIdx);
        this->report_step_starts_ = true;
        this->report_step_start_events_ = this->schedule()[timeStepIdx].wellgroup_events();
 
        this->rateConverter_ = std::make_unique<RateConverterType>
            (std::vector<int>(this->local_num_cells_, 0));
 
        {
            const bool initializeWellState = !this->deserialized_state_pending_;
            const auto enableWellPIScaling = true;
            this->initializeLocalWellStructure(timeStepIdx,
                                               enableWellPIScaling,
                                               initializeWellState);
            this->deserialized_state_pending_ = false;
        }
 
        this->initializeGroupStructure(timeStepIdx);
 
        const auto& comm = this->simulator_.vanguard().grid().comm();
 
        OPM_BEGIN_PARALLEL_TRY_CATCH()
        {
            // Create facility for calculating reservoir voidage volumes for
            // purpose of RESV controls.
            this->rateConverter_->template defineState<ElementContext>(this->simulator_);
 
            // Update VFP properties.
            {
                const auto& sched_state = this->schedule()[timeStepIdx];
 
                this->vfp_properties_ = std::make_unique<VFPProperties<Scalar, IndexTraits>>
                    (sched_state.vfpinj(), sched_state.vfpprod(), this->wellState());
            }
        }
        OPM_END_PARALLEL_TRY_CATCH("beginReportStep() failed: ", comm)
 
        // Store the current well and group states in order to recover in
        // the case of failed iterations
        this->commitWGState();
 
        this->wellStructureChangedDynamically_ = false;
    }
 
 
 
 
 
    template <typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    initializeLocalWellStructure(const int  reportStepIdx,
                                 const bool enableWellPIScaling,
                                 const bool initializeWellState)
    {
        auto logger_guard = this->groupStateHelper().pushLogger();
        auto& local_deferredLogger = this->groupStateHelper().deferredLogger();
 
        const auto& comm = this->simulator_.vanguard().grid().comm();
 
        // Wells drilled by an action are not part of the well set the
        // parallel well bookkeeping was built from.  Register them before
        // anything looks them up.  Collective, hence outside the try/catch.
        this->registerNewParallelWells(reportStepIdx);
 
        // Wells_ecl_ holds this rank's wells, both open and stopped/shut.
        this->wells_ecl_ = this->getLocalWells(reportStepIdx);
        this->local_parallel_well_info_ =
            this->createLocalParallelWellInfo(this->wells_ecl_);
 
        // At least initializeWellState() might be throw an exception in
        // UniformTabulated2DFunction.  Playing it safe by extending the
        // scope a bit.
        OPM_BEGIN_PARALLEL_TRY_CATCH()
        {
            if (initializeWellState) {
                this->initializeWellPerfData();
                this->initializeWellState(reportStepIdx);
            }
            this->wbp_.initializeWBPCalculationService();
 
            if (initializeWellState && this->param_.use_multisegment_well_ && this->anyMSWellOpenLocal()) {
                this->wellState().initWellStateMSWell(this->wells_ecl_, &this->prevWellState(), has_energy_);
            }
 
            this->initializeWellProdIndCalculators();
 
            if (enableWellPIScaling && this->schedule()[reportStepIdx].events()
                .hasEvent(ScheduleEvents::Events::WELL_PRODUCTIVITY_INDEX))
            {
                this->runWellPIScaling(reportStepIdx, local_deferredLogger);
            }
        }
        OPM_END_PARALLEL_TRY_CATCH_LOG(local_deferredLogger,
                                       "Failed to initialize local well structure: ",
                                       this->terminal_output_, comm)
    }
 
 
 
 
 
    template <typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    initializeGroupStructure(const int reportStepIdx)
    {
        const auto& comm = this->simulator_.vanguard().grid().comm();
 
        OPM_BEGIN_PARALLEL_TRY_CATCH()
        {
            const auto& fieldGroup =
                this->schedule().getGroup("FIELD", reportStepIdx);
 
            this->groupStateHelper().setCmodeGroup(fieldGroup);
 
            // Define per region average pressure calculators for use by
            // pressure maintenance groups (GPMAINT keyword).
            if (this->schedule()[reportStepIdx].has_gpmaint()) {
                this->groupStateHelper().setRegionAveragePressureCalculator(
                    fieldGroup,
                    this->eclState_.fieldProps(),
                    this->regionalAveragePressureCalculator_
                );
            }
        }
        OPM_END_PARALLEL_TRY_CATCH("Failed to initialize group structure: ", comm)
    }
 
 
 
 
 
    // called at the beginning of a time step
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    beginTimeStep()
    {
        OPM_TIMEBLOCK(beginTimeStep);
 
        this->updateAverageFormationFactor();
 
        auto logger_guard = this->groupStateHelper().pushLogger();
        auto& local_deferredLogger = this->groupStateHelper().deferredLogger();
 
#ifdef RESERVOIR_COUPLING_ENABLED
        auto rescoup_logger_guard = this->rescoupHelper_.setupScopedLogger(local_deferredLogger);
#endif
 
        this->switched_prod_groups_.clear();
        this->switched_inj_groups_.clear();
 
        if (this->wellStructureChangedDynamically_) {
            // Something altered the well structure/topology.  Possibly
            // WELSPECS/COMPDAT and/or WELOPEN run from an ACTIONX block.
            // Reconstruct the local wells to account for the new well
            // structure.
            const auto reportStepIdx =
                this->simulator_.episodeIndex();
 
            // Disable WELPI scaling when well structure is updated in the
            // middle of a report step.
            const auto enableWellPIScaling = false;
 
            this->initializeLocalWellStructure(reportStepIdx, enableWellPIScaling, true);
            this->initializeGroupStructure(reportStepIdx);
 
            this->commitWGState();
 
            // Reset topology flag to signal that we've handled this
            // structure change.  That way we don't end up here in
            // subsequent calls to beginTimeStep() unless there's a new
            // dynamic change to the well structure during a report step.
            this->wellStructureChangedDynamically_ = false;
        }
 
        this->resetWGState();
        const int reportStepIdx = simulator_.episodeIndex();
 
        this->wellState().updateWellsDefaultALQ(this->schedule(), reportStepIdx, this->summaryState());
        this->wellState().gliftTimeStepInit();
 
        const double simulationTime = simulator_.time();
        OPM_BEGIN_PARALLEL_TRY_CATCH();
        {
            // test wells
            wellTesting(reportStepIdx, simulationTime, local_deferredLogger);
 
            // create the well container
            createWellContainer(reportStepIdx);
 
#ifdef RESERVOIR_COUPLING_ENABLED
            if (this->isReservoirCouplingMaster()) {
                if (this->reservoirCouplingMaster().isFirstSubstepOfSyncTimestep()) {
                    this->rescoupHelper_.receiveSlaveGroupData();
                }
            }
#endif
 
            // we need to update the group data after the well is created
            // to make sure we get the correct mapping.
            this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget*/ false);
 
            // Wells are active if they are active wells on at least one process.
            const Grid& grid = simulator_.vanguard().grid();
            this->wells_active_ = grid.comm().max(!this->well_container_.empty());
 
            // do the initialization for all the wells
            // TODO: to see whether we can postpone of the intialization of the well containers to
            // optimize the usage of the following several member variables
            this->initWellContainer(reportStepIdx);
 
            // update the updated cell flag
            std::fill(is_cell_perforated_.begin(), is_cell_perforated_.end(), false);
            for (auto& well : well_container_) {
                well->updatePerforatedCell(is_cell_perforated_);
            }
 
            // calculate the efficiency factors for each well
            this->calculateEfficiencyFactors(reportStepIdx);
 
            if constexpr (has_polymer_)
            {
                if (PolymerModule::hasPlyshlog() || getPropValue<TypeTag, Properties::EnablePolymerMW>() ) {
                    this->setRepRadiusPerfLength();
                }
            }
 
        }
 
        OPM_END_PARALLEL_TRY_CATCH_LOG(local_deferredLogger, "beginTimeStep() failed: ",
                                        this->terminal_output_, simulator_.vanguard().grid().comm());
 
        for (auto& well : well_container_) {
            well->setVFPProperties(this->vfp_properties_.get());
            well->setGuideRate(&this->guideRate_);
        }
 
        this->updateFiltrationModelsPreStep(local_deferredLogger);
 
        // Close completions due to economic reasons
        for (auto& well : well_container_) {
            well->closeCompletions(this->wellTestState());
        }
 
        // we need the inj_multiplier from the previous time step
        this->initInjMult();
 
        if (alternative_well_rate_init_) {
            // Update the well rates of well_state_, if only single-phase rates, to
            // have proper multi-phase rates proportional to rates at bhp zero.
            // This is done only for producers, as injectors will only have a single
            // nonzero phase anyway.
            for (const auto& well : well_container_) {
                if (well->isProducer() && !well->wellIsStopped()) {
                    well->initializeProducerWellState(simulator_, this->wellState(), local_deferredLogger);
                }
            }
        }
 
        for (const auto& well : well_container_) {
            if (well->isVFPActive(local_deferredLogger)){
                well->setPrevSurfaceRates(this->wellState(), this->prevWellState());
            }
        }
        try {
            this->updateWellPotentials(reportStepIdx,
                                       /*onlyAfterEvent*/true,
                                       simulator_.vanguard().summaryConfig(),
                                       local_deferredLogger);
        } catch ( std::runtime_error& e ) {
            const std::string msg = "A zero well potential is returned for output purposes. ";
            local_deferredLogger.warning("WELL_POTENTIAL_CALCULATION_FAILED", msg);
        }
        //update guide rates
        this->guide_rate_handler_.updateGuideRates(
            reportStepIdx, simulationTime, this->wellState(), this->groupState()
        );
        bool slave_needs_well_solution = false;
#ifdef RESERVOIR_COUPLING_ENABLED
        if (this->isReservoirCouplingSlave()) {
            if (this->reservoirCouplingSlave().isFirstSubstepOfSyncTimestep()) {
                // The wells have not been solved for this sync step yet, so a well that
                // opens in this report step still carries its WCONPROD target as its rate.
                // See RescoupSendSlaveGroupData::collectSlaveGroupSurfaceProductionRates_().
                this->reservoirCouplingSlave().setWellsSolvedThisSyncStep(false);
                this->rescoupHelper_.sendSlaveGroupDataToMaster();
                this->rescoupHelper_.receiveGroupConstraintsFromMaster();
                this->rescoupHelper_.receiveCoupledNetworkActiveStatus();
                this->groupStateHelper().updateSlaveGroupCmodesFromMaster();
                this->reservoirCouplingSlave().markSlaveGroupsInSchedule(
                    this->schedule_, reportStepIdx);
                slave_needs_well_solution = true;
            }
        }
#endif
        std::string exc_msg;
        auto exc_type = ExceptionType::NONE;
        // update gpmaint targets
        if (this->schedule_[reportStepIdx].has_gpmaint()) {
            for (const auto& calculator : regionalAveragePressureCalculator_) {
                calculator.second->template defineState<ElementContext>(simulator_);
            }
            const double dt = simulator_.timeStepSize();
            const Group& fieldGroup = this->schedule().getGroup("FIELD", reportStepIdx);
            try {
                this->groupStateHelper().updateGpMaintTargetForGroups(fieldGroup,
                                                              regionalAveragePressureCalculator_,
                                                              dt);
            }
            OPM_PARALLEL_CATCH_CLAUSE(exc_type, exc_msg);
        }
 
        this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget*/ true);
        try {
            // Compute initial well solution for new wells and injectors that change injection type i.e. WAG.
            for (auto& well : well_container_) {
                const uint64_t effective_events_mask = ScheduleEvents::WELL_STATUS_CHANGE
                        + ScheduleEvents::INJECTION_TYPE_CHANGED
                        + ScheduleEvents::WELL_SWITCHED_INJECTOR_PRODUCER
                        + ScheduleEvents::NEW_WELL;
 
                const auto& events = this->schedule()[reportStepIdx].wellgroup_events();
                const bool event = this->report_step_starts_ && events.hasEvent(well->name(), effective_events_mask);
                const bool dyn_status_change = this->wellState().well(well->name()).status
                        != this->prevWellState().well(well->name()).status;
 
                if (event || dyn_status_change || slave_needs_well_solution) {
                    try {
                        well->scaleSegmentRatesAndPressure(this->wellState());
                        well->calculateExplicitQuantities(simulator_, this->groupStateHelper());
                        well->updateWellStateWithTarget(simulator_, this->groupStateHelper(), this->wellState());
                        well->updatePrimaryVariables(this->groupStateHelper());
                        well->solveWellEquation(
                            simulator_, this->groupStateHelper(), this->wellState()
                        );
                    } catch (const std::exception& e) {
                        const std::string msg = "Compute initial well solution for new well " + well->name() + " failed. Continue with zero initial rates";
                        local_deferredLogger.warning("WELL_INITIAL_SOLVE_FAILED", msg);
                    }
                }
            }
        }
        // Catch clauses for all errors setting exc_type and exc_msg
        OPM_PARALLEL_CATCH_CLAUSE(exc_type, exc_msg);
 
#ifdef RESERVOIR_COUPLING_ENABLED
        if (slave_needs_well_solution) {  // isReservoirCouplingSlave()
            // The initial well solve above has run, so the well states now hold solved rates.
            this->reservoirCouplingSlave().setWellsSolvedThisSyncStep(true);
            // Need to update group data based on new well solution.
            this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget*/ false);
            this->rescoupHelper_.sendSlaveGroupDataToMaster();
        }
        else if (this->isReservoirCouplingMaster()) {
            if (this->reservoirCouplingMaster().isFirstSubstepOfSyncTimestep()) {
                this->rescoupHelper_.sendMasterGroupConstraintsToSlaves();
                this->rescoupHelper_.sendCoupledNetworkActiveStatus();
                this->rescoupHelper_.receiveSlaveGroupData();
            }
        }
#endif
 
        if (exc_type != ExceptionType::NONE) {
            const std::string msg = "Compute initial well solution for new wells failed. Continue with zero initial rates";
            local_deferredLogger.warning("WELL_INITIAL_SOLVE_FAILED", msg);
        }
 
        const auto& comm = simulator_.vanguard().grid().comm();
        logAndCheckForExceptionsAndThrow(local_deferredLogger,
                                         exc_type, "beginTimeStep() failed: " + exc_msg, this->terminal_output_, comm);
 
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updateFailed()
    {
        this->BlackoilWellModelGeneric<Scalar, IndexTraits>::updateFailed();
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    advanceTimeLevel()
    {
        this->BlackoilWellModelGeneric<Scalar, IndexTraits>::advanceTimeLevel();
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::wellTesting(const int timeStepIdx,
                                            const double simulationTime,
                                            DeferredLogger& deferred_logger)
    {
        for (const std::string& well_name : this->getWellsForTesting(timeStepIdx, simulationTime)) {
            const Well& wellEcl = this->schedule().getWell(well_name, timeStepIdx);
            if (wellEcl.getStatus() == Well::Status::SHUT)
                continue;
 
            WellInterfacePtr well = createWellForWellTest(well_name, timeStepIdx, deferred_logger);
            // some preparation before the well can be used
            well->init(depth_, gravity_, B_avg_, true);
 
            Scalar well_efficiency_factor = wellEcl.getEfficiencyFactor() *
                                            this->wellState().getGlobalEfficiencyScalingFactor(well_name);
            this->groupStateHelper().accumulateGroupEfficiencyFactor(
                this->schedule().getGroup(wellEcl.groupName(), timeStepIdx),
                well_efficiency_factor
            );
 
            well->setWellEfficiencyFactor(well_efficiency_factor);
            well->setVFPProperties(this->vfp_properties_.get());
            well->setGuideRate(&this->guideRate_);
 
            // initialize rates/previous rates to prevent zero fractions in vfp-interpolation
            if (well->isProducer() && alternative_well_rate_init_) {
                well->initializeProducerWellState(simulator_, this->wellState(), deferred_logger);
            }
            if (well->isVFPActive(deferred_logger)) {
                well->setPrevSurfaceRates(this->wellState(), this->prevWellState());
            }
 
            this->network_.initializeWell(*well);
            try {
                using GLiftEclWells = typename GasLiftGroupInfo<Scalar, IndexTraits>::GLiftEclWells;
                GLiftEclWells ecl_well_map;
                gaslift_.initGliftEclWellMap(well_container_, ecl_well_map);
                well->wellTesting(simulator_,
                                  simulationTime,
                                  this->groupStateHelper(),
                                  this->wellState(),
                                  this->wellTestState(),
                                  ecl_well_map,
                                  this->well_open_times_);
            } catch (const std::exception& e) {
                const std::string msg =
                  fmt::format(fmt::runtime("Exception during testing of well: {}. The well will not open.\n"
                                           "Exception message: {}"), wellEcl.name(), e.what());
                deferred_logger.warning("WELL_TESTING_FAILED", msg);
            }
        }
    }
 
    // called at the end of a report step
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    endReportStep()
    {
        // Clear the communication data structures for above values.
        for (auto&& pinfo : this->local_parallel_well_info_)
        {
            pinfo.get().clear();
        }
    }
 
 
 
 
 
    // called at the end of a report step
    template<typename TypeTag>
    const SimulatorReportSingle&
    BlackoilWellModel<TypeTag>::
    lastReport() const {return last_report_; }
 
 
 
 
 
    // called at the end of a time step
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    timeStepSucceeded(const double simulationTime, const double dt)
    {
        this->closed_this_step_.clear();
 
        // time step is finished and we are not any more at the beginning of an report step
        this->report_step_starts_ = false;
        const int reportStepIdx = simulator_.episodeIndex();
 
        auto logger_guard = this->groupStateHelper().pushLogger();
        auto& local_deferredLogger = this->groupStateHelper().deferredLogger();
        for (const auto& well : well_container_) {
            if (getPropValue<TypeTag, Properties::EnablePolymerMW>() && well->isInjector()) {
                well->updateWaterThroughput(dt, this->wellState());
            }
        }
        // update connection transmissibility factor and d factor (if applicable) in the wellstate
        for (const auto& well : well_container_) {
            well->updateConnectionTransmissibilityFactor(simulator_, this->wellState().well(well->indexOfWell()));
            well->updateConnectionDFactor(simulator_, this->wellState().well(well->indexOfWell()));
        }
 
        if (Indices::waterEnabled) {
            this->updateFiltrationModelsPostStep(dt, FluidSystem::waterPhaseIdx, local_deferredLogger);
        }
 
        // WINJMULT: At the end of the time step, update the inj_multiplier saved in WellState for later use
        this->updateInjMult(local_deferredLogger);
 
        // report well switching
        for (const auto& well : well_container_) {
            well->reportWellSwitching(this->wellState().well(well->indexOfWell()), local_deferredLogger);
        }
        // report group switching
        if (this->terminal_output_) {
            this->reportGroupSwitching(local_deferredLogger);
        }
 
        // update the rate converter with current averages pressures etc in
        rateConverter_->template defineState<ElementContext>(simulator_);
 
        // calculate the well potentials
        try {
            this->updateWellPotentials(reportStepIdx,
                                       /*onlyAfterEvent*/false,
                                       simulator_.vanguard().summaryConfig(),
                                       local_deferredLogger);
        } catch ( std::runtime_error& e ) {
            const std::string msg = "A zero well potential is returned for output purposes. ";
            local_deferredLogger.warning("WELL_POTENTIAL_CALCULATION_FAILED", msg);
        }
 
        // simulationTime is the start of the step that has just been completed,
        // but a well shut by the economic or physical limit checks below keeps
        // flowing until its end. Record that instant as the closure time, so
        // the WTEST re-test countdown starts when the well actually stops.
        const double closure_time = simulationTime + dt;
 
        updateWellTestState(closure_time, this->wellTestState());
 
        // check group sales limits at the end of the timestep
        const Group& fieldGroup = this->schedule_.getGroup("FIELD", reportStepIdx);
        this->checkGEconLimits(fieldGroup, closure_time,
                               simulator_.episodeIndex(), local_deferredLogger);
        this->checkGconsaleLimits(fieldGroup, this->wellState(),
                                  simulator_.episodeIndex(), local_deferredLogger);
 
        this->calculateProductivityIndexValues(local_deferredLogger);
 
        this->groupStateHelper().updateNONEProductionGroups();
 
#ifdef RESERVOIR_COUPLING_ENABLED
        this->rescoupHelper_.rescoupSyncSummaryData();
#endif
        this->commitWGState();
 
        //reporting output temperatures
        this->computeWellTemperature();
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    computeTotalRatesForDof(RateVector& rate,
                            unsigned elemIdx) const
    {
        rate = 0;
 
        if (!is_cell_perforated_[elemIdx] || cellRates_.count(elemIdx) == 0) {
            return;
        }
 
        rate = cellRates_.at(elemIdx);
    }
 
 
    template<typename TypeTag>
    template <class Context>
    void
    BlackoilWellModel<TypeTag>::
    computeTotalRatesForDof(RateVector& rate,
                            const Context& context,
                            unsigned spaceIdx,
                            unsigned timeIdx) const
    {
        rate = 0;
        int elemIdx = context.globalSpaceIndex(spaceIdx, timeIdx);
 
        if (!is_cell_perforated_[elemIdx] || cellRates_.count(elemIdx) == 0) {
            return;
        }
 
        rate = cellRates_.at(elemIdx);
    }
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    initializeWellState(const int timeStepIdx)
    {
        const auto pressIx = []()
        {
            if (Indices::oilEnabled)   { return FluidSystem::oilPhaseIdx;   }
            if (Indices::waterEnabled) { return FluidSystem::waterPhaseIdx; }
 
            return FluidSystem::gasPhaseIdx;
        }();
 
        auto cellPressures = std::vector<Scalar>(this->local_num_cells_, Scalar{0});
        auto cellTemperatures = std::vector<Scalar>(this->local_num_cells_, Scalar{0});
 
        auto elemCtx = ElementContext { this->simulator_ };
        const auto& gridView = this->simulator_.vanguard().gridView();
 
        OPM_BEGIN_PARALLEL_TRY_CATCH();
        for (const auto& elem : elements(gridView, Dune::Partitions::interior)) {
            elemCtx.updatePrimaryStencil(elem);
            elemCtx.updatePrimaryIntensiveQuantities(/*timeIdx=*/0);
 
            const auto ix = elemCtx.globalSpaceIndex(/*spaceIdx=*/0, /*timeIdx=*/0);
            const auto& fs = elemCtx.intensiveQuantities(/*spaceIdx=*/0, /*timeIdx=*/0).fluidState();
 
            cellPressures[ix] = fs.pressure(pressIx).value();
            cellTemperatures[ix] = fs.temperature(0).value();
        }
        OPM_END_PARALLEL_TRY_CATCH("BlackoilWellModel::initializeWellState() failed: ",
                                   this->simulator_.vanguard().grid().comm());
 
        this->wellState().init(cellPressures, cellTemperatures, this->schedule(), this->wells_ecl_,
                               this->local_parallel_well_info_, timeStepIdx,
                               &this->prevWellState(), this->well_perf_data_,
                               this->summaryState(), simulator_.vanguard().enableDistributedWells());
    }
 
 
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    createWellContainer(const int report_step)
    {
        auto logger_guard = this->groupStateHelper().pushLogger();
        auto& local_deferredLogger = this->groupStateHelper().deferredLogger();
 
        const int nw = this->numLocalWells();
 
        well_container_.clear();
 
        if (nw > 0) {
            well_container_.reserve(nw);
 
            const auto& wmatcher = this->schedule().wellMatcher(report_step);
            const auto& wcycle = this->schedule()[report_step].wcycle.get();
 
            // First loop and check for status changes. This is necessary
            // as wcycle needs the updated open/close times.
            std::ranges::for_each(this->wells_ecl_,
                          [this, &wg_events = this->report_step_start_events_](const auto& well_ecl)
                          {
                              if (!well_ecl.hasConnections()) {
                                  // No connections in this well.  Nothing to do.
                                  return;
                              }
 
                              constexpr auto events_mask = ScheduleEvents::WELL_STATUS_CHANGE |
                                                           ScheduleEvents::REQUEST_OPEN_WELL |
                                                           ScheduleEvents::REQUEST_SHUT_WELL;
                              const bool well_event =
                                  this->report_step_starts_ &&
                                  wg_events.hasEvent(well_ecl.name(), events_mask);
                              // WCYCLE is suspendended by explicit SHUT events by the user.
                              // and restarted after explicit OPEN events.
                              // Note: OPEN or SHUT event does not necessary mean the well
                              // actually opened or shut at this point as the simulator could
                              // have done this by operabilty checks and well testing. This
                              // may need further testing and imply code changes to cope with
                              // these corner cases.
                              if (well_event) {
                                  if (well_ecl.getStatus() == WellStatus::OPEN) {
                                      this->well_open_times_.insert_or_assign(well_ecl.name(),
                                                                              this->simulator_.time());
                                      this->well_close_times_.erase(well_ecl.name());
                                  } else if (well_ecl.getStatus() == WellStatus::SHUT) {
                                      this->well_close_times_.insert_or_assign(well_ecl.name(),
                                                                               this->simulator_.time());
                                      this->well_open_times_.erase(well_ecl.name());
                                  }
                              }
                          });
 
            // Grab wcycle states. This needs to run before the schedule gets processed
            const auto cycle_states = wcycle.wellStatus(this->simulator_.time(),
                                                         wmatcher,
                                                         this->well_open_times_,
                                                         this->well_close_times_);
 
            for (int w = 0; w < nw; ++w) {
                const Well& well_ecl = this->wells_ecl_[w];
 
                if (!well_ecl.hasConnections()) {
                    // No connections in this well.  Nothing to do.
                    continue;
                }
 
                const std::string& well_name = well_ecl.name();
                const auto well_status = this->schedule()
                    .getWell(well_name, report_step).getStatus();
 
                const bool shut_event = this->wellState().well(w).events.hasEvent(ScheduleEvents::WELL_STATUS_CHANGE)
                                    && well_status == Well::Status::SHUT;
                const bool open_event = this->wellState().well(w).events.hasEvent(ScheduleEvents::WELL_STATUS_CHANGE)
                                    && well_status == Well::Status::OPEN;
                const auto& ws = this->wellState().well(well_name);
 
                if (shut_event && ws.status != Well::Status::SHUT) {
                    this->closed_this_step_.insert(well_name);
                    this->wellState().shutWell(w);
                } else if (open_event && ws.status != Well::Status::OPEN) {
                    this->wellState().openWell(w);
                }
 
                // A new WCON keywords can re-open a well that was closed/shut due to Physical limit
                if (this->wellTestState().well_is_closed(well_name)) {
                    // The well was shut this timestep, we are most likely retrying
                    // a timestep without the well in question, after it caused
                    // repeated timestep cuts. It should therefore not be opened,
                    // even if it was new or received new targets this report step.
                    //
                    // The time stamp alone cannot establish that, since a shut-in
                    // decided at the *end* of the previous step carries that
                    // step's end time, which coincides with the current step's
                    // start time. Such shut-ins are the ones a new WCON keyword
                    // may undo, and are exactly what wasDynamicallyShutThisTimeStep()
                    // reports; mid-step ones from forceShutWellByName() are not
                    // registered there, so they still block the re-open.
                    const bool closed_this_step =
                        (this->wellTestState().lastTestTime(well_name) == simulator_.time()) &&
                        !this->wasDynamicallyShutThisTimeStep(well_name);
                    // TODO: more checking here, to make sure this standard more specific and complete
                    // maybe there is some WCON keywords will not open the well
                    auto& events = this->wellState().well(w).events;
                    if (events.hasEvent(ScheduleEvents::REQUEST_OPEN_WELL)) {
                        if (!closed_this_step) {
                            this->wellTestState().open_well(well_name);
                            this->wellTestState().open_completions(well_name);
                            this->well_open_times_.insert_or_assign(well_name,
                                                                    this->simulator_.time());
                            this->well_close_times_.erase(well_name);
                        }
                        events.clearEvent(ScheduleEvents::REQUEST_OPEN_WELL);
                    }
                }
 
                // WELOPEN/COMPDAT can reopen individual connections shut at run
                // time by physical/economic limits, without touching the rest
                // of the well.  Act only when the well is open (a SHUT well
                // would not flow) and the schedule changed completions this
                // step (global COMPLETION_CHANGE, set by both COMPDAT and
                // WELOPEN).
                auto& well_test_state = this->wellTestState();
                const auto& sched_state = this->schedule()[report_step];
                const bool may_reopen_completions =
                    ws.status == Well::Status::OPEN &&
                    sched_state.events().hasEvent(ScheduleEvents::COMPLETION_CHANGE) &&
                    well_test_state.num_closed_completions() > 0;
 
                if (may_reopen_completions) {
                    const auto& completion_events = sched_state.wellcompletion_events();
                    for (const auto& connection : well_ecl.getConnections()) {
                        const int complnum = connection.complnum();
 
                        // Reopen only connections currently shut at run time
                        // that are explicitly requested OPEN this step.
                        if (!well_test_state.completion_is_closed(well_name, complnum) ||
                            !completion_events.hasEvent(well_name, complnum, ScheduleEvents::REQUEST_OPEN_COMPLETION)) {
                            continue;
                        }
 
                        // ... but not one closed during the current timestep
                        const bool closed_this_step =
                            (well_test_state.lastCompletionCloseTime(well_name, complnum) == simulator_.time());
                        if (closed_this_step) {
                            continue;
                        }
 
                        well_test_state.open_completion(well_name, complnum);
                        local_deferredLogger.info(
                            fmt::format("Completion {} - block ({}, {}, {}) for well {} "
                                        "is reopened due to an explicit WELOPEN/COMPDAT "
                                        "OPEN request",
                                        complnum,
                                        connection.getI() + 1,
                                        connection.getJ() + 1,
                                        connection.getK() + 1,
                                        well_name));
                    }
                }
 
                // TODO: should we do this for all kinds of closing reasons?
                // something like wellTestState().hasWell(well_name)?
                if (this->wellTestState().well_is_closed(well_name))
                {
                    if (well_ecl.getAutomaticShutIn() ||
                        !well_ecl.getAllowCrossFlow() ||
                        this->allConnectionsClosed(well_ecl))
                    {
                        this->wellState().shutWell(w);
                        this->well_close_times_.erase(well_name);
                        this->well_open_times_.erase(well_name);
                        continue;
                    }
                    // stopped wells are added to the container but marked as stopped
                    this->wellState().stopWell(w);
                }
 
                // shut wells with zero rante constraints and disallowing
                if (!well_ecl.getAllowCrossFlow()) {
                    const bool any_zero_rate_constraint = well_ecl.isProducer()
                        ? well_ecl.productionControls(this->summaryState_).anyZeroRateConstraint()
                        : well_ecl.injectionControls(this->summaryState_).anyZeroRateConstraint();
                    if (any_zero_rate_constraint) {
                        // Treat as shut, do not add to container.
                        local_deferredLogger.debug(fmt::format(fmt::runtime("  Well {} gets shut due to having zero rate constraint and disallowing crossflow "), well_ecl.name()));
                        this->wellState().shutWell(w);
                        this->well_close_times_.erase(well_name);
                        this->well_open_times_.erase(well_name);
                        continue;
                    }
                }
 
                if (!wcycle.empty()) {
                    const auto it = cycle_states.find(well_name);
                    if (it != cycle_states.end()) {
                        if (!it->second || well_status == Well::Status::SHUT) {
                            // If well is shut in schedule we keep it shut
                            if (well_status == Well::Status::SHUT) {
                                this->well_open_times_.erase(well_name);
                                this->well_close_times_.erase(well_name);
                            }
                            this->wellState().shutWell(w);
                            continue;
                        } else {
                            this->wellState().openWell(w);
                        }
                    }
                }
 
                // We dont add SHUT wells to the container
                if (ws.status == Well::Status::SHUT) {
                    continue;
                }
 
                well_container_.emplace_back(this->createWellPointer(w, report_step));
 
                if (ws.status == Well::Status::STOP) {
                    well_container_.back()->stopWell();
                    this->well_close_times_.erase(well_name);
                    this->well_open_times_.erase(well_name);
                }
            }
 
            if (!wcycle.empty()) {
                const auto schedule_open =
                    [&wg_events = this->report_step_start_events_](const std::string& name)
                    {
                        return wg_events.hasEvent(name, ScheduleEvents::REQUEST_OPEN_WELL);
                    };
                for (const auto& [wname, wscale] : wcycle.efficiencyScale(this->simulator_.time(),
                                                                          this->simulator_.timeStepSize(),
                                                                          wmatcher,
                                                                          this->well_open_times_,
                                                                          schedule_open))
                {
                    this->wellState().updateEfficiencyScalingFactor(wname, wscale);
                    this->schedule_.add_event(ScheduleEvents::WELLGROUP_EFFICIENCY_UPDATE, report_step);
                }
            }
        }
 
        this->well_container_generic_.clear();
        for (auto& w : well_container_) {
            this->well_container_generic_.push_back(w.get());
        }
 
        this->network_.initialize(report_step);
 
        this->wbp_.registerOpenWellsForWBPCalculation();
    }
 
 
 
 
 
    template <typename TypeTag>
    typename BlackoilWellModel<TypeTag>::WellInterfacePtr
    BlackoilWellModel<TypeTag>::
    createWellPointer(const int wellID, const int report_step) const
    {
        const auto is_multiseg = this->wells_ecl_[wellID].isMultiSegment();
 
        if (! (this->param_.use_multisegment_well_ && is_multiseg)) {
            return this->template createTypedWellPointer<StandardWell<TypeTag>>(wellID, report_step);
        }
        else {
            return this->template createTypedWellPointer<MultisegmentWell<TypeTag>>(wellID, report_step);
        }
    }
 
 
 
 
 
    template <typename TypeTag>
    template <typename WellType>
    std::unique_ptr<WellType>
    BlackoilWellModel<TypeTag>::
    createTypedWellPointer(const int wellID, const int time_step) const
    {
        // Use the pvtRegionIdx from the top cell
        const auto& perf_data = this->well_perf_data_[wellID];
 
        // Cater for case where local part might have no perforations.
        const auto pvtreg = perf_data.empty()
            ? 0 : this->pvt_region_idx_[perf_data.front().cell_index];
 
        const auto& parallel_well_info = this->local_parallel_well_info_[wellID].get();
        const auto global_pvtreg = parallel_well_info.broadcastFirstPerforationValue(pvtreg);
 
        return std::make_unique<WellType>(this->wells_ecl_[wellID],
                                          parallel_well_info,
                                          time_step,
                                          this->param_,
                                          *this->rateConverter_,
                                          global_pvtreg,
                                          this->numConservationQuantities(),
                                          this->numPhases(),
                                          wellID,
                                          perf_data);
    }
 
 
 
 
 
    template<typename TypeTag>
    typename BlackoilWellModel<TypeTag>::WellInterfacePtr
    BlackoilWellModel<TypeTag>::
    createWellForWellTest(const std::string& well_name,
                          const int report_step,
                          DeferredLogger& deferred_logger) const
    {
        // Finding the location of the well in wells_ecl
        const auto it =
            std::ranges::find_if(this->wells_ecl_,
                                 [&well_name](const auto& w)
                                 { return well_name == w.name(); });
        // It should be able to find in wells_ecl.
        if (it == this->wells_ecl_.end()) {
            OPM_DEFLOG_THROW(std::logic_error,
                             fmt::format(fmt::runtime("Could not find well {} in wells_ecl"), well_name),
                             deferred_logger);
        }
 
        const int pos = static_cast<int>(std::distance(this->wells_ecl_.begin(), it));
        return this->createWellPointer(pos, report_step);
    }
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    assemble(const double dt)
    {
        OPM_TIMEFUNCTION();
        auto logger_guard = this->groupStateHelper().pushLogger();
        auto& local_deferredLogger = this->groupStateHelper().deferredLogger();
 
        const auto& iterCtx = simulator_.problem().iterationContext();
 
        if constexpr (BlackoilWellModelGasLift<TypeTag>::glift_debug) {
            if (gaslift_.terminalOutput()) {
                const std::string msg =
                    fmt::format(fmt::runtime("assemble() : iteration {}"), iterCtx.iteration());
                gaslift_.gliftDebug(msg, local_deferredLogger);
            }
        }
        last_report_ = SimulatorReportSingle();
        Dune::Timer perfTimer;
        perfTimer.start();
        this->closed_offending_wells_.clear();
 
        {
            if (iterCtx.needsTimestepInit()) {
                this->updateNetworkActiveState_();
            }
            const int episodeIdx = simulator_.episodeIndex();
            const auto& network = this->schedule()[episodeIdx].network();
            if (!this->wellsActive() && !network.active()) {
                return;
            }
        }
 
        // Timestep initialization: should run once at the start of each timestep.
        if (iterCtx.needsTimestepInit() && this->wellsActive()) {
            OPM_TIMEBLOCK(firstIterationAssemble);
            Dune::Timer prepareTimer;
            prepareTimer.start();
            // try-catch is needed here as updateWellControls
            // contains global communication and has either to
            // be reached by all processes or all need to abort
            // before.
            OPM_BEGIN_PARALLEL_TRY_CATCH();
            {
                calculateExplicitQuantities();
                prepareTimeStep(local_deferredLogger);
            }
            OPM_END_PARALLEL_TRY_CATCH_LOG(local_deferredLogger,
                                           "assemble() failed during well initialization: ",
                                           this->terminal_output_, grid().comm());
            last_report_.well_facility_time += prepareTimer.stop();
        }
 
        Dune::Timer networkTimer;
        networkTimer.start();
        const bool well_group_control_changed = updateWellControlsAndNetwork(
                            /*mandatory_network_balance=*/false,
                            dt,
                            local_deferredLogger);
        // the control/network update is part of the facility calculations,
        // together with the time step preparation of the wells above
        const double network_time = networkTimer.stop();
        last_report_.well_control_network_time += network_time;
        last_report_.well_facility_time += network_time;
 
        // even when there is no wells active, the network nodal pressure still need to be updated through updateWellControlsAndNetwork()
        // but there is no need to assemble the well equations
        if ( ! this->wellsActive() ) {
            return;
        }
 
        assembleWellEqWithoutIteration(dt);
        // Pre-compute cell rates to we don't have to do this for every cell during linearization...
        updateCellRates();
 
        // collect the statistics for the standalone well solves done since
        // the last assembly (prepareTimeStep, well testing and well
        // potential calculations)
        collectWellSolveStats();
 
        // if group or well control changes we don't consider the
        // case converged
        last_report_.well_group_control_changed = well_group_control_changed;
        last_report_.assemble_time_well += perfTimer.stop();
    }
 
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    collectWellSolveStats()
    {
        for (const auto& well : well_container_) {
            const auto& stats = well->solveStats();
            last_report_.well_solve_time += stats.solve_time;
            last_report_.well_potential_solve_time += stats.potential_solve_time;
            last_report_.well_solve_assemble_time += stats.assemble_time;
            last_report_.well_solve_linear_solve_time += stats.linear_solve_time;
            last_report_.total_well_iterations += stats.iterations;
            last_report_.total_well_potential_iterations += stats.potential_iterations;
            well->resetSolveStats();
        }
    }
 
 
 
 
    template<typename TypeTag>
    bool
    BlackoilWellModel<TypeTag>::
    updateWellControlsAndNetwork(const bool mandatory_network_balance,
                                 const double dt,
                                 DeferredLogger& local_deferredLogger)
    {
        OPM_TIMEFUNCTION();
        // not necessarily that we always need to update once of the network solutions
        bool do_network_update = true;
        bool well_group_control_changed = false;
        Scalar network_imbalance = 0.0;
        // after certain number of the iterations, we use relaxed tolerance for the network update
        const std::size_t iteration_to_relax = param_.network_max_strict_outer_iterations_;
        // after certain number of the iterations, we terminate
        const std::size_t max_iteration = param_.network_max_outer_iterations_;
        std::size_t network_update_iteration = 0;
        network_needs_more_balancing_force_another_newton_iteration_ = false;
        while (do_network_update) {
            if (!this->isRescoupSlaveCoupledNetworkIteration_()
                && network_update_iteration >= max_iteration ) {
                // only output to terminal if we at the last newton iterations where we try to balance the network.
                const int episodeIdx = simulator_.episodeIndex();
                if (this->network_.willBalanceOnNextIteration(episodeIdx)) {
                    if (this->terminal_output_) {
                        const std::string msg = fmt::format("Maximum of {:d} network iterations has been used and we stop the update, \n"
                            "and try again after the next Newton iteration (imbalance = {:.2e} bar)",
                            max_iteration, network_imbalance*1.0e-5);
                        local_deferredLogger.debug(msg);
                    }
                    // To avoid stopping the newton iterations too early, before the network is converged,
                    // we need to report it
                    network_needs_more_balancing_force_another_newton_iteration_ = true;
                } else {
                    if (this->terminal_output_) {
                        const std::string msg = fmt::format("Maximum of {:d} network iterations has been used and we stop the update. \n"
                            "The simulator will continue with unconverged network results (imbalance = {:.2e} bar)",
                            max_iteration, network_imbalance*1.0e-5);
                        local_deferredLogger.info(msg);
                    }
                }
                break;
            }
            if (this->terminal_output_ && (network_update_iteration == iteration_to_relax) ) {
                local_deferredLogger.debug("We begin using relaxed tolerance for network update now after " + std::to_string(iteration_to_relax) + " iterations ");
            }
            const bool relax_network_balance = network_update_iteration >= iteration_to_relax;
            // Never optimize gas lift in last iteration, to allow network convergence (unless max_iter < 2)
            const bool optimize_gas_lift = ( (network_update_iteration + 1) < std::max(max_iteration, static_cast<std::size_t>(2)) );
            std::tie(well_group_control_changed, do_network_update, network_imbalance) =
                    updateWellControlsAndNetworkIteration(mandatory_network_balance, relax_network_balance, optimize_gas_lift, dt,local_deferredLogger);
            ++network_update_iteration;
        }
        if (this->isRescoupMasterCoupledNetworkIteration_()) {
            this->sendSlaveNetworkLoopTerminationSignal_();
        }
        // only count the balancing iterations when a network is active
        if (this->schedule()[simulator_.episodeIndex()].network().active()) {
            last_report_.total_network_iterations += network_update_iteration;
        }
        return well_group_control_changed;
    }
 
 
 
 
    template<typename TypeTag>
    std::tuple<bool, bool, typename BlackoilWellModel<TypeTag>::Scalar>
    BlackoilWellModel<TypeTag>::
    updateWellControlsAndNetworkIteration(const bool mandatory_network_balance,
                                          const bool relax_network_tolerance,
                                          const bool optimize_gas_lift,
                                          const double dt,
                                          DeferredLogger& local_deferredLogger)
    {
        OPM_TIMEFUNCTION();
        const int reportStepIdx = simulator_.episodeIndex();
 
#ifdef RESERVOIR_COUPLING_ENABLED
        if (this->isRescoupSlaveCoupledNetworkIteration_()) {
            this->rescoupHelper_.receiveMasterGroupNodePressuresFromMaster();
        }
#endif
        Dune::Timer groupTimer;
        groupTimer.start();
        this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget*/ true);
        // We need to call updateWellControls before we update the network as
        // network updates are only done on thp controlled wells.
        // Note that well controls are allowed to change during updateNetwork
        // and in prepareWellsBeforeAssembling during well solves.
        bool well_group_control_changed = updateWellControls(local_deferredLogger);
        last_report_.group_control_time += groupTimer.stop();
 
        Dune::Timer networkBalanceTimer;
        networkBalanceTimer.start();
        const auto [more_inner_network_update, network_imbalance] =
                this->network_.update(mandatory_network_balance,
                                      local_deferredLogger,
                                      relax_network_tolerance);
        // only account for the time when a network is active
        if (this->schedule()[reportStepIdx].network().active()) {
            last_report_.network_balance_time += networkBalanceTimer.stop();
        }
#ifdef RESERVOIR_COUPLING_ENABLED
        if (this->isReservoirCouplingMaster()) {
            this->rescoupHelper_.maybeExchangeNetworkOuterIterationWithSlaves(more_inner_network_update);
        }
#endif
 
        bool alq_updated = false;
        OPM_BEGIN_PARALLEL_TRY_CATCH();
        {
            if (optimize_gas_lift) {
                // we need to update the potentials if the thp limit as been modified by
                // the network balancing
                const bool updatePotentials = (this->network_.shouldBalance(reportStepIdx) ||
                                               mandatory_network_balance);
                Dune::Timer gliftTimer;
                gliftTimer.start();
                alq_updated = gaslift_.maybeDoGasLiftOptimize(simulator_,
                                                          well_container_,
                                                          this->network_.nodePressures(),
                                                          updatePotentials,
                                                          this->wellState(),
                                                          this->groupState(),
                                                          local_deferredLogger);
                // only account for the time when gas lift optimization is in use
                if (this->schedule().glo(reportStepIdx).active()) {
                    last_report_.gaslift_time += gliftTimer.stop();
                }
            }
            // the well solves triggered by control changes are part of the
            // control/network update, keep track of the time separately
            Dune::Timer prepareWellsTimer;
            prepareWellsTimer.start();
            prepareWellsBeforeAssembling(dt);
            last_report_.control_well_solve_time += prepareWellsTimer.stop();
        }
        OPM_END_PARALLEL_TRY_CATCH_LOG(local_deferredLogger,
                                       "updateWellControlsAndNetworkIteration() failed: ",
                                       this->terminal_output_, grid().comm());
 
        // update guide rates
        if (alq_updated || BlackoilWellModelGuideRates(*this).
                              guideRateUpdateIsNeeded(reportStepIdx)) {
            const double simulationTime = simulator_.time();
            Dune::Timer guideRateTimer;
            guideRateTimer.start();
            // NOTE: For reservoir coupling: Slave group potentials are only communicated
            //    at the start of the time step, see beginTimeStep(). Here, we assume those
            //    potentials remain unchanged during the time step when updating guide rates below.
            this->guide_rate_handler_.updateGuideRates(
                reportStepIdx, simulationTime, this->wellState(), this->groupState()
            );
            last_report_.group_control_time += guideRateTimer.stop();
        }
        // we need to re-iterate the network when the well group controls changed or gaslift/alq is changed or
        // the inner iterations are did not converge
        bool more_network_update = this->network_.shouldBalance(reportStepIdx) &&
                    (more_inner_network_update || alq_updated);
 
        if (this->isRescoupSlaveOnSyncStepFirstSubstep_()
            && this->isRescoupSlaveConnectedToMasterNetwork_()) {
            // Connected slave: the call ships this slave's flow to the master
            // and reports whether the cross-rescoup exchange continues.  OR
            // with the local decision so a connected slave that also has its
            // own network keeps iterating it.  A slave not connected to the
            // master network skips this branch entirely and runs purely on its
            // local more_network_update.
            const bool more_cross_rescoup_update =
                this->maybeSendSlaveGroupFlowToMaster_(reportStepIdx);
            more_network_update = more_network_update || more_cross_rescoup_update;
        }
 
        return {well_group_control_changed, more_network_update, network_imbalance};
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    assembleWellEq(const double dt)
    {
        OPM_TIMEFUNCTION();
        for (auto& well : well_container_) {
            well->assembleWellEq(simulator_, dt, this->groupStateHelper(), this->wellState());
        }
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    prepareWellsBeforeAssembling(const double dt)
    {
        OPM_TIMEFUNCTION();
        for (auto& well : well_container_) {
            well->prepareWellBeforeAssembling(
                simulator_, dt, this->groupStateHelper(), this->wellState()
            );
        }
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    assembleWellEqWithoutIteration(const double dt)
    {
        OPM_TIMEFUNCTION();
        auto& deferred_logger = this->groupStateHelper().deferredLogger();
        // We make sure that all processes throw in case there is an exception
        // on one of them (WetGasPvt::saturationPressure might throw if not converged)
        OPM_BEGIN_PARALLEL_TRY_CATCH();
 
        for (auto& well: well_container_) {
            well->assembleWellEqWithoutIteration(simulator_, this->groupStateHelper(), dt, this->wellState(),
                                                 /*solving_with_zero_rate=*/false);
        }
        OPM_END_PARALLEL_TRY_CATCH_LOG(deferred_logger, "BlackoilWellModel::assembleWellEqWithoutIteration failed: ",
                                       this->terminal_output_, grid().comm());
 
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updateCellRates()
    {
        // Pre-compute cell rates for all wells
        cellRates_.clear();
        for (const auto& well : well_container_) {
            well->addCellRates(cellRates_);
        }
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updateCellRatesForDomain(int domainIndex, const std::map<std::string, int>& well_domain_map)
    {
        // Pre-compute cell rates only for wells in the specified domain
        cellRates_.clear();
        for (const auto& well : well_container_) {
            const auto it = well_domain_map.find(well->name());
            if (it != well_domain_map.end() && it->second == domainIndex) {
                well->addCellRates(cellRates_);
            }
        }
    }
 
#if COMPILE_GPU_BRIDGE
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    getWellContributions(WellContributions<Scalar>& wellContribs) const
    {
        // prepare for StandardWells
        wellContribs.setBlockSize(StandardWell<TypeTag>::Indices::numEq, StandardWell<TypeTag>::numStaticWellEq);
 
        for(unsigned int i = 0; i < well_container_.size(); i++){
            auto& well = well_container_[i];
            auto derived = dynamic_cast<StandardWell<TypeTag>*>(well.get());
            if (derived) {
                wellContribs.addNumBlocks(derived->linSys().getNumBlocks());
            }
        }
 
        // allocate memory for data from StandardWells
        wellContribs.alloc();
 
        for(unsigned int i = 0; i < well_container_.size(); i++){
            auto& well = well_container_[i];
            // maybe WellInterface could implement addWellContribution()
            auto derived_std = dynamic_cast<StandardWell<TypeTag>*>(well.get());
            if (derived_std) {
                derived_std->linSys().extract(derived_std->numStaticWellEq, wellContribs);
            } else {
                auto derived_ms = dynamic_cast<MultisegmentWell<TypeTag>*>(well.get());
                if (derived_ms) {
                    derived_ms->linSys().extract(wellContribs);
                } else {
                    OpmLog::warning("Warning unknown type of well");
                }
            }
        }
    }
#endif
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    addWellContributions(SparseMatrixAdapter& jacobian) const
    {
        for ( const auto& well: well_container_ ) {
            well->addWellContributions(jacobian);
        }
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::addBCDMatrix(std::vector<BMatrix>& b_matrices,
                                            std::vector<CMatrix>& c_matrices,
                                            std::vector<DMatrix>& d_matrices,
                                            Opm::SparseTable<int>& wcells) const
    {
        wcells.clear();
        for ( const auto& well: well_container_ ) {
            well->addBCDMatrix(b_matrices, c_matrices, d_matrices, wcells);
        }
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    addWellPressureEquations(PressureMatrix& jacobian,
                             const BVector& weights,
                             const bool use_well_weights) const
    {
        int nw = this->numLocalWellsEnd();
        int rdofs = local_num_cells_;
        for ( int i = 0; i < nw; i++ ) {
            int wdof = rdofs + i;
            jacobian[wdof][wdof] = 1.0;// better scaling ?
        }
 
        for (const auto& well : well_container_) {
            well->addWellPressureEquations(jacobian,
                                           weights,
                                           pressureVarIndex,
                                           use_well_weights,
                                           this->wellState());
        }
    }
 
    template <typename TypeTag>
    void BlackoilWellModel<TypeTag>::
    addReservoirSourceTerms(GlobalEqVector& residual,
                            const std::vector<typename SparseMatrixAdapter::MatrixBlock*>& diagMatAddress) const
    {
        // NB this loop may write multiple times to the same element
        // if a cell is perforated by more than one well, so it should
        // not be OpenMP-parallelized.
        for (const auto& well : well_container_) {
            if (!well->isOperableAndSolvable() && !well->wellIsStopped()) {
                continue;
            }
            const auto& cells = well->cells();
            const auto& rates = well->connectionRates();
            for (unsigned perfIdx = 0; perfIdx < rates.size(); ++perfIdx) {
                unsigned cellIdx = cells[perfIdx];
                auto rate = rates[perfIdx];
                rate *= -1.0;
                VectorBlockType res(0.0);
                using MatrixBlockType = typename SparseMatrixAdapter::MatrixBlock;
                MatrixBlockType bMat(0.0);
                simulator_.model().linearizer().setResAndJacobi(res, bMat, rate);
                residual[cellIdx] += res;
                *diagMatAddress[cellIdx] += bMat;
            }
        }
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    addWellPressureEquationsStruct(PressureMatrix& jacobian) const
    {
        int nw =  this->numLocalWellsEnd();
        int rdofs = local_num_cells_;
        const auto wellconnections = this->getMaxWellConnections();
        for (int i = 0; i < nw; ++i) {
            int wdof = rdofs + i;
            jacobian.entry(wdof,wdof) = 0.0;
            const auto& perfcells = wellconnections[i];
            for (int perfcell : perfcells) {
                jacobian.entry(wdof, perfcell) = 0.0;
                jacobian.entry(perfcell, wdof) = 0.0;
            }
        }
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    recoverWellSolutionAndUpdateWellState(const BVector& x)
    {
        auto loggerGuard = this->groupStateHelper().pushLogger();
        OPM_BEGIN_PARALLEL_TRY_CATCH();
        {
            for (const auto& well : well_container_) {
                const auto& cells = well->cells();
                x_local_.resize(cells.size());
 
                for (size_t i = 0; i < cells.size(); ++i) {
                    x_local_[i] = x[cells[i]];
                }
                well->recoverWellSolutionAndUpdateWellState(simulator_, x_local_,
                                                            this->groupStateHelper(), this->wellState());
            }
        }
        OPM_END_PARALLEL_TRY_CATCH("recoverWellSolutionAndUpdateWellState() failed: ",
                                   simulator_.vanguard().grid().comm());
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    recoverWellSolutionAndUpdateWellStateDomain(const BVector& x, const int domainIdx)
    {
        if (!nldd_) {
            OPM_THROW(std::logic_error, "Attempt to call NLDD method without a NLDD solver");
        }
 
        return nldd_->recoverWellSolutionAndUpdateWellState(x, domainIdx);
    }
 
 
    template<typename TypeTag>
    ConvergenceReport
    BlackoilWellModel<TypeTag>::
    getWellConvergence(const std::vector<Scalar>& B_avg, bool checkWellGroupControlsAndNetwork) const
    {
        // Get global (from all processes) convergence report.
        ConvergenceReport local_report;
        const auto& iterCtx = simulator_.problem().iterationContext();
        const bool relaxTolerance = iterCtx.shouldRelax(param_.strict_outer_iter_wells_ + 1);
        {
            auto logger_guard = this->groupStateHelper().pushLogger();
            for (const auto& well : well_container_) {
                if (well->isOperableAndSolvable() || well->wellIsStopped()) {
                    local_report += well->getWellConvergence(
                            this->groupStateHelper(), B_avg,
                            relaxTolerance);
                } else {
                    ConvergenceReport report;
                    using CR = ConvergenceReport;
                    report.setWellFailed({CR::WellFailure::Type::Unsolvable, CR::Severity::Normal, -1, well->name()});
                    local_report += report;
                }
            }
        } // logger_guard goes out of scope here, before the OpmLog::debug() calls below
 
        const Opm::Parallel::Communication comm = grid().comm();
        ConvergenceReport report = gatherConvergenceReport(local_report, comm);
 
        if (checkWellGroupControlsAndNetwork) {
            // the well_group_control_changed info is already communicated
            report.setWellGroupTargetsViolated(this->lastReport().well_group_control_changed);
            report.setNetworkNotYetBalancedForceAnotherNewtonIteration(network_needs_more_balancing_force_another_newton_iteration_);
        }
 
        if (this->terminal_output_) {
            // Log debug messages for NaN or too large residuals.
            for (const auto& f : report.wellFailures()) {
                if (f.severity() == ConvergenceReport::Severity::NotANumber) {
                        OpmLog::debug("NaN residual found with phase " + std::to_string(f.phase()) + " for well " + f.wellName());
                } else if (f.severity() == ConvergenceReport::Severity::TooLarge) {
                        OpmLog::debug("Too large residual found with phase " + std::to_string(f.phase()) + " for well " + f.wellName());
                }
            }
        }
        return report;
    }
 
 
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    calculateExplicitQuantities() const
    {
        // TODO: checking isOperableAndSolvable() ?
        for (auto& well : well_container_) {
            well->calculateExplicitQuantities(simulator_, this->groupStateHelper());
        }
    }
 
 
 
 
 
    template<typename TypeTag>
    bool
    BlackoilWellModel<TypeTag>::
    updateWellControls(DeferredLogger& deferred_logger)
    {
        OPM_TIMEFUNCTION();
        if (!this->wellsActive() && !this->isReservoirCouplingMaster()) {
            return false;
        }
        const int episodeIdx = simulator_.episodeIndex();
        const auto& comm = simulator_.vanguard().grid().comm();
 
        // Convert WELDRAW drawdown limits into maximum production rates.
        // Like the rate targets of wells under group control, these are
        // only updated during the first NUPCOL iterations of each timestep
        // and kept frozen for the remaining iterations.
        {
            const auto nupcol = this->schedule()[episodeIdx].nupcol();
            const auto& iter_ctx = simulator_.problem().iterationContext();
            if (iter_ctx.withinNupcol(nupcol)) {
                OPM_BEGIN_PARALLEL_TRY_CATCH()
                    for (const auto& well : well_container_) {
                        well->updateWeldrawMaxRate(simulator_, this->wellState(), deferred_logger);
                    }
                OPM_END_PARALLEL_TRY_CATCH("BlackoilWellModel: updating WELDRAW rate limits failed: ",
                                           simulator_.gridView().comm());
            }
        }
 
        size_t iter = 0;
        bool changed_well_group = false;
        const Group& fieldGroup = this->schedule().getGroup("FIELD", episodeIdx);
        // Check group individual constraints.
        // iterate a few times to make sure all constraints are honored
        const std::size_t max_iter = param_.well_group_constraints_max_iterations_;
        while(!changed_well_group && iter < max_iter) {
            changed_well_group = updateGroupControls(fieldGroup, deferred_logger, episodeIdx);
 
            // Check wells' group constraints and communicate.
            bool changed_well_to_group = false;
            {
                OPM_TIMEBLOCK(UpdateWellControls);
                // For MS Wells a linear solve is performed below and the matrix might be singular.
                // We need to communicate the exception thrown to the others and rethrow.
                OPM_BEGIN_PARALLEL_TRY_CATCH()
                    for (const auto& well : well_container_) {
                        const auto mode = WellInterface<TypeTag>::IndividualOrGroup::Group;
                        const bool changed_well = well->updateWellControl(
                            simulator_, mode, this->groupStateHelper(), this->wellState()
                        );
                        if (changed_well) {
                            changed_well_to_group = changed_well || changed_well_to_group;
                        }
                    }
                OPM_END_PARALLEL_TRY_CATCH("BlackoilWellModel: updating well controls failed: ",
                                        simulator_.gridView().comm());
            }
 
            changed_well_to_group = comm.sum(static_cast<int>(changed_well_to_group));
            if (changed_well_to_group) {
                updateAndCommunicate(episodeIdx);
                changed_well_group = true;
            }
 
            // Check individual well constraints and communicate.
            bool changed_well_individual = false;
            {
                // For MS Wells a linear solve is performed below and the matrix might be singular.
                // We need to communicate the exception thrown to the others and rethrow.
                OPM_BEGIN_PARALLEL_TRY_CATCH()
                    for (const auto& well : well_container_) {
                        const auto mode = WellInterface<TypeTag>::IndividualOrGroup::Individual;
                        const bool changed_well = well->updateWellControl(
                            simulator_, mode, this->groupStateHelper(), this->wellState()
                        );
                        if (changed_well) {
                            changed_well_individual = changed_well || changed_well_individual;
                        }
                    }
                OPM_END_PARALLEL_TRY_CATCH("BlackoilWellModel: updating well controls failed: ",
                                        simulator_.gridView().comm());
            }
 
            changed_well_individual = comm.sum(static_cast<int>(changed_well_individual));
            if (changed_well_individual) {
                updateAndCommunicate(episodeIdx);
                changed_well_group = true;
            }
            iter++;
        }
 
        // update wsolvent fraction for REIN wells
        this->updateWsolvent(fieldGroup, episodeIdx,  this->nupcolWellState());
 
        return changed_well_group;
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updateAndCommunicate(const int reportStepIdx)
    {
        this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget*/ true);
 
        // updateWellStateWithTarget might throw for multisegment wells hence we
        // have a parallel try catch here to thrown on all processes.
        OPM_BEGIN_PARALLEL_TRY_CATCH()
        // if a well or group change control it affects all wells that are under the same group
        for (const auto& well : well_container_) {
            // We only want to update wells under group-control here
            const auto& ws = this->wellState().well(well->indexOfWell());
            if (ws.production_cmode ==  Well::ProducerCMode::GRUP ||
                ws.injection_cmode == Well::InjectorCMode::GRUP)
            {
                well->updateWellStateWithTarget(
                    simulator_, this->groupStateHelper(), this->wellState()
                );
            }
        }
        OPM_END_PARALLEL_TRY_CATCH("BlackoilWellModel::updateAndCommunicate failed: ",
                                   simulator_.gridView().comm())
        this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget*/ true);
    }
 
    template<typename TypeTag>
    bool
    BlackoilWellModel<TypeTag>::
    updateGroupControls(const Group& group,
                        DeferredLogger& deferred_logger,
                        const int reportStepIdx)
    {
        OPM_TIMEFUNCTION();
        const auto& iterCtx = simulator_.problem().iterationContext();
        bool changed = false;
        // restrict the number of group switches but only after nupcol iterations.
        const int nupcol = this->schedule()[reportStepIdx].nupcol();
        const bool update_group_switching_log = !iterCtx.withinNupcol(nupcol);
        const bool changed_hc = this->checkGroupHigherConstraints(
            group, deferred_logger, reportStepIdx, update_group_switching_log);
        if (changed_hc) {
            changed = true;
            updateAndCommunicate(reportStepIdx);
        }
 
        bool changed_individual =
            BlackoilWellModelConstraints(*this).
                updateGroupIndividualControl(group,
                                             reportStepIdx,
                                             param_.max_number_of_group_switches_,
                                             update_group_switching_log,
                                             this->switched_inj_groups_,
                                             this->switched_prod_groups_,
                                             this->closed_offending_wells_,
                                             this->groupState(),
                                             this->wellState(),
                                             deferred_logger);
 
        if (changed_individual) {
            changed = true;
            updateAndCommunicate(reportStepIdx);
        }
        // call recursively down the group hierarchy
        for (const std::string& groupName : group.groups()) {
            bool changed_this = updateGroupControls(this->schedule().getGroup(groupName, reportStepIdx), deferred_logger, reportStepIdx);
            changed = changed || changed_this;
        }
        return changed;
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updateWellTestState(const double simulationTime, WellTestState& wellTestState)
    {
        OPM_TIMEFUNCTION();
        auto logger_guard = this->groupStateHelper().pushLogger();
        auto& local_deferredLogger = this->groupStateHelper().deferredLogger();
        for (const auto& well : well_container_) {
            const auto& wname = well->name();
            const auto wasClosed = wellTestState.well_is_closed(wname);
            well->checkWellOperability(simulator_,
                                       this->wellState(),
                                       this->groupStateHelper());
            const bool under_zero_target =
                well->wellUnderZeroGroupRateTarget(this->groupStateHelper());
            well->updateWellTestState(this->wellState().well(wname),
                                      simulationTime,
                                      /*writeMessageToOPMLog=*/ true,
                                      /*during_well_test=*/ false,
                                      under_zero_target,
                                      wellTestState,
                                      this->eclipseState().getUnits(),
                                      this->schedule().getStartTime(),
                                      local_deferredLogger);
 
            if (!wasClosed && wellTestState.well_is_closed(wname)) {
                this->closed_this_step_.insert(wname);
 
                // maybe open a new well
                const WellEconProductionLimits& econ_production_limits = well->wellEcl().getEconLimits();
                if (econ_production_limits.validFollowonWell()) {
                    const auto episode_idx = simulator_.episodeIndex();
                    const auto follow_on_well = econ_production_limits.followonWell();
                    if (!this->schedule().hasWell(follow_on_well, episode_idx)) {
                        const auto msg = fmt::format("Well {} was closed. But the given follow on well {} does not exist."
                                                     "The simulator continues without opening a follow on well.",
                                                     wname, follow_on_well);
                        local_deferredLogger.warning(msg);
                    }
                    auto& ws = this->wellState().well(follow_on_well);
                    const bool success = ws.updateStatus(WellStatus::OPEN);
                    if (success) {
                        const auto msg = fmt::format("Well {} was closed. The follow on well {} opens instead.", wname, follow_on_well);
                        local_deferredLogger.info(msg);
                    } else {
                        const auto msg = fmt::format("Well {} was closed. The follow on well {} is already open.", wname, follow_on_well);
                        local_deferredLogger.warning(msg);
                    }
                }
 
            }
        }
 
        for (const auto& [group_name, to] : this->closed_offending_wells_) {
            if (this->hasOpenLocalWell(to.second) &&
                !this->wasDynamicallyShutThisTimeStep(to.second))
            {
                wellTestState.close_well(to.second,
                                         WellTestConfig::Reason::GROUP,
                                         simulationTime);
                this->updateClosedWellsThisStep(to.second);
                const std::string msg =
                    fmt::format("Procedure on exceeding {} limit is WELL for group {}. "
                                "Well {} is {}.",
                                to.first,
                                group_name,
                                to.second,
                                "shut");
                local_deferredLogger.info(msg);
            }
        }
    }
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::computePotentials(const std::size_t widx,
                                                  const WellState<Scalar, IndexTraits>& well_state_copy,
                                                  std::string& exc_msg,
                                                  ExceptionType::ExcEnum& exc_type)
    {
        OPM_TIMEFUNCTION();
        const int np = this->numPhases();
        std::vector<Scalar> potentials;
        const auto& well = well_container_[widx];
        std::string cur_exc_msg;
        auto cur_exc_type = ExceptionType::NONE;
        try {
            well->computeWellPotentials(simulator_, well_state_copy, this->groupStateHelper(), potentials);
        }
        // catch all possible exception and store type and message.
        OPM_PARALLEL_CATCH_CLAUSE(cur_exc_type, cur_exc_msg);
        if (cur_exc_type != ExceptionType::NONE) {
            exc_msg += fmt::format("\nFor well {}: {}", well->name(), cur_exc_msg);
        }
        exc_type = std::max(exc_type, cur_exc_type);
        // Store it in the well state
        // potentials is resized and set to zero in the beginning of well->ComputeWellPotentials
        // and updated only if sucessfull. i.e. the potentials are zero for exceptions
        auto& ws = this->wellState().well(well->indexOfWell());
        for (int p = 0; p < np; ++p) {
            // make sure the potentials are positive
            ws.well_potentials[p] = std::max(Scalar{0.0}, potentials[p]);
        }
    }
 
 
 
    template <typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    calculateProductivityIndexValues(DeferredLogger& deferred_logger)
    {
        for (const auto& wellPtr : this->well_container_) {
            this->calculateProductivityIndexValues(wellPtr.get(), deferred_logger);
        }
    }
 
 
 
 
 
    template <typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    calculateProductivityIndexValuesShutWells(const int reportStepIdx,
                                              DeferredLogger& deferred_logger)
    {
        // For the purpose of computing PI/II values, it is sufficient to
        // construct StandardWell instances only.  We don't need to form
        // well objects that honour the 'isMultisegment()' flag of the
        // corresponding "this->wells_ecl_[shutWell]".
 
        for (const auto& shutWell : this->local_shut_wells_) {
            if (!this->wells_ecl_[shutWell].hasConnections()) {
                // No connections in this well.  Nothing to do.
                continue;
            }
 
            auto wellPtr = this->template createTypedWellPointer
                <StandardWell<TypeTag>>(shutWell, reportStepIdx);
 
            wellPtr->init(this->depth_, this->gravity_, this->B_avg_, true);
 
            this->calculateProductivityIndexValues(wellPtr.get(), deferred_logger);
        }
    }
 
 
 
 
 
    template <typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    calculateProductivityIndexValues(const WellInterface<TypeTag>* wellPtr,
                                     DeferredLogger& deferred_logger)
    {
        wellPtr->updateProductivityIndex(this->simulator_,
                                         this->prod_index_calc_[wellPtr->indexOfWell()],
                                         this->wellState(),
                                         deferred_logger);
    }
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    prepareTimeStep(DeferredLogger& deferred_logger)
    {
        const auto episodeIdx = simulator_.episodeIndex();
 
        // Need to check this before clearing events
        const bool do_prestep_network_rebalance = this->shouldDoPreStepNetworkRebalance_(episodeIdx);
 
        for (const auto& well : well_container_) {
            auto& events = this->wellState().well(well->indexOfWell()).events;
            if (events.hasEvent(WellState<Scalar, IndexTraits>::event_mask)) {
                well->updateWellStateWithTarget(
                    simulator_, this->groupStateHelper(), this->wellState()
                );
                well->updatePrimaryVariables(this->groupStateHelper());
                // There is no new well control change input within a report step,
                // so next time step, the well does not consider to have effective events anymore.
                events.clearEvent(WellState<Scalar, IndexTraits>::event_mask);
            }
            // these events only work for the first time step within the report step
            if (events.hasEvent(ScheduleEvents::REQUEST_OPEN_WELL)) {
                events.clearEvent(ScheduleEvents::REQUEST_OPEN_WELL);
            }
            // solve the well equation initially to improve the initial solution of the well model
            if (param_.solve_welleq_initially_ && well->isOperableAndSolvable()) {
                try {
                    well->solveWellEquation(
                        simulator_, this->groupStateHelper(), this->wellState()
                    );
                } catch (const std::exception& e) {
                    const std::string msg = "Compute initial well solution for " + well->name() + " initially failed. Continue with the previous rates";
                    deferred_logger.warning("WELL_INITIAL_SOLVE_FAILED", msg);
                }
            }
            // If we're using local well solves that include control switches, they also update
            // operability, so reset before main iterations begin
            well->resetWellOperability();
        }
        updatePrimaryVariables();
 
        // Actually do the pre-step network rebalance, using the updated well states and initial solutions
        if (do_prestep_network_rebalance) {
            network_.doPreStepRebalance(deferred_logger);
        }
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updateAverageFormationFactor()
    {
        std::vector< Scalar > B_avg(numConservationQuantities(), Scalar() );
        const auto& grid = simulator_.vanguard().grid();
        const auto& gridView = grid.leafGridView();
        ElementContext elemCtx(simulator_);
 
        OPM_BEGIN_PARALLEL_TRY_CATCH();
        for (const auto& elem : elements(gridView, Dune::Partitions::interior)) {
            elemCtx.updatePrimaryStencil(elem);
            elemCtx.updatePrimaryIntensiveQuantities(/*timeIdx=*/0);
 
            const auto& intQuants = elemCtx.intensiveQuantities(/*spaceIdx=*/0, /*timeIdx=*/0);
            const auto& fs = intQuants.fluidState();
 
            for (unsigned phaseIdx = 0; phaseIdx < FluidSystem::numPhases; ++phaseIdx)
            {
                if (!FluidSystem::phaseIsActive(phaseIdx)) {
                    continue;
                }
 
                const unsigned compIdx = FluidSystem::canonicalToActiveCompIdx(FluidSystem::solventComponentIndex(phaseIdx));
                auto& B  = B_avg[ compIdx ];
 
                B += 1 / fs.invB(phaseIdx).value();
            }
            if constexpr (has_solvent_) {
                auto& B  = B_avg[solventSaturationIdx];
                B += 1 / intQuants.solventInverseFormationVolumeFactor().value();
            }
        }
        OPM_END_PARALLEL_TRY_CATCH("BlackoilWellModel::updateAverageFormationFactor() failed: ", grid.comm())
 
        // compute global average
        grid.comm().sum(B_avg.data(), B_avg.size());
        B_avg_.resize(B_avg.size());
        std::ranges::transform(B_avg, B_avg_.begin(),
                               [gcells = global_num_cells_](const auto bval)
                               { return bval / gcells; });
    }
 
 
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    updatePrimaryVariables()
    {
        for (const auto& well : well_container_) {
            well->updatePrimaryVariables(this->groupStateHelper());
        }
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::extractLegacyCellPvtRegionIndex_()
    {
        const auto& grid = simulator_.vanguard().grid();
        const auto& eclProblem = simulator_.problem();
        const unsigned numCells = grid.size(/*codim=*/0);
 
        this->pvt_region_idx_.resize(numCells);
        for (unsigned cellIdx = 0; cellIdx < numCells; ++cellIdx) {
            this->pvt_region_idx_[cellIdx] =
                eclProblem.pvtRegionIndex(cellIdx);
        }
    }
 
    // The number of components in the model.
    template<typename TypeTag>
    int
    BlackoilWellModel<TypeTag>::numConservationQuantities() const
    {
        // TODO: energy is also a conservation equation, so numConservationQuantities()
        // may need refactoring once it is enabled outside MSW.
 
        // The numPhases() functions returns 1-3, depending on which
        // of the (oil, water, gas) phases are active. For each of those phases,
        // if the phase is active the corresponding component is present and
        // conserved.
        // Apart from (oil, water, gas), in the current well model only solvent
        // is explicitly modelled as a conserved quantity (polymer, energy, salt
        // etc. are not), unlike the reservoir part where all such quantities are
        // conserved. This function must therefore be updated when/if we add
        // more conserved quantities in the well model.
        return this->numPhases() + has_solvent_;
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::extractLegacyDepth_()
    {
        const auto& eclProblem = simulator_.problem();
        depth_.resize(local_num_cells_);
        for (unsigned cellIdx = 0; cellIdx < local_num_cells_; ++cellIdx) {
            depth_[cellIdx] = eclProblem.dofCenterDepth(cellIdx);
        }
    }
 
    template<typename TypeTag>
    const WellInterface<TypeTag>&
    BlackoilWellModel<TypeTag>::
    getWell(const std::string& well_name) const
    {
        // finding the iterator of the well in wells_ecl
        const auto well =
            std::ranges::find_if(well_container_,
                                 [&well_name](const WellInterfacePtr& elem) -> bool
                                 { return elem->name() == well_name; });
 
        assert(well != well_container_.end());
 
        return **well;
    }
 
    template <typename TypeTag>
    int
    BlackoilWellModel<TypeTag>::
    reportStepIndex() const
    {
        return std::max(this->simulator_.episodeIndex(), 0);
    }
 
 
 
 
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    calcResvCoeff(const int fipnum,
                  const int pvtreg,
                  const std::vector<Scalar>& production_rates,
                  std::vector<Scalar>& resv_coeff) const
    {
        rateConverter_->calcCoeff(fipnum, pvtreg, production_rates, resv_coeff);
    }
 
    template<typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    calcInjResvCoeff(const int fipnum,
                     const int pvtreg,
                     std::vector<Scalar>& resv_coeff) const
    {
        rateConverter_->calcInjCoeff(fipnum, pvtreg, resv_coeff);
    }
 
 
    template <typename TypeTag>
    void
    BlackoilWellModel<TypeTag>::
    computeWellTemperature()
    {
        if constexpr (energyModuleType_ == EnergyModules::FullyImplicitThermal) {
            const int np = this->numPhases();
            const int nw = this->numLocalWells();
            for (auto wellID = 0*nw; wellID < nw; ++wellID) {
                const Well& well = this->wells_ecl_[wellID];
                auto& ws = this->wellState().well(wellID);
                if (well.isInjector()) {
                    if (ws.status != WellStatus::STOP) {
                        this->wellState().well(wellID).temperature = well.inj_temperature();
                        continue;
                    }
                }
                std::array<Scalar,2> weighted{0.0,0.0};
                auto& [weighted_temperature, total_weight] = weighted;
                const auto& well_info = this->local_parallel_well_info_[wellID].get();
                using int_type = decltype(this->well_perf_data_[wellID].size());
                for (int_type perf = 0, end_perf = this->well_perf_data_[wellID].size(); perf < end_perf; ++perf) {
                    const int cell_idx = this->well_perf_data_[wellID][perf].cell_index;
                    const auto& intQuants = simulator_.model().intensiveQuantities(cell_idx, /*timeIdx=*/0);
                    const auto& fs = intQuants.fluidState();
                    Scalar weight_factor = computeTemperatureWeightFactor(perf, np, fs, ws);
                    total_weight += weight_factor;
                    weighted_temperature += weight_factor * fs.temperature(/*phaseIdx*/0).value();
                }
                well_info.communication().sum(weighted.data(), 2);
                this->wellState().well(wellID).temperature = weighted_temperature / total_weight;
            }
        }
    }
 
 
    template <typename TypeTag>
    [[nodiscard]] auto BlackoilWellModel<TypeTag>::rsConstInfo() const
        -> typename WellState<Scalar,IndexTraits>::RsConstInfo
    {
        if (! FluidSystem::phaseIsActive(FluidSystem::oilPhaseIdx) ||
            ! FluidSystem::enableConstantRs())
        {
            return {};
        }
 
        const auto& rsConstTables = this->eclState_
            .getTableManager().getRsconstTables();
 
        if (rsConstTables.empty() ||
            (rsConstTables[0].numRows() != std::size_t{1}))
        {
            return {};
        }
 
        const auto rsConst = rsConstTables[0].getColumn(0).front();
 
        return { true, static_cast<Scalar>(rsConst) };
    }
 
    // Private helper methods (alphabetical order)
    // --------------------------------------------
 
    template <typename TypeTag>
    void BlackoilWellModel<TypeTag>::
    assignWellTracerRates_(data::Wells& wsrpt) const
    {
        const auto reportStepIdx = static_cast<unsigned int>(this->reportStepIndex());
        const auto& trMod = this->simulator_.problem().tracerModel();
 
        BlackoilWellModelGeneric<Scalar, IndexTraits>::assignWellTracerRates(wsrpt, trMod.getWellTracerRates(), reportStepIdx);
        BlackoilWellModelGeneric<Scalar, IndexTraits>::assignWellTracerRates(wsrpt, trMod.getWellFreeTracerRates(), reportStepIdx);
        BlackoilWellModelGeneric<Scalar, IndexTraits>::assignWellTracerRates(wsrpt, trMod.getWellSolTracerRates(), reportStepIdx);
 
        this->assignMswTracerRates(wsrpt, trMod.getMswTracerRates(), reportStepIdx);
    }
 
    template <typename TypeTag>
    void BlackoilWellModel<TypeTag>::
    assignWellSpeciesRates_(data::Wells& wsrpt) const
    {
        const auto reportStepIdx = static_cast<unsigned int>(this->reportStepIndex());
        const auto& geochemMod = this->simulator_.problem().geochemistryModel();
 
        BlackoilWellModelGeneric<Scalar, IndexTraits>::assignWellTracerRates(wsrpt, geochemMod.getWellSpeciesRates(), reportStepIdx);
 
        this->assignMswTracerRates(wsrpt, geochemMod.getMswSpeciesRates(), reportStepIdx);
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::isRescoupMasterCoupledNetworkIteration_() const
    {
#ifdef RESERVOIR_COUPLING_ENABLED
        return this->rescoupHelper_.masterIsInCoupledNetworkIteration();
#else
        return false;
#endif
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::isRescoupSlaveCoupledNetworkIteration_() const
    {
        // True when the slave is on the first substep of a sync step AND the
        // master has not yet signaled termination.  Gates the per-iteration
        // master->slave node-pressure receive at the top of
        // updateWellControlsAndNetworkIteration().  The outer loop exit on
        // the slave is driven by the master's is_final flag (propagated to
        // local variable "more_network_update" at the end of updateWellControlsAndNetworkIteration(),
        // not by the slave's local network convergence.  The master's own max_iter
        // bounds the iteration count from above, so the slave skips the local max_iter check entirely
        // and lets the master signal termination.
#ifdef RESERVOIR_COUPLING_ENABLED
        return this->isRescoupSlaveOnSyncStepFirstSubstep_()
            && this->reservoirCouplingSlave().connectedToMasterCoupledNetwork()
            && !this->reservoirCouplingSlave().lastReceivedMasterGroupNodePressuresIsFinal();
#else
        return false;
#endif
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::isRescoupSlaveOnSyncStepFirstSubstep_() const
    {
        // True when the slave is on the first substep of a sync step,
        // regardless of is_final state.  Gates post-Newton handling at the
        // end of updateWellControlsAndNetworkIteration(), which must run on
        // the terminating iteration too (so the slave can set
        // more_network_update = false and exit its outer loop).
#ifdef RESERVOIR_COUPLING_ENABLED
        return this->isReservoirCouplingSlave()
            && this->reservoirCouplingSlave().isFirstSubstepOfSyncTimestep();
#else
        return false;
#endif
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::isRescoupSlaveConnectedToMasterNetwork_() const
    {
#ifdef RESERVOIR_COUPLING_ENABLED
        return this->isReservoirCouplingSlave()
            && this->reservoirCouplingSlave().connectedToMasterCoupledNetwork();
#else
        return false;
#endif
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::
    maybeSendSlaveGroupFlowToMaster_([[maybe_unused]] const int reportStepIdx)
    {
#ifdef RESERVOIR_COUPLING_ENABLED
        // For a rescoup slave: after the well-solve in
        // prepareWellsBeforeAssembling() has produced fresh rates under the
        // new THP, ship them back to the master and force one more outer
        // iteration so we re-enter updateWellControlsAndNetworkIteration() to receive the next pressures.
        // When the just-received message had is_final = true, we skip the
        // send and let the slave's outer loop exit naturally.
        assert(this->isReservoirCouplingSlave());
        const bool is_final =
            this->reservoirCouplingSlave().lastReceivedMasterGroupNodePressuresIsFinal();
        if (!is_final) {
            this->updateAndCommunicateGroupData(reportStepIdx, /*update_wellgrouptarget=*/false);
            this->rescoupHelper_.sendSlaveGroupDataToMaster();
            // The master turns the rates just sent into fresh injection targets
            // for the groups it controls through a derived GCONINJE mode, and
            // sends them straight back.  See
            // BlackoilWellModelRescoup::refreshAndSendInjectionTargets_().
            this->rescoupHelper_.receiveGroupConstraintsFromMaster();
            return /*more_network_update=*/true;
        }
        return /*more_network_update=*/false;
#else
        return /*more_network_update=*/false;
#endif
    }
 
    template <typename TypeTag>
    void BlackoilWellModel<TypeTag>::
    sendSlaveNetworkLoopTerminationSignal_()
    {
#ifdef RESERVOIR_COUPLING_ENABLED
        // When the master's outer loop exits without having sent is_final = true (e.g. max_iter
        // exceeded with the network still unconverged), the slave is stuck
        // waiting on its next receive.  Fire one final pressure send to
        // unblock it.
        assert(this->isReservoirCouplingMaster());
        this->rescoupHelper_.sendMasterGroupNodePressuresToSlaves(/*is_final=*/true);
#endif
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::
    shouldDoPreStepNetworkRebalance_(const int episodeIdx) const
    {
        // Rebalance the network initially if any wells in the network have status changes
        //
        // The rebalance is skipped only for *coupled-network participants*: its
        // inner updateWellControlsAndNetwork call would run the cross-rescoup
        // pressure/rate exchange, but needPreStepRebalance is collectivised only
        // over the local OPM communicator -- not across the rescoup boundary --
        // so a coupled master and slave may disagree on whether to enter the
        // rebalance, deadlocking the exchange.  A non-participant (a master with
        // no master-group network leaves, or a slave not connected to the master
        // network) does no cross-rescoup MPI in the network solve, so it is safe
        // to rebalance like a standalone process and we no longer skip it.
        return param_.pre_solve_network_
            && this->network_.needPreStepRebalance(episodeIdx)
            && !this->isRescoupCoupledNetworkParticipant_();
    }
 
    template <typename TypeTag>
    bool BlackoilWellModel<TypeTag>::isRescoupCoupledNetworkParticipant_() const
    {
#ifdef RESERVOIR_COUPLING_ENABLED
        if (this->isReservoirCouplingMaster()) {
            return this->rescoupHelper_.masterNetworkHasMasterGroupLeaves();
        }
        if (this->isReservoirCouplingSlave()) {
            return this->reservoirCouplingSlave().connectedToMasterCoupledNetwork();
        }
        return false;
#else
        return false;
#endif
    }
 
    template <typename TypeTag>
    void BlackoilWellModel<TypeTag>::
    updateNetworkActiveState_()
    {
        // Refresh the network's cached `active_` flag once per timestep
        // init.  updateActiveState's inputs (Schedule network, well list,
        // per-well groupName/predictionMode, and rescoup master groups)
        // are constant within a substep; ACTIONX-driven well structure
        // changes propagate via wellStructureChangedDynamically_ at the
        // top of beginTimeStep, before the first assemble() of the new
        // substep.  Doing this in assemble() rather than only in
        // prepareTimeStep() covers the case of a rescoup master with no
        // local wells, where prepareTimeStep() is skipped (gated on wellsActive()).
        const int episodeIdx = this->simulator_.episodeIndex();
        this->network_.updateActiveState(episodeIdx);
    }
 
} // namespace Opm
 
#endif // OPM_BLACKOILWELLMODEL_IMPL_HEADER_INCLUDED