mf::service::ELdestination Class Reference

#include "ELdestination.h"

Inheritance diagram for mf::service::ELdestination:

Classes
struct	Category
struct	CategoryParams
struct	Config
class	MsgFormatSettings
class	MsgStatistics
struct	StatsCount
struct	XidLimiter

Public Types
enum	flag_enum {   NO_LINE_BREAKS, TIMESTAMP, MILLISECOND, MODULE,   SUBROUTINE, TEXT, SOME_CONTEXT, SERIAL,   FULL_CONTEXT, TIME_SEPARATE, EPILOGUE_SEPARATE, NFLAGS }

Public Member Functions
virtual	~ELdestination () noexcept=default
	ELdestination (Config const &)
	ELdestination (ELdestination const &)=delete
	ELdestination (ELdestination &&)=delete
ELdestination &	operator= (ELdestination const &)=delete
ELdestination &	operator= (ELdestination &&)=delete
void	setThreshold (ELseverityLevel sv)
virtual void	log (mf::ErrorObj &)
virtual void	finish ()
virtual void	summary ()

Protected Member Functions
std::string	summarizeContext (std::string const &)
void	emitToken (std::ostream &os, std::string const &s, bool nl=false, bool preambleMode=false)
std::string	formSummary ()
bool	skipMsg (ELextendedID const &)
void	resetLimiters ()
void	resetMsgCounters ()
virtual void	fillPrefix (std::ostringstream &, mf::ErrorObj const &msg)
virtual void	fillUsrMsg (std::ostringstream &, mf::ErrorObj const &msg)
virtual void	fillSuffix (std::ostringstream &, mf::ErrorObj const &msg)
virtual void	routePayload (std::ostringstream const &, mf::ErrorObj const &msg)
virtual void	flush ()

Protected Attributes
ELseverityLevel	threshold_
MsgFormatSettings	format_
int	defaultLimit_
int	defaultReportEvery_
int	defaultTimespan_
std::map< std::string const, CategoryParams >	categoryParams_
std::map< ELextendedID const, XidLimiter >	xidLimiters_
std::map< ELextendedID const, StatsCount >	statsMap_
bool	outputStatistics_ {false}
bool	updatedStats_ {false}
bool	reset_ {false}

Private Attributes
std::size_t	charsOnLine_ {}

Detailed Description

Definition at line 25 of file ELdestination.h.

Member Enumeration Documentation

enum mf::service::ELdestination::flag_enum

Enumerator
NO_LINE_BREAKS
TIMESTAMP
MILLISECOND
MODULE
SUBROUTINE
TEXT
SOME_CONTEXT
SERIAL
FULL_CONTEXT
TIME_SEPARATE
EPILOGUE_SEPARATE
NFLAGS

Definition at line 30 of file ELdestination.h.

                     {
        NO_LINE_BREAKS,
        TIMESTAMP,
        MILLISECOND,
        MODULE,
        SUBROUTINE,
        TEXT,
        SOME_CONTEXT,
        SERIAL,
        FULL_CONTEXT,
        TIME_SEPARATE,
        EPILOGUE_SEPARATE,
        NFLAGS
      };

Constructor & Destructor Documentation

virtual mf::service::ELdestination::~ELdestination ( )

virtualdefaultnoexcept

mf::service::ELdestination::ELdestination

(

Config const &

pset

)

Definition at line 285 of file ELdestination.cc.

