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();

    std::chrono::milliseconds GetPeriod();

    rad::cii::OldbAdapter& GetOldbAdapter();

    void SetPeriod(const std::chrono::milliseconds period);

    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));
        if (m_logger.isEnabledFor(log4cplus::DEBUG_LOG_LEVEL)) {
            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));
        if (m_logger.isEnabledFor(log4cplus::DEBUG_LOG_LEVEL)) {
            auto v = std::get<std::vector<T>>(values);
            size_t len = v.size();
            if (len == 0) {
                LOG4CPLUS_DEBUG(m_logger, "Writing vector to OLDB: "
                        << m_oldb_prefix + key << " = []");
            } else if (len == 1) {
                LOG4CPLUS_DEBUG(m_logger, "Writing vector to OLDB: "
                        << m_oldb_prefix + key << " = [" << v.front() << "]");
            } else {
                LOG4CPLUS_DEBUG(m_logger, "Writing vector to OLDB: "
                        << m_oldb_prefix + key << " = [" << v.front() << "..."
                        << v.back() << "]");
            }
        }
    }
 
 
    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