Skip to content

Commit

Permalink
Enable saving and restoring subsimulator state
Browse files Browse the repository at this point in the history
This is the first step towards closing #756.  I've added functions
corresponding to FMI 2.0's `fmi2{Get,Set,Free}FMUstate()` throughout the
various layers of subsimulator interfaces and implementations:

* `cosim::slave` and its implementation in
   `cosim::fmi::v2::slave_instance`
* `cosim::simulator` and its implementation in `cosim::slave_simulator`

This led me to also remove the `slave_state` and `state_guard` stuff
that was in `slave_simulator.{hpp,cpp}`. The overloading of the "state"
terminology became confusing, and it seemed like it was a lot of code
for very little gain. (It was supposed to be a check of correct API
usage, but I can't remember it ever actually catching a bug.)

This commit also fixes #762.
  • Loading branch information
kyllingstad committed Jun 24, 2024
1 parent 6682586 commit bc87812
Show file tree
Hide file tree
Showing 18 changed files with 522 additions and 231 deletions.
53 changes: 53 additions & 0 deletions include/cosim/algorithm/simulator.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -133,6 +133,59 @@ class simulator : public manipulable
virtual step_result do_step(
time_point currentT,
duration deltaT) = 0;

/// A type used for references to saved states (see `save_state()`).
using state_index = int;

/**
* Saves the current state.
*
* This will create and store a copy of the simulator's current internal
* state, so that it can be restored at a later time. The copy is stored
* internally in the simulator, and must be referred to by the returned
* `state_index`. The index is only valid for this particular simulator.
*
* The function may be called at any point after `setup()` has been called.
*
* \pre `this->model_description().can_save_state`
*/
virtual state_index save_state() = 0;

/**
* Saves the current state, overwriting a previously-saved state.
*
* This function does the same as `save_state()`, except that it
* overwrites a state which has previously been stored by that function.
* The old index thereafter refers to the newly-saved state.
*
* \pre `this->model_description().can_save_state`
*/
virtual void save_state(state_index stateIndex) = 0;

/**
* Restores a previously-saved state.
*
* This restores the simulator to a state which has previously been saved
* using `save_state()`.
*
* Note that the saved state is supposed to be the *complete and exact*
* state of the simulator at the moment `save_state()` was called. For example,
* if the state was saved while the simulator was in initialisation mode
* (between `setup()` and `start_simulation()`), then it will be restored
* in that mode, and `start_simulation()` must be called before the
* simulation can start. Similarly, if it is saved at logical time `t`,
* then the first `do_step()` call after restoration must start at `t`.
*/
virtual void restore_state(state_index stateIndex) = 0;

/**
* Frees all resources (e.g. memory) associated with a saved state.
*
* After this, the state may no longer be restored with `restore_state()`,
* nor may it be overwritten with `save_state(state_index)`. The
* implementation is free to reuse the same `state_index` at a later point.
*/
virtual void release_state(state_index stateIndex) = 0;
};

} // namespace cosim
Expand Down
5 changes: 5 additions & 0 deletions include/cosim/fmi/v1/fmu.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,11 @@ class slave_instance : public fmi::slave_instance
gsl::span<const value_reference> variables,
gsl::span<const std::string> values) override;

state_index save_state() override;
void save_state(state_index overwriteState) override;
void restore_state(state_index state) override;
void release_state(state_index state) override;

// fmi::slave_instance methods
std::shared_ptr<fmi::fmu> fmu() const override
{
Expand Down
18 changes: 18 additions & 0 deletions include/cosim/fmi/v2/fmu.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,11 @@
#include <string>
#include <string_view>
#include <vector>
#include <queue>


struct fmi2_import_t;
using fmi2_FMU_state_t = void*;


namespace cosim
Expand Down Expand Up @@ -165,6 +167,11 @@ class slave_instance : public fmi::slave_instance
gsl::span<const value_reference> variables,
gsl::span<const std::string> values) override;

state_index save_state() override;
void save_state(state_index stateIndex) override;
void restore_state(state_index stateIndex) override;
void release_state(state_index stateIndex) override;