References evd::details::begin(), mf::detail::bold_fontify(), categoryParams_, charsOnLine_, defaultLimit_, defaultReportEvery_, defaultTimespan_, e, evd::details::end(), format_, fhicl::ParameterSet::get_if_present(), max, outputStatistics_, reset_, s, statsMap_, mf::service::ELdestination::Config::threshold, updatedStats_, fhicl::detail::validationException::what(), and xidLimiters_.

      : threshold_{pset.threshold()}
      , format_{pset.format()}
      , defaultLimit_{numeric_limits<decltype(defaultLimit_)>::max()}
      , defaultReportEvery_{-1}
      , defaultTimespan_{numeric_limits<decltype(defaultTimespan_)>::max()}
      , categoryParams_{}
      , xidLimiters_{}
      , statsMap_{}
      , outputStatistics_{pset.outputStatistics()}
      , updatedStats_{false}
      , reset_{pset.msgStatistics().reset() ||
               pset.msgStatistics().resetStatistics()}
      , charsOnLine_{}
    {
      vector<string> configuration_errors;
      // Grab this destination's category configurations.
      fhicl::ParameterSet cats_pset{};
      pset.categories.get_if_present<fhicl::ParameterSet>(cats_pset);
      // Grab the list of categories, removing the default category
      // since it is handled specially.
      auto const default_category_name = "default"s;
      auto categories = cats_pset.get_pset_names();
      auto erase_from =
        remove_if(begin(categories), end(categories), [](auto const& category) {
          return category == "default"s;
        });
      categories.erase(erase_from, categories.cend());
      // Setup the default configuration for categories--this involves
      // resetting the limits table according to the user-specified
      // default configuration.
      auto const& default_pset =
        cats_pset.get<fhicl::ParameterSet>("default"s, {});
      try {
        fhicl::WrappedTable<Category::Config> default_params{default_pset};
        defaultLimit_ = (default_params().limit() < 0) ?
                          numeric_limits<decltype(defaultLimit_)>::max() :
                          default_params().limit();
        defaultReportEvery_ = default_params().reportEvery();
        defaultTimespan_ = (default_params().timespan() < 0) ?
                             numeric_limits<decltype(defaultTimespan_)>::max() :
                             default_params().timespan();
      }
      catch (fhicl::detail::validationException const& e) {
        string msg{"Category: "s + detail::bold_fontify("default"s) + "\n\n"s};
        msg += e.what();
        configuration_errors.push_back(move(msg));
      }
      // Now establish this destination's limit/reportEvery/timespan for
      // each category, using the values of the possibly-specified
      // default configuration when a given category is missing the
      // fields.
      for (auto const& category : categories) {
        fhicl::Table<Category::Config> category_params{fhicl::Name{category},
                                                       default_pset};
        try {
          category_params.validate_ParameterSet(
            cats_pset.get<fhicl::ParameterSet>(category));
        }
        catch (fhicl::detail::validationException const& e) {
          string msg{"Category: " + detail::bold_fontify(category) + "\n\n"};
          msg += e.what();
          configuration_errors.push_back(move(msg));
        }
        // limits_.setCategoryParams(category, category_params().limit(),
        // category_params().reportEvery(), category_params().timespan());
        // setCategoryParams(string const& category, int limit, int reportEvery,
        // int timespan)
        {
          if (category_params().limit() < 0) {
            categoryParams_[category].limit_ = numeric_limits<int>::max();
          } else {
            categoryParams_[category].limit_ = category_params().limit();
          }
          categoryParams_[category].reportEvery_ =
            category_params().reportEvery();
          if (category_params().timespan() < 0) {
            categoryParams_[category].timespan_ = numeric_limits<int>::max();
          } else {
            categoryParams_[category].timespan_ = category_params().timespan();
          }
        }
      }
      if (!configuration_errors.empty()) {
        string msg{"The following categories were misconfigured:\n\n"};
        for (auto const& error : configuration_errors) {
          msg += error;
        }
        throw fhicl::detail::validationException{msg};
      }
    }

mf::service::ELdestination::ELdestination ( ELdestination const &  )

delete

mf::service::ELdestination::ELdestination ( ELdestination &&  )

delete

Member Function Documentation

void mf::service::ELdestination::emitToken ( std::ostream &  os, std::string const &  s, bool  nl = false, bool  preambleMode = false  )

protected

Definition at line 408 of file ELdestination.cc.

References charsOnLine_, format_, art::detail::indent(), mf::service::ELdestination::MsgFormatSettings::lineLength, and s.

