DataStreamTool.h

Go to the documentation of this file.

/***********************************************************************************\
* (c) Copyright 1998-2025 CERN for the benefit of the LHCb and ATLAS collaborations *
*                                                                                   *
* This software is distributed under the terms of the Apache version 2 licence,     *
* copied verbatim in the file "LICENSE".                                            *
*                                                                                   *
* In applying this licence, CERN does not waive the privileges and immunities       *
* granted to it by virtue of its status as an Intergovernmental Organization        *
* or submit itself to any jurisdiction.                                             *
\***********************************************************************************/
#pragma once
 
#include <GaudiKernel/AlgTool.h>
#include <GaudiKernel/IDataStreamTool.h>
#include <GaudiKernel/IEvtSelector.h>
#include <GaudiKernel/IIncidentSvc.h>
#include <GaudiKernel/Service.h>
#include <vector>

 
class GAUDI_API DataStreamTool : public extends<AlgTool, IDataStreamTool> {
public:
  typedef std::vector<EventSelectorDataStream*>     Streams;
  typedef std::vector<Gaudi::Property<std::string>> Properties;

  using extends::extends;
 
  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;
};