Simple auditor which uses SequencerTimerTool for ALL algorithms, including the algorithm from main Gaudi "TopAlg" list and algorithms managed by Data-On-Demand Service. More...

Inheritance diagram for TimingAuditor:

[legend]

Collaboration diagram for TimingAuditor:

[legend]

Public Member Functions
void	before (StandardEventType evt, INamedInterface *alg) override

void	after (StandardEventType evt, INamedInterface *alg, const StatusCode &sc) override

void	before (CustomEventTypeRef evt, const std::string &name) override

void	after (CustomEventTypeRef evt, const std::string &name, const StatusCode &sc) override

void	handle (const Incident &) override
	Inform that a new incident has occurred. More...

StatusCode	initialize () override
	factory: More...

StatusCode	finalize () override

	TimingAuditor (const std::string &name, ISvcLocator *pSvc)
	standard constructor More...

	~TimingAuditor () override=default
	destructor More...

	TimingAuditor ()=delete

	TimingAuditor (const TimingAuditor &)=delete

TimingAuditor &	operator= (const TimingAuditor &)=delete

Public Member Functions inherited from extends< Auditor, IIncidentListener >
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 Auditor
	Auditor (const std::string &name, ISvcLocator *svcloc)
	Constructor. More...

	~Auditor () override=default
	Destructor. More...

StatusCode	sysInitialize () override
	Initialization method invoked by the framework. More...

StatusCode	sysFinalize () override
	Finalization method invoked by the framework. More...

void	before (StandardEventType, INamedInterface *) override
	The following methods are meant to be implemented by the child class... More...

void	before (StandardEventType, const std::string &) override

void	before (CustomEventTypeRef, INamedInterface *) override

void	before (CustomEventTypeRef, const std::string &) override

void	after (StandardEventType, INamedInterface *, const StatusCode &) override

void	after (StandardEventType, const std::string &, const StatusCode &) override

void	after (CustomEventTypeRef, INamedInterface *, const StatusCode &) override

void	after (CustomEventTypeRef, const std::string &, const StatusCode &) override

void	beforeInitialize (INamedInterface *) override

void	afterInitialize (INamedInterface *) override

void	beforeReinitialize (INamedInterface *) override

void	afterReinitialize (INamedInterface *) override

void	beforeExecute (INamedInterface *) override

void	afterExecute (INamedInterface *, const StatusCode &) override

void	beforeFinalize (INamedInterface *) override

void	afterFinalize (INamedInterface *) override

void	beforeBeginRun (INamedInterface *) override

void	afterBeginRun (INamedInterface *) override

void	beforeEndRun (INamedInterface *) override

void	afterEndRun (INamedInterface *) override

const std::string &	name () const override

bool	isEnabled () const override

SmartIF< ISvcLocator > &	serviceLocator () const
	The standard service locator. More...

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

template<class T = IService>
SmartIF< T >	service (const std::string &name, bool createIf=false) const

StatusCode	setProperty (const Property &p) override
	Set a value of a property of an auditor. More...

StatusCode	setProperty (const std::string &s) override
	Implementation of IProperty::setProperty. More...

StatusCode	setProperty (const std::string &n, const std::string &v) override
	Implementation of IProperty::setProperty. More...

StatusCode	getProperty (Property *p) const override
	Get the value of a property. More...

const Property &	getProperty (const std::string &name) const override
	Get the property by name. More...

StatusCode	getProperty (const std::string &n, std::string &v) const override
	Implementation of IProperty::getProperty. More...

const std::vector< Property * > &	getProperties () const override
	Get all properties. More...

bool	hasProperty (const std::string &name) const override
	Implementation of IProperty::hasProperty. More...

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

StatusCode	setProperties ()
	Set the auditor's properties. More...

template<class T >
Property *	declareProperty (const std::string &name, T &property, const std::string &doc="none") const
	Declare the named property. More...

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

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 output level 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...

Private Member Functions
void	i_beforeInitialize (INamedInterface *alg)

void	i_afterInitialize (INamedInterface *alg)

void	i_beforeFinalize (INamedInterface *alg)

void	i_beforeExecute (INamedInterface *alg)

