DecisionSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
#ifndef ATHENASERVICES_DECISIONSVC_H
#define ATHENASERVICES_DECISIONSVC_H 
 
// STL includes
#include <string>
#include <vector>
#include <map>
 
// FrameWork includes
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/IAlgExecStateSvc.h"
 
// Athena includes
#include "AthenaBaseComps/AthService.h"
#include "AthenaKernel/IDecisionSvc.h"
#include "AthenaKernel/ICutFlowSvc.h"
#include "CxxUtils/checker_macros.h"
#include "StoreGate/StoreGateSvc.h"
 

class DecisionSvc : public extends<AthService, IDecisionSvc>
{ 
 
public: 

  DecisionSvc(const std::string& name, ISvcLocator* pSvcLocator );

  virtual ~DecisionSvc();


  virtual StatusCode initialize() override;
  virtual StatusCode start ATLAS_NOT_THREAD_SAFE () override;
  virtual StatusCode finalize() override;
 

  // Non-const methods: 
 
public:
  virtual StatusCode addStream(const std::string& stream) override;
  virtual StatusCode addAcceptAlg(const std::string& name,const std::string& stream) override;
  virtual StatusCode addRequireAlg(const std::string& name,const std::string& stream) override;
  virtual StatusCode addVetoAlg(const std::string& name,const std::string& stream) override;
 

  virtual const std::vector<std::string> getAcceptAlgs(const std::string& stream) const override;
  virtual const std::vector<std::string> getRequireAlgs(const std::string& stream) const override;
  virtual const std::vector<std::string> getVetoAlgs(const std::string& stream) const override;
  virtual const std::vector<std::string> getStreams() const override;
 
private:
  StatusCode interpretAlgMap();
 

  // Const methods: 
 
public:
  virtual bool isEventAccepted(const std::string& stream ) const override;
  virtual bool isEventAccepted(const std::string& stream, const EventContext& ) const override;
 
private:

  std::map<std::string, std::vector<std::string> > m_stream_accept;
  std::map<std::string, std::vector<std::string> > m_stream_require;
  std::map<std::string, std::vector<std::string> > m_stream_veto;
 
  std::vector<std::string> m_streamNames;
 
  Gaudi::Property<bool> m_calcStats{this, "CalcStats", false};
  bool m_frozen{false};
  ServiceHandle<StoreGateSvc> m_evtStore;
  ServiceHandle<ICutFlowSvc> m_cutflowSvc;
  ServiceHandle<IAlgExecStateSvc> m_algstateSvc;
 
  StatusCode DeclareToCutFlowSvc ATLAS_NOT_THREAD_SAFE ();
  StatusCode fillMap(std::map<std::string, std::vector<std::string> >& streamsModeMap, 
                     const std::string& name,
                     const std::string& stream);
}; 
 
#endif //> !ATHENASERVICES_DECISIONSVC_H