IncidentSvc.h

Go to the documentation of this file.

// $Id:$
// ============================================================================
#ifndef IncidentSvc_IncidentSvc_H
#define IncidentSvc_IncidentSvc_H
// ============================================================================
// Include Files
// ============================================================================
// STD & STL 
// ============================================================================
#include <map>
#include <list>
// ============================================================================
// GaudiKernel
// ============================================================================
#include "GaudiKernel/Service.h"
#include "GaudiKernel/SvcFactory.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/StringKey.h"
#include "GaudiKernel/StringKey.h"
#include "GaudiKernel/HashMap.h"
#include "GaudiKernel/ChronoEntity.h"
// ============================================================================
// Booots 
// ============================================================================
#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  ) ;
  
  // 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;
  
  MsgStream m_log;
  
  boost::recursive_mutex m_listenerMapMutex;
  
  mutable ChronoEntity m_timer     ;
  mutable bool         m_timerLock ;
  // ==========================================================================

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