| The Gaudi Framework v29r1 (5cd95fa2)

- Main Page
- Related Pages
- Modules
- Namespaces
- Classes
- Files

- Class List
- Class Index
- Class Hierarchy
- Class Members

Classes | Public Types | Public Member Functions | Protected Member Functions | Private Member Functions | Private Attributes | List of all members
MessageSvc Class Reference

`#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 > | 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
typedef Gaudi::PluginService::Factory< IService *, const std::string &, ISvcLocator * > | Factory
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)
| ~MessageSvc () override=default
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, const 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 (const std::string &source) const override
void | setOutputLevel (int new_level) override
void | setOutputLevel (const std::string &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...
| ~extends () override=default
| Virtual destructor. 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
| ~PropertyHolder () override=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, TYPE &value, const std::string &doc="none") const
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
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, GaudiHandleBase &ref, const std::string &doc="none")
| Specializations for various GaudiHandles. More...
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, GaudiHandleArrayBase &ref, const std::string &doc="none")
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, DataObjectHandleBase &ref, const std::string &doc="none")
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...
MSG::Level | msgLevel () const
| get the cached level (originally extracted from the embedded MsgStream) More...
MSG::Level | outputLevel () const __attribute__((deprecated))
| Backward compatibility function for getting the output level. More...
bool | msgLevel (MSG::Level lvl) const
| get the output level from the embedded MsgStream More...
Public Member Functions inherited from extend_interfaces< Interfaces... >
| ~extend_interfaces () override=default
| Virtual destructor. 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 ()
| 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, ""}
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, "[[deprecated]] 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 30 of file MessageSvc.h.

## Member Typedef Documentation

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

Definition at line 35 of file MessageSvc.h.

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

Definition at line 33 of file MessageSvc.h.

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

Definition at line 34 of file MessageSvc.h.

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

Definition at line 36 of file MessageSvc.h.

## Constructor & Destructor Documentation

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

Definition at line 83 of file MessageSvc.cpp.

83 : base_class( name, svcloc )
84 {
85 m_inactCount.declareUpdateHandler( &MessageSvc::setupInactCount, this );
86
87 m_outputLevel.declareUpdateHandler( [svcloc]( Gaudi::Details::PropertyBase& ) {
88 SmartIF<IAppMgrUI> app = svcloc;
89 if ( app ) app->outputLevelUpdate();
90 } );
91
92 #ifndef NDEBUG
93 // initialize the MsgStream static flag.
94 MsgStream::enableCountInactive( m_inactCount );
95 #endif
96
97 for ( int ic = 0; ic < MSG::NUM_LEVELS; ++ic ) {
98 m_logColors[ic].declareUpdateHandler( &MessageSvc::setupColors, this );
99 m_msgLimit[ic].declareUpdateHandler( &MessageSvc::setupLimits, this );
100 m_thresholdProp[ic].declareUpdateHandler( &MessageSvc::setupThreshold, this );
101 }
102
103 m_logColors[MSG::FATAL].set( {"blue", "red"} );
104 m_logColors[MSG::ERROR].set( {"white", "red"} );
105 m_logColors[MSG::WARNING].set( {"yellow"} );
106
107 std::fill( std::begin( m_msgCount ), std::end( m_msgCount ), 0 );
108 }
Service::m_outputLevel
Gaudi::Property< int > m_outputLevel
Definition: Service.h:183
SmartIF< IAppMgrUI >
MessageSvc::setupInactCount
void setupInactCount(Gaudi::Details::PropertyBase &prop)
Definition: MessageSvc.cpp:238
std::end
T end(T...args)
extends< Service, IMessageSvc, IInactiveMessageCounter >::base_class
extends base_class
Typedef to this class.
Definition: extends.h:15
MessageSvc::setupColors
void setupColors(Gaudi::Details::PropertyBase &prop)
Definition: MessageSvc.cpp:139
IAppMgrUI::outputLevelUpdate
virtual void outputLevelUpdate()=0
Function to call to update the outputLevel of the components (after a change in MessageSvc).
MSG::FATAL
Definition: IMessageSvc.h:16
MessageSvc::m_inactCount
Gaudi::Property< bool > m_inactCount
Definition: MessageSvc.h:169
MessageSvc::m_logColors
std::array< Gaudi::Property< std::vector< std::string > >, MSG::NUM_LEVELS > m_logColors
Definition: MessageSvc.h:150
Gaudi::Details::PropertyBase
PropertyBase base class allowing PropertyBase* collections to be "homogeneous".
Definition: Property.h:32
std::begin
T begin(T...args)
MSG::NUM_LEVELS
Definition: IMessageSvc.h:16
BrunelScenarioForwardScheduler.app
app
Definition: BrunelScenarioForwardScheduler.py:147
MSG::ERROR
Definition: IMessageSvc.h:16
MessageSvc::setupLimits
void setupLimits(Gaudi::Details::PropertyBase &prop)
Definition: MessageSvc.cpp:182
MessageSvc::setupThreshold
void setupThreshold(Gaudi::Details::PropertyBase &prop)
Definition: MessageSvc.cpp:205
MessageSvc::m_msgCount
std::array< int, MSG::NUM_LEVELS > m_msgCount
Definition: MessageSvc.h:198
MessageSvc::m_thresholdProp
std::array< Gaudi::Property< std::vector< std::string > >, MSG::NUM_LEVELS > m_thresholdProp
Definition: MessageSvc.h:139
MSG::WARNING
Definition: IMessageSvc.h:16
std::fill
T fill(T...args)
MessageSvc::m_msgLimit
std::array< Gaudi::Property< int >, MSG::NUM_LEVELS > m_msgLimit
Definition: MessageSvc.h:159
MsgStream::enableCountInactive
static GAUDI_API bool enableCountInactive(bool value=true)
Enable/disable the count of inactive messages.
Definition: MsgStream.cpp:31

MessageSvc::~MessageSvc | ( |  | ) |
| override default

## Member Function Documentation

std::ostream* MessageSvc::defaultStream | ( |  | ) | const
| inline override

Definition at line 93 of file MessageSvc.h.

93 { return m_defaultStream; }
MessageSvc::m_defaultStream
std::ostream * m_defaultStream
Pointer to the output stream.
Definition: MessageSvc.h:180

void MessageSvc::eraseMessage | ( |  | ) |
| override

Definition at line 563 of file MessageSvc.cpp.

564 {
565 std::unique_lock<std::recursive_mutex> lock( m_messageMapMutex );
566 m_messageMap.clear();
567 }
MessageSvc::m_messageMap
MessageMap m_messageMap
Message map.
Definition: MessageSvc.h:183
MessageSvc::m_messageMapMutex
std::recursive_mutex m_messageMapMutex
Mutex to synchronize multiple access to m_messageMap.
Definition: MessageSvc.h:216
std::lock
T lock(T...args)
std::multimap::clear
T clear(T...args)
std::unique_lock

void MessageSvc::eraseMessage | ( | const StatusCode & | code | ) |
| override

Definition at line 576 of file MessageSvc.cpp.

577 {
578 std::unique_lock<std::recursive_mutex> lock( m_messageMapMutex );
579 m_messageMap.erase( key );
580 }
MessageSvc::m_messageMap
MessageMap m_messageMap
Message map.
Definition: MessageSvc.h:183
MessageSvc::m_messageMapMutex
std::recursive_mutex m_messageMapMutex
Mutex to synchronize multiple access to m_messageMap.
Definition: MessageSvc.h:216
std::multimap::erase
T erase(T...args)
std::lock
T lock(T...args)
std::unique_lock

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

Definition at line 589 of file MessageSvc.cpp.

590 {
591 std::unique_lock<std::recursive_mutex> lock( m_messageMapMutex );
592
593 erase_if( m_messageMap, m_messageMap.equal_range( key ),
594 [&]( MessageMap::const_reference j ) { return j.second == msg; } );
595 }
CommonMessagingBase::msg
MsgStream & msg() const
shortcut for the method msgStream(MSG::INFO)
Definition: CommonMessaging.h:121
MessageSvc::m_messageMap
MessageMap m_messageMap
Message map.
Definition: MessageSvc.h:183
MessageSvc::m_messageMapMutex
std::recursive_mutex m_messageMapMutex
Mutex to synchronize multiple access to m_messageMap.
Definition: MessageSvc.h:216
std::lock
T lock(T...args)
std::unique_lock
std::multimap::equal_range
T equal_range(T...args)

void MessageSvc::eraseStream | ( |  | ) |
| override

Definition at line 503 of file MessageSvc.cpp.

503 { m_streamMap.clear(); }
MessageSvc::m_streamMap
StreamMap m_streamMap
Stream map.
Definition: MessageSvc.h:182
std::multimap::clear
T clear(T...args)

void MessageSvc::eraseStream | ( | int | message_type | ) |
| override

Definition at line 512 of file MessageSvc.cpp.

512 { m_streamMap.erase( message_type ); }
MessageSvc::m_streamMap
StreamMap m_streamMap
Stream map.
Definition: MessageSvc.h:182
std::multimap::erase
T erase(T...args)

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

Definition at line 521 of file MessageSvc.cpp.

522 {
523 if ( stream ) {
524 erase_if( m_streamMap, m_streamMap.equal_range( key ),
525 [&]( StreamMap::const_reference j ) { return j.second.second == stream; } );
526 }
527 }
MessageSvc::m_streamMap
StreamMap m_streamMap
Stream map.
Definition: MessageSvc.h:182
std::multimap::equal_range
T equal_range(T...args)

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

Definition at line 536 of file MessageSvc.cpp.

537 {
538 if ( stream ) {
539 erase_if( m_streamMap, [&]( StreamMap::const_reference j ) { return j.second.second == stream; } );
540 }
541 }
MessageSvc::m_streamMap
StreamMap m_streamMap
Stream map.
Definition: MessageSvc.h:182

StatusCode MessageSvc::finalize | ( |  | ) |
| override

Finalize Service.

Definition at line 249 of file MessageSvc.cpp.

250 {
251
252 m_suppress = false;
253
254 {
255 std::ostringstream os;
256
257 if ( m_stats ) {
258 os << "Summarizing all message counts" << std::endl;
259 } else {
260 os << "Listing sources of suppressed message: " << std::endl;
261 }
262
263 os << "=====================================================" << std::endl;
264 os << " Message Source | Level | Count" << std::endl;
265 os << "-----------------------------+---------+-------------" << std::endl;
266
267 bool found( false );
268
269 for ( auto itr = m_sourceMap.begin(); itr != m_sourceMap.end(); ++itr ) {
270 for ( unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic ) {
271 if ( ( itr->second.msg[ic] >= m_msgLimit[ic] && m_msgLimit[ic] != 0 ) ||
272 ( m_stats && itr->second.msg[ic] > 0 && ic >= m_statLevel.value() ) ) {
273 os << " ";
274 os.width( 28 );
275 os.setf( std::ios_base::left, std::ios_base::adjustfield );
276 os << itr->first;
277 os << "|";
278
279 os.width( 8 );
280 os.setf( std::ios_base::right, std::ios_base::adjustfield );
281 os << levelNames[ic];
282 os << " |";
283
284 os.width( 9 );
285 os << itr->second.msg[ic];
286 os << std::endl;
287
288 found = true;
289 }
290 }
291 }
292 os << "=====================================================" << std::endl;
293 if ( found || m_stats ) std::cout << os.str();
294 }
295
296 #ifndef NDEBUG
297 if ( m_inactCount.value() ) {
298
299 std::ostringstream os;
300 os << "Listing sources of Unprotected and Unseen messages\n";
301
302 bool found( false );
303
304 unsigned int ml( 0 );
305 for ( const auto& itr : m_inactiveMap ) {
306 for ( unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic ) {
307 if ( itr.second.msg[ic] != 0 && itr.first.length() > ml ) {
308 ml = itr.first.length();
309 }
310 }
311 }
312
313 for ( unsigned int i = 0; i < ml + 25; ++i ) os << "=";
314
315 os << std::endl << " ";
316 os.width( ml + 2 );
317 os.setf( std::ios_base::left, std::ios_base::adjustfield );
318 os << "Message Source";
319 os.width( 1 );
320 os << "| Level | Count" << std::endl;
321
322 for ( unsigned int i = 0; i < ml + 3; ++i ) os << "-";
323 os << "+---------+-----------" << std::endl;
324
325 for ( auto itr = m_inactiveMap.begin(); itr != m_inactiveMap.end(); ++itr ) {
326 for ( unsigned int ic = 0; ic < MSG::NUM_LEVELS; ++ic ) {
327 if ( itr->second.msg[ic] != 0 ) {
328 os << " ";
329 os.width( ml + 2 );
330 os.setf( std::ios_base::left, std::ios_base::adjustfield );
331 os << itr->first;
332
333 os << "|";
334
335 os.width( 8 );
336 os.setf( std::ios_base::right, std::ios_base::adjustfield );
337 os << levelNames[ic];
338
339 os << " |";
340
341 os.width( 9 );
342 os << itr->second.msg[ic];
343
344 os << std::endl;
345
346 found = true;
347 }
348 }
349 }
350 for ( unsigned int i = 0; i < ml + 25; ++i ) os << "=";
351 os << std::endl;
352
353 if ( found ) std::cout << os.str();
354 }
355 #endif
356
357 return StatusCode::SUCCESS;
358 }
std::ostringstream::setf
T setf(T...args)
StatusCode::SUCCESS
Definition: StatusCode.h:31
MessageSvc::m_sourceMap
std::map< std::string, MsgAry > m_sourceMap
Definition: MessageSvc.h:196
MessageSvc::m_inactiveMap
std::map< std::string, MsgAry > m_inactiveMap
Definition: MessageSvc.h:196
std::endl
T endl(T...args)
MessageSvc::m_inactCount
Gaudi::Property< bool > m_inactCount
Definition: MessageSvc.h:169
MessageSvc::m_statLevel
Gaudi::Property< unsigned int > m_statLevel
Definition: MessageSvc.h:137
std::ostringstream
STL class.
std::ostringstream::width
T width(T...args)
std::ostringstream::str
T str(T...args)
MSG::NUM_LEVELS
Definition: IMessageSvc.h:16
MessageSvc::m_stats
Gaudi::Property< bool > m_stats
Definition: MessageSvc.h:136
MessageSvc::m_msgLimit
std::array< Gaudi::Property< int >, MSG::NUM_LEVELS > m_msgLimit
Definition: MessageSvc.h:159
MessageSvc::m_suppress
Gaudi::Property< bool > m_suppress
Definition: MessageSvc.h:168
std::cout

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

Definition at line 636 of file MessageSvc.cpp.

637 {
638 // ---------------------------------------------------------------------------
639 return ( logLevel < MSG::NUM_LEVELS ) ? m_logColorCodes[logLevel] : "";
640 }
MSG::NUM_LEVELS
Definition: IMessageSvc.h:16
MessageSvc::m_logColorCodes
std::string m_logColorCodes[MSG::NUM_LEVELS]
Definition: MessageSvc.h:186

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

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

Definition at line 372 of file MessageSvc.cpp.

373 {
374 int key = msg.getType();
375
376 ++m_msgCount[key];
377
378 const Message* cmsg = &msg;
379
380 // processing logged streams
381 if ( !m_loggedStreams.empty() ) {
382 auto iLog = m_loggedStreams.find( msg.getSource() );
383 if ( m_loggedStreams.end() != iLog ) {
384 ( *iLog->second ) << *cmsg << std::endl;
385 }
386 }
387
388 if ( m_suppress.value() || m_stats.value() ) {
389
390 // Increase the counter of 'key' type of messages for the source and
391 // get the new value.
392 const int nmsg = ++( m_sourceMap[msg.getSource()].msg[key] );
393
394 if ( m_suppress.value() && m_msgLimit[key] != 0 ) {
395 if ( nmsg > m_msgLimit[key] ) return;
396 if ( nmsg == m_msgLimit[key] ) {
397 std::string txt = levelNames[key] + " message limit (" + std::to_string( m_msgLimit[key].value() ) +
398 ") reached for " + msg.getSource() + ". Suppressing further output.";
399 cmsg = new Message( msg.getSource(), MSG::WARNING, std::move( txt ) );
400 cmsg->setFormat( msg.getFormat() );
401 }
402 }
403 }
404
405 auto range = m_streamMap.equal_range( key );
406 if ( range.first != m_streamMap.end() ) {
407 std::for_each( range.first, range.second,
408 [&]( StreamMap::const_reference sm ) { *sm.second.second << *cmsg << std::endl; } );
409 } else if ( key >= outputLevel ) {
410 msg.setFormat( m_defaultFormat );
411 msg.setTimeFormat( m_defaultTimeFormat );
412 if ( !m_color ) {
413 ( *m_defaultStream ) << *cmsg << std::endl << std::flush;
414 } else {
415 ( *m_defaultStream ) << m_logColorCodes[key] << *cmsg << "\033[m" << std::endl << std::flush;
416 }
417 }
418
419 if ( cmsg != &msg ) {
420 delete cmsg;
421 }
422 }
Message::getFormat
const std::string & getFormat() const
Get the format string.
Definition: Message.cpp:154
CommonMessagingBase::msg
MsgStream & msg() const
shortcut for the method msgStream(MSG::INFO)
Definition: CommonMessaging.h:121
std::map::empty
T empty(T...args)
MessageSvc::m_streamMap
StreamMap m_streamMap
Stream map.
Definition: MessageSvc.h:182
MessageSvc::m_sourceMap
std::map< std::string, MsgAry > m_sourceMap
Definition: MessageSvc.h:196
std::to_string
T to_string(T...args)
std::endl
T endl(T...args)
MessageSvc::m_defaultTimeFormat
Gaudi::Property< std::string > m_defaultTimeFormat
Definition: MessageSvc.h:135
std::map::end
T end(T...args)
Message::getType
int getType() const
Get the message type.
Definition: Message.cpp:87
std::string
STL class.
MessageSvc::m_loggedStreams
std::map< std::string, std::shared_ptr< std::ostream > > m_loggedStreams
Definition: MessageSvc.h:200
MessageSvc::m_color
Gaudi::Property< bool > m_color
Definition: MessageSvc.h:148
Gaudi::Functional::details::zip::range
decltype(auto) range(Args &&...args)
Zips multiple containers together to form a single range.
Definition: FunctionalDetails.h:85
MessageSvc::m_defaultFormat
Gaudi::Property< std::string > m_defaultFormat
Definition: MessageSvc.h:134
std::move
T move(T...args)
std::flush
T flush(T...args)
std::map::find
T find(T...args)
Message::setFormat
void setFormat(std::string msg) const
Set the format string.
Definition: Message.cpp:171
Message
The Message class.
Definition: Message.h:15
Message::setTimeFormat
void setTimeFormat(std::string timeFormat) const
Set the time format string.
Definition: Message.cpp:203
MessageSvc::outputLevel
int outputLevel() const override
Definition: MessageSvc.cpp:598
MessageSvc::m_logColorCodes
std::string m_logColorCodes[MSG::NUM_LEVELS]
Definition: MessageSvc.h:186
MessageSvc::m_stats
Gaudi::Property< bool > m_stats
Definition: MessageSvc.h:136
Message::getSource
const std::string & getSource() const
Get the message source.
Definition: Message.cpp:103
MessageSvc::m_msgCount
std::array< int, MSG::NUM_LEVELS > m_msgCount
Definition: MessageSvc.h:198
MSG::WARNING
Definition: IMessageSvc.h:16
MessageSvc::m_msgLimit
std::array< Gaudi::Property< int >, MSG::NUM_LEVELS > m_msgLimit
Definition: MessageSvc.h:159
std::for_each
T for_each(T...args)
MessageSvc::m_suppress
Gaudi::Property< bool > m_suppress
Definition: MessageSvc.h:168
std::multimap::equal_range
T equal_range(T...args)

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

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

Definition at line 466 of file MessageSvc.cpp.

467 {
468 int level = outputLevel( source );
469 auto report = [&]( Message mesg ) {
470 mesg.setSource( source );
471 Message stat_code( source, mesg.getType(), "Status Code " + std::to_string( code.getCode() ) );
472 i_reportMessage( std::move( stat_code ), level );
473 i_reportMessage( std::move( mesg ), level );
474 };
475
476 auto range = m_messageMap.equal_range( code );
477 if ( range.first != m_messageMap.end() ) {
478 std::for_each( range.first, range.second, [&]( MessageMap::const_reference sm ) { report( sm.second ); } );
479 } else {
480 report( m_defaultMessage );
481 }
482 }
StatusCode::getCode
unsigned long getCode() const
Get the status code by value.
Definition: StatusCode.h:94
MessageSvc::i_reportMessage
virtual void i_reportMessage(const Message &msg, int outputLevel)
Internal implementation of reportMessage(const Message&,int) without lock.
Definition: MessageSvc.cpp:372
MessageSvc::m_defaultMessage
Message m_defaultMessage
Default Message.
Definition: MessageSvc.h:181
std::to_string
T to_string(T...args)
MessageSvc::m_messageMap
MessageMap m_messageMap
Message map.
Definition: MessageSvc.h:183
std::multimap::end
T end(T...args)
Gaudi::Functional::details::zip::range
decltype(auto) range(Args &&...args)
Zips multiple containers together to form a single range.
Definition: FunctionalDetails.h:85
std::move
T move(T...args)
Message
The Message class.
Definition: Message.h:15
MessageSvc::outputLevel
int outputLevel() const override
Definition: MessageSvc.cpp:598
gaudirun.level
level
Definition: gaudirun.py:271
std::for_each
T for_each(T...args)
std::multimap::equal_range
T equal_range(T...args)

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

Definition at line 646 of file MessageSvc.cpp.

647 {
648 ++( m_inactiveMap[source].msg[level] );
649
650 if ( std::find( begin( m_tracedInactiveSources ), end( m_tracedInactiveSources ), source ) !=
651 end( m_tracedInactiveSources ) ) {
652 std::cout << "== inactive message detected from " << source << " ==" << std::endl;
653 std::string t;
654 System::backTrace( t, 25, 0 );
655 std::cout << t << std::endl;
656 }
657 }
MessageSvc::m_inactiveMap
std::map< std::string, MsgAry > m_inactiveMap
Definition: MessageSvc.h:196
std::endl
T endl(T...args)
MessageSvc::m_tracedInactiveSources
Gaudi::Property< std::vector< std::string > > m_tracedInactiveSources
Definition: MessageSvc.h:171
System::backTrace
GAUDI_API int backTrace(void **addresses, const int depth)
begin
auto begin(reverse_wrapper< T > &w)
Definition: reverse.h:58
std::string
STL class.
end
auto end(reverse_wrapper< T > &w)
Definition: reverse.h:64
std::find
T find(T...args)
gaudirun.level
level
Definition: gaudirun.py:271
std::cout

StatusCode MessageSvc::initialize | ( |  | ) |
| override

Initialize Service.

Definition at line 113 of file MessageSvc.cpp.

114 {
115 StatusCode sc = Service::initialize();
116 if ( sc.isFailure() ) return sc;
117
118 #ifdef _WIN32
119 m_color = false;
120 #endif
121
122 // make sure the map of logged stream names is initialized
123 setupLogStreams();
124
125 return StatusCode::SUCCESS;
126 }
Service::initialize
StatusCode initialize() override
Definition: Service.cpp:64
StatusCode::SUCCESS
Definition: StatusCode.h:31
MessageSvc::setupLogStreams
void setupLogStreams()
Definition: MessageSvc.cpp:660
StatusCode::isFailure
bool isFailure() const
Test for a status code of FAILURE.
Definition: StatusCode.h:86
StatusCode
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:28
MessageSvc::m_color
Gaudi::Property< bool > m_color
Definition: MessageSvc.h:148

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

Definition at line 550 of file MessageSvc.cpp.

551 {
552 std::unique_lock<std::recursive_mutex> lock( m_messageMapMutex );
553 m_messageMap.emplace( key, msg );
554 }
CommonMessagingBase::msg
MsgStream & msg() const
shortcut for the method msgStream(MSG::INFO)
Definition: CommonMessaging.h:121
MessageSvc::m_messageMap
MessageMap m_messageMap
Message map.
Definition: MessageSvc.h:183
MessageSvc::m_messageMapMutex
std::recursive_mutex m_messageMapMutex
Mutex to synchronize multiple access to m_messageMap.
Definition: MessageSvc.h:216
std::lock
T lock(T...args)
std::unique_lock
std::multimap::emplace
T emplace(T...args)

void MessageSvc::insertStream | ( | int | message_type,
|  | const std::string & | name,
|  | std::ostream * | stream
| ) |  |
| override

Definition at line 491 of file MessageSvc.cpp.

492 {
493 m_streamMap.emplace( key, NamedStream( name, stream ) );
494 }
MessageSvc::m_streamMap
StreamMap m_streamMap
Stream map.
Definition: MessageSvc.h:182
MessageSvc::NamedStream
std::pair< std::string, std::ostream * > NamedStream
Definition: MessageSvc.h:33
std::multimap::emplace
T emplace(T...args)

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

Definition at line 643 of file MessageSvc.cpp.

643 { return m_msgCount[level]; }
gaudirun.level
level
Definition: gaudirun.py:271
MessageSvc::m_msgCount
std::array< int, MSG::NUM_LEVELS > m_msgCount
Definition: MessageSvc.h:198

int MessageSvc::outputLevel | ( |  | ) | const
| override

Definition at line 598 of file MessageSvc.cpp.

599 {
600 // ---------------------------------------------------------------------------
601 return m_outputLevel;
602 }
Service::m_outputLevel
Gaudi::Property< int > m_outputLevel
Definition: Service.h:183

int MessageSvc::outputLevel | ( | const std::string & | source | ) | const
| override

Definition at line 605 of file MessageSvc.cpp.

606 {
607 // ---------------------------------------------------------------------------
608 std::unique_lock<std::recursive_mutex> lock( m_thresholdMapMutex );
609 auto it = m_thresholdMap.find( source );
610 return it != m_thresholdMap.end() ? it->second : m_outputLevel.value();
611 }
Service::m_outputLevel
Gaudi::Property< int > m_outputLevel
Definition: Service.h:183
std::map::end
T end(T...args)
MessageSvc::m_thresholdMap
ThresholdMap m_thresholdMap
Output level threshold map.
Definition: MessageSvc.h:184
std::lock
T lock(T...args)
std::map::find
T find(T...args)
std::unique_lock
MessageSvc::m_thresholdMapMutex
std::recursive_mutex m_thresholdMapMutex
Mutex to synchronize multiple access to m_thresholdMap (.
Definition: MessageSvc.h:220

StatusCode MessageSvc::reinitialize | ( |  | ) |
| override

Reinitialize Service.

Definition at line 131 of file MessageSvc.cpp.

132 {
133 m_state = Gaudi::StateMachine::OFFLINE;
134 return initialize();
135 }
Service::m_state
Gaudi::StateMachine::State m_state
Service state.
Definition: Service.h:160
MessageSvc::initialize
StatusCode initialize() override
Initialize Service.
Definition: MessageSvc.cpp:113
Gaudi::StateMachine::OFFLINE
Definition: StateMachine.h:15

void MessageSvc::reportMessage | ( | const Message & | message | ) |
| override

Definition at line 430 of file MessageSvc.cpp.

430 { reportMessage( msg, outputLevel( msg.getSource() ) ); }
CommonMessagingBase::msg
MsgStream & msg() const
shortcut for the method msgStream(MSG::INFO)
Definition: CommonMessaging.h:121
MessageSvc::reportMessage
void reportMessage(const Message &message) override
Definition: MessageSvc.cpp:430
MessageSvc::outputLevel
int outputLevel() const override
Definition: MessageSvc.cpp:598

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

Definition at line 366 of file MessageSvc.cpp.

367 {
368 std::unique_lock<std::recursive_mutex> lock( m_reportMutex );
369 i_reportMessage( msg, outputLevel );
370 }
MessageSvc::i_reportMessage
virtual void i_reportMessage(const Message &msg, int outputLevel)
Internal implementation of reportMessage(const Message&,int) without lock.
Definition: MessageSvc.cpp:372
std::lock
T lock(T...args)
MessageSvc::m_reportMutex
std::recursive_mutex m_reportMutex
Mutex to synchronize multiple threads printing.
Definition: MessageSvc.h:213
std::unique_lock
MessageSvc::outputLevel
int outputLevel() const override
Definition: MessageSvc.cpp:598

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

Definition at line 460 of file MessageSvc.cpp.

461 {
462 std::unique_lock<std::recursive_mutex> lock( m_messageMapMutex );
463 i_reportMessage( code, source );
464 }
MessageSvc::i_reportMessage
virtual void i_reportMessage(const Message &msg, int outputLevel)
Internal implementation of reportMessage(const Message&,int) without lock.
Definition: MessageSvc.cpp:372
MessageSvc::m_messageMapMutex
std::recursive_mutex m_messageMapMutex
Mutex to synchronize multiple access to m_messageMap.
Definition: MessageSvc.h:216
std::lock
T lock(T...args)
std::unique_lock

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

Definition at line 438 of file MessageSvc.cpp.

439 {
440 reportMessage( Message{source, type, message} );
441 }
gaudirun.type
type
Definition: gaudirun.py:133
MessageSvc::reportMessage
void reportMessage(const Message &message) override
Definition: MessageSvc.cpp:430
Message
The Message class.
Definition: Message.h:15

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

Definition at line 449 of file MessageSvc.cpp.

450 {
451 reportMessage( Message{source, type, message} );
452 }
gaudirun.type
type
Definition: gaudirun.py:133
MessageSvc::reportMessage
void reportMessage(const Message &message) override
Definition: MessageSvc.cpp:430
Message
The Message class.
Definition: Message.h:15

void MessageSvc::setDefaultStream | ( | std::ostream * | stream | ) |
| inline override

Definition at line 96 of file MessageSvc.h.

97 {
98 std::unique_lock<std::recursive_mutex> lock( m_reportMutex );
99 m_defaultStream = stream;
100 }
MessageSvc::m_defaultStream
std::ostream * m_defaultStream
Pointer to the output stream.
Definition: MessageSvc.h:180
std::lock
T lock(T...args)
MessageSvc::m_reportMutex
std::recursive_mutex m_reportMutex
Mutex to synchronize multiple threads printing.
Definition: MessageSvc.h:213
std::unique_lock

void MessageSvc::setOutputLevel | ( | int | new_level | ) |
| override

Definition at line 614 of file MessageSvc.cpp.

615 {
616 // ---------------------------------------------------------------------------
617 m_outputLevel = new_level;
618 }
Service::m_outputLevel
Gaudi::Property< int > m_outputLevel
Definition: Service.h:183

void MessageSvc::setOutputLevel | ( | const std::string & | source,
|  | int | new_level
| ) |  |
| override

Definition at line 621 of file MessageSvc.cpp.

622 {
623 // ---------------------------------------------------------------------------
624 std::unique_lock<std::recursive_mutex> lock( m_thresholdMapMutex );
625
626 // only write if we really have to...
627 auto i = m_thresholdMap.find( source );
628 if ( i == m_thresholdMap.end() ) {
629 m_thresholdMap[source] = level;
630 } else if ( i->second != level ) {
631 i->second = level;
632 }
633 }
std::map::end
T end(T...args)
MessageSvc::m_thresholdMap
ThresholdMap m_thresholdMap
Output level threshold map.
Definition: MessageSvc.h:184
std::lock
T lock(T...args)
std::map::find
T find(T...args)
std::unique_lock
gaudirun.level
level
Definition: gaudirun.py:271
MessageSvc::m_thresholdMapMutex
std::recursive_mutex m_thresholdMapMutex
Mutex to synchronize multiple access to m_thresholdMap (.
Definition: MessageSvc.h:220

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

Definition at line 139 of file MessageSvc.cpp.

140 {
141 const std::string& pname = prop.name();
142 int level;
143 if ( pname == "fatalColorCode" )
144 level = MSG::FATAL;
145 else if ( pname == "errorColorCode" )
146 level = MSG::ERROR;
147 else if ( pname == "warningColorCode" )
148 level = MSG::WARNING;
149 else if ( pname == "infoColorCode" )
150 level = MSG::INFO;
151 else if ( pname == "debugColorCode" )
152 level = MSG::DEBUG;
153 else if ( pname == "verboseColorCode" )
154 level = MSG::VERBOSE;
155 else if ( pname == "alwaysColorCode" )
156 level = MSG::ALWAYS;
157 else {
158 throw GaudiException( "ERROR: Unknown message color parameter: " + pname, name(), StatusCode::FAILURE );
159 }
160
161 auto& code = m_logColorCodes[level];
162
163 const auto& col_desc = m_logColors[level].value();
164
165 if ( col_desc.size() == 1 ) {
166 const std::string& desc = col_desc[0];
167 if ( desc.empty() ) {
168 code = "";
169 } else if ( desc[0] == '[' ) {
170 code = "\033" + desc;
171 } else {
172 code = "\033[" + colTrans( desc, 90 ) + ";1m";
173 }
174 } else if ( col_desc.size() == 2 ) {
175 code = "\033[" + colTrans( col_desc[0], 90 ) + ";" + colTrans( col_desc[1], 100 ) + ";1m";
176 } else { // empty desc: no color
177 code = "";
178 }
179 }
std::string::empty
T empty(T...args)
GaudiException
Define general base for Gaudi exception.
Definition: GaudiException.h:22
Service::name
const std::string & name() const override
Retrieve name of the service.
Definition: Service.cpp:289
StatusCode::FAILURE
Definition: StatusCode.h:31
Gaudi::Details::PropertyBase::name
const std::string name() const
property name
Definition: Property.h:40
MSG::DEBUG
Definition: IMessageSvc.h:16
MSG::VERBOSE
Definition: IMessageSvc.h:16
std::string
STL class.
MSG::FATAL
Definition: IMessageSvc.h:16
MessageSvc::m_logColors
std::array< Gaudi::Property< std::vector< std::string > >, MSG::NUM_LEVELS > m_logColors
Definition: MessageSvc.h:150
compareOutputFiles.pname
pname
Definition: compareOutputFiles.py:442
MSG::ERROR
Definition: IMessageSvc.h:16
MessageSvc::m_logColorCodes
std::string m_logColorCodes[MSG::NUM_LEVELS]
Definition: MessageSvc.h:186
gaudirun.level
level
Definition: gaudirun.py:271
MSG::WARNING
Definition: IMessageSvc.h:16
MSG::INFO
Definition: IMessageSvc.h:16
MSG::ALWAYS
Definition: IMessageSvc.h:16

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

Definition at line 238 of file MessageSvc.cpp.

239 {
240 if ( prop.name() == "countInactive" ) {
241 Gaudi::Property<bool>* p = dynamic_cast<Gaudi::Property<bool>*>( &prop );
242 if ( p ) MsgStream::enableCountInactive( p->value() );
243 }
244 }
Gaudi::Property
Implementation of property with value of concrete type.
Definition: Property.h:319
Gaudi::Details::PropertyBase::name
const std::string name() const
property name
Definition: Property.h:40
Gaudi::Property::value
const ValueType & value() const
Backward compatibility (.
Definition: Property.h:479
MsgStream::enableCountInactive
static GAUDI_API bool enableCountInactive(bool value=true)
Enable/disable the count of inactive messages.
Definition: MsgStream.cpp:31

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

Definition at line 182 of file MessageSvc.cpp.

183 {
184 // Just report problems in the settings of the limits and unknown limit parameters
185 if ( prop.name() == "alwaysLimit" ) {
186 Gaudi::Property<int>* p = dynamic_cast<Gaudi::Property<int>*>( &prop );
187 if ( p && p->value() != 0 ) {
188 std::cout << "MessageSvc ERROR: cannot suppress ALWAYS messages" << std::endl;
189 p->setValue( 0 );
190 }
191 } else if ( prop.name() == "defaultLimit" ) {
192 for ( int i = MSG::VERBOSE; i < MSG::NUM_LEVELS; ++i ) {
193 if ( i != MSG::ALWAYS ) {
194 m_msgLimit[i] = m_msgLimit[MSG::NIL].value();
195 }
196 }
197 } else if ( prop.name() != "fatalLimit" && prop.name() != "errorLimit" && prop.name() != "warningLimit" &&
198 prop.name() == "infoLimit" && prop.name() == "debugLimit" && prop.name() == "verboseLimit" ) {
199 std::cout << "MessageSvc ERROR: Unknown message limit parameter: " << prop.name() << std::endl;
200 return;
201 }
202 }
Gaudi::Property::setValue
bool setValue(const ValueType &v)
Definition: Property.h:481
Gaudi::Property
Implementation of property with value of concrete type.
Definition: Property.h:319
Gaudi::Details::PropertyBase::name
const std::string name() const
property name
Definition: Property.h:40
std::endl
T endl(T...args)
MSG::VERBOSE
Definition: IMessageSvc.h:16
MSG::NIL
Definition: IMessageSvc.h:16
MSG::NUM_LEVELS
Definition: IMessageSvc.h:16
Gaudi::Property::value
const ValueType & value() const
Backward compatibility (.
Definition: Property.h:479
MessageSvc::m_msgLimit
std::array< Gaudi::Property< int >, MSG::NUM_LEVELS > m_msgLimit
Definition: MessageSvc.h:159
std::cout
MSG::ALWAYS
Definition: IMessageSvc.h:16

void MessageSvc::setupLogStreams | ( |  | ) |
| private

Definition at line 660 of file MessageSvc.cpp.

661 {
662 // reset state
663 m_loggedStreams.clear();
664
665 for ( auto& iProp : m_loggedStreamsName ) {
666
667 std::set<std::string> outFileNames;
668 for ( auto& jProp : m_loggedStreamsName ) {
669 if ( jProp.first != iProp.first ) {
670 outFileNames.insert( jProp.second );
671 }
672 }
673 tee( iProp.first, iProp.second, outFileNames );
674
675 } //> loop over property entries
676 }
MessageSvc::m_loggedStreams
std::map< std::string, std::shared_ptr< std::ostream > > m_loggedStreams
Definition: MessageSvc.h:200
std::map::clear
T clear(T...args)
std::set::insert
T insert(T...args)
std::set< std::string >
MessageSvc::tee
void tee(const std::string &sourceName, const std::string &logFileName, const std::set< std::string > &declaredOutFileNames)
Definition: MessageSvc.cpp:679
MessageSvc::m_loggedStreamsName
Gaudi::Property< std::map< std::string, std::string > > m_loggedStreamsName
Definition: MessageSvc.h:177

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

Definition at line 205 of file MessageSvc.cpp.

206 {
207
208 static const std::array<std::pair<const char*, MSG::Level>, 7> tbl{{{"setFatal", MSG::FATAL},
209 {"setError", MSG::ERROR},
210 {"setWarning", MSG::WARNING},
211 {"setInfo", MSG::INFO},
212 {"setDebug", MSG::DEBUG},
213 {"setVerbose", MSG::VERBOSE},
214 {"setAlways", MSG::ALWAYS}}};
215
216 auto i = std::find_if( std::begin( tbl ), std::end( tbl ),
217 [&]( const std::pair<const char*, MSG::Level>& t ) { return prop.name() == t.first; } );
218 if ( i == std::end( tbl ) ) {
219 std::cerr << "MessageSvc ERROR: Unknown message threshold parameter: " << prop.name() << std::endl;
220 return;
221 }
222 int ic = i->second;
223
224 Gaudi::Property<std::vector<std::string>>* sap = dynamic_cast<Gaudi::Property<std::vector<std::string>>*>( &prop );
225 if ( !sap ) {
226 std::cerr << "could not dcast " << prop.name()
227 << " to a Gaudi::Property<std::vector<std::string>> (which it should be!)" << std::endl;
228 } else {
229 for ( auto& i : sap->value() ) setOutputLevel( i, ic );
230 }
231 }
Gaudi::Property
Implementation of property with value of concrete type.
Definition: Property.h:319
Gaudi::Details::PropertyBase::name
const std::string name() const
property name
Definition: Property.h:40
MSG::DEBUG
Definition: IMessageSvc.h:16
std::endl
T endl(T...args)
std::end
T end(T...args)
MSG::VERBOSE
Definition: IMessageSvc.h:16
MSG::FATAL
Definition: IMessageSvc.h:16
MessageSvc::setOutputLevel
void setOutputLevel(int new_level) override
Definition: MessageSvc.cpp:614
std::pair
std::find_if
T find_if(T...args)
std::begin
T begin(T...args)
std::array
STL class.
MSG::ERROR
Definition: IMessageSvc.h:16
MSG::WARNING
Definition: IMessageSvc.h:16
Gaudi::Property::value
const ValueType & value() const
Backward compatibility (.
Definition: Property.h:479
MSG::INFO
Definition: IMessageSvc.h:16
std::cerr
MSG::ALWAYS
Definition: IMessageSvc.h:16

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

Definition at line 679 of file MessageSvc.cpp.

681 {
682 const std::ios_base::openmode openMode = std::ios_base::out | std::ios_base::trunc;
683
684 auto iStream = m_loggedStreams.find( sourceName );
685 if ( iStream != std::end( m_loggedStreams ) ) {
686 m_loggedStreams.erase( iStream );
687 }
688
689 // before creating a new ofstream, make sure there is no already existing
690 // one with the same file name...
691 for ( auto& iStream : m_loggedStreams ) {
692 if ( outFileNames.find( outFileName ) != outFileNames.end() ) {
693 m_loggedStreams[sourceName] = m_loggedStreams[iStream.first];
694 return;
695 }
696 }
697
698 auto out = std::make_shared<std::ofstream>( outFileName, openMode );
699 if ( out->good() ) m_loggedStreams[sourceName] = std::move( out );
700 }
std::end
T end(T...args)
MessageSvc::m_loggedStreams
std::map< std::string, std::shared_ptr< std::ostream > > m_loggedStreams
Definition: MessageSvc.h:200
std::map::erase
T erase(T...args)
std::move
T move(T...args)
std::map::find
T find(T...args)

bool MessageSvc::useColor | ( |  | ) | const
| inline override

Definition at line 115 of file MessageSvc.h.

115 { return m_color; }
MessageSvc::m_color
Gaudi::Property< bool > m_color
Definition: MessageSvc.h:148

## Member Data Documentation

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

Definition at line 148 of file MessageSvc.h.

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

Definition at line 134 of file MessageSvc.h.

Message MessageSvc::m_defaultMessage
| private

Default Message.

Definition at line 181 of file MessageSvc.h.

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

Pointer to the output stream.

Definition at line 180 of file MessageSvc.h.

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

Definition at line 135 of file MessageSvc.h.

Gaudi::Property<bool> MessageSvc::m_inactCount {this, "countInactive", false, ""}
| private

Definition at line 169 of file MessageSvc.h.

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

Definition at line 196 of file MessageSvc.h.

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

Definition at line 186 of file MessageSvc.h.

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 150 of file MessageSvc.h.

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

Definition at line 200 of file MessageSvc.h.

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 177 of file MessageSvc.h.

MessageMap MessageSvc::m_messageMap
| private

Message map.

Definition at line 183 of file MessageSvc.h.

std::recursive_mutex MessageSvc::m_messageMapMutex
| mutable private

Mutex to synchronize multiple access to m_messageMap.

Definition at line 216 of file MessageSvc.h.

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

Definition at line 198 of file MessageSvc.h.

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 159 of file MessageSvc.h.

std::recursive_mutex MessageSvc::m_reportMutex
| mutable private

Mutex to synchronize multiple threads printing.

Definition at line 213 of file MessageSvc.h.

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

Definition at line 196 of file MessageSvc.h.

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

Definition at line 137 of file MessageSvc.h.

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

Definition at line 136 of file MessageSvc.h.

StreamMap MessageSvc::m_streamMap
| private

Stream map.

Definition at line 182 of file MessageSvc.h.

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

Definition at line 168 of file MessageSvc.h.

ThresholdMap MessageSvc::m_thresholdMap
| private

Output level threshold map.

Definition at line 184 of file MessageSvc.h.

std::recursive_mutex MessageSvc::m_thresholdMapMutex
| mutable private

Mutex to synchronize multiple access to m_thresholdMap (.

See also
  MsgStream::doOutput).

Definition at line 220 of file MessageSvc.h.

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 139 of file MessageSvc.h.

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 171 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