#include <src/MessageSvc/MessageSvc.h>

Inheritance diagram for MessageSvc:

[legend]

Collaboration diagram for MessageSvc:

[legend]

Classes
struct	MsgAry
	Private helper class to keep the count of messages of a type (MSG::LEVEL). More...

Public Types
typedef std::pair< std::string, std::ostream * >	NamedStream

typedef std::multimap< int, NamedStream >	StreamMap

typedef std::multimap< StatusCode, Message >	MessageMap

typedef std::map< std::string, int, std::less<> >	ThresholdMap

Public Types inherited from extends< Service, IMessageSvc, IInactiveMessageCounter >
using	base_class = extends
	Typedef to this class. More...

using	extend_interfaces_base = extend_interfaces< Interfaces... >
	Typedef to the base of this class. More...

Public Types inherited from Service
using	Factory = Gaudi::PluginService::Factory< IService (const std::string &, ISvcLocator )>

Public Types inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
using	PropertyHolderImpl = PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
	Typedef used to refer to this class from derived classes, as in. More...

Public Types inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
using	base_class = CommonMessaging

Public Types inherited from extend_interfaces< Interfaces... >
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids... >::type
	take union of the ext_iids of all Interfaces... More...

Public Member Functions
	MessageSvc (const std::string &name, ISvcLocator *svcloc)

StatusCode	reinitialize () override
	Reinitialize Service. More...

StatusCode	initialize () override
	Initialize Service. More...

StatusCode	finalize () override
	Finalize Service. More...

void	reportMessage (const Message &message) override

void	reportMessage (const Message &msg, int outputLevel) override

void	reportMessage (const StatusCode &code, const std::string &source="") override

void	reportMessage (const char source, int type, const char message) override

void	reportMessage (const std::string &source, int type, const std::string &message) override

void	insertMessage (const StatusCode &code, const Message &message) override

void	eraseMessage () override

void	eraseMessage (const StatusCode &code) override

void	eraseMessage (const StatusCode &code, const Message &message) override

void	insertStream (int message_type, std::string name, std::ostream *stream) override

void	eraseStream () override

void	eraseStream (int message_type) override

void	eraseStream (int message_type, std::ostream *stream) override

void	eraseStream (std::ostream *stream) override

std::ostream *	defaultStream () const override

void	setDefaultStream (std::ostream *stream) override

int	outputLevel () const override

int	outputLevel (std::string_view source) const override

void	setOutputLevel (int new_level) override

void	setOutputLevel (std::string_view source, int new_level) override

bool	useColor () const override

std::string	getLogColor (int logLevel) const override

int	messageCount (MSG::Level logLevel) const override

void	incrInactiveCount (MSG::Level level, const std::string &src) override

Public Member Functions inherited from extends< Service, IMessageSvc, IInactiveMessageCounter >
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...

StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...

std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...

Public Member Functions inherited from Service
const std::string &	name () const override
	Retrieve name of the service. More...

StatusCode	configure () override

StatusCode	initialize () override

StatusCode	start () override

StatusCode	stop () override

StatusCode	finalize () override

StatusCode	terminate () override

Gaudi::StateMachine::State	FSMState () const override

Gaudi::StateMachine::State	targetFSMState () const override

StatusCode	reinitialize () override

StatusCode	restart () override

StatusCode	sysInitialize () override
	Initialize Service. More...

StatusCode	sysStart () override
	Initialize Service. More...

StatusCode	sysStop () override
	Initialize Service. More...

StatusCode	sysFinalize () override
	Finalize Service. More...

StatusCode	sysReinitialize () override
	Re-initialize the Service. More...

StatusCode	sysRestart () override
	Re-initialize the Service. More...

	Service (std::string name, ISvcLocator *svcloc)
	Standard Constructor. More...

SmartIF< ISvcLocator > &	serviceLocator () const override
	Retrieve pointer to service locator. More...

StatusCode	setProperties ()
	Method for setting declared properties to the values specified for the job. More...

template<class T >
StatusCode	service (const std::string &name, const T *&psvc, bool createIf=true) const
	Access a service by name, creating it if it doesn't already exist. More...

template<class T >
StatusCode	service (const std::string &name, T *&psvc, bool createIf=true) const

template<typename IFace = IService>
SmartIF< IFace >	service (const std::string &name, bool createIf=true) const

template<class T >
StatusCode	service (const std::string &svcType, const std::string &svcName, T *&psvc) const
	Access a service by name and type, creating it if it doesn't already exist. More...

template<class T >
StatusCode	declareTool (ToolHandle< T > &handle, std::string toolTypeAndName, bool createIf=true)
	Declare used tool. More...

SmartIF< IAuditorSvc > &	auditorSvc () const
	The standard auditor service.May not be invoked before sysInitialize() has been invoked. More...

Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
	PropertyHolder ()=default

Gaudi::Details::PropertyBase &	declareProperty (Gaudi::Details::PropertyBase &prop)
	Declare a property. More...

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, TYPE &value, const std::string &doc="none")
	Helper to wrap a regular data member and use it as a regular property. More...

Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, Gaudi::Property< TYPE, VERIFIER, HANDLERS > &prop, const std::string &doc="none")
	Declare a PropertyBase instance setting name and documentation. More...

Gaudi::Details::PropertyBase *	declareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="")
	Declare a remote property. More...

StatusCode	setProperty (const Gaudi::Details::PropertyBase &p) override
	set the property form another property More...

