Addressed comments - 02

open-simulation-platform · May 7, 2024 · 51e95bf · 51e95bf
1 parent 8519ba2
commit 51e95bf
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 8 deletions.
diff --git a/include/cosim/timer.hpp b/include/cosim/timer.hpp
@@ -44,7 +44,7 @@ struct real_time_config
      *  When the value is greater than zero, the real time factor is computed periodically using the
      *  specified time instead of the `steps_to_monitor` value.
      */
-    std::atomic<std::chrono::milliseconds> sampling_period_to_monitor = std::chrono::milliseconds(-1);
+    std::atomic<int> sampling_period_to_monitor = -1;
 };
 
 } // namespace cosim
@@ -63,7 +63,7 @@ class hash<cosim::real_time_config>
         boost::hash_combine(seed, v.real_time_simulation.load());
         boost::hash_combine(seed, v.real_time_factor_target.load());
         boost::hash_combine(seed, v.steps_to_monitor.load());
-        boost::hash_combine(seed, v.sampling_period_to_monitor.load().count());
+        boost::hash_combine(seed, v.sampling_period_to_monitor.load());
         return seed;
     }
 };

diff --git a/src/cosim/timer.cpp b/src/cosim/timer.cpp
@@ -36,9 +36,9 @@ class real_time_timer::impl
         const auto newHash = std::hash<real_time_config>()(*config_);
         if (newHash != configHashValue_) {
             start(currentTime);
-            const auto sampling_period = config_->sampling_period_to_monitor.load();
-            if (sampling_period.count() > 0) {
-                sampling_period_to_monitor_ = sampling_period;
+            auto samping_period = config_->sampling_period_to_monitor.load();
+            if (samping_period > 0) {
+                sampling_period_to_monitor_ = std::chrono::milliseconds(samping_period);
             } else {
                 sampling_period_to_monitor_ = std::nullopt;
             }
@@ -78,13 +78,16 @@ class real_time_timer::impl
     size_t configHashValue_;
     std::shared_ptr<real_time_metrics> metrics_;
     std::optional<std::chrono::milliseconds> sampling_period_to_monitor_ = std::nullopt;
+    bool tick_period_match_ = std::is_same<cosim::time_point::period, Time::time_point::period>::value;
 
     void update_rolling_average_real_time_factor(
         Time::time_point& currentTime,
         time_point& currentSimulationTime,
         const duration& elapsedRealTime)
     {
-        const auto elapsedSimTime = std::chrono::duration_cast<duration>(currentSimulationTime - rtSimulationStartTime_);
+        const auto elapsedSimTime =
+            tick_period_match_ ? currentSimulationTime - rtSimulationStartTime_ : std::chrono::duration_cast<duration>(currentSimulationTime - rtSimulationStartTime_);
+
         metrics_->rolling_average_real_time_factor = elapsedSimTime.count() / (1.0 * elapsedRealTime.count());
         rtStartTime_ = currentTime;
         rtSimulationStartTime_ = currentSimulationTime;
@@ -93,8 +96,11 @@ class real_time_timer::impl
 
     void update_real_time_factor(Time::time_point currentTime, time_point currentSimulationTime)
     {
-        const auto relativeSimTime = std::chrono::duration_cast<duration>(currentSimulationTime - simulationStartTime_);
-        const auto relativeRealTime = std::chrono::duration_cast<duration>(currentTime - startTime_);
+        const auto relativeSimTime =
+            tick_period_match_ ? currentSimulationTime - simulationStartTime_ : std::chrono::duration_cast<duration>(currentSimulationTime - simulationStartTime_);
+        const auto relativeRealTime =
+            tick_period_match_ ? currentTime - startTime_ : std::chrono::duration_cast<duration>(currentTime - startTime_);
+
         metrics_->total_average_real_time_factor = relativeSimTime.count() / (1.0 * relativeRealTime.count());
 
         if (sampling_period_to_monitor_.has_value()) {