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