#include <ThreadSafeLogMessageLoggerScribe.h>

Inheritance diagram for edm::service::ThreadSafeLogMessageLoggerScribe:

Classes
struct	ConfigurableDefaults

Public Member Functions
void	runCommand (MessageLoggerQ::OpCode opcode, void *operand) override

	ThreadSafeLogMessageLoggerScribe ()
	— If queue is NULL, this sets singleThread true More...

	~ThreadSafeLogMessageLoggerScribe () override

Public Member Functions inherited from edm::service::AbstractMLscribe
	AbstractMLscribe ()

	AbstractMLscribe (AbstractMLscribe const &)=delete

void	operator= (AbstractMLscribe const &)=delete

virtual	~AbstractMLscribe ()

Private Types
using	vString = std::vector< std::string >

Private Member Functions
void	configure_dest (edm::ParameterSet const &job_pset, ConfigurableDefaults const &, vString const &categories, std::shared_ptr< ELdestination > dest_ctrl, edm::ParameterSet const &dest_pset, std::string const &filename)

void	configure_errorlog (edm::ParameterSet &)

void	configure_errorlog_new (edm::ParameterSet &)

std::vector< std::string >	configure_ordinary_destinations (edm::ParameterSet const &, ConfigurableDefaults const &defaults, vString const &categories)

void	configure_statistics (edm::ParameterSet const &, ConfigurableDefaults const &defaults, vString const &categories, std::vector< std::string > const &destination_names)

void	configure_statistics_dest (edm::ParameterSet const &job_pset, ConfigurableDefaults const &defaults, vString const &categories, edm::ParameterSet const &stat_pset, std::string const &psetname, std::string const &filename)

std::string	destinationFileName (edm::ParameterSet const &, std::string const &) const

void	log (ErrorObj *errorobj_p)

std::shared_ptr< ELdestination >	makeDestinationCtrl (std::string const &filename)

void	parseCategories (std::string const &s, std::vector< std::string > &cats)

void	triggerFJRmessageSummary (std::map< std::string, double > &sm)

void	triggerStatisticsSummaries ()

void	validate (edm::ParameterSet &) const

Static Private Member Functions
template<class T >
static T	getAparameter (edm::ParameterSet const &p, std::string const &id, T const &def)

static ConfigurableDefaults	parseDefaults (edm::ParameterSet const &job_pset)

Private Attributes
bool	m_active

edm::propagate_const< std::shared_ptr< ELadministrator > >	m_admin_p

bool	m_clean_slate_configuration

std::atomic< int >	m_count

std::shared_ptr< ELdestination >	m_early_dest

std::vector< edm::propagate_const< std::shared_ptr< std::ofstream > > >	m_file_ps

std::atomic< bool >	m_messageBeingSent

value_ptr< MessageLoggerDefaults >	m_messageLoggerDefaults

std::atomic< bool >	m_purge_mode

std::vector< std::shared_ptr< ELstatistics > >	m_statisticsDestControls

std::vector< bool >	m_statisticsResets

std::map< std::string, edm::propagate_const< std::ostream * > >	m_stream_ps

std::atomic< unsigned long >	m_tooManyWaitingMessagesCount

oneapi::tbb::concurrent_queue< ErrorObj * >	m_waitingMessages

size_t	m_waitingThreshold

Detailed Description

Definition at line 38 of file ThreadSafeLogMessageLoggerScribe.h.

Member Typedef Documentation

◆ vString

using edm::service::ThreadSafeLogMessageLoggerScribe::vString = std::vector<std::string>

private

Definition at line 72 of file ThreadSafeLogMessageLoggerScribe.h.

Constructor & Destructor Documentation

◆ ThreadSafeLogMessageLoggerScribe()

edm::service::ThreadSafeLogMessageLoggerScribe::ThreadSafeLogMessageLoggerScribe ( )

explicit

— If queue is NULL, this sets singleThread true

Definition at line 41 of file ThreadSafeLogMessageLoggerScribe.cc.

         : m_admin_p(std::make_shared<ELadministrator>()),
           m_early_dest(m_admin_p->attach(std::make_shared<ELoutput>(std::cerr, false))),
           m_clean_slate_configuration(true),
           m_active(true),
           m_purge_mode(false),
           m_count(0),
           m_messageBeingSent(false),
           m_waitingThreshold(100),
           m_tooManyWaitingMessagesCount(0) {}

◆ ~ThreadSafeLogMessageLoggerScribe()

edm::service::ThreadSafeLogMessageLoggerScribe::~ThreadSafeLogMessageLoggerScribe ( )

override

Definition at line 52 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, edm::ELextendedID::id, m_admin_p, m_purge_mode, m_waitingMessages, parseCategories(), edm::ErrorObj::setID(), and edm::ErrorObj::xid().

                                                                         {
       //if there are any waiting message, finish them off
       ErrorObj* errorobj_p = nullptr;
       std::vector<std::string> categories;
       while (m_waitingMessages.try_pop(errorobj_p)) {
         if (not m_purge_mode) {
           categories.clear();
           parseCategories(errorobj_p->xid().id, categories);
           for (unsigned int icat = 0; icat < categories.size(); ++icat) {
             errorobj_p->setID(categories[icat]);
             m_admin_p->log(*errorobj_p);  // route the message text
           }
         }
         delete errorobj_p;
       }
 
       m_admin_p->finish();
     }

Member Function Documentation

◆ configure_dest()

void edm::service::ThreadSafeLogMessageLoggerScribe::configure_dest	(	edm::ParameterSet const &	job_pset,
		ConfigurableDefaults const &	defaults,
		vString const &	categories,
		std::shared_ptr< ELdestination >	dest_ctrl,
		edm::ParameterSet const &	dest_pset,
		std::string const &	filename
	)

private

