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"
#include "GaudiKernel/ThreadLocalContext.h"

class IAlgManager;
class IDataManagerSvc;

class ReplayOutputStream : public GaudiAlgorithm
{
public:
  using GaudiAlgorithm::GaudiAlgorithm;
  ~ReplayOutputStream() override = default; 

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

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

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 ) {
        if ( !alg->isExecuted() ) {
          alg->sysExecute( Gaudi::Hive::currentContext() );
        } 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();

  Gaudi::Property<std::vector<std::string>> m_outputStreamNames{
      this, "OutputStreams", {}, "OutputStream instances that can be called."};

  OutStreamsMapType m_outputStreams;

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

#endif // COMPONENT_REPLAYOUTPUTSTREAM_H