HiveSlimEventLoopMgr.h

Go to the documentation of this file.

/***********************************************************************************\
* (c) Copyright 1998-2025 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.                                             *
\***********************************************************************************/
#pragma once
 
// Framework include files
#include <GaudiKernel/IAlgExecStateSvc.h>
#include <GaudiKernel/IAlgResourcePool.h>
#include <GaudiKernel/IDataManagerSvc.h>
#include <GaudiKernel/IEvtSelector.h>
#include <GaudiKernel/IHiveWhiteBoard.h>
#include <GaudiKernel/IIncidentListener.h>
#include <GaudiKernel/IIncidentSvc.h>
#include <GaudiKernel/IScheduler.h>
#include <GaudiKernel/MinimalEventLoopMgr.h>
#include <GaudiKernel/SmartIF.h>
 
// External Libraries
#include <boost/dynamic_bitset.hpp>
 
// STL
#include <memory>
 
class HiveSlimEventLoopMgr : public extends<Service, IEventProcessor> {
 
protected:
  Gaudi::Property<std::string> m_histPersName{ this, "HistogramPersistency", "", "" };
  Gaudi::Property<std::string> m_evtsel{ this, "EvtSel", "", "" };
  Gaudi::Property<std::string> m_schedulerName{ this, "SchedulerName", "AvalancheSchedulerSvc",
                                                "Name of the scheduler to be used" };
 
  Gaudi::Property<std::vector<unsigned int>> m_eventNumberBlacklist{ this, "EventNumberBlackList", {}, "" };
  Gaudi::Property<bool> m_abortOnFailure{ this, "AbortOnFailure", true, "Abort job on event failure" };

  SmartIF<IDataManagerSvc> m_evtDataMgrSvc;
  SmartIF<IEvtSelector> m_evtSelector;
  IEvtSelector::Context* m_evtContext = nullptr;
  SmartIF<IDataManagerSvc> m_histoDataMgrSvc;
  SmartIF<IConversionSvc> m_histoPersSvc;
  SmartIF<IHiveWhiteBoard> m_whiteboard;
  SmartIF<IAlgResourcePool> m_algResourcePool;
  SmartIF<IAlgExecStateSvc> m_algExecStateSvc;
  SmartIF<IProperty> m_appMgrProperty;
  bool m_endEventFired = false;
  SmartIF<IScheduler> m_schedulerSvc;
  StatusCode clearWBSlot( int evtSlot );
  StatusCode declareEventRootAddress();
  StatusCode drainScheduler( int& finishedEvents );
  SmartIF<IIncidentListener> m_abortEventListener;
  bool m_scheduledStop = false;
  SmartIF<IIncidentSvc> m_incidentSvc;
 
  // if finite number of evts is processed use bitset
  std::unique_ptr<boost::dynamic_bitset<>> m_blackListBS;
 
  EventContext::ContextEvt_t m_nevt{ 0 };
 
public:
  // inherit base class constructor
  using extends::extends;
 
  ~HiveSlimEventLoopMgr() override;

  StatusCode getEventRoot( IOpaqueAddress*& refpAddr );
  StatusCode initialize() override;
  StatusCode reinitialize() override;
  StatusCode stop() override;
  StatusCode finalize() override;
  StatusCode nextEvent( int maxevt ) override;
  EventContext createEventContext() override;
  StatusCode executeEvent( EventContext&& ctx ) override;
  StatusCode executeRun( int maxevt ) override;
  StatusCode stopRun() override;
};