mf::service::ELostreamOutput Class Reference

#include "ELostreamOutput.h"

Inheritance diagram for mf::service::ELostreamOutput:

Classes
struct	Config

Public Types
using	Parameters = fhicl::WrappedTable< Config >
enum	flag_enum {   NO_LINE_BREAKS, TIMESTAMP, MILLISECOND, MODULE,   SUBROUTINE, TEXT, SOME_CONTEXT, SERIAL,   FULL_CONTEXT, TIME_SEPARATE, EPILOGUE_SEPARATE, NFLAGS }

Public Member Functions
	~ELostreamOutput ()
	ELostreamOutput (Parameters const &config, cet::ostream_handle &&, bool emitAtStart=false)
	ELostreamOutput (Parameters const &config, std::ostream &, bool emitAtStart=false)
	ELostreamOutput (Config const &config, cet::ostream_handle &&, bool emitAtStart=false)
	ELostreamOutput (ELostreamOutput const &)=delete
	ELostreamOutput (ELostreamOutput &&)=delete
ELostreamOutput &	operator= (ELostreamOutput const &)=delete
ELostreamOutput &	operator= (ELostreamOutput &&)=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	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 Member Functions
void	routePayload (std::ostringstream const &oss, mf::ErrorObj const &msg) override

Private Attributes
cet::ostream_handle	osh
mf::ELextendedID	xid {}

Detailed Description

Definition at line 24 of file ELostreamOutput.h.

Member Typedef Documentation

using mf::service::ELostreamOutput::Parameters = fhicl::WrappedTable<Config>

Definition at line 31 of file ELostreamOutput.h.

Member Enumeration Documentation

enum mf::service::ELdestination::flag_enum

inherited

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

mf::service::ELostreamOutput::~ELostreamOutput

(

)

Definition at line 17 of file ELostreamOutput.cc.

{}

mf::service::ELostreamOutput::ELostreamOutput	(	Parameters const &	config,
		cet::ostream_handle &&	h,
		bool	emitAtStart = false
	)

Definition at line 25 of file ELostreamOutput.cc.

      : ELostreamOutput{ps(), move(h), emitAtStart}
    {}

mf::service::ELostreamOutput::ELostreamOutput	(	Parameters const &	config,
		std::ostream &	os,
		bool	emitAtStart = false
	)

Definition at line 19 of file ELostreamOutput.cc.

      : ELostreamOutput{ps, cet::ostream_handle{os}, emitAtStart}
    {}

mf::service::ELostreamOutput::ELostreamOutput	(	Config const &	config,
		cet::ostream_handle &&	h,
		bool	emitAtStart = false
	)

Definition at line 31 of file ELostreamOutput.cc.

References mf::service::ELostreamOutput::Config::elDestConfig, mf::service::ELdestination::emitToken(), and osh.

      : ELdestination{config.elDestConfig()}, osh{move(h)}
    {
      if (emitAtStart) {
        emitToken(osh,
                  "\n=================================================",
                  true,
                  true);
        emitToken(osh,
                  "\nMessage Log File written by MessageLogger service\n",
                  false,
                  true);
        emitToken(osh,
                  "\n=================================================\n",
                  true,
                  true);
      }
    }

mf::service::ELostreamOutput::ELostreamOutput ( ELostreamOutput const &  )

delete

mf::service::ELostreamOutput::ELostreamOutput ( ELostreamOutput &&  )

delete

Member Function Documentation

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

protectedinherited

Definition at line 408 of file ELdestination.cc.

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

Referenced by ELostreamOutput(), mf::service::ELdestination::fillPrefix(), mf::service::ELdestination::fillSuffix(), and mf::service::ELdestination::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  )

protectedvirtualinherited

Reimplemented in mfplugins::ELsyslog.

Definition at line 462 of file ELdestination.cc.

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

Referenced by mf::service::ELdestination::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  )

protectedvirtualinherited

Reimplemented in mfplugins::ELsyslog.

Definition at line 552 of file ELdestination.cc.

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

Referenced by mf::service::ELdestination::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  )

protectedvirtualinherited

Reimplemented in mfplugins::ELsyslog.

Definition at line 525 of file ELdestination.cc.

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

Referenced by mfplugins::ELsyslog::fillUsrMsg(), and mf::service::ELdestination::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 ( )

virtualinherited

Definition at line 723 of file ELdestination.cc.

    {}

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