void	i_afterExecute (INamedInterface *alg)

Private Attributes
SmartIF< IToolSvc >	m_toolSvc = nullptr
	tool service More...

SmartIF< IIncidentSvc >	m_incSvc = nullptr
	incident service More...

ISequencerTimerTool *	m_timer = nullptr
	the timer tool More...

SmartIF< INamedInterface >	m_appMgr = nullptr
	ApplicationManager. More...

GaudiUtils::VectorMap< const INamedInterface *, int >	m_map

int	m_indent = 0
	indentation level More...

bool	m_inEvent = false
	"In event" flag More...

bool	m_goodForDOD = false
	"optimized for DOD" More...

GaudiUtils::HashMap< std::string, int >	m_mapUser
	map used to record user timing events More...

bool	m_histoSaved = false

Additional Inherited Members
Public Types inherited from extends< Auditor, IIncidentListener >
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 Auditor
typedef Gaudi::PluginService::Factory< IAuditor , const std::string &, ISvcLocator >	Factory

Public Types inherited from CommonMessaging< implements< IAuditor, IProperty > >
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...

Protected Member Functions inherited from CommonMessaging< implements< IAuditor, IProperty > >
void	updateMsgStreamOutputLevel (int level)
	Update the output level of the cached MsgStream. More...

Detailed Description

Simple auditor which uses SequencerTimerTool for ALL algorithms, including the algorithm from main Gaudi "TopAlg" list and algorithms managed by Data-On-Demand Service.

Author: Vanya BELYAEV ibely.nosp@m.aev@.nosp@m.physi.nosp@m.cs.s.nosp@m.yr.ed.nosp@m.u

Date: 2007-01-31

Definition at line 28 of file TimingAuditor.cpp.

Constructor & Destructor Documentation

TimingAuditor::TimingAuditor	(	const std::string &	name,
		ISvcLocator *	pSvc
	)

inline

standard constructor

Definition at line 57 of file TimingAuditor.cpp.

     : base_class ( name , pSvc )
   {
     declareProperty ( "OptimizedForDOD" , m_goodForDOD ) ;
   } 

TimingAuditor::~TimingAuditor ( )

overridedefault

destructor

TimingAuditor::TimingAuditor ( )

delete

TimingAuditor::TimingAuditor ( const TimingAuditor & )

delete

Member Function Documentation

void TimingAuditor::after	(	StandardEventType	evt,
		INamedInterface *	alg,
		const StatusCode &	sc
	)

override

Definition at line 189 of file TimingAuditor.cpp.

 {
   switch (evt) {
   case IAuditor::Initialize : i_afterInitialize( alg ); break;
   case IAuditor::Execute    : i_afterExecute( alg ); break;
   default: break;
   }
 }

void TimingAuditor::after	(	CustomEventTypeRef	evt,
		const std::string &	name,
		const StatusCode &	sc
	)

override

Definition at line 288 of file TimingAuditor.cpp.

 {
   // Ignore obvious mistakes
   if ( name.empty() && evt.empty() ) { return; }
 
   // look for the user timer in the map
   std::string nick = name + ":" + evt;
   auto found = m_mapUser.find( nick );
 
   // We cannot do much if the timer is not available
   if ( m_mapUser.end() == found ) {
     warning() << "Trying to stop the measure  of the timing for '"
               << nick << "' but it was never started. Check the code"
                         << endmsg;
     return;
   }
   m_timer->stop( found->second );
 }

void TimingAuditor::before	(	StandardEventType	evt,
		INamedInterface *	alg
	)

override

Definition at line 179 of file TimingAuditor.cpp.

 {
   switch (evt) {
   case IAuditor::Initialize : i_beforeInitialize( alg ); break;
   case IAuditor::Execute    : i_beforeExecute( alg );    break;
   case IAuditor::Finalize   : i_beforeFinalize( alg );   break;
   default: break;
   }
 }

void TimingAuditor::before	(	CustomEventTypeRef	evt,
		const std::string &	name
	)

override