Referenced by mf::service::ELostreamOutput::ELostreamOutput(), fillPrefix(), fillSuffix(), and fillUsrMsg().

    {
      string indent(6, ' ');
      if (s.empty()) {
        if (nl) {
          os << '\n';
          charsOnLine_ = 0UL;
        }
        return;
      }
      if (!preambleMode) {
        os << s;
        return;
      }
      char const first = s[0];
      char const second = (s.length() < 2) ? '\0' : s[1];
      char const last = (s.length() < 2) ? '\0' : s[s.length() - 1];
      char const last2 = (s.length() < 3) ? '\0' : s[s.length() - 2];
      // checking -2 because the very last char is sometimes a ' '
      // inserted by ErrorLog::operator<<
      // Accounts for newline @ the beginning of the string
      if (first == '\n' || (charsOnLine_ + s.length()) > format_.lineLength) {
        charsOnLine_ = 0UL;
        if (second != ' ') {
          os << ' ';
          ++charsOnLine_;
        }
        if (first == '\n') {
          os << s.substr(1);
        } else {
          os << s;
        }
      } else {
        os << s;
      }
      if ((last == '\n') || (last2 == '\n')) {
        os << indent;
        if (last != ' ') {
          os << ' ';
        }
        charsOnLine_ = indent.length() + 1UL;
      }
      if (nl) {
        os << '\n';
        charsOnLine_ = 0UL;
      } else {
        charsOnLine_ += s.length();
      }
    }

void mf::service::ELdestination::fillPrefix ( std::ostringstream &  oss, mf::ErrorObj const &  msg  )

protectedvirtual

Reimplemented in mfplugins::ELsyslog.

Definition at line 462 of file ELdestination.cc.

References charsOnLine_, mf::ErrorObj::context(), emitToken(), EPILOGUE_SEPARATE, format_, mf::ErrorObj::idOverflow(), mf::ErrorObj::is_verbatim(), MODULE, s, mf::ErrorObj::serial(), SERIAL, SOME_CONTEXT, SUBROUTINE, TIME_SEPARATE, TIMESTAMP, mf::ErrorObj::timestamp(), mf::service::ELdestination::MsgFormatSettings::timestamp(), mf::service::ELdestination::MsgFormatSettings::want(), and mf::ErrorObj::xid().

Referenced by log().

    {
      if (msg.is_verbatim()) {
        return;
      }
      auto const& xid = msg.xid();
      charsOnLine_ = 0UL;
      emitToken(oss, "%MSG"s, false, true);
      emitToken(oss, xid.severity().getSymbol(), false, true);
      emitToken(oss, " ", false, true);
      emitToken(oss, xid.id(), false, true);
      emitToken(oss, msg.idOverflow(), false, true);
      emitToken(oss, ": ", false, true);
      if (format_.want(SERIAL)) {
        ostringstream s;
        s << msg.serial();
        emitToken(oss, "[serial #" + s.str() + "] ", false, true);
      }
      bool needAspace = true;
      if (format_.want(EPILOGUE_SEPARATE)) {
        if (xid.module().length() + xid.subroutine().length() > 0) {
          emitToken(oss, "\n", false, true);
          needAspace = false;
        } else if (format_.want(TIMESTAMP) && !format_.want(TIME_SEPARATE)) {
          emitToken(oss, "\n", false, true);
          needAspace = false;
        }
      }
      if (format_.want(MODULE) && (xid.module().length() > 0)) {
        if (needAspace) {
          emitToken(oss, " ", false, true);
          needAspace = false;
        }
        emitToken(oss, xid.module() + " ", false, true);
      }
      if (format_.want(SUBROUTINE) && (xid.subroutine().length() > 0)) {
        if (needAspace) {
          emitToken(oss, " ", false, true);
          needAspace = false;
        }
        emitToken(oss, xid.subroutine() + "() ", false, true);
      }
      if (format_.want(TIMESTAMP)) {
        if (format_.want(TIME_SEPARATE)) {
          emitToken(oss, "\n", false, true);
          needAspace = false;
        }
        if (needAspace) {
          emitToken(oss, " ", false, true);
          needAspace = false;
        }
        emitToken(oss, format_.timestamp(msg.timestamp()) + " ", false, true);
      }
      if (format_.want(SOME_CONTEXT)) {
        if (needAspace) {
          emitToken(oss, " ", false, true);
          needAspace = false;
        }
        emitToken(oss, msg.context(), false, true);
      }
    }