protectedvirtualinherited

Definition at line 735 of file ELdestination.cc.

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

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

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

protectedinherited

Definition at line 594 of file ELdestination.cc.

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

Referenced by mf::service::ELstatistics::summary(), and mf::service::ELdestination::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 )

virtualinherited

Reimplemented in mf::service::ELstatistics.

Definition at line 565 of file ELdestination.cc.

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

Referenced by mf::service::ELdestination::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;
      }
    }

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

delete

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

delete

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

protectedinherited

Definition at line 840 of file ELdestination.cc.

References mf::service::ELdestination::xidLimiters_.

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

    {
      xidLimiters_.clear();
    }

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

protectedinherited

Definition at line 834 of file ELdestination.cc.

References mf::service::ELdestination::statsMap_.

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

    {
      statsMap_.clear();
    }

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

overrideprivatevirtual

Reimplemented from mf::service::ELdestination.

Definition at line 53 of file ELostreamOutput.cc.

References osh.

    {
      osh << oss.str();
      osh.flush();
    }

void mf::service::ELdestination::setThreshold ( ELseverityLevel  sv )

inherited

Definition at line 729 of file ELdestination.cc.

References mf::service::ELdestination::threshold_.

    {
      threshold_ = sv;
    }

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

protectedinherited

Definition at line 746 of file ELdestination.cc.

References mf::service::ELdestination::categoryParams_, mf::service::ELdestination::defaultLimit_, mf::service::ELdestination::defaultReportEvery_, mf::service::ELdestination::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 mf::service::ELdestination::xidLimiters_.

Referenced by mf::service::ELstatistics::log(), and mf::service::ELdestination::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 &  )

protectedinherited

Definition at line 378 of file ELdestination.cc.

Referenced by mf::service::ELstatistics::log(), and mf::service::ELdestination::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 ( )

virtualinherited

Reimplemented in mf::service::ELstatistics.

Definition at line 706 of file ELdestination.cc.

References mf::ELzeroSeverity, mf::service::ELdestination::formSummary(), mf::service::ELdestination::outputStatistics_, mf::service::ELdestination::reset_, mf::service::ELdestination::resetLimiters(), mf::service::ELdestination::resetMsgCounters(), mf::service::ELdestination::routePayload(), s, and mf::service::ELdestination::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_

protectedinherited

Definition at line 264 of file ELdestination.h.

Referenced by mf::service::ELdestination::ELdestination(), and mf::service::ELdestination::skipMsg().

int mf::service::ELdestination::defaultLimit_

protectedinherited

Definition at line 261 of file ELdestination.h.

Referenced by mf::service::ELdestination::ELdestination(), and mf::service::ELdestination::skipMsg().

int mf::service::ELdestination::defaultReportEvery_

protectedinherited

Definition at line 262 of file ELdestination.h.

Referenced by mf::service::ELdestination::ELdestination(), and mf::service::ELdestination::skipMsg().

int mf::service::ELdestination::defaultTimespan_

protectedinherited

Definition at line 263 of file ELdestination.h.

Referenced by mf::service::ELdestination::ELdestination(), and mf::service::ELdestination::skipMsg().

MsgFormatSettings mf::service::ELdestination::format_

protectedinherited

Definition at line 260 of file ELdestination.h.

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

cet::ostream_handle mf::service::ELostreamOutput::osh

private

Definition at line 54 of file ELostreamOutput.h.

Referenced by ELostreamOutput(), and routePayload().

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

protectedinherited

Definition at line 267 of file ELdestination.h.

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

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

protectedinherited

Definition at line 269 of file ELdestination.h.

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

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

protectedinherited

Definition at line 266 of file ELdestination.h.

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

ELseverityLevel mf::service::ELdestination::threshold_

protectedinherited

Definition at line 259 of file ELdestination.h.

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

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

protectedinherited

Definition at line 268 of file ELdestination.h.

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

mf::ELextendedID mf::service::ELostreamOutput::xid {}

private

Definition at line 55 of file ELostreamOutput.h.

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

protectedinherited

Definition at line 265 of file ELdestination.h.

Referenced by mf::service::ELdestination::ELdestination(), mf::service::ELdestination::resetLimiters(), and mf::service::ELdestination::skipMsg().

---

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

• messagefacility/MessageService/ELostreamOutput.h
• messagefacility/MessageService/ELostreamOutput.cc