MessageLoggerQ.h

Go to the documentation of this file.

#ifndef FWCore_MessageLogger_MessageLoggerQ_h
#define FWCore_MessageLogger_MessageLoggerQ_h
 
#include "FWCore/MessageLogger/interface/ELseverityLevel.h"
#include "FWCore/Utilities/interface/thread_safety_macros.h"
 
#include <memory>
 
#include <string>
#include <map>
#include <set>
 
namespace edm {
 
  // --- forward declarations:
  class ErrorObj;
  class ParameterSet;
  class ELdestination;
  namespace service {
    class AbstractMLscribe;
  }
 
  class MessageLoggerQ {
  public:
    // --- enumerate types of messages that can be enqueued:
    enum OpCode   // abbrev's used hereinafter
    { END_THREAD  // END
      ,
      LOG_A_MESSAGE  // LOG
      ,
      CONFIGURE  // CFG -- handshaked
      ,
      EXTERN_DEST  // EXT
      ,
      SUMMARIZE  // SUM
      ,
      JOBMODE  // MOD
      ,
      SHUT_UP  // SHT
      ,
      FLUSH_LOG_Q  // FLS -- handshaked
      ,
      GROUP_STATS  // GRP
      ,
      FJR_SUMMARY  // JRS -- handshaked
    };             // OpCode
 
    // ---  birth via a surrogate:
    static MessageLoggerQ* instance();
 
    // ---  post a message to the queue:
    static void MLqEND();
    static void MLqLOG(ErrorObj* p);
    static void MLqCFG(ParameterSet* p);
    static void MLqSUM();
    static void MLqMOD(std::string* jm);
    static void MLqSHT();
    static void MLqFLS();
    static void MLqGRP(std::string* cat_p);
    static void MLqJRS(std::map<std::string, double>* sum_p);
 
    // ---  bookkeeping for single-thread mode
    static void setMLscribe_ptr(std::shared_ptr<edm::service::AbstractMLscribe> m);
 
    // ---  helper for scribes
    static bool handshaked(const OpCode& op);
 
    // --- special control of standAlone logging behavior
    static void standAloneThreshold(edm::ELseverityLevel const& severity);
    static void squelch(std::string const& category);
    static bool ignore(edm::ELseverityLevel const& severity, std::string const& category);
 
  private:
    // ---  traditional birth/death, but disallowed to users:
    MessageLoggerQ();
    ~MessageLoggerQ();
 
    // ---  place an item onto the queue, or execute the command directly
    static void simpleCommand(OpCode opcode, void* operand);
    static void handshakedCommand(OpCode opcode, void* operand, std::string const& commandMnemonic);
 
    // --- no copying:
    MessageLoggerQ(MessageLoggerQ const&) = delete;
    void operator=(MessageLoggerQ const&) = delete;
 
    // --- data:
    CMS_THREAD_SAFE static std::shared_ptr<edm::service::AbstractMLscribe> mlscribe_ptr;
    CMS_THREAD_SAFE static edm::ELseverityLevel threshold;
    CMS_THREAD_SAFE static std::set<std::string> squelchSet;
 
  };  // MessageLoggerQ
 
}  // namespace edm
 
#endif  // FWCore_MessageLogger_MessageLoggerQ_h