void mf::service::ELdestination::fillSuffix ( std::ostringstream &  oss, mf::ErrorObj const &  msg  )

protectedvirtual

Reimplemented in mfplugins::ELsyslog.

Definition at line 552 of file ELdestination.cc.

References emitToken(), format_, mf::ErrorObj::is_verbatim(), NO_LINE_BREAKS, and mf::service::ELdestination::MsgFormatSettings::want().

Referenced by log().

    {
      if (!msg.is_verbatim() && !format_.want(NO_LINE_BREAKS)) {
        emitToken(oss, "\n%MSG");
      }
      oss << '\n';
    }

void mf::service::ELdestination::fillUsrMsg ( std::ostringstream &  oss, mf::ErrorObj const &  msg  )

protectedvirtual

Reimplemented in mfplugins::ELsyslog.

Definition at line 525 of file ELdestination.cc.

References emitToken(), mf::ErrorObj::filename(), format_, mf::ErrorObj::is_verbatim(), mf::ErrorObj::items(), mf::ErrorObj::lineNumber(), NO_LINE_BREAKS, s, TEXT, util::flags::to_string(), and mf::service::ELdestination::MsgFormatSettings::want().

Referenced by mfplugins::ELsyslog::fillUsrMsg(), and log().

    {
      if (!format_.want(TEXT)) {
        return;
      }
      // Determine if file and line should be included
      if (!msg.is_verbatim()) {
        if (!msg.filename().empty()) {
          emitToken(oss, " "s);
          emitToken(oss, msg.filename());
          emitToken(oss, ":"s);
          emitToken(oss, to_string(msg.lineNumber()));
        }
        // Check for user-requested line breaks
        if (format_.want(NO_LINE_BREAKS)) {
          emitToken(oss, " ==> ");
        } else {
          emitToken(oss, "", true);
        }
      }
      // Print the contents.
      for (auto const& val : msg.items()) {
        emitToken(oss, val);
      }
    }

void mf::service::ELdestination::finish ( )

virtual

Definition at line 723 of file ELdestination.cc.

    {}

void mf::service::ELdestination::flush ( )

protectedvirtual

Definition at line 735 of file ELdestination.cc.

References mf::ELwarning, log(), and s.

    {
      ErrorObj msg{ELwarning, "ELdestination"s};
      msg << "Call to unimplemented flush()!";
      log(msg);
    }

string mf::service::ELdestination::formSummary ( )

protected

Definition at line 594 of file ELdestination.cc.

References art::left(), n, mf::ELseverityLevel::nLevels, art::right(), s, and statsMap_.

