LoggedMessageSvc.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2023 CERN for the benefit of the ATLAS collaboration
*/
 
 
#include "GaudiKernel/Kernel.h"
#include "GaudiKernel/StatusCode.h"
#include "GaudiKernel/Message.h"
#include "LoggedMessageSvc.h"
 
#include <sstream>
#include <iostream>
#include <fstream>
#include <utility>
#include <cstdlib>
 
using namespace std;
 
static const std::string levelNames[MSG::NUM_LEVELS] = {"NIL",     "VERBOSE", "DEBUG", "INFO",
                                                        "WARNING", "ERROR",   "FATAL", "ALWAYS"};
 
// Constructor
LoggedMessageSvc::LoggedMessageSvc( const std::string& name, ISvcLocator* svcloc )
  : base_class( name, svcloc ), m_keysUsed(false)
 {
  m_defaultStream = &std::cout;
  m_outputLevel   = MSG::INFO;
  declareProperty( "Format",      m_defaultFormat = Message::getDefaultFormat() );
  declareProperty( "timeFormat",  m_defaultTimeFormat = Message::getDefaultTimeFormat() );
  declareProperty( "showStats",   m_stats = false );
  declareProperty( "statLevel",   m_statLevel = 0 );
 
  // Special properties to control output level of individual sources
  declareProperty( "setVerbose",  m_thresholdProp[MSG::VERBOSE] );
  declareProperty( "setDebug",    m_thresholdProp[MSG::DEBUG] );
  declareProperty( "setInfo",     m_thresholdProp[MSG::INFO] );
  declareProperty( "setWarning",  m_thresholdProp[MSG::WARNING] );
  declareProperty( "setError",    m_thresholdProp[MSG::ERROR] );
  declareProperty( "setFatal",    m_thresholdProp[MSG::FATAL] );
  declareProperty( "setAlways",   m_thresholdProp[MSG::ALWAYS] );
 
  declareProperty( "useColors",        m_color=false);
  m_color.declareUpdateHandler(&LoggedMessageSvc::initColors, this);
 
  declareProperty( "fatalColorCode",   m_logColors[MSG::FATAL] );
  declareProperty( "errorColorCode",   m_logColors[MSG::ERROR] );
  declareProperty( "warningColorCode", m_logColors[MSG::WARNING] );
  declareProperty( "infoColorCode",    m_logColors[MSG::INFO] );
  declareProperty( "debugColorCode",   m_logColors[MSG::DEBUG] );
  declareProperty( "verboseColorCode", m_logColors[MSG::VERBOSE] );
  declareProperty( "alwaysColorCode",  m_logColors[MSG::ALWAYS] );
 
  const int defaultLimit = 500;
  declareProperty( "fatalLimit",    m_msgLimit[MSG::FATAL]   = defaultLimit );
  declareProperty( "errorLimit",    m_msgLimit[MSG::ERROR]   = defaultLimit );
  declareProperty( "warningLimit",  m_msgLimit[MSG::WARNING] = defaultLimit );
  declareProperty( "infoLimit",     m_msgLimit[MSG::INFO]    = defaultLimit );
  declareProperty( "debugLimit",    m_msgLimit[MSG::DEBUG]   = defaultLimit );
  declareProperty( "verboseLimit",  m_msgLimit[MSG::VERBOSE] = defaultLimit );
  declareProperty( "alwaysLimit",   m_msgLimit[MSG::ALWAYS]  = 0 );
 
  declareProperty( "defaultLimit",  m_msgLimit[MSG::NIL]     = defaultLimit );
 
  declareProperty( "enableSuppression", m_suppress = false );
  declareProperty( "countInactive", m_inactCount = false )->declareUpdateHandler( &LoggedMessageSvc::setupInactCount, this );
#ifndef NDEBUG
  // initialize the MsgStream static flag.
  MsgStream::enableCountInactive(m_inactCount);
#endif
 
  declareProperty( "loggingLevel", m_logLevel = MSG::FATAL, "Message level above which all messages are saved" );
  m_logLevel.declareUpdateHandler(&LoggedMessageSvc::setupThreshold, this);
 
  declareProperty( "keywords", m_keywords, "keywords to scan messages for and save");
  m_keywords.declareUpdateHandler(&LoggedMessageSvc::setupThreshold, this);
 
  declareProperty( "loggedStreams",
                   m_loggedStreamsName,
                   "MessageStream sources we want to dump into a logfile" );
 
  for (int ic=0; ic<MSG::NUM_LEVELS; ++ic) {
    m_logColors[ic].declareUpdateHandler(&LoggedMessageSvc::setupColors, this);
    m_msgLimit[ic].declareUpdateHandler(&LoggedMessageSvc::setupLimits, this);
    m_thresholdProp[ic].declareUpdateHandler(&LoggedMessageSvc::setupThreshold, this);
  }
 
  for (int i=0; i<MSG::NUM_LEVELS; ++i) {
      m_msgCount[i] = 0;
  }
 
}
 
