DataStreamTool.h

Go to the documentation of this file.

// $Id: DataStreamTool.h,v 1.3 2007/01/15 16:48:21 hmd Exp $
#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/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);

  virtual ~DataStreamTool( ); 

  virtual StatusCode initialize();

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

  virtual StatusCode addStreams(const StreamSpecs &);

  virtual StatusCode eraseStream( const std::string& );

  virtual StatusCode finalize();

  virtual StatusCode initializeStream( EventSelectorDataStream* );

  virtual StatusCode finalizeStream( EventSelectorDataStream* );

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

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

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

  virtual EventSelectorDataStream* lastStream();

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

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

  virtual EventSelectorDataStream* getStream( const std::string& );

  virtual EventSelectorDataStream* getStream( size_type );

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

  virtual StatusCode clear();

protected:

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

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

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

  size_type m_streamID;

  size_type m_streamCount;

  Streams m_streams;

  StreamSpecs m_streamSpecs;

  SmartIF<IIncidentSvc>     m_incidentSvc;

  bool m_reconfigure;

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

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

};
#endif // GAUDIKERNEL_DATASTREAMTOOL_H