MinimalEventLoopMgr.h

Go to the documentation of this file.

#ifndef GAUDIKERNEL_MINIMALEVENTLOOPMGR_H
#define GAUDIKERNEL_MINIMALEVENTLOOPMGR_H 1

// Framework include files
#include "GaudiKernel/EventContext.h"
#include "GaudiKernel/IAlgExecStateSvc.h"
#include "GaudiKernel/IAlgorithm.h"
#include "GaudiKernel/IAppMgrUI.h"
#include "GaudiKernel/IEventProcessor.h"
#include "GaudiKernel/IIncidentListener.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/Service.h"

// STL include files
#include <list>
#include <vector>

class GAUDI_API MinimalEventLoopMgr : public extends<Service, IEventProcessor>
{
public:
  typedef std::vector<SmartIF<IAlgorithm>> ListAlg;

protected:
  // Properties
  Gaudi::Property<std::vector<std::string>> m_topAlgNames{this, "TopAlg", {}, "list of top level algorithms names"};
  Gaudi::Property<std::vector<std::string>> m_outStreamNames{this, "OutStream", {}, "list of output stream names"};
  Gaudi::Property<std::string> m_outStreamType{this, "OutStreamType", "OutputStream",
                                               "[[deprecated]] default type for OutputStream instances"};
  Gaudi::Property<bool> m_printCFExp{this, "PrintControlFlowExpression", false,
                                     "Print the control flow expression representing the content of TopAlg"};

  // enums
  enum State { OFFLINE, CONFIGURED, FINALIZED, INITIALIZED };
  SmartIF<IAppMgrUI> m_appMgrUI;
  SmartIF<IIncidentSvc> m_incidentSvc;
  SmartIF<IAlgExecStateSvc> m_aess;
  ListAlg m_topAlgList;
  ListAlg m_outStreamList;
  State m_state = OFFLINE;
  bool m_scheduledStop = false;
  SmartIF<IIncidentListener> m_abortEventListener;
  bool m_abortEvent = false;
  std::string m_abortEventSource;

public:
  MinimalEventLoopMgr( const std::string& nam, ISvcLocator* svcLoc );

#if defined( GAUDI_V20_COMPAT ) && !defined( G21_NO_DEPRECATED )
protected:
  template <class T>
  T* releaseInterface( T* iface )
  {
    if ( 0 != iface ) iface->release();
    return 0;
  }

public:
#endif

  StatusCode initialize() override;
  StatusCode start() override;
  StatusCode stop() override;
  StatusCode finalize() override;
  StatusCode reinitialize() override;
  StatusCode restart() override;

  StatusCode nextEvent( int maxevt ) override;
  StatusCode executeEvent( void* par ) override;
  StatusCode executeRun( int maxevt ) override;
  StatusCode stopRun() override;

  void topAlgHandler( Gaudi::Details::PropertyBase& p );
  StatusCode decodeTopAlgs();
  void outStreamHandler( Gaudi::Details::PropertyBase& p );
  StatusCode decodeOutStreams();

private:
  MinimalEventLoopMgr( const MinimalEventLoopMgr& );
  MinimalEventLoopMgr& operator=( const MinimalEventLoopMgr& );

  // number of events processed
  size_t m_nevt {0};

};
#endif // GAUDIKERNEL_MINIMALEVENTLOOPMGR_H