StatusCode	setProperty (const std::string &s) override
	set the property from the formatted string More...

StatusCode	setProperty (const std::string &n, const std::string &v) override
	set the property from name and the value More...

StatusCode	setProperty (const std::string &name, const TYPE &value)
	set the property form the value More...

StatusCode	getProperty (Gaudi::Details::PropertyBase *p) const override
	get the property More...

const Gaudi::Details::PropertyBase &	getProperty (const std::string &name) const override
	get the property by name More...

StatusCode	getProperty (const std::string &n, std::string &v) const override
	convert the property to the string More...

const std::vector< Gaudi::Details::PropertyBase * > &	getProperties () const override
	get all properties More...

bool	hasProperty (const std::string &name) const override
	Return true if we have a property with the given name. More...

	PropertyHolder (const PropertyHolder &)=delete

PropertyHolder &	operator= (const PropertyHolder &)=delete

Public Member Functions inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
MSG::Level	msgLevel () const
	get the cached level (originally extracted from the embedded MsgStream) More...

bool	msgLevel (MSG::Level lvl) const
	get the output level from the embedded MsgStream More...

Public Member Functions inherited from CommonMessagingBase
virtual	~CommonMessagingBase ()=default
	Virtual destructor. More...

const SmartIF< IMessageSvc > &	msgSvc () const
	The standard message service. More...

MsgStream &	msgStream () const
	Return an uninitialized MsgStream. More...

MsgStream &	msgStream (const MSG::Level level) const
	Predefined configurable message stream for the efficient printouts. More...

MsgStream &	always () const
	shortcut for the method msgStream(MSG::ALWAYS) More...

MsgStream &	fatal () const
	shortcut for the method msgStream(MSG::FATAL) More...

MsgStream &	err () const
	shortcut for the method msgStream(MSG::ERROR) More...

MsgStream &	error () const
	shortcut for the method msgStream(MSG::ERROR) More...

MsgStream &	warning () const
	shortcut for the method msgStream(MSG::WARNING) More...

MsgStream &	info () const
	shortcut for the method msgStream(MSG::INFO) More...

MsgStream &	debug () const
	shortcut for the method msgStream(MSG::DEBUG) More...

MsgStream &	verbose () const
	shortcut for the method msgStream(MSG::VERBOSE) More...

MsgStream &	msg () const
	shortcut for the method msgStream(MSG::INFO) More...

Protected Member Functions
virtual void	i_reportMessage (const Message &msg, int outputLevel)
	Internal implementation of reportMessage(const Message&,int) without lock. More...

virtual void	i_reportMessage (const StatusCode &code, const std::string &source)
	Internal implementation of reportMessage(const StatusCode&,const std::string&) without lock. More...

Protected Member Functions inherited from Service
	~Service () override
	Standard Destructor. More...

int	outputLevel () const
	get the `Service's` output level More...

Protected Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
Gaudi::Details::PropertyBase *	property (const std::string &name) const

Protected Member Functions inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
MSG::Level	setUpMessaging () const
	Set up local caches. More...

MSG::Level	resetMessaging ()
	Reinitialize internal states. More...

void	updateMsgStreamOutputLevel (int level)
	Update the output level of the cached MsgStream. More...

Private Member Functions
void	setupColors (Gaudi::Details::PropertyBase &prop)

void	setupLimits (Gaudi::Details::PropertyBase &prop)

void	setupThreshold (Gaudi::Details::PropertyBase &prop)

void	setupInactCount (Gaudi::Details::PropertyBase &prop)

void	setupLogStreams ()

void	tee (const std::string &sourceName, const std::string &logFileName, const std::set< std::string > &declaredOutFileNames)

Private Attributes
Gaudi::Property< std::string >	m_defaultFormat {this, "Format", Message::getDefaultFormat(), ""}

Gaudi::Property< std::string >	m_defaultTimeFormat {this, "timeFormat", Message::getDefaultTimeFormat(), ""}

Gaudi::Property< bool >	m_stats {this, "showStats", false, ""}

Gaudi::Property< unsigned int >	m_statLevel {this, "statLevel", 0, ""}

std::array< Gaudi::Property< std::vector< std::string > >, MSG::NUM_LEVELS >	m_thresholdProp

Gaudi::Property< bool >	m_color {this, "useColors", false, ""}

std::array< Gaudi::Property< std::vector< std::string > >, MSG::NUM_LEVELS >	m_logColors

std::array< Gaudi::Property< int >, MSG::NUM_LEVELS >	m_msgLimit

Gaudi::Property< bool >	m_suppress {this, "enableSuppression", false, ""}

Gaudi::Property< bool >	m_inactCount {this, "countInactive", false, &MessageSvc::setupInactCount, ""}

Gaudi::Property< std::vector< std::string > >	m_tracedInactiveSources

Gaudi::Property< std::map< std::string, std::string > >	m_loggedStreamsName

std::ostream *	m_defaultStream = &std::cout
	Pointer to the output stream. More...

Message	m_defaultMessage
	Default Message. More...

StreamMap	m_streamMap
	Stream map. More...

MessageMap	m_messageMap
	Message map. More...

ThresholdMap	m_thresholdMap
	Output level threshold map. More...

std::string	m_logColorCodes [MSG::NUM_LEVELS]

std::map< std::string, MsgAry >	m_sourceMap

std::map< std::string, MsgAry >	m_inactiveMap

std::array< int, MSG::NUM_LEVELS >	m_msgCount

