mirror of
https://github.com/OPM/opm-simulators.git
synced 2024-12-28 18:21:00 -06:00
141 lines
3.5 KiB
C++
141 lines
3.5 KiB
C++
/*
|
|
Copyright 2021 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/>.
|
|
*/
|
|
|
|
#if HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif // HAVE_CONFIG_H
|
|
|
|
#include <cstddef>
|
|
#include <stdexcept>
|
|
|
|
|
|
#include <opm/simulators/wells/ALQState.hpp>
|
|
|
|
namespace Opm {
|
|
|
|
double ALQState::get(const std::string& wname) const {
|
|
auto iter = this->current_alq_.find(wname);
|
|
if (iter != this->current_alq_.end())
|
|
return iter->second;
|
|
|
|
auto default_iter = this->default_alq_.find(wname);
|
|
if (default_iter != this->default_alq_.end())
|
|
return default_iter->second;
|
|
|
|
throw std::logic_error("No ALQ value registered for well: " + wname);
|
|
}
|
|
|
|
void ALQState::update_default(const std::string& wname, double value) {
|
|
auto default_iter = this->default_alq_.find(wname);
|
|
if (default_iter == this->default_alq_.end() || default_iter->second != value) {
|
|
this->default_alq_.insert_or_assign(wname, value);
|
|
this->current_alq_.insert_or_assign(wname, value);
|
|
}
|
|
}
|
|
|
|
void ALQState::set(const std::string& wname, double value) {
|
|
this->current_alq_[wname] = value;
|
|
}
|
|
|
|
int ALQState::get_debug_counter() {
|
|
return this->debug_counter_;
|
|
}
|
|
|
|
int ALQState::update_debug_counter() {
|
|
this->debug_counter_++;
|
|
return this->debug_counter_;
|
|
}
|
|
|
|
void ALQState::set_debug_counter(int value) {
|
|
this->debug_counter_ = value;
|
|
}
|
|
|
|
namespace {
|
|
|
|
int get_counter(const std::map<std::string, int>& count_map, const std::string& wname) {
|
|
auto count_iter = count_map.find(wname);
|
|
if (count_iter == count_map.end())
|
|
return 0;
|
|
return count_iter->second;
|
|
}
|
|
|
|
}
|
|
|
|
bool ALQState::oscillation(const std::string& wname) const {
|
|
auto inc_count = get_counter(this->alq_increase_count_, wname);
|
|
if (inc_count == 0)
|
|
return false;
|
|
|
|
auto dec_count = get_counter(this->alq_decrease_count_, wname);
|
|
return dec_count >= 1;
|
|
}
|
|
|
|
|
|
void ALQState::update_count(const std::string& wname, bool increase) {
|
|
if (increase)
|
|
this->alq_increase_count_[wname] += 1;
|
|
else
|
|
this->alq_decrease_count_[wname] += 1;
|
|
|
|
}
|
|
|
|
|
|
void ALQState::reset_count() {
|
|
this->alq_decrease_count_.clear();
|
|
this->alq_increase_count_.clear();
|
|
}
|
|
|
|
|
|
int ALQState::get_increment_count(const std::string& wname) const {
|
|
return get_counter(this->alq_increase_count_, wname);
|
|
}
|
|
|
|
int ALQState::get_decrement_count(const std::string& wname) const {
|
|
return get_counter(this->alq_decrease_count_, wname);
|
|
}
|
|
|
|
std::size_t ALQState::pack_size() const {
|
|
return this->current_alq_.size();
|
|
}
|
|
|
|
std::size_t ALQState::pack_data(double * data) const {
|
|
std::size_t index = 0;
|
|
for (const auto& [_, value] : this->current_alq_) {
|
|
(void)_;
|
|
data[index++] = value;
|
|
}
|
|
return index;
|
|
}
|
|
|
|
std::size_t ALQState::unpack_data(const double * data) {
|
|
std::size_t index = 0;
|
|
for (auto& [_, value] : this->current_alq_) {
|
|
(void)_;
|
|
value = data[index++];
|
|
}
|
|
return index;
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|