Referenced by mf::service::ELstatistics::summary(), and summary().

    {
      ostringstream s;
      int n{};
      // -----  Summary part I:
      //
      bool ftnote{false};
      struct part3 {
        long n{}, t{};
      } p3[ELseverityLevel::nLevels];
      for (auto const& pr : statsMap_) {
        auto const& xid = pr.first;
        auto const& count = pr.second;
        auto const& cat = xid.id();
        // -----  Emit new part I header, if needed:
        //
        if (n == 0) {
          s << "\n";
          s << " type     category        sev    module        subroutine      "
               "  count    total\n"
            << " ---- -------------------- -- ---------------- "
               "----------------  -----    -----\n";
        }
        // -----  Emit detailed message information:
        //
        s
          // Type
          << right << setw(5) << ++n
          << ' '
          // Category
          << left << setw(20) << cat.substr(0, 20)
          << ' '
          // Severity
          << left << setw(2) << xid.severity().getSymbol()
          << ' '
          // Module
          << left << setw(16) << xid.module().substr(0, 16)
          << ' '
          // Subroutine
          << left << setw(16)
          << xid.subroutine().substr(0, 16)
          // Count
          << right << setw(7) << count.n_ << left << setw(1)
          << (count.ignoredFlag_ ? '*' : ' ')
          // Total Count
          << right << setw(8) << count.aggregateN_ << '\n';
        ftnote = ftnote || count.ignoredFlag_;
        // -----  Obtain information for Part III, below:
        //
        p3[xid.severity().getLevel()].n += count.n_;
        p3[xid.severity().getLevel()].t += count.aggregateN_;
      }
      // -----  Provide footnote to part I, if needed:
      //
      if (ftnote) {
        s << "\n* Some occurrences of this message were suppressed in all "
             "logs, due to limits.\n";
      }
      // -----  Summary part II:
      //
      n = 0;
      for (auto const& pr : statsMap_) {
        auto const& xid = pr.first;
        auto const& count = pr.second;
        string const& cat = xid.id();
        if (n == 0) {
          s << '\n'
            << " type    category    Examples: run/evt        run/evt          "
               "run/evt\n"
            << " ---- -------------------- ---------------- ---------------- "
               "----------------\n";
        }
        s
          // Type
          << right << setw(5) << ++n
          << ' '
          // Category
          << left << setw(20) << cat
          << ' '
          // Context1
          << left << setw(16) << count.context1_.c_str()
          << ' '
          // Context2
          << left << setw(16) << count.context2_.c_str()
          << ' '
          // ContextLast
          << count.contextLast_ << '\n';
      }
      // -----  Summary part III:
      //
      s << '\n'
        << "Severity    # Occurrences   Total Occurrences\n"
        << "--------    -------------   -----------------\n";
      for (int k = 0; k < ELseverityLevel::nLevels; ++k) {
        if (p3[k].n != 0 || p3[k].t != 0) {
          s
            // Severity
            << left << setw(8)
            << ELseverityLevel{ELseverityLevel::ELsev_(k)}.getName().c_str()
            // Occurrences
            << right << setw(17)
            << p3[k].n
            // Total Occurrences
            << right << setw(20) << p3[k].t << '\n';
        }
      }
      return s.str();
    }

void mf::service::ELdestination::log ( mf::ErrorObj &  msg )

virtual

Reimplemented in mf::service::ELstatistics.

Definition at line 565 of file ELdestination.cc.

References mf::ErrorObj::context(), fillPrefix(), fillSuffix(), fillUsrMsg(), outputStatistics_, routePayload(), mf::ErrorObj::setReactedTo(), mf::ELextendedID::severity(), skipMsg(), statsMap_, summarizeContext(), threshold_, updatedStats_, and mf::ErrorObj::xid().

Referenced by flush().

    {
      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);
      ostringstream payload;
      fillPrefix(payload, msg);
      fillUsrMsg(payload, msg);
      fillSuffix(payload, msg);
      routePayload(payload, msg);
      if (outputStatistics_) {
        statsMap_[msg.xid()].add(summarizeContext(msg.context()), true);
        updatedStats_ = true;
      }
    }

ELdestination& mf::service::ELdestination::operator= ( ELdestination const &  )

delete

ELdestination& mf::service::ELdestination::operator= ( ELdestination &&  )

delete

void mf::service::ELdestination::resetLimiters ( )

protected

Definition at line 840 of file ELdestination.cc.

References xidLimiters_.

Referenced by mf::service::ELstatistics::summary(), and summary().

    {
      xidLimiters_.clear();
    }

void mf::service::ELdestination::resetMsgCounters ( )

protected

Definition at line 834 of file ELdestination.cc.

References statsMap_.

Referenced by mf::service::ELstatistics::summary(), and summary().

    {
      statsMap_.clear();
    }

void mf::service::ELdestination::routePayload ( std::ostringstream const &  , mf::ErrorObj const &  msg  )

protectedvirtual

Reimplemented in mf::service::ELostreamOutput, and mfplugins::ELsyslog.

Definition at line 561 of file ELdestination.cc.

Referenced by log(), and summary().

    {}

void mf::service::ELdestination::setThreshold

(

ELseverityLevel

sv

)

Definition at line 729 of file ELdestination.cc.

