ELstatistics.cc

Go to the documentation of this file.

#include "messagefacility/MessageService/ELstatistics.h"
// vim: set sw=2 expandtab :

#include "fhiclcpp/ParameterSet.h"
#include "messagefacility/Utilities/ErrorObj.h"

#include <fstream>
#include <sstream>
#include <string>

namespace mf {
  namespace service {

    ELstatistics::~ELstatistics() {}

    ELstatistics::ELstatistics(Config const& config, cet::ostream_handle&& osh)
      : ELdestination{config.elDestConfig()}, osh_{std::move(osh)}
    {}

    ELstatistics::ELstatistics(Parameters const& pset, std::ostream& osp)
      : ELstatistics{pset(), cet::ostream_handle{osp}}
    {}

    void
    ELstatistics::log(ErrorObj& msg)
    {
      if (msg.xid().severity() < threshold_) {
        if (outputStatistics_) {
          statsMap_[msg.xid()].add(summarizeContext(msg.context()), false);
          updatedStats_ = true;
        }
        return;
      }
      if (skipMsg(msg.xid())) {
        if (outputStatistics_) {
          statsMap_[msg.xid()].add(summarizeContext(msg.context()), false);
          updatedStats_ = true;
        }
        return;
      }
      msg.setReactedTo(true);
      // The only real difference between a statistics destination
      // and an ordinary one is here, where we make no attempt to
      // output the message.
      if (outputStatistics_) {
        statsMap_[msg.xid()].add(summarizeContext(msg.context()), true);
        updatedStats_ = true;
      }
    }

    // Called only by MessageLoggerScribe::summarize()
    //   Called only by MessageLogger::LogStatistics()
    void
    ELstatistics::summary()
    {
      if (outputStatistics_ && updatedStats_) {
        osh_ << "\n=============================================\n\n"
             << "MessageLogger Summary\n"
             << formSummary();
      }
      updatedStats_ = false;
      if (reset_) {
        resetMsgCounters();
        resetLimiters();
      }
    }

  } // namespace service
} // namespace mf