ReplayOutputStream.h

Go to the documentation of this file.

/***********************************************************************************\
* (c) Copyright 1998-2019 CERN for the benefit of the LHCb and ATLAS collaborations *
*                                                                                   *
* This software is distributed under the terms of the Apache version 2 licence,     *
* copied verbatim in the file "LICENSE".                                            *
*                                                                                   *
* In applying this licence, CERN does not waive the privileges and immunities       *
* granted to it by virtue of its status as an Intergovernmental Organization        *
* or submit itself to any jurisdiction.                                             *
\***********************************************************************************/
#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;
struct IDataManagerSvc;
 
class ReplayOutputStream : public GaudiAlgorithm {
public:
  using GaudiAlgorithm::GaudiAlgorithm;
 
  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;
  };
 
  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