Definition at line 461 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, validateAlignments::category, hltLogMonitorFilter_cfi::default_threshold, common_cff::defaults, corrVsCorr::filename, writeEcalDQMStatus::interval, remoteMonitoring_LASER_era2018_cfg::limit, m_messageLoggerDefaults, hlt_jetmet_dqm_QT_fromfile_cfg::noLineBreaks, ErrorSummaryFilter_cfi::severity, AlCaHLTBitMon_QueryRunRegistry::string, and MessageLogger_ReleaseValidation_cfi::timespan.

Referenced by configure_errorlog_new(), configure_ordinary_destinations(), and configure_statistics_dest().

                                                                                      {
       vString const empty_vString;
       edm::ParameterSet const empty_PSet;
       std::string const empty_String;
 
       // Defaults:                          // change log 3a
       const std::string COMMON_DEFAULT_THRESHOLD = "INFO";
 
       vString const severities = {{"WARNING", "INFO", "FWKINFO", "ERROR", "DEBUG"}};
 
       // grab default threshold common to all destinations
       std::string const default_threshold = getAparameter<std::string>(job_pset, "threshold", empty_String);
       // change log 3a
       // change log 24
 
       // grab default limit/interval/timespan common to all destinations/categories:
       edm::ParameterSet const default_pset = getAparameter<edm::ParameterSet>(job_pset, "default", empty_PSet);
 
       // See if this is just a placeholder          // change log 9
       bool is_placeholder = getAparameter<bool>(dest_pset, "placeholder", false);
       if (is_placeholder)
         return;
 
       // grab this destination's default limit/interval/timespan:
       edm::ParameterSet dest_default_pset = getAparameter<edm::ParameterSet>(dest_pset, "default", empty_PSet);
       int dest_default_limit = getAparameter<int>(dest_default_pset, "limit", defaults.limit_);
       int dest_default_interval = getAparameter<int>(dest_default_pset, "reportEvery", defaults.reportEvery_);
       // change log 6
       int dest_default_timespan = getAparameter<int>(dest_default_pset, "timespan", defaults.timespan_);
       // change log 1a
       if (dest_default_limit != defaults.NO_VALUE_SET) {
         if (dest_default_limit < 0)
           dest_default_limit = 2000000000;
         dest_ctrl->setLimit("*", dest_default_limit);
       }                                                      // change log 1b, 2a, 2b
       if (dest_default_interval != defaults.NO_VALUE_SET) {  // change log 6
         dest_ctrl->setInterval("*", dest_default_interval);
       }
       if (dest_default_timespan != defaults.NO_VALUE_SET) {
         if (dest_default_timespan < 0)
           dest_default_timespan = 2000000000;
         dest_ctrl->setTimespan("*", dest_default_timespan);
       }  // change log 1b, 2a, 2b
 
       // establish this destination's threshold:
       std::string dest_threshold = getAparameter<std::string>(dest_pset, "threshold", default_threshold);
       if (dest_threshold == empty_String) {
         dest_threshold = default_threshold;
       }
       if (dest_threshold == empty_String) {  // change log 34
         dest_threshold = defaults.threshold_;
       }
       if (dest_threshold == empty_String) {
         dest_threshold = m_messageLoggerDefaults->threshold(filename);
       }
       if (dest_threshold == empty_String)
         dest_threshold = COMMON_DEFAULT_THRESHOLD;
       ELseverityLevel threshold_sev(dest_threshold);
       dest_ctrl->setThreshold(threshold_sev);
       // change log 37
       setGlobalThresholds(threshold_sev);
 
       // establish this destination's limit/interval/timespan for each category:
       for (vString::const_iterator id_it = categories.begin(); id_it != categories.end(); ++id_it) {
         const std::string& msgID = *id_it;
         edm::ParameterSet default_category_pset =
             getAparameter<edm::ParameterSet>(default_pset, msgID, empty_PSet);  // change log 5
         edm::ParameterSet category_pset = getAparameter<edm::ParameterSet>(dest_pset, msgID, default_category_pset);
 
         int category_default_limit = getAparameter<int>(default_category_pset, "limit", defaults.NO_VALUE_SET);
         int limit = getAparameter<int>(category_pset, "limit", category_default_limit);
         if (limit == defaults.NO_VALUE_SET)
           limit = dest_default_limit;
         // change log 7
         int category_default_interval = getAparameter<int>(default_category_pset, "reportEvery", defaults.NO_VALUE_SET);
         int interval = getAparameter<int>(category_pset, "reportEvery", category_default_interval);
         if (interval == defaults.NO_VALUE_SET)
           interval = dest_default_interval;
         // change log 6  and then 7
         int category_default_timespan = getAparameter<int>(default_category_pset, "timespan", defaults.NO_VALUE_SET);
         int timespan = getAparameter<int>(category_pset, "timespan", category_default_timespan);
         if (timespan == defaults.NO_VALUE_SET)
           timespan = dest_default_timespan;
         // change log 7
 
         const std::string& category = msgID;
         if (limit == defaults.NO_VALUE_SET) {  // change log 24
           limit = m_messageLoggerDefaults->limit(filename, category);
         }
         if (interval == defaults.NO_VALUE_SET) {  // change log 24
           interval = m_messageLoggerDefaults->reportEvery(filename, category);
         }
         if (timespan == defaults.NO_VALUE_SET) {  // change log 24
           timespan = m_messageLoggerDefaults->timespan(filename, category);
         }
 
         if (limit != defaults.NO_VALUE_SET) {
           if (limit < 0)
             limit = 2000000000;
           dest_ctrl->setLimit(msgID, limit);
         }  // change log 2a, 2b
         if (interval != defaults.NO_VALUE_SET) {
           dest_ctrl->setInterval(msgID, interval);
         }  // change log 6
         if (timespan != defaults.NO_VALUE_SET) {
           if (timespan < 0)
             timespan = 2000000000;
           dest_ctrl->setTimespan(msgID, timespan);
         }  // change log 2a, 2b
 
       }  // for
 
       // establish this destination's limit for each severity:
       for (vString::const_iterator sev_it = severities.begin(); sev_it != severities.end(); ++sev_it) {
         const std::string& sevID = *sev_it;
         ELseverityLevel severity(sevID);
         edm::ParameterSet default_sev_pset = getAparameter<edm::ParameterSet>(default_pset, sevID, empty_PSet);
         edm::ParameterSet sev_pset = getAparameter<edm::ParameterSet>(dest_pset, sevID, default_sev_pset);
         // change log 5
         int limit = getAparameter<int>(sev_pset, "limit", defaults.NO_VALUE_SET);
         if (limit == defaults.NO_VALUE_SET) {  // change log 24
           limit = m_messageLoggerDefaults->sev_limit(filename, sevID);
         }
         if (limit != defaults.NO_VALUE_SET) {
           if (limit < 0)
             limit = 2000000000;  // change log 38
           dest_ctrl->setLimit(severity, limit);
         }
         int interval = getAparameter<int>(sev_pset, "reportEvery", defaults.NO_VALUE_SET);
         if (interval == defaults.NO_VALUE_SET) {  // change log 24
           interval = m_messageLoggerDefaults->sev_reportEvery(filename, sevID);
         }
         if (interval != defaults.NO_VALUE_SET)
           dest_ctrl->setInterval(severity, interval);
         // change log 2
         int timespan = getAparameter<int>(sev_pset, "timespan", defaults.NO_VALUE_SET);
         if (timespan == defaults.NO_VALUE_SET) {  // change log 24
           timespan = m_messageLoggerDefaults->sev_timespan(filename, sevID);
         }
         if (timespan != defaults.NO_VALUE_SET) {
           if (timespan < 0)
             timespan = 2000000000;  // change log 38
           dest_ctrl->setTimespan(severity, timespan);
         }
       }  // for
 
       // establish this destination's linebreak policy:
       // change log 5
       bool noLineBreaks = getAparameter<bool>(dest_pset, "noLineBreaks", defaults.noLineBreaks_);
       if (noLineBreaks) {
         dest_ctrl->setLineLength(32000);
       } else {
         // change log 5
         int lineLen = getAparameter<int>(dest_pset, "lineLength", defaults.lineLength_);
         dest_ctrl->setLineLength(lineLen);
       }
 
       // if indicated, suppress time stamps in this destination's output
       bool suppressTime = getAparameter<bool>(dest_pset, "noTimeStamps", defaults.noTimeStamps_);
       if (suppressTime) {
         dest_ctrl->suppressTime();
       }
 
     }  // ThreadSafeLogMessageLoggerScribe::configure_dest()