//#############################################################################
 
LoggedMessageSvc::~LoggedMessageSvc()
{
  // closing log-files, if any
  LoggedStreamsMap_t::iterator iStream   = m_loggedStreams.begin();
  LoggedStreamsMap_t::iterator endStream = m_loggedStreams.end();
  for ( ; iStream != endStream; ++iStream ) {
    delete iStream->second;
    iStream->second = nullptr;
  }
}
//#############################################################################
 
 
StatusCode LoggedMessageSvc::initialize() {
  StatusCode sc;
  sc = base_class::initialize();
  if( sc.isFailure() ) return sc;
  // hack since in Gaudi v30, msgSvc() now returns a const SmartIF<IMessageSvc>
  // Release pointer to myself done in Service base class
  SmartIF<IMessageSvc> &si ATLAS_THREAD_SAFE = const_cast<SmartIF<IMessageSvc>&> (msgSvc());
  si.reset();
 
#ifdef _WIN32
  m_color = false;
#endif
 
  m_colMap["black"]  = MSG::BLACK;
  m_colMap["red"]    = MSG::RED;
  m_colMap["green"]  = MSG::GREEN;
  m_colMap["yellow"] = MSG::YELLOW;
  m_colMap["blue"]   = MSG::BLUE;
  m_colMap["purple"] = MSG::PURPLE;
  m_colMap["cyan"]   = MSG::CYAN;
  m_colMap["white"]  = MSG::WHITE;
 
  // make sure the map of logged stream names is initialized
  setupLogStreams();
 
  if (m_keywords.value().size() > 0) {
    m_keysUsed = true;
  }
 
  return StatusCode::SUCCESS;
}
 
//#############################################################################
 
StatusCode LoggedMessageSvc::reinitialize() {
  m_state = Gaudi::StateMachine::OFFLINE;
  return initialize();
}
 
//#############################################################################
 
void LoggedMessageSvc::initColors(Gaudi::Details::PropertyBase& /*prop*/) {
 
  if (m_color == true) {
 
    if (m_logColors[MSG::FATAL].value().size() == 0) {
      vector<string> fatDef;
      fatDef.push_back( "[94;101;1m" );
      m_logColors[MSG::FATAL].set( fatDef );
    } else {
      LoggedMessageSvc::setupColors( m_logColors[MSG::FATAL] );
    }
 
    if (m_logColors[MSG::ERROR].value().size() == 0) {
      vector<string> errDef;
      errDef.push_back( "[97;101;1m" );
      m_logColors[MSG::ERROR].set( errDef );
    } else {
      LoggedMessageSvc::setupColors( m_logColors[MSG::ERROR] );
    }
 
    if (m_logColors[MSG::WARNING].value().size() == 0) {
      vector<string> warDef;
      warDef.push_back( "[93;1m" );
      m_logColors[MSG::WARNING].set( warDef );
    } else {
      LoggedMessageSvc::setupColors( m_logColors[MSG::WARNING] );
    }
 
  } else {
 
    // reset all color codes;
    for (int ic=0; ic<MSG::NUM_LEVELS; ++ic) {
      vector<string> def;
      m_logColors[ic].set( def );
    }
 
  }
 
}
 
//#############################################################################
 
