businessLogicDetail.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_TELEMETRYRECORDER_BUSINESSLOGIC_DETAIL_HPP
#define RTCTK_REUSABLECOMPONENT_TELEMETRYRECORDER_BUSINESSLOGIC_DETAIL_HPP
 
 
#include <rtctk/componentFramework/logger.hpp>
#include <rtctk/componentFramework/runtimeRepoIf.hpp>
#include <thread>
#include <chrono>
 
#include <rtctk/telemetryRecorder/businessLogic.hpp>
 
#include <rtctk/telemetryRecorder/recorderIf.hpp>
 
using namespace rtctk::componentFramework;
using namespace std::chrono_literals;
 
using std::this_thread::sleep_for;
 
namespace rtctk::telemetryRecorder {
 
template <typename T>
TelemetryRecorderBusinessLogic<T>::TelemetryRecorderBusinessLogic(const std::string& name,
                                                                  ServiceContainer& services)
    : m_name(name), m_services(services) {
    static_assert((std::is_base_of<RecorderIf<typename T::TelemetryType>, T>::value),
                  "template parameter for TelemetryRecorderBusinessLogic needs to be derived from "
                  "RecorderIf");
}
 
// activities
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityStarting(StopToken st)
{
    return;
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityInitialising(StopToken st)
{
    auto& rtr = m_services.Get<RuntimeRepoIf>();
    m_recorder_thread.SetTopic(rtr.GetDataPoint<std::string>(DataPointPath("/" + m_name + "/static/topic_name")));
    m_recorder_thread.SetSubSampleFactor(rtr.GetDataPoint<int64_t>(DataPointPath("/" + m_name + "/dynamic/subsample_factor")));
    m_recorder_thread.SetTelemetrySubSet(rtr.GetDataPoint<std::string>(DataPointPath("/" + m_name + "/dynamic/tel_subset")));
    m_recorder_thread.SetOutputUri(::elt::mal::Uri(rtr.GetDataPoint<std::string>(DataPointPath("/" + m_name + "/dynamic/output_uri"))));
    m_recorder_thread.SetStartSampleId(rtr.GetDataPoint<int64_t>(DataPointPath("/" + m_name + "/static/start_with_sample_id")));
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityEnabling(StopToken st)
{
    m_recorder_thread.Open();
    m_recorder_thread.Start();
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityDisabling(StopToken st)
{
    m_recorder_thread.Stop();
    m_recorder_thread.Close();
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityGoingRunning(StopToken st)
{
    m_recorder_thread.Unpause();
    return;
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityGoingIdle(StopToken st)
{
    m_recorder_thread.Pause();
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityRunning(StopToken st)
{
    while(not st.StopRequested()) {
        sleep_for(100ms);
    }
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityRecovering(StopToken st)
{
    return;
}
 
template<typename T>
void TelemetryRecorderBusinessLogic<T>::ActivityUpdating(StopToken st, Payload args)
{
    auto& rtr = m_services.Get<RuntimeRepoIf>();
    m_recorder_thread.SetOutputUri(::elt::mal::Uri(rtr.GetDataPoint<std::string>(DataPointPath("/" + m_name + "/dynamic/output_uri"))));
    m_recorder_thread.SetSubSampleFactor(rtr.GetDataPoint<int64_t>(DataPointPath("/" + m_name + "/dynamic/subsample_factor")));
    m_recorder_thread.SetTelemetrySubSet(rtr.GetDataPoint<std::string>(DataPointPath("/" + m_name + "/dynamic/tel_subset")));
 
    return;
}
 
// guards
template<typename T>
bool TelemetryRecorderBusinessLogic<T>::GuardUpdatingAllowed(Payload args)
{
    // Updates are always allowed in states Running and Idle
    return true;
}
 
}
 
#endif // RTCTK_REUSABLECOMPONENT_TELEMETRYRECORDER_BUSINESSLOGIC_DETAIL_HPP