std::map< std::string, std::shared_ptr< std::ostream > >	m_loggedStreams

std::recursive_mutex	m_reportMutex
	Mutex to synchronize multiple threads printing. More...

std::recursive_mutex	m_messageMapMutex
	Mutex to synchronize multiple access to m_messageMap. More...

std::recursive_mutex	m_thresholdMapMutex
	Mutex to synchronize multiple access to m_thresholdMap (. More...

Additional Inherited Members
Protected Attributes inherited from Service
Gaudi::StateMachine::State	m_state = Gaudi::StateMachine::OFFLINE
	Service state. More...

Gaudi::StateMachine::State	m_targetState = Gaudi::StateMachine::OFFLINE
	Service state. More...

Gaudi::Property< int >	m_outputLevel {this, "OutputLevel", MSG::NIL, "output level"}

Gaudi::Property< bool >	m_auditInit {this, "AuditServices", false, " unused"}

Gaudi::Property< bool >	m_auditorInitialize {this, "AuditInitialize", false, "trigger auditor on initialize()"}

Gaudi::Property< bool >	m_auditorStart {this, "AuditStart", false, "trigger auditor on start()"}

Gaudi::Property< bool >	m_auditorStop {this, "AuditStop", false, "trigger auditor on stop()"}

Gaudi::Property< bool >	m_auditorFinalize {this, "AuditFinalize", false, "trigger auditor on finalize()"}

Gaudi::Property< bool >	m_auditorReinitialize {this, "AuditReinitialize", false, "trigger auditor on reinitialize()"}

Gaudi::Property< bool >	m_auditorRestart {this, "AuditRestart", false, "trigger auditor on restart()"}

SmartIF< IAuditorSvc >	m_pAuditorSvc
	Auditor Service. More...

Detailed Description

Definition at line 40 of file MessageSvc.h.

Member Typedef Documentation

◆ MessageMap

typedef std::multimap<StatusCode, Message> MessageSvc::MessageMap

Definition at line 44 of file MessageSvc.h.

◆ NamedStream

typedef std::pair<std::string, std::ostream*> MessageSvc::NamedStream

Definition at line 42 of file MessageSvc.h.

◆ StreamMap

typedef std::multimap<int, NamedStream> MessageSvc::StreamMap

Definition at line 43 of file MessageSvc.h.

◆ ThresholdMap

typedef std::map<std::string, int, std::less<> > MessageSvc::ThresholdMap

Definition at line 45 of file MessageSvc.h.

Constructor & Destructor Documentation

◆ MessageSvc()

MessageSvc::MessageSvc	(	const std::string &	name,
		ISvcLocator *	svcloc
	)

Definition at line 88 of file MessageSvc.cpp.

                                                                    : base_class( name, svcloc ) {
 
   m_outputLevel.declareUpdateHandler( [svcloc]( Gaudi::Details::PropertyBase& ) {
     SmartIF<IAppMgrUI> app = svcloc;
     if ( app ) app->outputLevelUpdate();
   } );
 
 #ifndef NDEBUG
   // initialize the MsgStream static flag.
   MsgStream::enableCountInactive( m_inactCount );
 #endif
 
   for ( int ic = 0; ic < MSG::NUM_LEVELS; ++ic ) {
     m_logColors[ic].declareUpdateHandler( &MessageSvc::setupColors, this );
     m_msgLimit[ic].declareUpdateHandler( &MessageSvc::setupLimits, this );
     m_thresholdProp[ic].declareUpdateHandler( &MessageSvc::setupThreshold, this );
   }
 
   m_logColors[MSG::FATAL].set( {"blue", "red"} );
   m_logColors[MSG::ERROR].set( {"white", "red"} );
   m_logColors[MSG::WARNING].set( {"yellow"} );
 
   std::fill( std::begin( m_msgCount ), std::end( m_msgCount ), 0 );
 }

Member Function Documentation

◆ defaultStream()

std::ostream* MessageSvc::defaultStream ( ) const

inlineoverride

Definition at line 100 of file MessageSvc.h.

100 { return m_defaultStream; }

MessageSvc::m_defaultStream

std::ostream * m_defaultStream

Pointer to the output stream.

Definition: MessageSvc.h:186

◆ eraseMessage() [1/3]

void MessageSvc::eraseMessage ( )

override

Definition at line 544 of file MessageSvc.cpp.

                               {
   auto lock = std::scoped_lock{m_messageMapMutex};
   m_messageMap.clear();
 }

◆ eraseMessage() [2/3]

void MessageSvc::eraseMessage ( const StatusCode & code )

override

Definition at line 556 of file MessageSvc.cpp.

                                                      {
   auto lock = std::scoped_lock{m_messageMapMutex};
   m_messageMap.erase( key );
 }

◆ eraseMessage() [3/3]

void MessageSvc::eraseMessage	(	const StatusCode &	code,
		const Message &	message
	)

override

Definition at line 568 of file MessageSvc.cpp.

                                                                          {
   auto lock = std::scoped_lock{m_messageMapMutex};
 
   erase_if( m_messageMap, m_messageMap.equal_range( key ),
             [&]( MessageMap::const_reference j ) { return j.second == msg; } );
 }

◆ eraseStream() [1/4]

void MessageSvc::eraseStream ( )

override

Definition at line 487 of file MessageSvc.cpp.

487 { m_streamMap.clear(); }

MessageSvc::m_streamMap

StreamMap m_streamMap

Stream map.

Definition: MessageSvc.h:188

std::multimap::clear

T clear(T... args)

◆ eraseStream() [2/4]

void MessageSvc::eraseStream ( int message_type )

override

Definition at line 496 of file MessageSvc.cpp.

496 { m_streamMap.erase( message_type ); }

MessageSvc::m_streamMap

StreamMap m_streamMap

Stream map.

Definition: MessageSvc.h:188

std::multimap::erase

T erase(T... args)

◆ eraseStream() [3/4]

void MessageSvc::eraseStream	(	int	message_type,
		std::ostream *	stream
	)

override

Definition at line 505 of file MessageSvc.cpp.

                                                           {
   if ( stream ) {
     erase_if( m_streamMap, m_streamMap.equal_range( key ),
               [&]( StreamMap::const_reference j ) { return j.second.second == stream; } );
   }
 }

◆ eraseStream() [4/4]

void MessageSvc::eraseStream ( std::ostream * stream )

override

Definition at line 519 of file MessageSvc.cpp.

                                                  {
   if ( stream ) {
     erase_if( m_streamMap, [&]( StreamMap::const_reference j ) { return j.second.second == stream; } );
   }
 }

◆ finalize()

StatusCode MessageSvc::finalize ( )

override

Finalize Service.

Definition at line 247 of file MessageSvc.cpp.

                                 {
 
   m_suppress = false;
 
   {
     std::ostringstream os;
 
     if ( m_stats ) {
       os << "Summarizing all message counts" << std::endl;
     } else {
       os << "Listing sources of suppressed message: " << std::endl;
     }
 
     os << "=====================================================" << std::endl;
     os << " Message Source              |   Level |    Count" << std::endl;
     os << "-----------------------------+---------+-------------" << std::endl;
 
     bool found( false );
 
     for ( auto 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( std::ios_base::left, std::ios_base::adjustfield );
           os << itr->first;
           os << "|";
 
           os.width( 8 );
           os.setf( std::ios_base::right, std::ios_base::adjustfield );
           os << levelNames[ic];
           os << " |";
 
           os.width( 9 );
           os << itr->second.msg[ic];
           os << std::endl;
 
           found = true;
         }
       }
     }
     os << "=====================================================" << std::endl;
     if ( found || m_stats ) std::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 );
     for ( const auto& itr : m_inactiveMap ) {
       for ( unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic ) {
         if ( itr.second.msg[ic] != 0 && itr.first.length() > ml ) { ml = itr.first.length(); }
       }
     }
 
     for ( unsigned int i = 0; i < ml + 25; ++i ) os << "=";
 
     os << std::endl << " ";
     os.width( ml + 2 );
     os.setf( std::ios_base::left, std::ios_base::adjustfield );
     os << "Message Source";
     os.width( 1 );
     os << "|   Level |    Count" << std::endl;
 
     for ( unsigned int i = 0; i < ml + 3; ++i ) os << "-";
     os << "+---------+-----------" << std::endl;
 
     for ( auto 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( std::ios_base::left, std::ios_base::adjustfield );
           os << itr->first;
 
           os << "|";
 
           os.width( 8 );
           os.setf( std::ios_base::right, std::ios_base::adjustfield );
           os << levelNames[ic];
 
           os << " |";
 
           os.width( 9 );
           os << itr->second.msg[ic];
 
           os << std::endl;
 
           found = true;
         }
       }
     }
     for ( unsigned int i = 0; i < ml + 25; ++i ) os << "=";
     os << std::endl;
 
     if ( found ) std::cout << os.str();
   }
 #endif
 
   return StatusCode::SUCCESS;
 }