void LoggedMessageSvc::setupColors(Gaudi::Details::PropertyBase& prop) {
 
  if (! m_color) return;
 
  int ic;
  if (prop.name() == "fatalColorCode") {
    ic = MSG::FATAL;
  } else if (prop.name() == "errorColorCode") {
    ic = MSG::ERROR;
  } else if (prop.name() == "warningColorCode") {
    ic = MSG::WARNING;
  } else if (prop.name() == "infoColorCode") {
    ic = MSG::INFO;
  } else if (prop.name() == "debugColorCode") {
    ic = MSG::DEBUG;
  } else if (prop.name() == "verboseColorCode") {
    ic = MSG::VERBOSE;
  } else if (prop.name() == "alwaysColorCode") {
    ic = MSG::ALWAYS;
  } else {
    cout << "ERROR: Unknown message color parameter: " << prop.name()
         << endl;
    return;
  }
 
  string code;
  vector<string>::const_iterator itr;
  itr = m_logColors[ic].value().begin();
 
  if ( m_logColors[ic].value().size() == 1 ) {
 
    if (itr->empty() ) {
      code = "";
    } else if ((*itr)[0] == '[') {
      code = "\033" + *itr;
    } else {
      code = "\033[" + colTrans(*itr, 90) + ";1m";
    }
 
  } else if (m_logColors[ic].value().size() == 2) {
    vector<string>::const_iterator itr2 = itr + 1;
 
    code =  "\033[" + colTrans(*itr, 90) + ";"
      + colTrans(*itr2, 100) + ";1m";
 
  }
 
  m_logColorCodes[ic] = std::move(code);
 
}
//#############################################################################
 
void LoggedMessageSvc::setupLimits(Gaudi::Details::PropertyBase& prop) {
 
  //int ic = 0;
  if (prop.name() == "fatalLimit") {
    //ic = MSG::FATAL;
  } else if (prop.name() == "errorLimit") {
    //ic = MSG::ERROR;
  } else if (prop.name() == "warningLimit") {
    //ic = MSG::WARNING;
  } else if (prop.name() == "infoLimit") {
    //ic = MSG::INFO;
  } else if (prop.name() == "debugLimit") {
    //ic = MSG::DEBUG;
  } else if (prop.name() == "verboseLimit") {
    //ic = MSG::VERBOSE;
  } else if (prop.name() == "alwaysLimit") {
    IntegerProperty *p = dynamic_cast<IntegerProperty*>(&prop);
    if (p && p->value() != 0) {
      cout << "LoggedMessageSvc ERROR: cannot suppress ALWAYS messages" << endl;
      p->setValue(0);
    }
    //ic = MSG::ALWAYS;
  } else if (prop.name() == "defaultLimit") {
    for (int i = MSG::VERBOSE; i< MSG::NUM_LEVELS; ++i) {
      if (i != MSG::ALWAYS) {
        m_msgLimit[i] = m_msgLimit[MSG::NIL].value();
      }
    }
  } else {
    cout << "LoggedMessageSvc ERROR: Unknown message limit parameter: "
         << prop.name() << endl;
    return;
  }
 
}
//#############################################################################
 
void LoggedMessageSvc::setupThreshold(Gaudi::Details::PropertyBase& prop) {
 
  int ic = 0;
  if (prop.name() == "setFatal") {
    ic = MSG::FATAL;
  } else if (prop.name() == "setError") {
    ic = MSG::ERROR;
  } else if (prop.name() == "setWarning") {
    ic = MSG::WARNING;
  } else if (prop.name() == "setInfo") {
    ic = MSG::INFO;
  } else if (prop.name() == "setDebug") {
    ic = MSG::DEBUG;
  } else if (prop.name() == "setVerbose") {
    ic = MSG::VERBOSE;
  } else if (prop.name() == "setAlways") {
    ic = MSG::ALWAYS;
  } else if (prop.name() == "loggingLevel") {
    IntegerProperty *iap = dynamic_cast<IntegerProperty*>( &prop );
    if (iap)
      m_logLevel = iap->value();
    return;
  } else if (prop.name() == "keywords") {
    StringArrayProperty *sap = dynamic_cast<StringArrayProperty*>( &prop );
    if (sap!= nullptr && sap->value().size() > 0) {
      m_keysUsed = true;
    } else {
      m_keysUsed = false;
    }
    return;
  } else {
    cerr << "LoggedMessageSvc ERROR: Unknown message theshold parameter: "
         << prop.name() << endl;
    return;
  }
 
  StringArrayProperty *sap = dynamic_cast<StringArrayProperty*>( &prop);
  if (sap == nullptr) {
    std::cerr << "could not dcast " << prop.name()
              << " to a StringArrayProperty (which it should be!)" << endl;
    return;
  } else {
    std::vector<std::string>::const_iterator itr;
    for ( itr =  sap->value().begin();
          itr != sap->value().end();
          ++itr) {
      setOutputLevel( *itr, ic );
    }
  }
 
}
 
