IncidentSvc.h

Go to the documentation of this file.

#ifndef IncidentSvc_IncidentSvc_H
#define IncidentSvc_IncidentSvc_H
// ============================================================================
// Include Files
// ============================================================================
// STD & STL
// ============================================================================
#include <map>
#include <list>
// ============================================================================
// GaudiKernel
// ============================================================================
#include "GaudiKernel/Service.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/StringKey.h"
#include "GaudiKernel/StringKey.h"
#include "GaudiKernel/HashMap.h"
#include "GaudiKernel/ChronoEntity.h"
// ============================================================================
// Boost
// ============================================================================
#include "boost/thread/recursive_mutex.hpp"
// ============================================================================
class IncidentSvc : public extends1<Service, IIncidentSvc>
{
  // ==========================================================================
public:
  // ==========================================================================
  struct Listener
  {
    IIncidentListener* iListener;
    long priority;
    bool rethrow;
    bool singleShot;

    Listener(IIncidentListener* il, long pri, bool thr=false, bool single=false):
      iListener(il), priority(pri), rethrow(thr), singleShot(single){}

  };

  // Typedefs
  typedef std::list<Listener> ListenerList;
  // typedef std::map<std::string, ListenerList*> ListenerMap;
  typedef GaudiUtils::HashMap<Gaudi::StringKey, ListenerList*> ListenerMap;

  // Inherited Service overrides:
  //
  virtual StatusCode initialize();
  virtual StatusCode finalize();

  // IIncidentSvc interfaces overwrite
  //
  virtual void addListener
  ( IIncidentListener* lis       ,
    const std::string& type = "" ,
    long priority   = 0          ,
    bool rethrow    = false      ,
    bool singleShot = false      ) ;

  virtual void removeListener
  ( IIncidentListener* lis       ,
    const std::string& type = "" ) ;
  virtual void fireIncident
  ( const Incident&    incident  ) ;

  virtual void getListeners (std::vector<IIncidentListener*>& lis,
                 const std::string& type = "") const ;

  // Standard Constructor.
  IncidentSvc( const std::string& name, ISvcLocator* svc );
  // Destructor.
  virtual ~IncidentSvc();

private:
  // ==========================================================================
  void i_fireIncident(const Incident& incident, const std::string& type);

  ListenerMap  m_listenerMap;

  const std::string *m_currentIncidentType;

  mutable boost::recursive_mutex m_listenerMapMutex;

  mutable ChronoEntity m_timer     ;
  mutable bool         m_timerLock ;
  // ==========================================================================

};
// ============================================================================
// The END
// ============================================================================
#endif
// ============================================================================