◆ getLogColor()

std::string MessageSvc::getLogColor ( int logLevel ) const

override

Definition at line 610 of file MessageSvc.cpp.

                                                       {
   // ---------------------------------------------------------------------------
   return ( logLevel < MSG::NUM_LEVELS ) ? m_logColorCodes[logLevel] : "";
 }

◆ i_reportMessage() [1/2]

void MessageSvc::i_reportMessage	(	const Message &	msg,
		int	outputLevel
	)

protectedvirtual

Internal implementation of reportMessage(const Message&,int) without lock.

Definition at line 366 of file MessageSvc.cpp.

                                                                       {
   int key = msg.getType();
 
   ++m_msgCount[key];
 
   const Message* cmsg = &msg;
 
   // processing logged streams
   if ( !m_loggedStreams.empty() ) {
     auto iLog = m_loggedStreams.find( msg.getSource() );
     if ( m_loggedStreams.end() != iLog ) { ( *iLog->second ) << *cmsg << std::endl; }
   }
 
   if ( m_suppress.value() || m_stats.value() ) {
 
     // Increase the counter of 'key' type of messages for the source and
     // get the new value.
     const int nmsg = ++( m_sourceMap[msg.getSource()].msg[key] );
 
     if ( m_suppress.value() && m_msgLimit[key] != 0 ) {
       if ( nmsg > m_msgLimit[key] ) return;
       if ( nmsg == m_msgLimit[key] ) {
         std::string txt = levelNames[key] + " message limit (" + std::to_string( m_msgLimit[key].value() ) +
                           ") reached for " + msg.getSource() + ". Suppressing further output.";
         cmsg = new Message( msg.getSource(), MSG::WARNING, std::move( txt ) );
         cmsg->setFormat( msg.getFormat() );
       }
     }
   }
 
   auto range = m_streamMap.equal_range( key );
   if ( range.first != m_streamMap.end() ) {
     std::for_each( range.first, range.second,
                    [&]( StreamMap::const_reference sm ) { *sm.second.second << *cmsg << std::endl; } );
   } 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;
     }
   }
 
   if ( cmsg != &msg ) { delete cmsg; }
 }