// fmi::slave_instance methods
std::shared_ptr<fmi::fmu> fmu() const override
{
Expand All @@ -178,13 +185,24 @@ class slave_instance : public fmi::slave_instance
fmi2_import_t* fmilib_handle() const;

private:
struct saved_state
{
fmi2_FMU_state_t fmuState = nullptr;
bool setupComplete = false;
bool simStarted = false;
};
void copy_current_state(saved_state& state);

std::shared_ptr<v2::fmu> fmu_;
fmi2_import_t* handle_;

bool setupComplete_ = false;
bool simStarted_ = false;

std::string instanceName_;

std::vector<saved_state> savedStates_;
std::queue<state_index> savedStatesFreelist_;
};


Expand Down
3 changes: 3 additions & 0 deletions include/cosim/model_description.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -195,6 +195,9 @@ struct model_description

/// Variable descriptions.
std::vector<variable_description> variables;

/// Whether saving of state is supported.
bool can_save_state = false;
};

/// Getter for returning a variable description.
Expand Down
54 changes: 54 additions & 0 deletions include/cosim/slave.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
namespace cosim
{


/**
* An interface for classes that represent co-simulation slaves.
*
Expand Down Expand Up @@ -276,6 +277,59 @@ class slave
set_boolean_variables(boolean_variables, boolean_values);
set_string_variables(string_variables, string_values);
}

/// A type used for references to saved states (see `save_state()`).
using state_index = int;

/**
* Saves the current state.
*
* This will create and store a copy of the slave's current internal
* state, so that it can be restored at a later time. The copy is stored
* internally in the slave, and must be referred to by the returned
* `state_index`. The index is only valid for this particular slave.
*
* The function may be called at any point after `setup()` has been called.
*
* \pre `this->model_description().can_save_state`
*/
virtual state_index save_state() = 0;

/**
* Saves the current state, overwriting a previously-saved state.
*
* This function does the same as `save_state()`, except that it
* overwrites a state which has previously been stored by that function.
* The old index thereafter refers to the newly-saved state.
*
* \pre `this->model_description().can_save_state`
*/
virtual void save_state(state_index stateIndex) = 0;

/**
* Restores a previously-saved state.
*
* This restores the slave to a state which has previously been saved
* using `save_state()`.
*
* Note that the saved state is supposed to be the *complete and exact*
* state of the slave at the moment `save_state()` was called. For example,
* if the state was saved while the slave was in initialisation mode
* (between `setup()` and `start_simulation()`), then it will be restored
* in that mode, and `start_simulation()` must be called before the
* simulation can start. Similarly, if it is saved at logical time `t`,
* then the first `do_step()` call after restoration must start at `t`.
*/
virtual void restore_state(state_index stateIndex) = 0;

/**
* Frees all resources (e.g. memory) associated with a saved state.
*
* After this, the state may no longer be restored with `restore_state()`,
* nor may it be overwritten with `save_state(state_index)`. The
* implementation is free to reuse the same `state_index` at a later point.
*/
virtual void release_state(state_index stateIndex) = 0;
};


Expand Down
32 changes: 32 additions & 0 deletions src/cosim/fmi/v1/fmu.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -549,6 +549,38 @@ void slave_instance::set_string_variables(
}


slave::state_index slave_instance::save_state()
{
throw error(
make_error_code(errc::unsupported_feature),
"Getting and setting state not supported");
}


void slave_instance::save_state(state_index)
{
throw error(
make_error_code(errc::unsupported_feature),
"Getting and setting state not supported");
}


void slave_instance::restore_state(state_index)
{
throw error(
make_error_code(errc::unsupported_feature),
"Getting and setting state not supported");
}


void slave_instance::release_state(state_index)
{
throw error(
make_error_code(errc::unsupported_feature),
"Getting and setting state not supported");
}


std::shared_ptr<v1::fmu> slave_instance::v1_fmu() const
{
return fmu_;
Expand Down
64 changes: 64 additions & 0 deletions src/cosim/fmi/v2/fmu.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,8 @@ fmu::fmu(
<< vd.name << " will be ignored";
}
}
modelDescription_.can_save_state =
fmi2_import_get_capability(handle_, fmi2_cs_canGetAndSetFMUstate) != 0;
}


