msgFacility_metric.cc

// msgFacility_metric.cc: Message Facility Metric Plugin
// Author: Eric Flumerfelt
// Last Modified: 09/29/2015
//
// An implementation of the MetricPlugin for Message Facility

#include "artdaq-utilities/Plugins/MetricMacros.hh"
#include "fhiclcpp/ParameterSet.h"
#include "messagefacility/MessageLogger/MessageLogger.h"

#include <algorithm>
#include <iostream>
#include <string>

namespace artdaq {
class MsgFacilityMetric : public MetricPlugin
{
private:
    std::string facility_;
    int outputLevel_;

public:
    explicit MsgFacilityMetric(fhicl::ParameterSet const& config, std::string const& app_name)
        : MetricPlugin(config, app_name)
        , facility_(config.get<std::string>("output_message_category_name", "ARTDAQ Metric"))
        , outputLevel_(0)
    {
        try
        {
            outputLevel_ = config.get<int>("output_message_severity", 0);
        }
        catch (const cet::exception&)
        {
            std::string levelString = config.get<std::string>("output_message_severity", "Info");
            if (levelString == "Info" || levelString == "info" || levelString == "LogInfo")
            {
                outputLevel_ = 0;
            }
            else if (levelString == "Debug" || levelString == "debug" || levelString == "LogDebug")
            {
                outputLevel_ = 1;
            }
            else if (levelString == "Warning" || levelString == "warning" || levelString == "LogWarning" || levelString == "Warn" || levelString == "warn")
            {
                outputLevel_ = 2;
            }
            else if (levelString == "Error" || levelString == "error" || levelString == "LogError")
            {
                outputLevel_ = 3;
            }
        }
        startMetrics();
    }

    virtual ~MsgFacilityMetric() { stopMetrics(); }
    std::string getLibName() const override { return "msgFacility"; }

    void sendMetric_(const std::string& name, const std::string& value, const std::string& unit) override
    {
        if (!inhibit_)
        {
            switch (outputLevel_)
            {
                case 0:
                    mf::LogInfo(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                case 1:
                    mf::LogDebug(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                case 2:
                    mf::LogWarning(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
                case 3:
                    mf::LogError(facility_) << name << ": " << value << " " << unit << "." << std::endl;
                    break;
            }
        }
    }

    void sendMetric_(const std::string& name, const int& value, const std::string& unit) override
    {
        sendMetric_(name, std::to_string(value), unit);
    }

    void sendMetric_(const std::string& name, const double& value, const std::string& unit) override
    {
        sendMetric_(name, std::to_string(value), unit);
    }

    void sendMetric_(const std::string& name, const float& value, const std::string& unit) override
    {
        sendMetric_(name, std::to_string(value), unit);
    }

    void sendMetric_(const std::string& name, const unsigned long int& value, const std::string& unit) override
    {
        sendMetric_(name, std::to_string(value), unit);
    }

    void startMetrics_() override {}
    void stopMetrics_() override {}
};
}  //End namespace artdaq

DEFINE_ARTDAQ_METRIC(artdaq::MsgFacilityMetric)