◆ i_reportMessage() [2/2]

void MessageSvc::i_reportMessage	(	const StatusCode &	code,
		const std::string &	source
	)

protectedvirtual

Internal implementation of reportMessage(const StatusCode&,const std::string&) without lock.

Definition at line 452 of file MessageSvc.cpp.

                                                                                   {
   int  level  = outputLevel( source );
   auto report = [&]( Message mesg ) {
     mesg.setSource( source );
     Message stat_code( source, mesg.getType(), "Status Code " + std::to_string( code.getCode() ) );
     i_reportMessage( std::move( stat_code ), level );
     i_reportMessage( std::move( mesg ), level );
   };
 
   auto range = m_messageMap.equal_range( code );
   if ( range.first != m_messageMap.end() ) {
     std::for_each( range.first, range.second, [&]( MessageMap::const_reference sm ) { report( sm.second ); } );
   } else {
     report( m_defaultMessage );
   }
 }

◆ incrInactiveCount()

void MessageSvc::incrInactiveCount	(	MSG::Level	level,
		const std::string &	src
	)

override

Definition at line 619 of file MessageSvc.cpp.

                                                                             {
   ++( m_inactiveMap[source].msg[level] );
 
   if ( std::find( begin( m_tracedInactiveSources ), end( m_tracedInactiveSources ), source ) !=
        end( m_tracedInactiveSources ) ) {
     std::cout << "== inactive message detected from " << source << " ==" << std::endl;
     std::string t;
     System::backTrace( t, 25, 0 );
     std::cout << t << std::endl;
   }
 }

◆ initialize()

StatusCode MessageSvc::initialize ( )

override

Initialize Service.

Definition at line 116 of file MessageSvc.cpp.

                                   {
   StatusCode sc = Service::initialize();
   if ( sc.isFailure() ) return sc;
 
 #ifdef _WIN32
   m_color = false;
 #endif
 
   // make sure the map of logged stream names is initialized
   setupLogStreams();
 
   return StatusCode::SUCCESS;
 }

◆ insertMessage()

void MessageSvc::insertMessage	(	const StatusCode &	code,
		const Message &	message
	)

override

Definition at line 532 of file MessageSvc.cpp.

                                                                           {
   auto lock = std::scoped_lock{m_messageMapMutex};
   m_messageMap.emplace( key, msg );
 }

◆ insertStream()

void MessageSvc::insertStream	(	int	message_type,
		std::string	name,
		std::ostream *	stream
	)

override

Definition at line 476 of file MessageSvc.cpp.

                                                                            {
   m_streamMap.emplace( key, NamedStream( std::move( name ), stream ) );
 }

◆ messageCount()

int MessageSvc::messageCount ( MSG::Level logLevel ) const

override

Definition at line 616 of file MessageSvc.cpp.

616 { return m_msgCount[level]; }

gaudirun.level

level

Definition: gaudirun.py:346

MessageSvc::m_msgCount

std::array< int, MSG::NUM_LEVELS > m_msgCount

Definition: MessageSvc.h:204

◆ outputLevel() [1/2]

int MessageSvc::outputLevel ( ) const

override

Definition at line 576 of file MessageSvc.cpp.

                                   {
   // ---------------------------------------------------------------------------
   return m_outputLevel;
 }

◆ outputLevel() [2/2]

int MessageSvc::outputLevel ( std::string_view source ) const

override

Definition at line 582 of file MessageSvc.cpp.

                                                          {
   // ---------------------------------------------------------------------------
   auto lock = std::scoped_lock{m_thresholdMapMutex};
   auto it   = m_thresholdMap.find( source );
   return it != m_thresholdMap.end() ? it->second : m_outputLevel.value();
 }

◆ reinitialize()

StatusCode MessageSvc::reinitialize ( )

override

Reinitialize Service.

Definition at line 133 of file MessageSvc.cpp.

                                     {
   m_state       = Gaudi::StateMachine::OFFLINE;
   StatusCode sc = initialize();
   if ( sc.isSuccess() ) m_state = Gaudi::StateMachine::INITIALIZED;
 
   return sc;
 }

◆ reportMessage() [1/5]

void MessageSvc::reportMessage ( const Message & message )

override

Definition at line 419 of file MessageSvc.cpp.

419 { reportMessage( msg, outputLevel( msg.getSource() ) ); }

MessageSvc::reportMessage

void reportMessage(const Message &message) override

Definition: MessageSvc.cpp:419

CommonMessagingBase::msg

MsgStream & msg() const

shortcut for the method msgStream(MSG::INFO)

Definition: CommonMessaging.h:123

MessageSvc::outputLevel

int outputLevel() const override

Definition: MessageSvc.cpp:576

◆ reportMessage() [2/5]

void MessageSvc::reportMessage	(	const Message &	msg,
		int	outputLevel
	)

override

Definition at line 361 of file MessageSvc.cpp.

                                                                     {
   auto lock = std::scoped_lock{m_reportMutex};
   i_reportMessage( msg, outputLevel );
 }

◆ reportMessage() [3/5]

void MessageSvc::reportMessage	(	const StatusCode &	code,
		const std::string &	source = `""`
	)