Definition at line 268 of file TimingAuditor.cpp.

 {
   // Ignore obvious mistakes
   if ( name.empty() && evt.empty() ) { return; }
 
   // look for the user timer in the map
   int timer = 0;
   std::string nick = name + ":" + evt;
   auto found = m_mapUser.find( nick );
 
   if ( m_mapUser.end() == found ) {
     // add a new timer if not yet available
     timer = m_timer->addTimer( nick ) ;
     m_mapUser[nick] = timer;
   } else {
     timer = found->second;
   }
   m_timer->start( timer );
 }

StatusCode TimingAuditor::finalize ( )

overridevirtual

Reimplemented from Auditor.

Definition at line 155 of file TimingAuditor.cpp.

 {
   if ( m_incSvc )
   {
     m_incSvc -> removeListener ( this , IncidentType::BeginEvent ) ;
     m_incSvc -> removeListener ( this , IncidentType::EndEvent   ) ;
     m_incSvc.reset();
   }
   if ( m_toolSvc )
   {
     // the 2 following line are commented out: it is
     // is a temporary hack which prevent a crash due to a problem in
     // the reference counting
     //     if ( 0 != m_timer )
     //     { m_toolSvc -> releaseTool ( m_timer ) . ignore() ; m_timer = 0 ; }
     m_toolSvc.reset();
   }
   m_appMgr.reset();
   // clear the map
   m_map.clear() ;
   // finalize the base class
   return Auditor::finalize () ;
 }

void TimingAuditor::handle ( const Incident & i )

override

Inform that a new incident has occurred.

Definition at line 307 of file TimingAuditor.cpp.

 {
   if      ( IncidentType::BeginEvent == i.type () ) {
     m_timer -> start ( m_map[ m_appMgr.get() ] ) ;
     ++m_indent ;
     m_inEvent = true ;
   } else if ( IncidentType::EndEvent   == i.type () ) {
     m_timer -> stop  ( m_map[ m_appMgr.get() ] ) ;
     --m_indent ;
     m_inEvent = false ;
   }
 }

void TimingAuditor::i_afterExecute ( INamedInterface * alg )

private

Definition at line 259 of file TimingAuditor.cpp.

 {
   if ( !alg ) { return ; }
   auto found = m_map.find( alg ) ;
   if ( m_map.end() == found ) { return ; }
   m_timer->stop( found->second ) ;
   --m_indent ;
 }

void TimingAuditor::i_afterInitialize ( INamedInterface * alg )

private

Definition at line 231 of file TimingAuditor.cpp.

 {
   if ( m_goodForDOD || !alg ) { return ; }
   --m_indent ;
 }

void TimingAuditor::i_beforeExecute ( INamedInterface * alg )

private

Definition at line 237 of file TimingAuditor.cpp.

 {
   if ( !alg ) { return ; }
   ++m_indent ;
   auto found = m_map.find( alg ) ;
   if ( m_map.end() == found )
   {
     debug() << "Insert non-structural component '"
            << alg->name() << "' of type '"
            << System::typeinfoName(typeid(*alg)) << "' at level "
            << m_indent << endmsg ;
     std::string nick = alg->name() ;
     if ( 0 < m_indent  ) { nick = std::string ( m_indent , ' ') + nick ; }
     if ( !m_goodForDOD ) { nick[0]='*' ;}
     int timer = m_timer->addTimer( nick ) ;
     m_map.insert ( alg , timer ) ;
     m_timer->start( timer ) ;
     return ;
   }
   m_timer->start( found->second ) ;
 }

void TimingAuditor::i_beforeFinalize ( INamedInterface * alg )

private

Definition at line 198 of file TimingAuditor.cpp.

 {
   if (!m_histoSaved)
   {
     m_timer->saveHistograms();
     m_histoSaved = true;
   }
 }

void TimingAuditor::i_beforeInitialize ( INamedInterface * alg )

private