//#############################################################################
 
void LoggedMessageSvc::setupInactCount(Gaudi::Details::PropertyBase& prop) {
  if (prop.name() == "countInactive") {
#ifndef NDEBUG
    BooleanProperty *p = dynamic_cast<BooleanProperty*>(&prop);
    if (p)
      MsgStream::enableCountInactive(p->value());
#endif
  }
}
 
//#############################################################################
StatusCode LoggedMessageSvc::finalize() {
 
  m_suppress = false;
 
  std::ostringstream os;
 
  if (m_stats) {
    os << "Summarizing all message counts" << endl;
  } else {
    os << "Listing sources of suppressed message: " << endl;
  }
 
  os << "=====================================================" << endl;
  os << " Message Source              |   Level |    Count" << endl;
  os << "-----------------------------+---------+-------------" << endl;
 
 
  bool found(false);
 
  std::map<std::string,MsgAry>::const_iterator itr;
  for (itr=m_sourceMap.begin(); itr!=m_sourceMap.end(); ++itr) {
    for (unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic) {
      if ( (itr->second.msg[ic] >= m_msgLimit[ic] && m_msgLimit[ic] != 0 ) ||
           (m_stats && itr->second.msg[ic] > 0 && ic >= m_statLevel.value()) ) {
        os << " ";
        os.width(28);
        os.setf(ios_base::left,ios_base::adjustfield);
        os << itr->first;
 
        os << "|";
 
        os.width(8);
        os.setf(ios_base::right,ios_base::adjustfield);
        os << levelNames[ic];
 
        os << " |";
 
        os.width(9);
        os << itr->second.msg[ic];
 
        os << endl;
 
        found = true;
      }
    }
  }
  os << "=====================================================" << endl;
 
  if (found || m_stats) {
    cout << os.str();
  }
 
 
#ifndef NDEBUG
  if (m_inactCount.value()) {
 
    std::ostringstream os;
    os << "Listing sources of Unprotected and Unseen messages\n";
 
    bool found(false);
 
    unsigned int ml(0);
    std::map<std::string,MsgAry>::const_iterator itr;
    for (itr=m_inactiveMap.begin(); itr!=m_inactiveMap.end(); ++itr) {
      for (unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic) {
    if (itr->second.msg[ic] != 0) {
      if (itr->first.length() > ml) { ml = itr->first.length(); }
    }
      }
    }
 
    for (unsigned int i=0; i<ml+25; ++i) {
      os << "=";
    }
 
    os << endl << " ";
    os.width(ml+2);
    os.setf(ios_base::left,ios_base::adjustfield);
    os << "Message Source";
    os.width(1);
    os << "|   Level |    Count" << endl;
 
    for (unsigned int i=0; i<ml+3; ++i) {
      os << "-";
    }
    os << "+---------+-----------" << endl;
 
 
    for (itr=m_inactiveMap.begin(); itr!=m_inactiveMap.end(); ++itr) {
      for (unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic) {
    if (itr->second.msg[ic] != 0) {
      os << " ";
      os.width(ml+2);
      os.setf(ios_base::left,ios_base::adjustfield);
      os << itr->first;
 
      os << "|";
 
      os.width(8);
      os.setf(ios_base::right,ios_base::adjustfield);
      os << levelNames[ic];
 
      os << " |";
 
      os.width(9);
      os << itr->second.msg[ic];
 
      os << endl;
 
      found = true;
    }
      }
    }
    for (unsigned int i=0; i<ml+25; ++i) {
      os << "=";
    }
    os << endl;
 
    if (found) {
      cout << os.str();
    }
  }
#endif
 
  return StatusCode::SUCCESS;
}
 
