HiveSlimEventLoopMgr.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 GAUDIHIVE_HIVESLIMEVENTLOOPMGR_H
#define GAUDIHIVE_HIVESLIMEVENTLOOPMGR_H 1

// 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<bool> m_warnings{this, "Warnings", true, "Set this property to false to suppress warning messages"};
  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;
};
#endif // GAUDIHIVE_HIVESLIMEVENTLOOPMGR_H