References threshold_.

    {
      threshold_ = sv;
    }

bool mf::service::ELdestination::skipMsg ( ELextendedID const &  xid )

protected

Definition at line 746 of file ELdestination.cc.

References categoryParams_, defaultLimit_, defaultReportEvery_, defaultTimespan_, mf::ELextendedID::id(), mf::service::ELdestination::XidLimiter::limit_, mf::service::ELdestination::XidLimiter::msgCount_, mf::service::ELdestination::XidLimiter::previousTimestamp_, mf::service::ELdestination::XidLimiter::reportEvery_, mf::service::ELdestination::XidLimiter::skippedMsgCount_, mf::service::ELdestination::XidLimiter::timespan_, and xidLimiters_.

Referenced by mf::service::ELstatistics::log(), and log().

    {
      auto xl_iter = xidLimiters_.find(xid);
      if (xl_iter == xidLimiters_.end()) {
        // Need to create and initialize a limiter for this xid.
        int limit{defaultLimit_};
        int reportEvery{defaultReportEvery_};
        int timespan{defaultTimespan_};
        // Does the category of this xid have explicit limits?
        auto cp_iter = categoryParams_.find(xid.id());
        if (cp_iter != categoryParams_.end()) {
          // Category limits found, use them.
          auto const& cp = cp_iter->second;
          limit = (cp.limit_ < 0) ? defaultLimit_ : cp.limit_;
          reportEvery =
            (cp.reportEvery_ < 0) ? defaultReportEvery_ : cp.reportEvery_;
          timespan = (cp.timespan_ < 0) ? defaultTimespan_ : cp.timespan_;
        }
        XidLimiter& limiter = xidLimiters_[xid];
        limiter.previousTimestamp_ = time(0);
        limiter.msgCount_ = 0;
        limiter.skippedMsgCount_ =
          reportEvery -
          1; // So that the FIRST of the prescaled messages emerges
        limiter.limit_ = limit;
        limiter.reportEvery_ = reportEvery;
        limiter.timespan_ = timespan;
        xl_iter = xidLimiters_.find(xid);
      }
      XidLimiter& limiter = xl_iter->second;
      time_t now = time(0);
      // Has it been so long that we should restart counting toward the limit?
      if ((limiter.timespan_ >= 0) &&
          (difftime(now, limiter.previousTimestamp_) >= limiter.timespan_)) {
        limiter.msgCount_ = 0;
        if (limiter.reportEvery_ > 0) {
          // So this message will be reacted to
          limiter.skippedMsgCount_ = limiter.reportEvery_ - 1;
        } else {
          limiter.skippedMsgCount_ = 0;
        }
      }
      limiter.previousTimestamp_ = now;
      ++limiter.msgCount_;
      ++limiter.skippedMsgCount_;
      if (limiter.skippedMsgCount_ < limiter.reportEvery_) {
        // Skip message.
        return true;
      }
      if (limiter.limit_ == 0) {
        // Zero limit - never react to this
        // Skip message.
        return true;
      }
      if ((limiter.limit_ < 0) || (limiter.msgCount_ <= limiter.limit_)) {
        limiter.skippedMsgCount_ = 0;
        // Accept message.
        return false;
      }
      // Now we are over the limit - have we exceeded limit by 2^N * limit?
      long diff = limiter.msgCount_ - limiter.limit_;
      long r = diff / limiter.limit_;
      if (r * limiter.limit_ != diff) {
        // Not a multiple of limit - don't react
        // Skip message.
        return true;
      }
      if (r == 1) {
        // Exactly twice limit - react
        limiter.skippedMsgCount_ = 0;
        // Accept message.
        return false;
      }
      while (r > 1) {
        if ((r & 1) != 0) {
          // Not 2**msgCount_ times limit - don't react
          // Skip message.
          return true;
        }
        r >>= 1;
      }
      // If you never get an odd number till one, r is 2**msgCount_ so react
      limiter.skippedMsgCount_ = 0;
      // Accept message.
      return false;
    }

string mf::service::ELdestination::summarizeContext ( std::string const &  )