override

Definition at line 447 of file MessageSvc.cpp.

                                                                                 {
   auto lock = std::scoped_lock{m_messageMapMutex};
   i_reportMessage( code, source );
 }

◆ reportMessage() [4/5]

void MessageSvc::reportMessage	(	const char *	source,
		int	type,
		const char *	message
	)

override

Definition at line 427 of file MessageSvc.cpp.

                                                                                   {
   reportMessage( Message{source, type, message} );
 }

◆ reportMessage() [5/5]

void MessageSvc::reportMessage	(	const std::string &	source,
		int	type,
		const std::string &	message
	)

override

Definition at line 437 of file MessageSvc.cpp.

                                                                                             {
   reportMessage( Message{source, type, message} );
 }

◆ setDefaultStream()

void MessageSvc::setDefaultStream ( std::ostream * stream )

inlineoverride

Definition at line 103 of file MessageSvc.h.

                                                        {
     auto lock       = std::scoped_lock{m_reportMutex};
     m_defaultStream = stream;
   }

◆ setOutputLevel() [1/2]

void MessageSvc::setOutputLevel ( int new_level )

override

Definition at line 590 of file MessageSvc.cpp.

                                                {
   // ---------------------------------------------------------------------------
   m_outputLevel = new_level;
 }

◆ setOutputLevel() [2/2]

void MessageSvc::setOutputLevel	(	std::string_view	source,
		int	new_level
	)

override

Definition at line 596 of file MessageSvc.cpp.

                                                                   {
   // ---------------------------------------------------------------------------
   auto lock = std::scoped_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;
   }
 }

◆ setupColors()

void MessageSvc::setupColors ( Gaudi::Details::PropertyBase & prop )

private

Definition at line 143 of file MessageSvc.cpp.

                                                              {
   const std::string& pname = prop.name();
   int                level;
   if ( pname == "fatalColorCode" )
     level = MSG::FATAL;
   else if ( pname == "errorColorCode" )
     level = MSG::ERROR;
   else if ( pname == "warningColorCode" )
     level = MSG::WARNING;
   else if ( pname == "infoColorCode" )
     level = MSG::INFO;
   else if ( pname == "debugColorCode" )
     level = MSG::DEBUG;
   else if ( pname == "verboseColorCode" )
     level = MSG::VERBOSE;
   else if ( pname == "alwaysColorCode" )
     level = MSG::ALWAYS;
   else {
     throw GaudiException( "ERROR: Unknown message color parameter: " + pname, name(), StatusCode::FAILURE );
   }
 
   auto& code = m_logColorCodes[level];
 
   const auto& col_desc = m_logColors[level].value();
 
   if ( col_desc.size() == 1 ) {
     const std::string& desc = col_desc[0];
     if ( desc.empty() ) {
       code = "";
     } else if ( desc[0] == '[' ) {
       code = "\033" + desc;
     } else {
       code = "\033[" + colTrans( desc, 90 ) + ";1m";
     }
   } else if ( col_desc.size() == 2 ) {
     code = "\033[" + colTrans( col_desc[0], 90 ) + ";" + colTrans( col_desc[1], 100 ) + ";1m";
   } else { // empty desc: no color
     code = "";
   }
 }

◆ setupInactCount()

void MessageSvc::setupInactCount ( Gaudi::Details::PropertyBase & prop )

private

Definition at line 237 of file MessageSvc.cpp.

                                                                  {
   if ( prop.name() == "countInactive" ) {
     Gaudi::Property<bool>* p = dynamic_cast<Gaudi::Property<bool>*>( &prop );
     if ( p ) MsgStream::enableCountInactive( p->value() );
   }
 }

◆ setupLimits()

void MessageSvc::setupLimits ( Gaudi::Details::PropertyBase & prop )

private

Definition at line 185 of file MessageSvc.cpp.

                                                              {
   // Just report problems in the settings of the limits and unknown limit parameters
   if ( prop.name() == "alwaysLimit" ) {
     Gaudi::Property<int>* p = dynamic_cast<Gaudi::Property<int>*>( &prop );
     if ( p && p->value() != 0 ) {
       std::cout << "MessageSvc ERROR: cannot suppress ALWAYS messages" << std::endl;
       p->setValue( 0 );
     }
   } 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 if ( prop.name() != "fatalLimit" && prop.name() != "errorLimit" && prop.name() != "warningLimit" &&
               prop.name() == "infoLimit" && prop.name() == "debugLimit" && prop.name() == "verboseLimit" ) {
     std::cout << "MessageSvc ERROR: Unknown message limit parameter: " << prop.name() << std::endl;
     return;
   }
 }

◆ setupLogStreams()

void MessageSvc::setupLogStreams ( )

private

Definition at line 632 of file MessageSvc.cpp.

                                  {
   // reset state
   m_loggedStreams.clear();
 
   for ( auto& iProp : m_loggedStreamsName ) {
 
     std::set<std::string> outFileNames;
     for ( auto& jProp : m_loggedStreamsName ) {
       if ( jProp.first != iProp.first ) { outFileNames.insert( jProp.second ); }
     }
     tee( iProp.first, iProp.second, outFileNames );
 
   } //> loop over property entries
 }

◆ setupThreshold()

void MessageSvc::setupThreshold ( Gaudi::Details::PropertyBase & prop )

private

