ReplayOutputStream.h

Go to the documentation of this file.

#ifndef COMPONENT_REPLAYOUTPUTSTREAM_H
#define COMPONENT_REPLAYOUTPUTSTREAM_H 1
// Include files
// from Gaudi
#include "GaudiAlg/GaudiAlgorithm.h"
#include "GaudiKernel/HashMap.h"
#include "GaudiKernel/SmartIF.h"

class IAlgManager;
class IDataManagerSvc;

class ReplayOutputStream: public GaudiAlgorithm {
public:
  ReplayOutputStream(const std::string& name, ISvcLocator* pSvcLocator);
  virtual ~ReplayOutputStream(); 

  virtual StatusCode initialize();    
  virtual StatusCode start     ();    
  virtual StatusCode execute   ();    
  virtual StatusCode stop      ();    
  virtual StatusCode finalize  ();    

  typedef GaudiUtils::HashMap<std::string, SmartIF<IAlgorithm> > OutStreamsMapType;

protected:
private:

  void i_addOutputStream(const Gaudi::Utils::TypeNameString &outStream);

  class OutStreamAdder {
  public:
    OutStreamAdder(ReplayOutputStream *ptr): m_ptr(ptr) {}
    inline void operator() (const Gaudi::Utils::TypeNameString &outStream) {
      m_ptr->i_addOutputStream(outStream);
    }
  private:
    ReplayOutputStream *m_ptr;
  };

  class OutStreamTrigger {
  public:
    OutStreamTrigger(ReplayOutputStream *ptr): m_ptr(ptr) {}
    inline void operator() (const std::string &name) const {
      SmartIF<IAlgorithm> &alg = m_ptr->m_outputStreams[name];
      if (alg.isValid()) {
        if (!alg->isExecuted()) {
          alg->sysExecute();
        } else {
          m_ptr->warning() << name
              << " already executed for the current event" << endmsg;
        }
      } else {
        m_ptr->warning() << "invalid OuputStream " << name << endmsg;
      }
    }
  private:
    ReplayOutputStream *m_ptr;
  };

  template <Gaudi::StateMachine::Transition TR>
  StatusCode i_outStreamTransition();

  std::vector<std::string> m_outputStreamNames;
  OutStreamsMapType m_outputStreams;

  SmartIF<IAlgManager> m_algMgr;
  SmartIF<IDataManagerSvc> m_evtMgr;
};

#endif // COMPONENT_REPLAYOUTPUTSTREAM_H