configManager.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_dpm_server
 * @copyright (c) Copyright ESO 2022
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 *
 * @brief DPM server config
 */
#ifndef DAQ_DPM_SERVER_CONFIGMANAGER_HPP
#define DAQ_DPM_SERVER_CONFIGMANAGER_HPP
 
#include <daq/config/manager.hpp>
 
#include <boost/numeric/conversion/cast.hpp>
 
#include <daq/dpm/config.hpp>
 
namespace daq::dpm {
 
/**
 * DPM Server specific configuration manager.
 *
 * Main responsibilities:
 * - Update configuration from various sources.
 * - Publish updates to OLDB.
 */
class ConfigManager {
public:
    ConfigManager(log4cplus::Logger logger);
 
    Configuration const& GetConfig() const {
        return m_config;
    }
    /**
     * Parse configuration from command line arguments.
     *
     * @param[in] argc Number of command line options.
     * @param[in] argv Pointer to the array of command line options.
     * @return false if the help option has been invoked, true otherwise.
     */
    bool ParseArguments(int argc, char* argv[]);
 
    /**
     * Load configuration file and update configuration.
     */
    void LoadConfig();
    /**
     * Visit all configuration parameters.
     */
    template <class Func>
    void Visit(Func&& func) {
        m_mgr.Visit(std::forward<Func>(func));
    }
 
private:
    /**
     * Helper that use canonical name to look up config.
     */
    template <class AttrType, class T>
    void UpdateFromConfig(T* ptr,
                          elt::configng::CiiConfigInstanceNode const& node,
                          config::OriginInfo const& origin) {
        auto info = m_mgr.Get(ptr);
        using daq::config::GetParamAs;
        if (auto value = GetParamAs<AttrType>(info.metadata.canonical_name, node); value) {
            if constexpr (std::is_same_v<T, std::uint16_t>) {
                m_mgr.Update(ptr, boost::numeric_cast<std::uint16_t>(*value), origin);
            } else if constexpr (std::is_same_v<T, std::chrono::seconds>) {
                m_mgr.Update(ptr, T{*value}, origin);
            } else {
                m_mgr.Update(ptr, *value, origin);
            }
        }
    }
    log4cplus::Logger m_logger;
    Configuration m_config;
    daq::config::Manager m_mgr;
};
 
}  // namespace daq::dpm
#endif  // DAQ_DPM_SERVER_CONFIGMANAGER_HPP