ReservoirCoupling.hpp

Go to the documentation of this file.

/*
  Copyright 2024 Equinor ASA
 
  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_RESERVOIR_COUPLING_HPP
#define OPM_RESERVOIR_COUPLING_HPP
#include <opm/simulators/utils/DeferredLogger.hpp>
#include <opm/input/eclipse/Schedule/Group/Group.hpp>
#include <opm/input/eclipse/Schedule/Group/GuideRate.hpp>
 
#include <dune/common/parallel/mpitraits.hh>
 
#include <mpi.h>
#include <cmath>
#include <iostream>
#include <memory>
#include <stdexcept>
#include <vector>
 
namespace Opm {
namespace ReservoirCoupling {
 
class Logger {
public:
    Logger() = default;
    void clearDeferredLogger() { deferred_logger_ = nullptr; }
    DeferredLogger& deferredLogger() { return *deferred_logger_; }
    DeferredLogger& deferredLogger() const { return *deferred_logger_; }
    bool haveDeferredLogger() const { return deferred_logger_ != nullptr; }
    void info(const std::string &msg) const;
    void setDeferredLogger(DeferredLogger *deferred_logger) { deferred_logger_ = deferred_logger; }
 
private:
    DeferredLogger *deferred_logger_ = nullptr;
};
 
class ScopedLoggerGuard {
public:
    explicit ScopedLoggerGuard(Logger& logger, DeferredLogger* deferred_logger)
        : logger_(&logger)
    {
        logger_->setDeferredLogger(deferred_logger);
    }
 
    ~ScopedLoggerGuard() {
        // Only clear if we still own the logger (not moved-from)
        if (logger_) {
            logger_->clearDeferredLogger();
        }
    }
 
    // Prevent copying to ensure single ownership
    ScopedLoggerGuard(const ScopedLoggerGuard&) = delete;
    ScopedLoggerGuard& operator=(const ScopedLoggerGuard&) = delete;
 
    // Enable moving - required for returning from functions and std::optional
    ScopedLoggerGuard(ScopedLoggerGuard&& other) noexcept
        : logger_(other.logger_)
    {
        // Transfer ownership: moved-from object becomes inactive and won't clear the logger
        other.logger_ = nullptr;
    }
 
    ScopedLoggerGuard& operator=(ScopedLoggerGuard&& other) noexcept {
        if (this != &other) {
            // Clean up current logger before taking ownership of new one
            if (logger_) {
                logger_->clearDeferredLogger();
            }
            // Transfer ownership from other
            logger_ = other.logger_;
            other.logger_ = nullptr;
        }
        return *this;
    }
 
private:
    // Use pointer instead of reference to enable move semantics
    // (references cannot be reassigned, which is required for move operations)
    Logger* logger_{nullptr};
};
 
enum class MessageTag : int {
    InjectionGroupTargets,
    MasterGroupNames,
    MasterGroupNamesSize,
    MasterStartOfReportStep,
    NumSlaveGroupTargets,
    ProductionGroupTargets,
    SlaveActivationDate,
    SlaveActivationHandshake,
    SlaveInjectionData,
    SlaveProcessTermination,
    SlaveName,
    SlaveNameSize,
    SlaveNextReportDate,
    SlaveNextTimeStep,
    SlaveProductionData,
    SlaveSimulationStartDate,
    SlaveStartOfReportStep,
};
 
enum class Phase : std::size_t {
    Oil = 0,  // Matches Opm::Phase::OIL
    Gas,      // Matches Opm::Phase::GAS
    Water,    // Matches Opm::Phase::WATER
    Count
};
 
template <class Scalar>
struct InjectionRates {
    InjectionRates() = default;
 
    std::array<Scalar, static_cast<std::size_t>(Phase::Count)> rate{};
    [[nodiscard]] Scalar& operator[](Phase p)       noexcept { return rate[static_cast<std::size_t>(p)]; }
    [[nodiscard]] Scalar  operator[](Phase p) const noexcept { return rate[static_cast<std::size_t>(p)]; }
};
 
 
// Used to communicate potentials for oil, gas, and water rates between slave and master processes
template <class Scalar>
struct Potentials {
    std::array<Scalar, static_cast<std::size_t>(Phase::Count)> rate{};
 
    [[nodiscard]] Scalar& operator[](Phase p)       noexcept { return rate[static_cast<std::size_t>(p)]; }
    [[nodiscard]] Scalar  operator[](Phase p) const noexcept { return rate[static_cast<std::size_t>(p)]; }
};
 
template <class Scalar>
struct ProductionRates {
    ProductionRates() = default;
 
    explicit ProductionRates(const GuideRate::RateVector& rate_vector)
        : rate{static_cast<Scalar>(rate_vector.oil_rat),
               static_cast<Scalar>(rate_vector.gas_rat),
               static_cast<Scalar>(rate_vector.wat_rat)}
    {}
 
    std::array<Scalar, static_cast<std::size_t>(Phase::Count)> rate{};
    [[nodiscard]] Scalar& operator[](Phase p)       noexcept { return rate[static_cast<std::size_t>(p)]; }
    [[nodiscard]] Scalar  operator[](Phase p) const noexcept { return rate[static_cast<std::size_t>(p)]; }
};
 
// Slave group production data sent to the corresponding master group for target calculation.
template <class Scalar>
struct SlaveGroupProductionData {
    // Group production potentials are used by the master group for guiderate calculations
    Potentials<Scalar> potentials;
    // Production rates are used by the master group in guiderate calculations
    // when converting the guide rate target to the phase of the master group.
    ProductionRates<Scalar> surface_rates;  // Surface production rates by phase
    // Individual phase reservoir production rates - needed when master's parent group
    // has RESV control mode, so the conversion uses slave's PVT properties
    ProductionRates<Scalar> reservoir_rates;  // Reservoir production rates by phase
    Scalar voidage_rate{0.0};               // Reservoir voidage replacement rate
    Scalar gas_reinjection_rate{0.0};       // Reinjection (surface) rate for the gas phase
};
 
// Slave group injection data sent to the corresponding master group for target calculation.
template <class Scalar>
struct SlaveGroupInjectionData {
    InjectionRates<Scalar> surface_rates;    // Surface injection rates by phase
    InjectionRates<Scalar> reservoir_rates;  // Reservoir injection rates by phase
};
 
template <class Scalar>
struct InjectionGroupTarget {
    // To save memory and avoid varying size of the struct when serializing
    // and deserializing the group name, we use an index instead of the full name.
    std::size_t group_name_idx;   // Index of group name in the master group names vector
    Scalar target;                // Target rate for the group
    Group::InjectionCMode cmode;  // Control mode for the group
    Phase phase;                  // Phase the target applies to
};
 
template <class Scalar>
struct ProductionGroupTarget {
    // To save memory and avoid varying size of the struct when serializing
    // and deserializing the group name, we use an index instead of the full name.
    std::size_t group_name_idx;   // Index of group name in the master group names vector
    Scalar target;                // Target rate for the group
    Group::ProductionCMode cmode;  // Control mode for the group
};
 
// Helper functions
Phase convertPhaseToReservoirCouplingPhase(::Opm::Phase phase);
void customErrorHandler_(MPI_Comm* comm, int* err, const std::string &msg);
void customErrorHandlerSlave_(MPI_Comm* comm, int* err, ...);
void customErrorHandlerMaster_(MPI_Comm* comm, int* err, ...);
void setErrhandler(MPI_Comm comm, bool is_master);
std::pair<std::vector<char>, std::size_t> serializeStrings(const std::vector<std::string>& data);
 
struct Seconds {
    static constexpr double abstol = 1e-15;
 
    static constexpr double reltol = 1e-15;
 
    static bool compare_eq(double a, double b);
 
    static bool compare_gt(double a, double b);
 
    static bool compare_gt_or_eq(double a, double b);
 
    static bool compare_lt(double a, double b);
 
    static bool compare_lt_or_eq(double a, double b);
};
 
} // namespace ReservoirCoupling
} // namespace Opm
 
#endif // OPM_RESERVOIR_COUPLING_HPP