Definition at line 205 of file MessageSvc.cpp.

                                                                 {
 
   static const std::array<std::pair<const char*, MSG::Level>, 7> tbl{{{"setFatal", MSG::FATAL},
                                                                       {"setError", MSG::ERROR},
                                                                       {"setWarning", MSG::WARNING},
                                                                       {"setInfo", MSG::INFO},
                                                                       {"setDebug", MSG::DEBUG},
                                                                       {"setVerbose", MSG::VERBOSE},
                                                                       {"setAlways", MSG::ALWAYS}}};
 
   auto i = std::find_if( std::begin( tbl ), std::end( tbl ),
                          [&]( const std::pair<const char*, MSG::Level>& t ) { return prop.name() == t.first; } );
   if ( i == std::end( tbl ) ) {
     std::cerr << "MessageSvc ERROR: Unknown message threshold parameter: " << prop.name() << std::endl;
     return;
   }
   int ic = i->second;
 
   Gaudi::Property<std::vector<std::string>>* sap = dynamic_cast<Gaudi::Property<std::vector<std::string>>*>( &prop );
   if ( !sap ) {
     std::cerr << "could not dcast " << prop.name()
               << " to a Gaudi::Property<std::vector<std::string>> (which it should be!)" << std::endl;
   } else {
     for ( auto& i : sap->value() ) setOutputLevel( i, ic );
   }
 }

◆ tee()

void MessageSvc::tee	(	const std::string &	sourceName,
		const std::string &	logFileName,
		const std::set< std::string > &	declaredOutFileNames
	)

private

Definition at line 648 of file MessageSvc.cpp.

                                                               {
   const std::ios_base::openmode openMode = std::ios_base::out | std::ios_base::trunc;
 
   auto iStream = m_loggedStreams.find( sourceName );
   if ( iStream != std::end( m_loggedStreams ) ) { m_loggedStreams.erase( iStream ); }
 
   // before creating a new ofstream, make sure there is no already existing
   // one with the same file name...
   for ( auto& iStream : m_loggedStreams ) {
     if ( outFileNames.find( outFileName ) != outFileNames.end() ) {
       m_loggedStreams[sourceName] = m_loggedStreams[iStream.first];
       return;
     }
   }
 
   auto out = std::make_shared<std::ofstream>( outFileName, openMode );
   if ( out->good() ) m_loggedStreams[sourceName] = std::move( out );
 }

◆ useColor()

bool MessageSvc::useColor ( ) const

inlineoverride

Definition at line 121 of file MessageSvc.h.

121 { return m_color; }

MessageSvc::m_color

Gaudi::Property< bool > m_color

Definition: MessageSvc.h:154

Member Data Documentation

◆ m_color

Gaudi::Property<bool> MessageSvc::m_color {this, "useColors", false, ""}

private

Definition at line 154 of file MessageSvc.h.

◆ m_defaultFormat

Gaudi::Property<std::string> MessageSvc::m_defaultFormat {this, "Format", Message::getDefaultFormat(), ""}

private

Definition at line 140 of file MessageSvc.h.

◆ m_defaultMessage

Message MessageSvc::m_defaultMessage

private

Default Message.

Definition at line 187 of file MessageSvc.h.

◆ m_defaultStream

std::ostream* MessageSvc::m_defaultStream = &std::cout

private

Pointer to the output stream.

Definition at line 186 of file MessageSvc.h.

◆ m_defaultTimeFormat

Gaudi::Property<std::string> MessageSvc::m_defaultTimeFormat {this, "timeFormat", Message::getDefaultTimeFormat(), ""}

private

Definition at line 141 of file MessageSvc.h.

◆ m_inactCount

Gaudi::Property<bool> MessageSvc::m_inactCount {this, "countInactive", false, &MessageSvc::setupInactCount, ""}

private

Definition at line 175 of file MessageSvc.h.

◆ m_inactiveMap

std::map<std::string, MsgAry> MessageSvc::m_inactiveMap

private

Definition at line 202 of file MessageSvc.h.

◆ m_logColorCodes

std::string MessageSvc::m_logColorCodes[MSG::NUM_LEVELS]

private

Definition at line 192 of file MessageSvc.h.

◆ m_logColors

std::array<Gaudi::Property<std::vector<std::string> >, MSG::NUM_LEVELS> MessageSvc::m_logColors

private

Initial value:

{{{},
                                                                                      {this, "verboseColorCode"},
                                                                                      {this, "debugColorCode"},
                                                                                      {this, "infoColorCode"},
                                                                                      {this, "warningColorCode"},
                                                                                      {this, "errorColorCode"},
                                                                                      {this, "fatalColorCode"},
                                                                                      {this, "alwaysColorCode"}}}

Definition at line 156 of file MessageSvc.h.

◆ m_loggedStreams

std::map<std::string, std::shared_ptr<std::ostream> > MessageSvc::m_loggedStreams

private

Definition at line 206 of file MessageSvc.h.

◆ m_loggedStreamsName

Gaudi::Property<std::map<std::string, std::string> > MessageSvc::m_loggedStreamsName

private

Initial value:

{

this, "loggedStreams", {}, "MessageStream sources we want to dump into a logfile"}

Definition at line 183 of file MessageSvc.h.

◆ m_messageMap

MessageMap MessageSvc::m_messageMap

private

Message map.

Definition at line 189 of file MessageSvc.h.

◆ m_messageMapMutex

std::recursive_mutex MessageSvc::m_messageMapMutex

mutableprivate

