Gaudi Framework, version v20r2
	Generated: 18 Jul 2008

DataOnDemandSvc.h

Go to the documentation of this file.

// $Id: DataOnDemandSvc.h,v 1.9 2008/05/14 17:21:25 marcocle Exp $ 
// ============================================================================
// CVS tag $Name: v17r1 $ 
// ============================================================================
#ifndef GAUDISVC_DATAONDEMANDSVC_H
#define GAUDISVC_DATAONDEMANDSVC_H
// ============================================================================
// Include Files
// ============================================================================
// STD & STL 
// ============================================================================
#include <map>
#include <vector>
// ============================================================================
// GaudiKernel
// ============================================================================
#include "GaudiKernel/Service.h"
#include "GaudiKernel/SvcFactory.h"
#include "GaudiKernel/IIncidentListener.h"
#include "GaudiKernel/ChronoEntity.h"
#include "GaudiKernel/StatEntity.h"
// ============================================================================
// Reflex
// ============================================================================
#include "Reflex/Reflex.h"
// ============================================================================
// Forward declarations
// ============================================================================
class IAlgTool;
class IAlgorithm;
class IAlgManager;
class IIncidentSvc;
class IDataProviderSvc;
// ============================================================================
class DataOnDemandSvc 
  :         public Service
  , virtual public IIncidentListener 
{
public: 
  // Typedefs
  typedef std::vector<std::string> Setup;
  typedef ROOT::Reflex::Type       ClassH;
  struct Protection 
  {
    bool& m_bool;
    Protection(bool& b) : m_bool(b) { m_bool = true;  }
    ~Protection()                   { m_bool = false; }
  };
  struct Node  
  {
    ClassH      clazz;
    bool        executing;
    std::string name;
    Node() : clazz() , executing(false) , name () {}
    Node(ClassH c, bool e, const std::string& n)
      : clazz(c), executing(e), name(n) {}
    Node(const Node& c)
      : clazz(c.clazz), executing(c.executing), name(c.name){}
  };
  struct Leaf  
  {
    IAlgorithm* algorithm;
    bool        executing;
    std::string name;
    std::string type;
    Leaf() : algorithm ( 0 ) , executing (false ) , name() , type() {}
    Leaf(const Leaf& l) 
      : algorithm(l.algorithm), 
        executing(l.executing), name(l.name), type(l.type) {}
    Leaf(const std::string& t, const std::string& n)
      : algorithm(0), executing(false), name(n), type(t) {}
  };
  struct Timer 
  {
  public:
    Timer  ( ChronoEntity& c ) 
      : m_timer ( c ) { m_timer.start () ; }
    ~Timer ( )        { m_timer.stop  () ; }
  private:
    Timer() ;
  private:
    ChronoEntity& m_timer ;
  } ;
  typedef std::map<std::string, Node>  NodeMap;
  typedef std::map<std::string, Leaf>  AlgMap;
  virtual StatusCode initialize();
  virtual StatusCode finalize();
  virtual StatusCode reinitialize();
  virtual StatusCode queryInterface( const InterfaceID& riid, void** ppvInterface );
  virtual void handle(const Incident& incident);
  DataOnDemandSvc( const std::string& name, ISvcLocator* svc );
  virtual ~DataOnDemandSvc();
protected:
   StatusCode configureHandler(Leaf& leaf);
  StatusCode execHandler(const std::string& tag, Leaf& leaf);
  StatusCode execHandler(const std::string& tag, Node& node);
  StatusCode setupNodeHandlers();
  StatusCode setupAlgHandlers();
  StatusCode setup();
public:
  void update_1 ( Property& p ) ;
  void update_2 ( Property& p ) ;
  void update_3 ( Property& p ) ;
protected:
  StatusCode update() ;
  inline MsgStream& stream () const 
  {
    if ( 0 == m_log ) { m_log = new MsgStream( msgSvc() , name() ) ; }
    return *m_log;
  }
  StatusCode dump( MSG::Level level = MSG::DEBUG ) const ;
private:
  IIncidentSvc*     m_incSvc;
  IAlgManager*      m_algMgr;
  IDataProviderSvc* m_dataSvc;
  std::string       m_trapType;
  std::string       m_dataSvcName;
  bool              m_partialPath;
  SimpleProperty<Setup> m_algMapping;
  SimpleProperty<Setup> m_nodeMapping;
  AlgMap            m_algs;
  NodeMap           m_nodes;
  //
  typedef std::map<std::string,std::string> Map ;
  typedef SimplePropertyRef<Map>  MapRef   ;
  Map                m_algMap          ;
  Map                m_nodeMap         ;
  MapRef*            m_algMap_         ;
  MapRef*            m_nodeMap_        ;
  bool               m_updateRequired  ;
  std::string        m_prefix          ;
  mutable MsgStream* m_log             ;
  ChronoEntity       m_total           ;
  ulonglong          m_statAlg         ;  
  ulonglong          m_statNode        ;  
  ulonglong          m_stat            ;  
} ; 
// ============================================================================

// ============================================================================
// The END 
// ============================================================================
#endif // GAUDISVC_DATAONDEMANDSVC_H
// ============================================================================

---