IncidentSvc.h

Go to the documentation of this file.

// $Header: /tmp/svngaudi/tmp.jEpFh25751/Gaudi/GaudiSvc/src/IncidentSvc/IncidentSvc.h,v 1.7 2008/11/10 16:00:23 marcocle Exp $
#ifndef IncidentSvc_IncidentSvc_H
#define IncidentSvc_IncidentSvc_H

// Include Files
#include "GaudiKernel/Service.h"
#include "GaudiKernel/SvcFactory.h"
#include "GaudiKernel/IIncidentSvc.h"

#include <map>
#include <list>

#include <boost/thread/recursive_mutex.hpp>

// Forward declarations

class IncidentSvc : public Service, virtual public 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;

// Inherited Service overrides:
//
  virtual StatusCode initialize();
  virtual StatusCode finalize();
  virtual StatusCode queryInterface( const InterfaceID& riid, void** ppvInterface );

// 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;
};

#endif