◆ configure_errorlog()

void edm::service::ThreadSafeLogMessageLoggerScribe::configure_errorlog ( edm::ParameterSet & job_pset )

private

Definition at line 364 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, configure_errorlog_new(), configure_ordinary_destinations(), configure_statistics(), edm::copy_all(), common_cff::defaults, m_clean_slate_configuration, m_early_dest, m_messageLoggerDefaults, m_stream_ps, m_waitingThreshold, parseDefaults(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by runCommand().

                                                                                        {
       if (not usingOldConfig(job_pset)) {
         configure_errorlog_new(job_pset);
         return;
       }
       const vString empty_vString;
       const std::string empty_String;
       const edm::ParameterSet empty_PSet;
 
       // The following is present to test pre-configuration message handling:
       std::string preconfiguration_message =
           getAparameter<std::string>(job_pset, "generate_preconfiguration_message", empty_String);
       if (preconfiguration_message != empty_String) {
         // To test a preconfiguration message without first going thru the
         // configuration we are about to do, we issue the message (so it sits
         // on the queue), then copy the processing that the LOG_A_MESSAGE case
         // does.  We suppress the timestamp to allow for automated unit testing.
         m_early_dest->suppressTime();
         LogError("preconfiguration") << preconfiguration_message;
       }
 
       if (!m_stream_ps.empty()) {
         LogWarning("multiLogConfig") << "The message logger has been configured multiple times";
         m_clean_slate_configuration = false;  // Change Log 22
       }
       m_waitingThreshold = getAparameter<unsigned int>(job_pset, "waiting_threshold", 100);
       auto defaults = parseDefaults(job_pset);
       // grab list of categories
       vString categories = getAparameter<vString>(job_pset, "categories", empty_vString);
       // grab list of hardwired categories (hardcats) -- these are to be added
       // to the list of categories -- change log 24
       {
         std::vector<std::string> hardcats = m_messageLoggerDefaults->categories;
         // combine the lists, not caring about possible duplicates (for now)
         copy_all(hardcats, std::back_inserter(categories));
       }  // no longer need hardcats
 
       auto destination_names = configure_ordinary_destinations(job_pset, defaults, categories);
       configure_statistics(job_pset, defaults, categories, destination_names);
     }  // ThreadSafeLogMessageLoggerScribe::configure_errorlog()

◆ configure_errorlog_new()

void edm::service::ThreadSafeLogMessageLoggerScribe::configure_errorlog_new ( edm::ParameterSet & job_pset )

private

Definition at line 280 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, configure_dest(), configure_statistics_dest(), edm::MessageDrop::debugAlwaysSuppressed, common_cff::defaults, destinationFileName(), edm::ELhighestSeverity, Exception, submitPVResolutionJobs::files, edm::MessageDrop::fwkInfoAlwaysSuppressed, edm::ParameterSet::getUntrackedParameter(), edm::MessageDrop::infoAlwaysSuppressed, m_clean_slate_configuration, m_early_dest, m_stream_ps, m_waitingThreshold, makeDestinationCtrl(), Skims_PA_cff::name, parseDefaults(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::MessageDrop::warningAlwaysSuppressed.

Referenced by configure_errorlog().

                                                                                            {
       {
         auto preconfiguration_message =
             job_pset.getUntrackedParameter<std::string>("generate_preconfiguration_message");
         if (not preconfiguration_message.empty()) {
           // To test a preconfiguration message without first going thru the
           // configuration we are about to do, we issue the message (so it sits
           // on the queue), then copy the processing that the LOG_A_MESSAGE case
           // does.  We suppress the timestamp to allow for automated unit testing.
           m_early_dest->suppressTime();
           LogError("preconfiguration") << preconfiguration_message;
         }
       }
       if (!m_stream_ps.empty()) {
         LogWarning("multiLogConfig") << "The message logger has been configured multiple times";
         m_clean_slate_configuration = false;  // Change Log 22
       }
       m_waitingThreshold = job_pset.getUntrackedParameter<unsigned int>("waiting_threshold");
 
       auto defaults = parseDefaults(job_pset);
       auto categories = findAllCategories(job_pset);
 
       // Initialize unversal suppression variables
       MessageDrop::debugAlwaysSuppressed = true;
       MessageDrop::infoAlwaysSuppressed = true;
       MessageDrop::fwkInfoAlwaysSuppressed = true;
       MessageDrop::warningAlwaysSuppressed = true;
 
       m_early_dest->setThreshold(ELhighestSeverity);
 
       auto cout_dest = job_pset.getUntrackedParameter<edm::ParameterSet>("cout");
       if (cout_dest.getUntrackedParameter<bool>("enable")) {
         auto dest_ctrl = makeDestinationCtrl("cout");
         configure_dest(job_pset, defaults, categories, dest_ctrl, cout_dest, "cout");
       }
 
       auto cerr_dest = job_pset.getUntrackedParameter<edm::ParameterSet>("cerr");
       if (cerr_dest.getUntrackedParameter<bool>("enable")) {
         auto dest_ctrl = makeDestinationCtrl("cerr");
         configure_dest(job_pset, defaults, categories, dest_ctrl, cerr_dest, "cerr");
       }
 
       auto const& files = job_pset.getUntrackedParameter<edm::ParameterSet>("files");
       for (auto const& name : files.getParameterNamesForType<edm::ParameterSet>(false)) {
         auto const& dest_pset = files.getUntrackedParameter<edm::ParameterSet>(name);
         auto const actual_filename = destinationFileName(dest_pset, name);
 
         // Check that this is not a duplicate name
         if (m_stream_ps.find(actual_filename) != m_stream_ps.end()) {
           if (m_clean_slate_configuration) {
             throw cms::Exception("DuplicateDestination")
                 << "Duplicate name for a MessageLogger Destination: " << actual_filename << "\n"
                 << "Please modify the configuration to use unique file names.";
           } else {
             LogWarning("duplicateDestination")
                 << "Duplicate name for a MessageLogger Destination: " << actual_filename << "\n"
                 << "Only original configuration instructions are used";
             continue;
           }
         }
 
         auto dest_ctrl = makeDestinationCtrl(actual_filename);
         configure_dest(job_pset, defaults, categories, dest_ctrl, dest_pset, name);
       }
       //NOTE: statistics destinations MUST BE last in the list else they can be fooled into
       // thinking a message has been ignored just because a later destination which uses it
       // falls later in the list.
       for (auto const& name : files.getParameterNamesForType<edm::ParameterSet>(false)) {
         auto const& dest_pset = files.getUntrackedParameter<edm::ParameterSet>(name);
         auto const actual_filename = destinationFileName(dest_pset, name);
         if (getAparameter<bool>(dest_pset, "enableStatistics", false)) {
           configure_statistics_dest(job_pset, defaults, categories, dest_pset, name, actual_filename);
         }
       }
       if (cout_dest.getUntrackedParameter<bool>("enable") and
           getAparameter<bool>(cout_dest, "enableStatistics", true)) {
         configure_statistics_dest(job_pset, defaults, categories, cout_dest, "cout", "cout");
       }
       if (cerr_dest.getUntrackedParameter<bool>("enable") and
           getAparameter<bool>(cerr_dest, "enableStatistics", true)) {
         configure_statistics_dest(job_pset, defaults, categories, cerr_dest, "cerr", "cerr");
       }
     }

◆ configure_ordinary_destinations()

std::vector< std::string > edm::service::ThreadSafeLogMessageLoggerScribe::configure_ordinary_destinations	(	edm::ParameterSet const &	job_pset,
		ConfigurableDefaults const &	defaults,
		vString const &	categories
	)

private

Definition at line 631 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, configure_dest(), edm::MessageDrop::debugAlwaysSuppressed, common_cff::defaults, destinationFileName(), myMessageLogger_cff::destinations, edm::ELhighestSeverity, corrVsCorr::filename, edm::MessageDrop::fwkInfoAlwaysSuppressed, edm::MessageDrop::infoAlwaysSuppressed, m_clean_slate_configuration, m_early_dest, m_messageLoggerDefaults, m_stream_ps, makeDestinationCtrl(), AlCaHLTBitMon_QueryRunRegistry::string, and edm::MessageDrop::warningAlwaysSuppressed.

Referenced by configure_errorlog().

                                                                                                           {
       vString const empty_vString;
       std::string const empty_String;
       edm::ParameterSet const empty_PSet;
 
       // Initialize unversal suppression variables
       MessageDrop::debugAlwaysSuppressed = true;
       MessageDrop::infoAlwaysSuppressed = true;
       MessageDrop::fwkInfoAlwaysSuppressed = true;
       MessageDrop::warningAlwaysSuppressed = true;
 
       // grab list of destinations:
       vString destinations = getAparameter<vString>(job_pset, "destinations", empty_vString);
 
       // Use the default list of destinations if and only if the grabbed list is
       // empty                          // change log 24
       if (destinations.empty()) {
         destinations = m_messageLoggerDefaults->destinations;
       }
 
       // dial down the early destination if other dest's are supplied:
       if (!destinations.empty())
         m_early_dest->setThreshold(ELhighestSeverity);
 
       // establish each destination:
       std::vector<std::string> ordinary_destination_filenames;
       for (vString::const_iterator it = destinations.begin(); it != destinations.end(); ++it) {
         const std::string& filename = *it;
         const std::string& psetname = filename;
 
         // check that this destination is not just a placeholder // change log 11
         edm::ParameterSet dest_pset = getAparameter<edm::ParameterSet>(job_pset, psetname, empty_PSet);
         bool is_placeholder = getAparameter<bool>(dest_pset, "placeholder", false);
         if (is_placeholder)
           continue;
 
         // Modify the file name if extension or name is explicitly specified
         // change log 14
 
         // Although for an ordinary destination there is no output attribute
         // for the cfg (you can use filename instead) we provide output() for
         // uniformity with the statistics destinations.  The "right way" to
         // work this would have been to provide a filename() method, along with
         // an extension() method.  We recognize the potential name confusion here
         // (filename(filename))!
 
         auto const actual_filename = destinationFileName(dest_pset, psetname);
 
         // Check that this is not a duplicate name          // change log 18
         if (m_stream_ps.find(actual_filename) != m_stream_ps.end()) {
           if (m_clean_slate_configuration) {  // change log 22
                                               //        throw edm::Exception ( edm::errors::Configuration )
             LogError("duplicateDestination")  // change log 35
                 << "Duplicate name for a MessageLogger Destination: " << actual_filename << "\n"
                 << "Only the first configuration instructions are used";
             continue;
           } else {
             LogWarning("duplicateDestination")
                 << "Duplicate name for a MessageLogger Destination: " << actual_filename << "\n"
                 << "Only original configuration instructions are used";
             continue;
           }
         }
 
         ordinary_destination_filenames.push_back(actual_filename);
 
         // attach the current destination, keeping a control handle to it:
         std::shared_ptr<ELdestination> dest_ctrl = makeDestinationCtrl(actual_filename);
         // now configure this destination:
         configure_dest(job_pset, defaults, categories, dest_ctrl, dest_pset, psetname);
 
       }  // for [it = destinations.begin() to end()]
 
       return ordinary_destination_filenames;
     }  // configure_ordinary_destinations

◆ configure_statistics()

void edm::service::ThreadSafeLogMessageLoggerScribe::configure_statistics	(	edm::ParameterSet const &	,
		ConfigurableDefaults const &	defaults,
		vString const &	categories,
		std::vector< std::string > const &	destination_names
	)

private

Definition at line 742 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, DMR_cfg::cerr, edm::errors::Configuration, configure_statistics_dest(), gather_cfg::cout, common_cff::defaults, mps_fire::dest, myMessageLogger_cff::destinations, Exception, corrVsCorr::filename, m_clean_slate_configuration, m_file_ps, m_messageLoggerDefaults, m_stream_ps, edm::search_all(), MessageLogger_cfi::statistics, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by configure_errorlog().

                                                                                                                {
       vString const empty_vString;
       std::string const empty_String;
       edm::ParameterSet const empty_PSet;
 
       // grab list of statistics destinations:
       vString statistics = getAparameter<vString>(job_pset, "statistics", empty_vString);
 
       bool no_statistics_configured = statistics.empty();  // change log 24
 
       if (no_statistics_configured) {
         // Read the list of staistics destinations from hardwired defaults,
         // but only if there is also no list of ordinary destinations.
         // (If a cfg specifies destinations, and no statistics, assume that
         // is what the user wants.)
         vString destinations = getAparameter<vString>(job_pset, "destinations", empty_vString);
         if (destinations.empty()) {
           statistics = m_messageLoggerDefaults->statistics;
           no_statistics_configured = statistics.empty();
         } else {
           for (auto const& dest : destinations) {
             edm::ParameterSet stat_pset = getAparameter<edm::ParameterSet>(job_pset, dest, empty_PSet);
             if (getAparameter<bool>(stat_pset, "enableStatistics", false)) {
               statistics.push_back(dest);
             }
           }
         }
       }
 
       // establish each statistics destination:
       for (auto const& psetname : statistics) {
         // check that this destination is not just a placeholder // change log 20
         edm::ParameterSet stat_pset = getAparameter<edm::ParameterSet>(job_pset, psetname, empty_PSet);
         bool is_placeholder = getAparameter<bool>(stat_pset, "placeholder", false);
         if (is_placeholder)
           continue;
 
         // Determine the destination file name
         std::string filename = getAparameter<std::string>(stat_pset, "output", empty_String);
         if (filename == empty_String) {
           filename = m_messageLoggerDefaults->output(psetname);  // change log 31
           if (filename == empty_String) {
             filename = psetname;
           }
         }
 
         // Modify the file name if extension or name is explicitly specified
         // change log 14 -- probably suspenders and a belt, because ouput option
         // is present, but uniformity is nice.
 
         std::string explicit_filename = getAparameter<std::string>(stat_pset, "filename", filename);
         if (explicit_filename != empty_String)
           filename = explicit_filename;
         std::string explicit_extension = getAparameter<std::string>(stat_pset, "extension", empty_String);
         if (explicit_extension != empty_String) {
           if (explicit_extension[0] == '.') {
             filename += explicit_extension;
           } else {
             filename = filename + "." + explicit_extension;
           }
         }
 
         // Attach a default extension of .log if there is no extension on a file
         // change log 18 - this had been done in concert with attaching destination
 
         std::string actual_filename = filename;              // change log 4
         if ((filename != "cout") && (filename != "cerr")) {  // change log 23
           const std::string::size_type npos = std::string::npos;
           if (filename.find('.') == npos) {
             actual_filename += ".log";
           }
         }
 
         // Check that this is not a duplicate name -
         // unless it is an ordinary destination (which stats can share)
         if (!search_all(ordinary_destination_filenames, actual_filename)) {
           if (m_stream_ps.find(actual_filename) != m_stream_ps.end()) {
             if (m_clean_slate_configuration) {  // change log 22
               throw edm::Exception(edm::errors::Configuration)
                   << "Duplicate name for a MessageLogger Statistics Destination: " << actual_filename << "\n";
             } else {
               LogWarning("duplicateDestination")
                   << "Duplicate name for a MessageLogger Statistics Destination: " << actual_filename << "\n"
                   << "Only original configuration instructions are used";
               continue;
             }
           }
         }
 
         // create (if statistics file does not match any destination file name)
         // or note (if statistics file matches a destination file name) the ostream.
         // But if no statistics destinations were provided in the config, do not
         // create a new destination for this hardwired statistics - only act if
         // it is matches a destination.  (shange log 24)
         bool statistics_destination_is_real = !no_statistics_configured;
         std::ostream* os_p;
         if (m_stream_ps.find(actual_filename) == m_stream_ps.end()) {
           if (actual_filename == "cout") {
             os_p = &std::cout;
           } else if (actual_filename == "cerr") {
             os_p = &std::cerr;
           } else {
             auto os_sp = std::make_shared<std::ofstream>(actual_filename.c_str());
             m_file_ps.push_back(os_sp);
             os_p = os_sp.get();
           }
           m_stream_ps[actual_filename] = os_p;
         } else {
           statistics_destination_is_real = true;  // change log 24
         }
 
         if (statistics_destination_is_real) {  // change log 24
                                                // attach the statistics destination, keeping a control handle to it:
 
           configure_statistics_dest(job_pset, defaults, categories, stat_pset, psetname, actual_filename);
         }
 
       }  // for [it = statistics.begin() to end()]
 
     }  // configure_statistics

◆ configure_statistics_dest()

void edm::service::ThreadSafeLogMessageLoggerScribe::configure_statistics_dest	(	edm::ParameterSet const &	job_pset,
		ConfigurableDefaults const &	defaults,
		vString const &	categories,
		edm::ParameterSet const &	stat_pset,
		std::string const &	psetname,
		std::string const &	filename
	)

private

Definition at line 708 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, configure_dest(), common_cff::defaults, corrVsCorr::filename, m_admin_p, m_statisticsDestControls, m_statisticsResets, m_stream_ps, reset(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by configure_errorlog_new(), and configure_statistics().

                                                                                                 {
       auto os_p = m_stream_ps[filename];
 
       auto stat = std::make_shared<ELstatistics>(*os_p);
       m_admin_p->attach(stat);
       m_statisticsDestControls.push_back(stat);
       bool reset = getAparameter<bool>(stat_pset, "resetStatistics", false);
       if (not reset) {
         //check for old syntax
         reset = getAparameter<bool>(stat_pset, "reset", false);
       }
       m_statisticsResets.push_back(reset);
 
       // now configure this destination:
       configure_dest(job_pset, defaults, categories, stat, stat_pset, psetname);
 
       std::string dest_threshold = getAparameter<std::string>(stat_pset, "statisticsThreshold", std::string());
       if (not dest_threshold.empty()) {
         ELseverityLevel threshold_sev(dest_threshold);
         stat->setThreshold(threshold_sev);
 
         setGlobalThresholds(threshold_sev);
       }
 
       // and suppress the desire to do an extra termination summary just because
       // of end-of-job info messages
       stat->noTerminationSummary();
     }

◆ destinationFileName()

std::string edm::service::ThreadSafeLogMessageLoggerScribe::destinationFileName	(	edm::ParameterSet const &	dest_pset,
		std::string const &	psetname
	)		const

private

Definition at line 245 of file ThreadSafeLogMessageLoggerScribe.cc.

References corrVsCorr::filename, m_messageLoggerDefaults, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by configure_errorlog_new(), and configure_ordinary_destinations().

                                                                                                        {
       // Determine the destination file name to use if no explicit filename is
       // supplied in the cfg.
       std::string const empty_String;
       std::string filename = psetname;
       std::string filename_default = getAparameter<std::string>(dest_pset, "output", empty_String);
       if (filename_default == empty_String) {
         filename_default = m_messageLoggerDefaults->output(psetname);  // change log 31
         if (filename_default == empty_String) {
           filename_default = filename;
         }
       }
 
       std::string explicit_filename = getAparameter<std::string>(dest_pset, "filename", filename_default);
       if (explicit_filename != empty_String)
         filename = explicit_filename;
       std::string explicit_extension = getAparameter<std::string>(dest_pset, "extension", empty_String);
       if (explicit_extension != empty_String) {
         if (explicit_extension[0] == '.') {
           filename += explicit_extension;
         } else {
           filename = filename + "." + explicit_extension;
         }
       }
 
       // Attach a default extension of .log if there is no extension on a file
       if ((filename != "cout") && (filename != "cerr")) {
         if (filename.find('.') == std::string::npos) {
           filename += ".log";
         }
       }
       return filename;
     }

◆ getAparameter()

template<class T >

static T edm::service::ThreadSafeLogMessageLoggerScribe::getAparameter	(	edm::ParameterSet const &	p,
		std::string const &	id,
		T const &	def
	)

inlinestaticprivate

Definition at line 105 of file ThreadSafeLogMessageLoggerScribe.h.

References spu::def(), l1ctLayer2EG_cff::id, AlCaHLTBitMon_ParallelJobs::p, and submitPVValidationJobs::t.

                                                                                           {
         T t = def;
         try {
           t = p.template getUntrackedParameter<T>(id, def);
         } catch (...) {
           try {
             t = p.template getParameter<T>(id);
           } catch (...) {
             // Since PSetValidation will catch such errors, we simply proceed as
             // best we can in case we are setting up the logger just to contain the
             // validation-caught error messages.
           }
         }
         return t;
       }

◆ log()

void edm::service::ThreadSafeLogMessageLoggerScribe::log ( ErrorObj * errorobj_p )

private

Definition at line 161 of file ThreadSafeLogMessageLoggerScribe.cc.

References myMessageLogger_cff::categories, edm::ELextendedID::id, m_admin_p, m_messageBeingSent, m_purge_mode, m_tooManyWaitingMessagesCount, m_waitingMessages, m_waitingThreshold, getGTfromDQMFile::obj, parseCategories(), edm::ErrorObj::setID(), and edm::ErrorObj::xid().

Referenced by runCommand().

                                                                    {
       bool expected = false;
       std::unique_ptr<ErrorObj> obj(errorobj_p);
       if (m_messageBeingSent.compare_exchange_strong(expected, true)) {
         std::vector<std::string> categories;
         parseCategories(errorobj_p->xid().id, categories);
         for (unsigned int icat = 0; icat < categories.size(); ++icat) {
           errorobj_p->setID(categories[icat]);
           m_admin_p->log(*errorobj_p);  // route the message text
         }
         //process any waiting messages
         errorobj_p = nullptr;
         while (not m_purge_mode and m_waitingMessages.try_pop(errorobj_p)) {
           obj.reset(errorobj_p);
           categories.clear();
           parseCategories(errorobj_p->xid().id, categories);
           for (unsigned int icat = 0; icat < categories.size(); ++icat) {
             errorobj_p->setID(categories[icat]);
             m_admin_p->log(*errorobj_p);  // route the message text
           }
         }
         m_messageBeingSent.store(false);
       } else {
         if (m_waitingMessages.unsafe_size() < m_waitingThreshold) {
           obj.release();
           m_waitingMessages.push(errorobj_p);
         } else {
           ++m_tooManyWaitingMessagesCount;
         }
       }
     }

◆ makeDestinationCtrl()

std::shared_ptr< ELdestination > edm::service::ThreadSafeLogMessageLoggerScribe::makeDestinationCtrl ( std::string const & filename )

private

Definition at line 405 of file ThreadSafeLogMessageLoggerScribe.cc.

References DMR_cfg::cerr, gather_cfg::cout, edm::ELzeroSeverity, corrVsCorr::filename, m_admin_p, m_early_dest, m_file_ps, and m_stream_ps.

Referenced by configure_errorlog_new(), and configure_ordinary_destinations().

                                                                                                                 {
       std::shared_ptr<ELdestination> dest_ctrl;
       if (filename == "cout") {
         dest_ctrl = m_admin_p->attach(std::make_shared<ELoutput>(std::cout));
         m_stream_ps["cout"] = &std::cout;
       } else if (filename == "cerr") {
         m_early_dest->setThreshold(ELzeroSeverity);
         dest_ctrl = m_early_dest;
         m_stream_ps["cerr"] = &std::cerr;
       } else {
         auto os_sp = std::make_shared<std::ofstream>(filename.c_str());
         m_file_ps.push_back(os_sp);
         dest_ctrl = m_admin_p->attach(std::make_shared<ELoutput>(*os_sp));
         m_stream_ps[filename] = os_sp.get();
       }
       return dest_ctrl;
     }

◆ parseCategories()

void edm::service::ThreadSafeLogMessageLoggerScribe::parseCategories	(	std::string const &	s,
		std::vector< std::string > &	cats
	)

private

Definition at line 866 of file ThreadSafeLogMessageLoggerScribe.cc.

References mps_fire::i, dqmiolumiharvest::j, and alignCSCRings::s.

Referenced by log(), and ~ThreadSafeLogMessageLoggerScribe().

                                                                                                          {
       const std::string::size_type npos = std::string::npos;
       std::string::size_type i = 0;
       while (i != npos) {
         std::string::size_type j = s.find('|', i);
         cats.push_back(s.substr(i, j - i));
         i = j;
         while ((i != npos) && (s[i] == '|'))
           ++i;
         // the above handles cases of || and also | at end of string
       }
       // Note:  This algorithm assigns, as desired, one null category if it
       //        encounters an empty categories string
     }

◆ parseDefaults()

ThreadSafeLogMessageLoggerScribe::ConfigurableDefaults edm::service::ThreadSafeLogMessageLoggerScribe::parseDefaults ( edm::ParameterSet const & job_pset )

staticprivate

Definition at line 440 of file ThreadSafeLogMessageLoggerScribe.cc.

Referenced by configure_errorlog(), and configure_errorlog_new().

                                          {
       const edm::ParameterSet empty_PSet;
       ThreadSafeLogMessageLoggerScribe::ConfigurableDefaults returnValue;
       // grab default limit/interval/timespan common to all destinations/categories:
       edm::ParameterSet default_pset = getAparameter<edm::ParameterSet>(job_pset, "default", empty_PSet);
       returnValue.limit_ = getAparameter<int>(
           default_pset, "limit", ThreadSafeLogMessageLoggerScribe::ConfigurableDefaults::COMMON_DEFAULT_LIMIT);
       returnValue.reportEvery_ = getAparameter<int>(
           default_pset, "reportEvery", ThreadSafeLogMessageLoggerScribe::ConfigurableDefaults::COMMON_DEFAULT_INTERVAL);
       returnValue.timespan_ = getAparameter<int>(
           default_pset, "timespan", ThreadSafeLogMessageLoggerScribe::ConfigurableDefaults::COMMON_DEFAULT_TIMESPAN);
       std::string default_threshold = getAparameter<std::string>(job_pset, "threshold", std::string());
       returnValue.threshold_ = getAparameter<std::string>(default_pset, "threshold", default_threshold);
       returnValue.noLineBreaks_ = getAparameter<bool>(default_pset, "noLineBreaks", false);
       returnValue.lineLength_ = getAparameter<int>(default_pset, "lineLength", 80);
       returnValue.noTimeStamps_ = getAparameter<bool>(default_pset, "noTimeStamps", false);
 
       return returnValue;
     }

◆ runCommand()

void edm::service::ThreadSafeLogMessageLoggerScribe::runCommand	(	MessageLoggerQ::OpCode	opcode,
		void *	operand
	)

overridevirtual

Reimplemented from edm::service::AbstractMLscribe.

Definition at line 71 of file ThreadSafeLogMessageLoggerScribe.cc.

                        {
       switch (opcode) {  // interpret the work item
         default: {
           assert(false);  // can't happen (we certainly hope!)
           break;
         }
         case MessageLoggerQ::END_THREAD: {
           break;
         }
         case MessageLoggerQ::LOG_A_MESSAGE: {
           ErrorObj* errorobj_p = static_cast<ErrorObj*>(operand);
           try {
             if (m_active && !m_purge_mode) {
               log(errorobj_p);
             }
           } catch (cms::Exception& e) {
             ++m_count;
             std::cerr << "ThreadSafeLogMessageLoggerScribe caught " << m_count << " cms::Exceptions, text = \n"
                       << e.what() << "\n";
 
             if (m_count > 25) {
               cerr << "MessageLogger will no longer be processing "
                    << "messages due to errors (entering purge mode).\n";
               m_purge_mode = true;
             }
           } catch (...) {
             std::cerr << "ThreadSafeLogMessageLoggerScribe caught an unknown exception and "
                       << "will no longer be processing "
                       << "messages. (entering purge mode)\n";
             m_purge_mode = true;
           }
           break;
         }
         case MessageLoggerQ::CONFIGURE: {  // changelog 17
           auto job_pset_p = std::unique_ptr<edm::ParameterSet>(
               static_cast<edm::ParameterSet*>(operand));  // propagate_const<T> has no reset() function
           validate(*job_pset_p);
           configure_errorlog(*job_pset_p);
           break;
         }
         case MessageLoggerQ::SUMMARIZE: {
           assert(operand == nullptr);
           try {
             triggerStatisticsSummaries();
           } catch (cms::Exception& e) {
             std::cerr << "ThreadSafeLogMessageLoggerScribe caught exception "
                       << "during summarize:\n"
                       << e.what() << "\n";
           } catch (...) {
             std::cerr << "ThreadSafeLogMessageLoggerScribe caught unkonwn exception type "
                       << "during summarize. (Ignored)\n";
           }
           break;
         }
         case MessageLoggerQ::JOBMODE: {  // change log 24
           std::string* jobMode_p = static_cast<std::string*>(operand);
           JobMode jm = MessageLoggerDefaults::mode(*jobMode_p);
           m_messageLoggerDefaults = value_ptr<MessageLoggerDefaults>(new MessageLoggerDefaults(jm));
           // Note - since m_messageLoggerDefaults is a value_ptr,
           //        there is no concern about deleting here.
           delete jobMode_p;  // dispose of the message text
                              // which will have been new-ed
                              // in MessageLogger.cc (service version)
           break;
         }
         case MessageLoggerQ::SHUT_UP: {
           assert(operand == nullptr);
           m_active = false;
           break;
         }
         case MessageLoggerQ::FLUSH_LOG_Q: {  // changelog 26
           break;
         }
         case MessageLoggerQ::GROUP_STATS: {  // change log 27
           std::string* cat_p = static_cast<std::string*>(operand);
           ELstatistics::noteGroupedCategory(*cat_p);
           delete cat_p;  // dispose of the message text
           break;
         }
         case MessageLoggerQ::FJR_SUMMARY: {  // changelog 29
           std::map<std::string, double>* smp = static_cast<std::map<std::string, double>*>(operand);
           triggerFJRmessageSummary(*smp);
           break;
         }
       }  // switch
 
     }  // ThreadSafeLogMessageLoggerScribe::runCommand(opcode, operand)

◆ triggerFJRmessageSummary()

void edm::service::ThreadSafeLogMessageLoggerScribe::triggerFJRmessageSummary ( std::map< std::string, double > & sm )

private

Definition at line 899 of file ThreadSafeLogMessageLoggerScribe.cc.

References m_statisticsDestControls.

Referenced by runCommand().

     {
       if (m_statisticsDestControls.empty()) {
         sm["NoStatisticsDestinationsConfigured"] = 0.0;
       } else {
         m_statisticsDestControls[0]->summaryForJobReport(sm);
       }
     }

◆ triggerStatisticsSummaries()

void edm::service::ThreadSafeLogMessageLoggerScribe::triggerStatisticsSummaries ( )

private

Definition at line 881 of file ThreadSafeLogMessageLoggerScribe.cc.

References cms::cuda::assert(), DMR_cfg::cerr, gather_cfg::cout, mps_fire::i, m_statisticsDestControls, m_statisticsResets, m_stream_ps, and m_tooManyWaitingMessagesCount.

Referenced by runCommand().

                                                                       {
       assert(m_statisticsDestControls.size() == m_statisticsResets.size());
       for (unsigned int i = 0; i != m_statisticsDestControls.size(); ++i) {
         m_statisticsDestControls[i]->summary(m_tooManyWaitingMessagesCount.load());
         if (m_statisticsResets[i])
           m_statisticsDestControls[i]->wipe();
       }
       auto dropped = m_tooManyWaitingMessagesCount.load();
       if (m_statisticsDestControls.empty() and dropped != 0) {
         if (m_stream_ps.find("cerr") != m_stream_ps.end()) {
           std::cerr << "MessageLogger: dropped waiting message count " << dropped << "\n";
         }
         if (m_stream_ps.find("cout") != m_stream_ps.end()) {
           std::cout << "MessageLogger: dropped waiting message count " << dropped << "\n";
         }
       }
     }

◆ validate()

void edm::service::ThreadSafeLogMessageLoggerScribe::validate ( edm::ParameterSet & pset ) const

private

Definition at line 989 of file ThreadSafeLogMessageLoggerScribe.cc.

References fillDescriptions(), or, and muonDTDigis_cfi::pset.

Referenced by runCommand().

                                                                                {
       // See if old config API is being used
       if (usingOldConfig(pset))
         return;
       if (not pset.exists("files") and
           ((pset.exists("destinations") or pset.existsAs<std::vector<std::string>>("statistics", true) or
             pset.existsAs<std::vector<std::string>>("statistics", false) or pset.exists("categories")))) {
         return;
       }
 
       ConfigurationDescriptions config{"MessageLogger", "MessageLogger"};
       fillDescriptions(config);
 
       config.validate(pset, "MessageLogger");
     }