Mutex to synchronize multiple access to m_messageMap.

Definition at line 222 of file MessageSvc.h.

◆ m_msgCount

std::array<int, MSG::NUM_LEVELS> MessageSvc::m_msgCount

private

Definition at line 204 of file MessageSvc.h.

◆ m_msgLimit

std::array<Gaudi::Property<int>, MSG::NUM_LEVELS> MessageSvc::m_msgLimit

private

Initial value:

{{{this, "defaultLimit", 500},
                                                                {this, "verboseLimit", 500},
                                                                {this, "debugLimit", 500},
                                                                {this, "infoLimit", 500},
                                                                {this, "warningLimit", 500},
                                                                {this, "errorLimit", 500},
                                                                {this, "fatalLimit", 500},
                                                                {this, "alwaysLimit", 0}}}

Definition at line 165 of file MessageSvc.h.

◆ m_reportMutex

std::recursive_mutex MessageSvc::m_reportMutex

mutableprivate

Mutex to synchronize multiple threads printing.

Definition at line 219 of file MessageSvc.h.

◆ m_sourceMap

std::map<std::string, MsgAry> MessageSvc::m_sourceMap

private

Definition at line 202 of file MessageSvc.h.

◆ m_statLevel

Gaudi::Property<unsigned int> MessageSvc::m_statLevel {this, "statLevel", 0, ""}

private

Definition at line 143 of file MessageSvc.h.

◆ m_stats

Gaudi::Property<bool> MessageSvc::m_stats {this, "showStats", false, ""}

private

Definition at line 142 of file MessageSvc.h.

◆ m_streamMap

StreamMap MessageSvc::m_streamMap

private

Stream map.

Definition at line 188 of file MessageSvc.h.

◆ m_suppress

Gaudi::Property<bool> MessageSvc::m_suppress {this, "enableSuppression", false, ""}

private

Definition at line 174 of file MessageSvc.h.

◆ m_thresholdMap

ThresholdMap MessageSvc::m_thresholdMap

private

Output level threshold map.

Definition at line 190 of file MessageSvc.h.

◆ m_thresholdMapMutex

std::recursive_mutex MessageSvc::m_thresholdMapMutex

mutableprivate

Mutex to synchronize multiple access to m_thresholdMap (.

See also: MsgStream::doOutput).

Definition at line 226 of file MessageSvc.h.

◆ m_thresholdProp

std::array<Gaudi::Property<std::vector<std::string> >, MSG::NUM_LEVELS> MessageSvc::m_thresholdProp

private

Initial value:

{{{},
                                                                                          {this, "setVerbose"},
                                                                                          {this, "setDebug"},
                                                                                          {this, "setInfo"},
                                                                                          {this, "setWarning"},
                                                                                          {this, "setError"},
                                                                                          {this, "setFatal"},
                                                                                          {this, "setAlways"}}}

Definition at line 145 of file MessageSvc.h.

◆ m_tracedInactiveSources

Gaudi::Property<std::vector<std::string> > MessageSvc::m_tracedInactiveSources

private

Initial value:

{
      this,
      "tracedInactiveSources",
      {},
      "for each message source specified,  print a stack trace for the unprotected and unseen messages"}

Definition at line 177 of file MessageSvc.h.

The documentation for this class was generated from the following files:

GaudiCoreSvc/src/MessageSvc/MessageSvc.h
GaudiCoreSvc/src/MessageSvc/MessageSvc.cpp

Classes

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ MessageMap

◆ NamedStream

◆ StreamMap

◆ ThresholdMap

Constructor & Destructor Documentation

◆ MessageSvc()

Member Function Documentation

◆ defaultStream()

◆ eraseMessage() [1/3]

◆ eraseMessage() [2/3]

◆ eraseMessage() [3/3]

◆ eraseStream() [1/4]

◆ eraseStream() [2/4]

◆ eraseStream() [3/4]

◆ eraseStream() [4/4]

◆ finalize()

◆ getLogColor()

◆ i_reportMessage() [1/2]

◆ i_reportMessage() [2/2]

◆ incrInactiveCount()

◆ initialize()

◆ insertMessage()

◆ insertStream()

◆ messageCount()

◆ outputLevel() [1/2]

◆ outputLevel() [2/2]

◆ reinitialize()

◆ reportMessage() [1/5]

◆ reportMessage() [2/5]

◆ reportMessage() [3/5]

◆ reportMessage() [4/5]

◆ reportMessage() [5/5]

◆ setDefaultStream()

◆ setOutputLevel() [1/2]

◆ setOutputLevel() [2/2]

◆ setupColors()

◆ setupInactCount()

◆ setupLimits()

◆ setupLogStreams()

◆ setupThreshold()

◆ tee()

◆ useColor()

Member Data Documentation

◆ m_color

◆ m_defaultFormat

◆ m_defaultMessage

◆ m_defaultStream

◆ m_defaultTimeFormat

◆ m_inactCount

◆ m_inactiveMap

◆ m_logColorCodes

◆ m_logColors

◆ m_loggedStreams

◆ m_loggedStreamsName

◆ m_messageMap

◆ m_messageMapMutex

◆ m_msgCount

◆ m_msgLimit

◆ m_reportMutex

◆ m_sourceMap

◆ m_statLevel

◆ m_stats

◆ m_streamMap

◆ m_suppress

◆ m_thresholdMap

◆ m_thresholdMapMutex

◆ m_thresholdProp

◆ m_tracedInactiveSources