HLTEventLoopMgr.h

Go to the documentation of this file.

#pragma once

#include <memory>
#include <string>
#include <unordered_map>
#include <vector>

#include "tbb/task.h"

// Forward declarations
class IAlgExecStateSvc;
class IEvtSelector;
class IHiveWhiteBoard;
struct IDataManagerSvc;
class IDataProviderSvc;

class HLTEventLoopMgr : public extends<Service, IEventProcessor>
{

public:
  using extends::extends;

  StatusCode initialize() override;
  StatusCode reinitialize() override { return StatusCode::FAILURE; }
  StatusCode finalize() override;

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

private:
  StatusCode declareEventRootAddress();
  StatusCode eventFailed( EventContext* eventContext ) const;
  struct HLTExecutionTask;
  friend HLTExecutionTask; // must be able to call `promoteToExecuted`...
  void promoteToExecuted( std::unique_ptr<EventContext> eventContext ) const;

private:
  Gaudi::Property<std::string> m_histPersName{this, "HistogramPersistency", "", ""};
  Gaudi::Property<std::string> m_evtsel{this, "EvtSel", "", ""};
  Gaudi::Property<int> m_threadPoolSize{this, "ThreadPoolSize", -1, "Size of the threadpool initialised by TBB"};
  Gaudi::Property<std::string> m_whiteboardSvcName{this, "WhiteboardSvc", "EventDataSvc", "The whiteboard name"};
  Gaudi::Property<std::string> m_dotfile{
      this, "DotFile", {}, "Name of file to dump dependency graph; if empty, do not dump"};

  IDataManagerSvc* m_evtDataMgrSvc = nullptr;
  IEvtSelector* m_evtSelector = nullptr;
  IDataManagerSvc* m_histoDataMgrSvc = nullptr;
  IConversionSvc* m_histoPersSvc = nullptr;
  IHiveWhiteBoard* m_whiteboard = nullptr;
  IAlgExecStateSvc* m_algExecStateSvc = nullptr;

  mutable std::atomic<unsigned int> m_finishedEvt{0};
  mutable std::condition_variable m_createEventCond;
  std::mutex m_createEventMutex;

  IEvtSelector::Context* m_evtSelContext{nullptr};

  std::vector<Algorithm*> m_algos;
};