protected

Definition at line 378 of file ELdestination.cc.

Referenced by mf::service::ELstatistics::log(), and log().

    {
      if (c.substr(0, 4) != "Run:") {
        return c;
      }
      istringstream is(c);
      string runWord;
      int run;
      is >> runWord >> run;
      if (!is) {
        return c;
      }
      if (runWord != "Run:") {
        return c;
      }
      string eventWord;
      int event;
      is >> eventWord >> event;
      if (!is) {
        return c;
      }
      if (eventWord != "Event:") {
        return c;
      }
      ostringstream os;
      os << run << "/" << event;
      return os.str();
    }

void mf::service::ELdestination::summary ( )

virtual

Reimplemented in mf::service::ELstatistics.

Definition at line 706 of file ELdestination.cc.

References mf::ELzeroSeverity, formSummary(), outputStatistics_, reset_, resetLimiters(), resetMsgCounters(), routePayload(), s, and updatedStats_.

    {
      if (outputStatistics_ && updatedStats_) {
        ostringstream payload;
        payload << "\n=============================================\n\n"
                << "MessageLogger Summary\n"
                << formSummary();
        routePayload(payload, ErrorObj{ELzeroSeverity, "No ostream"s});
      }
      updatedStats_ = false;
      if (reset_) {
        resetMsgCounters();
        resetLimiters();
      }
    }

Member Data Documentation

std::map<std::string const, CategoryParams> mf::service::ELdestination::categoryParams_

protected

Definition at line 264 of file ELdestination.h.

Referenced by ELdestination(), and skipMsg().

std::size_t mf::service::ELdestination::charsOnLine_ {}

private

Definition at line 273 of file ELdestination.h.

Referenced by ELdestination(), emitToken(), and fillPrefix().

int mf::service::ELdestination::defaultLimit_

protected

Definition at line 261 of file ELdestination.h.

Referenced by ELdestination(), and skipMsg().

int mf::service::ELdestination::defaultReportEvery_

protected

Definition at line 262 of file ELdestination.h.

Referenced by ELdestination(), and skipMsg().

int mf::service::ELdestination::defaultTimespan_

protected

Definition at line 263 of file ELdestination.h.

Referenced by ELdestination(), and skipMsg().

MsgFormatSettings mf::service::ELdestination::format_

protected

Definition at line 260 of file ELdestination.h.

Referenced by ELdestination(), emitToken(), mfplugins::ELsyslog::fillPrefix(), fillPrefix(), fillSuffix(), and fillUsrMsg().

bool mf::service::ELdestination::outputStatistics_ {false}

protected

Definition at line 267 of file ELdestination.h.

Referenced by ELdestination(), mf::service::ELstatistics::log(), log(), mf::service::ELstatistics::summary(), and summary().

bool mf::service::ELdestination::reset_ {false}

protected

Definition at line 269 of file ELdestination.h.

Referenced by ELdestination(), mf::service::ELstatistics::summary(), and summary().

std::map<ELextendedID const, StatsCount> mf::service::ELdestination::statsMap_

protected

Definition at line 266 of file ELdestination.h.

Referenced by ELdestination(), formSummary(), mf::service::ELstatistics::log(), log(), and resetMsgCounters().

ELseverityLevel mf::service::ELdestination::threshold_

protected

Definition at line 259 of file ELdestination.h.

Referenced by mf::service::ELstatistics::log(), log(), and setThreshold().

bool mf::service::ELdestination::updatedStats_ {false}

protected

Definition at line 268 of file ELdestination.h.

Referenced by ELdestination(), mf::service::ELstatistics::log(), log(), mf::service::ELstatistics::summary(), and summary().

std::map<ELextendedID const, XidLimiter> mf::service::ELdestination::xidLimiters_

protected

Definition at line 265 of file ELdestination.h.

Referenced by ELdestination(), resetLimiters(), and skipMsg().

---

The documentation for this class was generated from the following files:

• messagefacility/MessageService/ELdestination.h
• messagefacility/MessageService/ELdestination.cc