//#############################################################################
std::string LoggedMessageSvc::colTrans(const std::string &col, int offset) {
  ColorMap::const_iterator itr = m_colMap.find(col);
  int icol;
  if (itr != m_colMap.end()) {
    icol = offset + itr->second;
  } else {
    icol = offset + 8;
  }
  std::ostringstream os1;
 
  os1 << icol;
 
  return os1.str();
 
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: reportMessage
// Purpose: dispatches a message to the relevant streams.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::reportMessage( const Message& msg, int outputLevel )    {
  std::lock_guard<std::mutex> lock(m_reportMutex);
 
  int key = msg.getType();
  int nmsg;
 
  m_msgCount[key] ++;
 
  if (outputLevel >= m_logLevel) {
    m_msgLog[ outputLevel ].push_back( make_pair (msg.getSource(), msg.getMessage() ) );
  }
 
  if (m_keysUsed) {
    if (msg.getSource() != "AthenaSummarySvc") {
      for (vector<string>::const_iterator itr=m_keywords.value().begin(); itr!= m_keywords.value().end(); ++itr) {
    if (msg.getMessage().find( *itr ) != string::npos) {
      m_msgKeyLog.push_back( LoggedMessage( outputLevel, msg.getSource(), msg.getMessage() ));
      break;
    }
      }
    }
  }
 
  const Message *cmsg = &msg;
  std::unique_ptr<Message> suppressed_msg;
 
  // processing logged streams
  if ( !m_loggedStreams.empty() ) {
    const LoggedStreamsMap_t::iterator iLog = m_loggedStreams.find( msg.getSource() );
    if ( m_loggedStreams.end() != iLog ) {
      (*iLog->second) << *cmsg << std::endl;
    }
  }
 
  if ( m_suppress.value() || m_stats.value() ) {
 
    std::map<std::string,MsgAry>::iterator itr =
      m_sourceMap.find(msg.getSource());
    if (itr != m_sourceMap.end()) {
      itr->second.msg[key] += 1;
      nmsg = itr->second.msg[key];
    } else {
      MsgAry A;
      for (int i=0; i<MSG::NUM_LEVELS; ++i) {
        A.msg[i] = 0;
      }
      A.msg[key] = 1;
      m_sourceMap[msg.getSource()] = A;
      nmsg = 1;
    }
 
    if (m_suppress.value()) {
 
      if ( m_msgLimit[key] != 0 ) {
        if (nmsg == m_msgLimit[key]) {
          std::string str = levelNames[key] + " message limit (";
          str += std::to_string( m_msgLimit[key].value() );
          str += ") reached for ";
          str += msg.getSource() + ". Suppressing further output.";
          suppressed_msg = std::make_unique<Message>(msg.getSource(),MSG::WARNING,str);
          suppressed_msg->setFormat(msg.getFormat());
          cmsg = suppressed_msg.get();
        } else if (nmsg > m_msgLimit[key]) {
          return;
        }
      }
    }
 
  }
 
  StreamMap::const_iterator first = m_streamMap.lower_bound( key );
  if ( first != m_streamMap.end() ) {
    StreamMap::const_iterator last = m_streamMap.upper_bound( key );
    while( first != last ) {
      std::ostream& stream = *( (*first).second.second );
      stream << *cmsg << std::endl;
      ++first;
    }
  }
  else if ( key >= outputLevel )   {
    msg.setFormat(m_defaultFormat);
    msg.setTimeFormat(m_defaultTimeFormat);
    if (!m_color) {
      (*m_defaultStream) << *cmsg << std::endl << std::flush;
    } else {
      (*m_defaultStream) <<  m_logColorCodes[key] << *cmsg << "\033[m"
                         << std::endl << std::flush;
    }
  }
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: reportMessage
// Purpose: dispatches a message to the relevant streams.
// ---------------------------------------------------------------------------
//
void LoggedMessageSvc::reportMessage( const Message& msg )    {
  reportMessage(msg, outputLevel(msg.getSource()));
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: reportMessage
// Purpose: dispatches a message to the relevant streams.
// ---------------------------------------------------------------------------
//
void LoggedMessageSvc::reportMessage (std::string source,
                                      int type,
                                      std::string message) {
  Message msg( source, type, message);
  reportMessage( msg );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: sendMessage
// Purpose: finds a message for a given status code and dispatches it.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::reportMessage (const StatusCode& key,
                                      std::string_view source)
{
  std::lock_guard<std::recursive_mutex> lock(m_messageMapMutex);
 
  MessageMap::const_iterator first = m_messageMap.lower_bound( key );
  if ( first != m_messageMap.end() ) {
    MessageMap::const_iterator last = m_messageMap.upper_bound( key );
    while( first != last ) {
      Message msg = (*first).second;
      msg.setSource( source );
      std::ostringstream os1;
      os1 << "Status Code " << key.getCode() << std::ends;
      Message stat_code1( std::string{source}, msg.getType(), os1.str() );
      reportMessage( stat_code1 );
      reportMessage( msg );
      ++first;
    }
  }
  else {
    Message mesg = m_defaultMessage;
    mesg.setSource( source );
      std::ostringstream os2;
    os2 << "Status Code " << key.getCode() << std::ends;
    Message stat_code2( std::string{source},  mesg.getType(), os2.str() );
    reportMessage( stat_code2 );
    reportMessage( mesg );
  }
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: insertStream
// Purpose: inserts a stream for a message type.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::insertStream (int key,
                               std::string name,
                               std::ostream *stream)
{
  typedef StreamMap::value_type value_type;
  m_streamMap.insert( value_type( key, NamedStream( std::move(name), stream) ) );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseStream
// Purpose: erases all the streams for all the message types.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseStream()
{
  m_streamMap.erase( m_streamMap.begin(), m_streamMap.end() );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseStream
// Purpose: erases all the streams for a message type.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseStream( int message_type )
{
  m_streamMap.erase( message_type );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseStream
// Purpose: erases one stream for a message type.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseStream( int key, std::ostream* stream )   {
  if ( nullptr != stream )    {
    bool changed = true;
    while( changed ) {
      changed = false;
      StreamMap::iterator first = m_streamMap.lower_bound( key );
      StreamMap::iterator last = m_streamMap.upper_bound( key );
      while( first != last ) {
        if ( (*first).second.second == stream ) {
          m_streamMap.erase( first );
          changed = true;
          break;
        }
      }
    }
  }
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseStream
// Purpose: erases one stream for all message types.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseStream( std::ostream* stream )    {
  if ( nullptr != stream )    {
    bool changed = true;
    while( changed ) {
      changed = false;
      StreamMap::iterator first = m_streamMap.begin();
      while( first != m_streamMap.end() ) {
        if ( (*first).second.second == stream ) {
          m_streamMap.erase( first );
          changed = true;
          break;
        }
      }
    }
  }
}
 
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: insertMessage
// Purpose: inserts a message for a status code.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::insertMessage( const StatusCode& key, Message msg )
{
  std::lock_guard<std::recursive_mutex> lock(m_messageMapMutex);
 
  m_messageMap.emplace( key, std::move( msg ) );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseMessage
// Purpose: erases all the messages for all the status codes.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseMessage()
{
  std::lock_guard<std::recursive_mutex> lock(m_messageMapMutex);
 
  m_messageMap.erase( m_messageMap.begin(), m_messageMap.end() );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseMessage
// Purpose: erases all the messages for a status code.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseMessage( const StatusCode& key )
{
  std::lock_guard<std::recursive_mutex> lock(m_messageMapMutex);
 
  m_messageMap.erase( key );
}
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: eraseMessage
// Purpose: erases one message for a status code.
// ---------------------------------------------------------------------------
//
 
void LoggedMessageSvc::eraseMessage( const StatusCode& key, const Message& msg )
{
  std::lock_guard<std::recursive_mutex> lock(m_messageMapMutex);
 
  bool changed = true;
  while( changed ) {
    changed = false;
    MessageMap::iterator first = m_messageMap.lower_bound( key );
    MessageMap::iterator last = m_messageMap.upper_bound( key );
    while( first != last ) {
      const Message& message = (*first).second;
      if ( message == msg ) {
        m_messageMap.erase( first );
        changed = true;
        break;
      }
    }
  }
}
 
// ---------------------------------------------------------------------------
StatusCode LoggedMessageSvc::queryInterface(const InterfaceID& riid, void** ppvInterface) {
// ---------------------------------------------------------------------------
  if ( riid == ILoggedMessageSvc::interfaceID() )  {
    *ppvInterface = (ILoggedMessageSvc*)this;
  }
  else if ( riid == IMessageSvc::interfaceID() )  {
    *ppvInterface = (IMessageSvc*)this;
  }
  else  {
    return base_class::queryInterface(riid, ppvInterface);
  }
  addRef();
  return StatusCode::SUCCESS;
}
 
// ---------------------------------------------------------------------------
int LoggedMessageSvc::outputLevel()   const {
// ---------------------------------------------------------------------------
  return m_outputLevel;
}
// ---------------------------------------------------------------------------
int LoggedMessageSvc::outputLevel( std::string_view source )   const {
// ---------------------------------------------------------------------------
  std::lock_guard<std::mutex> lock(m_thresholdMapMutex);
 
  auto it   = m_thresholdMap.find( source );
  return it != m_thresholdMap.end() ? it->second : m_outputLevel.value();
}
 
// ---------------------------------------------------------------------------
void LoggedMessageSvc::setOutputLevel(int new_level)    {
// ---------------------------------------------------------------------------
  m_outputLevel = new_level;
}
 
// ---------------------------------------------------------------------------
void LoggedMessageSvc::setOutputLevel(std::string_view source, int level)    {
// ---------------------------------------------------------------------------
  std::lock_guard<std::mutex> lock(m_thresholdMapMutex);
 
  // only write if we really have to...
  auto i = m_thresholdMap.find( source );
  if ( i == m_thresholdMap.end() ) {
    m_thresholdMap.emplace( source, level );
  } else if ( i->second != level ) {
    i->second = level;
  }
 
}
 
// ---------------------------------------------------------------------------
std::string LoggedMessageSvc::getLogColor(int logLevel) const   {
// ---------------------------------------------------------------------------
  if (logLevel < MSG::NUM_LEVELS) {
    return m_logColorCodes[logLevel];
  } else {
    return "";
  }
}
 
// ---------------------------------------------------------------------------
int LoggedMessageSvc::messageCount( MSG::Level level) const   {
 
  return m_msgCount[level];
 
}
 
// ---------------------------------------------------------------------------
void
LoggedMessageSvc::incrInactiveCount(MSG::Level level, std::string_view source) {
 
  auto entry = m_inactiveMap.find( source );
  if ( entry == m_inactiveMap.end() ) {
    entry = m_inactiveMap.emplace( source, MsgAry{} ).first;
  }
  ++entry->second.msg[level];
}
 
// ---------------------------------------------------------------------------
void LoggedMessageSvc::setupLogStreams()
{
  // reset state
  for ( LoggedStreamsMap_t::iterator iLog = m_loggedStreams.begin();
        iLog != m_loggedStreams.end();
        ++iLog ) {
    delete iLog->second;
  }
  m_loggedStreams.clear();
 
  typedef std::map<std::string,std::string> StreamMap_t;
  const StreamMap_t& streamMap = m_loggedStreamsName;
  typedef StreamMap_t::const_iterator StreamMapIter;
 
  for ( StreamMapIter iProp = streamMap.begin(), iEnd = streamMap.end();
        iProp != iEnd;
        ++iProp ) {
 
    const std::string sourceName  = iProp->first;
    const std::string outFileName = iProp->second;
 
    std::set<std::string> outFileNames;
    for ( StreamMapIter jProp = streamMap.begin();
          jProp != iEnd;
          ++jProp ) {
      if ( jProp->first != iProp->first ) {
        outFileNames.insert( jProp->second );
      }
    }
 
    tee( sourceName, outFileName, outFileNames );
 
  }//> loop over property entries
 
  return;
}
 
// ---------------------------------------------------------------------------
void LoggedMessageSvc::tee( const std::string& sourceName,
                      const std::string& outFileName,
                      const std::set<std::string>& outFileNames )
{
  const std::ios_base::openmode openMode = std::ios_base::out |
                                           std::ios_base::trunc;
 
  LoggedStreamsMap_t::iterator iEnd    = m_loggedStreams.end();
  LoggedStreamsMap_t::iterator iStream = m_loggedStreams.find( sourceName );
  if ( iStream != iEnd ) {
    delete iStream->second;
    iStream->second = nullptr;
    m_loggedStreams.erase( iStream );
  }
 
  // before creating a new ofstream, make sure there is no already existing
  // one with the same file name...
  iEnd = m_loggedStreams.end();
  for ( iStream = m_loggedStreams.begin(); iStream != iEnd; ++iStream ) {
    if ( outFileNames.find( outFileName ) != outFileNames.end() ) {
      m_loggedStreams[sourceName] = m_loggedStreams[iStream->first];
      return;
    }
  }
 
  std::ofstream * out =  new std::ofstream( outFileName.c_str(), openMode );
 
  if ( !out->good() ) {
    out->close();
    delete out;
    return;
  }
 
  m_loggedStreams[sourceName] = out;
 
  return;
}
 
 
//#############################################################################
// ---------------------------------------------------------------------------
// Routine: getMessages
// Purpose: get all messages of a certain MSG::Level
// ---------------------------------------------------------------------------
 
const std::vector< std::pair<std::string, std::string> >& 
LoggedMessageSvc::getMessages( MSG::Level level) const {
 
  return m_msgLog[ level ];
 
}