HiveSlimEventLoopMgr.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_HIVESLIMEVENTLOOPMGR_H
#define GAUDIHIVE_HIVESLIMEVENTLOOPMGR_H 1

// Framework include files
#include "GaudiKernel/IAlgResourcePool.h"
#include "GaudiKernel/IEvtSelector.h"
#include "GaudiKernel/IHiveWhiteBoard.h"
#include "GaudiKernel/MinimalEventLoopMgr.h"
#include "GaudiKernel/IScheduler.h"
#include "GaudiKernel/IIncidentSvc.h"
#include <GaudiKernel/IIncidentListener.h>

// Standard includes
#include <functional>

// External Libraries
#include "tbb/concurrent_queue.h"
#include <boost/dynamic_bitset.hpp>

// Forward declarations
class IIncidentSvc;
class IDataManagerSvc;
class IDataProviderSvc;

class HiveSlimEventLoopMgr: public extends<Service,
                                           IEventProcessor> {
  
protected:
  SmartIF<IDataManagerSvc>  m_evtDataMgrSvc;
  SmartIF<IEvtSelector>     m_evtSelector;
  IEvtSelector::Context*      m_evtContext;
  std::string       m_evtsel;
  SmartIF<IDataManagerSvc>  m_histoDataMgrSvc;
  SmartIF<IConversionSvc>   m_histoPersSvc;
  SmartIF<IHiveWhiteBoard>  m_whiteboard;
  SmartIF<IAlgResourcePool>  m_algResourcePool;
  std::string       m_histPersName;
  SmartIF<IProperty>        m_appMgrProperty;
  bool              m_endEventFired;
  bool              m_warnings;
  SmartIF<IScheduler> m_schedulerSvc;
  StatusCode clearWBSlot(int evtSlot);
  StatusCode declareEventRootAddress();
  StatusCode createEventContext(EventContext*& eventContext, int createdEvents);
  StatusCode drainScheduler(int& finishedEvents);
  SmartIF< IIncidentListener >  m_abortEventListener;
  std::string m_schedulerName;
  bool                m_scheduledStop;
  SmartIF<IAppMgrUI> m_appMgrUI;  
  SmartIF<IIncidentSvc> m_incidentSvc;
  
  std::vector<unsigned int> m_eventNumberBlacklist;

  //if finite number of evts is processed use bitset
  boost::dynamic_bitset<> * m_blackListBS;

public:
  HiveSlimEventLoopMgr(const std::string& nam, ISvcLocator* svcLoc);
  virtual ~HiveSlimEventLoopMgr();
  StatusCode getEventRoot(IOpaqueAddress*& refpAddr);    
  virtual StatusCode initialize();
  virtual StatusCode reinitialize();
  virtual StatusCode stop();
  virtual StatusCode finalize();
  virtual StatusCode nextEvent(int maxevt);
  virtual StatusCode executeEvent(void* par);
  virtual StatusCode executeRun(int maxevt);  
  virtual StatusCode stopRun();
};
#endif // GAUDIHIVE_HIVESLIMEVENTLOOPMGR_H