Expand Down Expand Up @@ -569,6 +571,55 @@ void slave_instance::set_string_variables(
}


slave::state_index slave_instance::save_state()
{
saved_state currentState;
copy_current_state(currentState);
if (savedStatesFreelist_.empty()) {
savedStates_.push_back(currentState);
return static_cast<state_index>(savedStates_.size()-1);
} else {
const auto stateIndex = savedStatesFreelist_.front();
savedStatesFreelist_.pop();
savedStates_.at(stateIndex) = currentState;
return stateIndex;
}
}


void slave_instance::save_state(state_index stateIndex)
{
copy_current_state(savedStates_.at(stateIndex));
}


void slave_instance::restore_state(state_index stateIndex)
{
const auto& state = savedStates_.at(stateIndex);
const auto status = fmi2_import_set_fmu_state(handle_, state.fmuState);
if (status != fmi2_status_ok && status != fmi2_status_warning) {
throw error(
make_error_code(errc::model_error),
last_log_record(instanceName_).message);
}
setupComplete_ = state.setupComplete;
simStarted_ = state.simStarted;
}


void slave_instance::release_state(state_index state)
{
auto fmuState = savedStates_.at(state).fmuState;
savedStatesFreelist_.push(state);
const auto status = fmi2_import_free_fmu_state(handle_, &fmuState);
if (status != fmi2_status_ok && status != fmi2_status_warning) {
throw error(
make_error_code(errc::model_error),
last_log_record(instanceName_).message);
}
}


std::shared_ptr<v2::fmu> slave_instance::v2_fmu() const
{
return fmu_;
Expand All @@ -581,6 +632,19 @@ fmi2_import_t* slave_instance::fmilib_handle() const
}


void slave_instance::copy_current_state(saved_state& state)
{
const auto status = fmi2_import_get_fmu_state(handle_, &state.fmuState);
if (status != fmi2_status_ok && status != fmi2_status_warning) {
throw error(
make_error_code(errc::model_error),
last_log_record(instanceName_).message);
}
state.setupComplete = setupComplete_;
state.simStarted = simStarted_;
}


} // namespace v2
} // namespace fmi
} // namespace cosim
1 change: 1 addition & 0 deletions src/cosim/proxy/remote_fmu.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@ std::unique_ptr<cosim::model_description> parse_model_description(const proxyfmu
_md->author = md.author;
_md->name = md.modelName;
_md->description = md.description;
_md->can_save_state = false; // Not supported by proxyfmu

for (auto& var : md.modelVariables) {
cosim::variable_description vd;
Expand Down
28 changes: 28 additions & 0 deletions src/cosim/proxy/remote_slave.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -202,6 +202,34 @@ void cosim::proxy::remote_slave::set_string_variables(gsl::span<const cosim::val
}
}

cosim::slave::state_index cosim::proxy::remote_slave::save_state()
{
throw error(
make_error_code(errc::unsupported_feature),
"Proxyfmu does not support state saving");
}

void cosim::proxy::remote_slave::save_state(state_index)
{
throw error(
make_error_code(errc::unsupported_feature),
"Proxyfmu does not support state saving");
}

void cosim::proxy::remote_slave::restore_state(state_index)
{
throw error(
make_error_code(errc::unsupported_feature),
"Proxyfmu does not support state saving");
}

void cosim::proxy::remote_slave::release_state(state_index)
{
throw error(
make_error_code(errc::unsupported_feature),
"Proxyfmu does not support state saving");
}

cosim::proxy::remote_slave::~remote_slave()
{
remote_slave::end_simulation();
Expand Down
8 changes: 8 additions & 0 deletions src/cosim/proxy/remote_slave.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,14 @@ class remote_slave : public slave
void set_string_variables(gsl::span<const value_reference> variables,
gsl::span<const std::string> values) override;

state_index save_state() override;

void save_state(state_index stateIndex) override;

void restore_state(state_index stateIndex) override;

void release_state(state_index stateIndex) override;

~remote_slave() override;

private:
Expand Down
Loading

0 comments on commit bc87812

Please sign in to comment.