activityUpdateOldb.hpp

Go to the documentation of this file.

 
#ifndef RAD_ACTIVITY_UPDATE_OLDB_HPP
#define RAD_ACTIVITY_UPDATE_OLDB_HPP
 
#include <rad/logger.hpp>
#include <rad/activity.hpp>
#include <rad/doubleMap.hpp>
#include <rad/cii/oldbAdapter.hpp>
#include <rad/cii/oldbTypes.hpp>
 
#include <string>
#include <chrono>
#include <vector>
 
namespace rad {
 
class ActivityUpdateOldb : public rad::ThreadActivity {
 public:
    ActivityUpdateOldb(const std::string& id,
                       const std::string& logger_name,
                       rad::DoubleMap<rad::cii::OldbType>& oldb_map,
                       std::chrono::seconds conn_timeout,
                       std::chrono::milliseconds period);
    virtual ~ActivityUpdateOldb();
 
    rad::cii::OldbAdapter& GetOldbAdapter();
 
    void SetOldbPrefix(const std::string& prefix);
 
    void Run() override;
 
    ActivityUpdateOldb(const ActivityUpdateOldb&) = delete;         
    ActivityUpdateOldb& operator=(const ActivityUpdateOldb&) = delete;  
 
 private:
    template<typename T>
    void WriteScalarToOldb(const std::string& key, rad::cii::OldbType& value) {
        m_oldb_adapter.TrySet<T>(m_oldb_prefix + key, std::get<T>(value));
        LOG4CPLUS_DEBUG(m_logger, "Writing to OLDB: " << m_oldb_prefix + key
                << " = " << std::get<T>(value));
    }
 
    template<typename T>
    void WriteVectorToOldb(const std::string& key, rad::cii::OldbType& values) {
        m_oldb_adapter.TrySet<T>(m_oldb_prefix + key, std::get<std::vector<T>>(values));
        LOG4CPLUS_DEBUG(m_logger, "Writing vector to OLDB: " << m_oldb_prefix + key << " = "
                << PrintVector<T>(std::get<std::vector<T>>(values)));
    }
 
    template<typename T>
    std::string PrintVector(const std::vector<T>& vec) {
        std::string str = "";
        for (auto el : vec) {
            str += std::to_string(el) + " ";
        }
        return str;
    }
 
    log4cplus::Logger m_logger;  
    rad::DoubleMap<rad::cii::OldbType>& m_oldb_map;  
    rad::cii::OldbAdapter m_oldb_adapter;  
    std::chrono::milliseconds m_period;  
    std::string m_oldb_prefix;
};
 
}  // namespace  rad
 
#endif  // RAD_ACTIVITY_UPDATE_OLDB_HPP