MsgHelpers.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/

 
 
 
//
// includes
//
 
#include <AsgMessaging/MsgHelpers.h>
#include <AsgMessaging/MessageCheckLocal.h>
#include <CxxUtils/checker_macros.h>
 
#include <cassert>
#include <mutex>
#include <unordered_map>
 
#ifndef XAOD_STANDALONE
#include <GaudiKernel/Bootstrap.h>
#include <GaudiKernel/ISvcLocator.h>
#include <AthenaKernel/getMessageSvc.h>
#endif
 
//
// method implementations
//
 
namespace asg
{
  namespace
  {
    std::unordered_map<std::string,MsgStream>& packageMsgStreamMap ()
    {
      // access is protected through packageMsgMutex()
      static std::unordered_map<std::string,MsgStream> result ATLAS_THREAD_SAFE;
      return result;
    }

    std::recursive_mutex& packageMsgMutex ()
    {
      static std::recursive_mutex result;
      return result;
    }
  }
 
  MsgStream& MsgHelpers ::
  pkgMsgStream (const std::string& package)
  {
    std::lock_guard<std::recursive_mutex> lock {packageMsgMutex()};
    auto iter = packageMsgStreamMap().find (package);
    if (iter != packageMsgStreamMap().end())
      return iter->second;
 
    const std::string fullName {"Package." + package};
#ifdef XAOD_STANDALONE
    auto result = packageMsgStreamMap().emplace (package, fullName);
#else
    auto result = packageMsgStreamMap().emplace
      (std::piecewise_construct,
       std::forward_as_tuple (package),
       std::forward_as_tuple (Athena::getMessageSvc(Athena::Options::Eager), fullName));
#endif
    assert (result.second);
    return result.first->second;
  }
 
 
 
  void MsgHelpers ::
  setPkgMsgLevel (const std::string& package, MSG::Level level)
  {
    std::lock_guard<std::recursive_mutex> lock {packageMsgMutex()};
    pkgMsgStream (package).setLevel (level);
  }
 
 
 
  void MsgHelpers ::
  printAllPkgMsgLevels ()
  {
    using namespace msgAsgMessaging;
    std::lock_guard<std::recursive_mutex> lock {packageMsgMutex()};
    ANA_MSG_INFO ("package message levels:");
    for (auto& msgStream : packageMsgStreamMap())
    {
      ANA_MSG_INFO ("  package=" << msgStream.first << " level=" << name (msgStream.second.level()) << "(" << unsigned (msgStream.second.level()) << ")");
    }
  }
}