Loading [MathJax]/extensions/tex2jax.js
The Gaudi Framework  v31r0 (aeb156f0)
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Modules Pages
IncidentProcAlg.cpp
Go to the documentation of this file.
1 #include "IncidentProcAlg.h"
4 #include "GaudiKernel/Incident.h"
7 
8 #define ON_DEBUG if ( msgLevel( MSG::DEBUG ) )
9 #define ON_VERBOSE if ( msgLevel( MSG::VERBOSE ) )
10 
11 #define DEBMSG ON_DEBUG debug()
12 #define VERMSG ON_VERBOSE verbose()
13 
14 namespace {
15  // ==========================================================================
16  static const std::string s_unknown = "<unknown>";
17  // Helper to get the name of the listener
18  inline const std::string& getListenerName( IIncidentListener* lis ) {
19  SmartIF<INamedInterface> iNamed( lis );
20  return iNamed ? iNamed->name() : s_unknown;
21  }
22  // ==========================================================================
23 } // namespace
24 
26  : Algorithm( name, pSvcLocator ) {}
27 
30  if ( sc.isFailure() ) return sc;
31  m_incSvc = service( "IncidentSvc", true );
32  return StatusCode::SUCCESS;
33 }
34 
35 //=============================================================================
37  const EventContext& context = Gaudi::Hive::currentContext();
38  auto incPack = m_incSvc->getIncidents( &context );
39  MsgStream log( msgSvc(), name() );
40  log << MSG::DEBUG << " Number of Incidents to process = " << incPack.incidents.size()
41  << " Context= " << Gaudi::Hive::currentContext() << endmsg;
42  while ( incPack.incidents.size() ) {
43  if ( incPack.incidents.size() != incPack.listeners.size() ) {
44  log << MSG::WARNING << " Size of fired incidents and listeners do not match!" << endmsg;
45  }
46  for ( size_t t = 0; t < incPack.incidents.size(); t++ ) {
47  auto& inc = incPack.incidents.at( t );
48  auto& lis = incPack.listeners.at( t );
49  for ( auto& l : lis ) {
50  log << MSG::DEBUG << "Calling '" << getListenerName( l ) << "' for incident [" << inc->type() << "]" << endmsg;
51 
52  // handle exceptions if they occur
53  try {
54  l->handle( *inc );
55  } catch ( const GaudiException& exc ) {
56  error() << "Exception with tag=" << exc.tag()
57  << " is caught"
58  " handling incident"
59  << inc->type() << endmsg;
60  error() << exc << endmsg;
61  } catch ( const std::exception& exc ) {
62  error() << "Standard std::exception is caught"
63  " handling incident"
64  << inc->type() << endmsg;
65  error() << exc.what() << endmsg;
66  } catch ( ... ) { error() << "UNKNOWN Exception is caught handling incident" << inc->type() << endmsg; }
67  // check wheter one of the listeners is singleShot
68  }
69  }
70  incPack = m_incSvc->getIncidents( &context );
71  }
72 
73  return StatusCode::SUCCESS;
74 }
75 
76 //=============================================================================
78  info() << "Finalize" << endmsg;
79  return Algorithm::finalize();
80 }
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:24
Define general base for Gaudi exception.
The ISvcLocator is the interface implemented by the Service Factory in the Application Manager to loc...
Definition: ISvcLocator.h:25
virtual IIncidentSvc::IncidentPack getIncidents(const EventContext *ctx)=0
MsgStream & info() const
shortcut for the method msgStream(MSG::INFO)
const std::string & name() const override
The identifying name of the algorithm object.
Definition: Algorithm.cpp:635
StatusCode service(const std::string &name, T *&psvc, bool createIf=true) const
Access a service by name, creating it if it doesn&#39;t already exist.
Definition: Algorithm.h:215
constexpr static const auto SUCCESS
Definition: StatusCode.h:85
This class represents an entry point to all the event specific data.
Definition: EventContext.h:31
bool isFailure() const
Definition: StatusCode.h:130
StatusCode initialize() override
StatusCode finalize() override
STL class.
#define DECLARE_COMPONENT(type)
MsgStream & error() const
shortcut for the method msgStream(MSG::ERROR)
StatusCode initialize() override
the default (empty) implementation of IStateful::initialize() method
Definition: Algorithm.h:180
The interface implemented by any class wanting to listen to Incidents.
T what(T...args)
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:50
IncidentProcAlg(const std::string &name, ISvcLocator *pSvcLocator)
Constructor(s)
SmartIF< IIncidentSvc > m_incSvc
StatusCode finalize() override
the default (empty) implementation of IStateful::finalize() method
Definition: Algorithm.h:186
GAUDI_API const EventContext & currentContext()
virtual const std::string & tag() const
name tag for the exception, or exception type
const SmartIF< IMessageSvc > & msgSvc() const
The standard message service.
StatusCode execute() override
STL class.
dictionary l
Definition: gaudirun.py:517
Alias for backward compatibility.
Definition: Algorithm.h:56
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:192
virtual const std::string & name() const =0
Retrieve the name of the instance.