businessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_METADATACOLLECTOR_BUSINESSLOGIC_HPP
#define RTCTK_METADATACOLLECTOR_BUSINESSLOGIC_HPP
 
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/componentFramework/oldbIf.hpp>
#include <rtctk/componentFramework/recordingUnit.hpp>
#include <rtctk/componentFramework/rtcComponent.hpp>
#include <rtctk/metadataCollector/acquisitor.hpp>
 
namespace rtctk::metadataCollector {
 
using namespace rtctk::componentFramework;
 
using LifeCycle = Acquisitor<RtcComponent>;

class BusinessLogic : public LifeCycle::BizLogicIf {
public:
    using ComponentType = LifeCycle;
 
    BusinessLogic(const std::string& name, ServiceContainer& services, RecUnitFactoryType factory);
    virtual ~BusinessLogic() = default;
 
    void ActivityStarting(StopToken st) override;
    void ActivityInitialising(StopToken st) override;
    void ActivityPreparing(StopToken st, const std::string& id) override;
    void ActivityAcquiring(StopToken st) override;
    DaqStopReply ActivityFinalising(StopToken st) override;
    void ActivityAborting(StopToken st) override;
    void ActivityRecovering(StopToken st) override;
    void ActivityUpdating(StopToken st, const JsonPayload& args) override;
 
private:
    log4cplus::Logger& m_logger;
    std::string m_name;
    ServiceContainer& m_services;
    OldbIf& m_oldb;
    ComponentMetricsIf& m_metrics;
    RecUnitFactoryType m_rec_unit_factory;
    RecUnitListType m_rec_units;
 
    std::string m_session_id;
    std::filesystem::path m_fs_path;
 
    DataPointPath m_dpp_session_id;
    DataPointPath m_dpp_session_files;
    DataPointPath m_dpp_session_files_size;
    DataPointPath m_dpp_session_total_size;
    DataPointPath m_dpp_session_space_info_cap;
    DataPointPath m_dpp_session_space_info_free;
    DataPointPath m_dpp_session_space_info_avail;
};
 
}  // namespace rtctk::metadataCollector
 
#endif  // RTCTK_METADATACOLLECTOR_BUSINESSLOGIC_HPP