DataStreamTool.h

Go to the documentation of this file.

#ifndef GAUDIKERNEL_DATASTREAMTOOL_H
#define GAUDIKERNEL_DATASTREAMTOOL_H 1

// Include files

#include <vector>

// from Gaudi
#include "GaudiKernel/Service.h"
#include "GaudiKernel/IEvtSelector.h"
#include "GaudiKernel/IDataStreamTool.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "GaudiKernel/AlgTool.h"

class IIncidentSvc;

class GAUDI_API DataStreamTool: public extends1<AlgTool, IDataStreamTool> {
public:

  typedef std::vector<EventSelectorDataStream*>  Streams;
  typedef std::vector<StringProperty>            Properties;

  DataStreamTool( const std::string& type,
                  const std::string& name,
                  const IInterface* parent);

  ~DataStreamTool( ) override = default; 

  StatusCode initialize() override;

  StatusCode finalize() override;

  StatusCode initializeStream( EventSelectorDataStream* ) override;

  StatusCode finalizeStream( EventSelectorDataStream* ) override;

  StatusCode getNextStream( const EventSelectorDataStream* &, size_type & ) override;

  StatusCode getPreviousStream( const EventSelectorDataStream* &, size_type & ) override;

  StatusCode addStream(const std::string &) override;

  StatusCode addStreams(const StreamSpecs &) override;

  StatusCode eraseStream( const std::string& ) override;
  EventSelectorDataStream* getStream( const std::string& ) override;

  EventSelectorDataStream* getStream( size_type ) override;

  EventSelectorDataStream* lastStream() override;

  size_type size() override { return m_streams.size(); };

  StatusCode clear() override;

  virtual Streams& getStreams() { return m_streams; };

  virtual Streams::iterator beginOfStreams() {return m_streams.begin(); };

  virtual Streams::iterator endOfStreams() {return m_streams.end(); };

protected:

  StatusCode createSelector( const std::string& , const std::string& ,
                             IEvtSelector*& ) override;

  StatusCode createStream(const std::string&, const std::string&,
                                  EventSelectorDataStream*& ) override;

  StatusCode connectStream( EventSelectorDataStream *);
  StatusCode connectStream( const std::string & );

  size_type m_streamID = 0;

  size_type m_streamCount = 0;

  Streams m_streams;

  StreamSpecs m_streamSpecs;

  SmartIF<IIncidentSvc>     m_incidentSvc = nullptr;

  Streams::iterator getStreamIterator ( const std::string& );

private:
  DataStreamTool(const DataStreamTool&) = delete;
  DataStreamTool& operator= (const DataStreamTool&) = delete;

};
#endif // GAUDIKERNEL_DATASTREAMTOOL_H