EventSelector.h

Go to the documentation of this file.

//====================================================================
//  EventSelector.h
//--------------------------------------------------------------------
//
//  Package    : EventSelector  (LHCb Event Selector Package)
//
//  Author     : M.Frank
//  Created    : 4/10/00
//
//====================================================================
//  Modified   : 11/11/06
//
//  Author     : Andres Felipe OSORIO OLIVEROS
//             : Marco CLEMENCIC
//
//====================================================================

#ifndef GAUDISVC_EVENTSELECTOR_EVENTSELECTOR_H
#define GAUDISVC_EVENTSELECTOR_EVENTSELECTOR_H 1

// Include files
#include "GaudiKernel/IEvtSelector.h"
#include "GaudiKernel/Service.h"

// STL include files
#include <vector>

// Forward declarations
class IIncidentSvc;
class IAddressCreator;
class IToolSvc;
class EventSelectorDataStream;
class EvtSelectorContext;
class IDataStreamTool;

class EventSelector : public extends<Service, IEvtSelector> {
public:
  typedef std::vector<EventSelectorDataStream*>     Streams;
  typedef std::vector<std::string>                  StreamSpecs;
  typedef std::vector<Gaudi::Property<std::string>> Properties;

  long int m_streamID;

protected:
  SmartIF<IIncidentSvc> m_incidentSvc = nullptr;

  SmartIF<IToolSvc> m_toolSvc = nullptr;

  IDataStreamTool* m_streamtool = nullptr;

  bool m_reconfigure = false;
  StreamSpecs m_streamSpecsLast;
  Streams m_streams;
  int m_streamCount = 0;

  // Properties
  Gaudi::Property<StreamSpecs> m_streamSpecs{this, "Input", {}, "input stream specifiers (for job options)"};
  Gaudi::Property<int>         m_firstEvent{this, "FirstEvent", 0, "first event to be processed"};
  Gaudi::Property<int>         m_evtMax{this, "EvtMax", INT_MAX, "maximum number of events to be processed"};
  Gaudi::Property<int>         m_evtPrintFrequency{this, "PrintFreq", 10, "printout frequency"};
  Gaudi::Property<std::string> m_streamManager{this, "StreamManager", "DataStreamTool", ""};

  virtual void printEvtInfo( const EvtSelectorContext* iter ) const;

public:
  StatusCode initialize() override;

  StatusCode finalize() override;

  StatusCode reinitialize() override;


  StatusCode createContext( Context*& refpCtxt ) const override;


  StatusCode next( Context& refCtxt ) const override;


  StatusCode next( Context& refCtxt, int jump ) const override;


  StatusCode previous( Context& refCtxt ) const override;


  StatusCode previous( Context& refCtxt, int jump ) const override;


  StatusCode rewind( Context& refCtxt ) const override;


  StatusCode createAddress( const Context& refCtxt, IOpaqueAddress*& refpAddr ) const override;


  StatusCode releaseContext( Context*& refCtxt ) const override;

  StatusCode resetCriteria( const std::string& cr, Context& c ) const override;

  StatusCode last( Context& c ) const override;

  StatusCode firstOfNextStream( bool shutDown, EvtSelectorContext& it ) const;
  StatusCode lastOfPreviousStream( bool shutDown, EvtSelectorContext& it ) const;

  using extends::extends;
};

#endif // GAUDISVC_EVENTSELECTOR_EVENTSELECTOR_H