Definition at line 208 of file TimingAuditor.cpp.

 {
   if ( m_goodForDOD ) { return ; }
   //
   if ( !alg ) { return ; }
   auto found = m_map.find( alg ) ;
   if ( m_map.end() != found ) { return ; }
   ++m_indent ;
   std::string nick = alg->name() ;
   if ( 0 < m_indent ) { nick = std::string ( m_indent , ' ') + nick ; }
   if ( m_inEvent )
   {
     nick[0] = '*' ;
     debug() << "Insert non-structural component '"
             << alg->name() << "' of type '"
             << System::typeinfoName(typeid(*alg)) << "' at level "
             << m_indent << endmsg ;
   }
   int timer = m_timer->addTimer( nick ) ;
   m_map.insert ( alg , timer ) ;
   m_timer->start( timer ) ;
 }

StatusCode TimingAuditor::initialize ( )

overridevirtual

factory:

Reimplemented from Auditor.

Definition at line 99 of file TimingAuditor.cpp.

 {
   StatusCode sc = Auditor::initialize() ;
   if ( sc.isFailure() ) { return sc ; }                  // RETURN
 
 
   // get tool service
   if ( ! m_toolSvc )
   {
     m_toolSvc = Auditor::service ( "ToolSvc" );
     if ( !m_toolSvc )
     {
       error() << "Could not retrieve 'ToolSvc' " << endmsg ;
       return StatusCode::FAILURE ;                                        // RETURN
     }
     if ( !m_timer )
     {
       sc = m_toolSvc->retrieveTool
         ( "SequencerTimerTool/TIMER" , m_timer , this  , true ) ;
       if ( sc.isFailure() )
       {
         error() << "Could not retrieve ISequencerTimerTool" << endmsg ;
         return sc ;
       }
     }
   }
   // get incident service
   if ( !m_incSvc )
   {
     m_incSvc = Auditor::service ( "IncidentSvc" );
     if ( !m_incSvc )
     {
       error() << "Could not retrieve 'IncidentSvc'" << endmsg ;
       return StatusCode::FAILURE ;
     }
     m_incSvc -> addListener ( this , IncidentType::BeginEvent ) ;
     m_incSvc -> addListener ( this , IncidentType::EndEvent   ) ;
   }
   // get the application manager
   if ( !m_appMgr )
   {
     m_appMgr = Auditor::service ( "ApplicationMgr" );
     if ( !m_appMgr )
     {
       error() << "Could not retrieve 'ApplicationMgr'" << endmsg ;
       return sc ;
     }
     if ( m_map.end() == m_map.find( m_appMgr.get() ) )
     {
       m_map.insert ( m_appMgr.get() , m_timer->addTimer( "EVENT LOOP" )  ) ;
     }
   }
   //
   return StatusCode::SUCCESS ;
 }

TimingAuditor& TimingAuditor::operator= ( const TimingAuditor & )

delete

Member Data Documentation

SmartIF<INamedInterface> TimingAuditor::m_appMgr = nullptr

private

ApplicationManager.

Definition at line 77 of file TimingAuditor.cpp.

bool TimingAuditor::m_goodForDOD = false

private

"optimized for DOD"

Definition at line 85 of file TimingAuditor.cpp.

bool TimingAuditor::m_histoSaved = false

private

Definition at line 90 of file TimingAuditor.cpp.

SmartIF<IIncidentSvc> TimingAuditor::m_incSvc = nullptr

private

incident service

Definition at line 73 of file TimingAuditor.cpp.

int TimingAuditor::m_indent = 0

private

indentation level

Definition at line 81 of file TimingAuditor.cpp.

bool TimingAuditor::m_inEvent = false

private

"In event" flag

Definition at line 83 of file TimingAuditor.cpp.

GaudiUtils::VectorMap<const INamedInterface*,int> TimingAuditor::m_map

private

Definition at line 79 of file TimingAuditor.cpp.

GaudiUtils::HashMap<std::string,int> TimingAuditor::m_mapUser

private

map used to record user timing events

Definition at line 87 of file TimingAuditor.cpp.

ISequencerTimerTool* TimingAuditor::m_timer = nullptr

private

the timer tool

Definition at line 75 of file TimingAuditor.cpp.

SmartIF<IToolSvc> TimingAuditor::m_toolSvc = nullptr

private

tool service

Definition at line 71 of file TimingAuditor.cpp.

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

GaudiAlg/src/components/TimingAuditor.cpp

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation