PileUpStream.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2023 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef PILEUPSTREAM_PILEUPSTREAM_H
#define PILEUPSTREAM_PILEUPSTREAM_H
 
#include <string>
 
// Framework include files
#include "GaudiKernel/IEvtSelector.h"
#include "AthenaBaseComps/AthMessaging.h"
 
#include "xAODEventInfo/EventInfo.h" //typedef, cannot fwd declare
 
// Forward declarations
class IMessageSvc;
class ISvcLocator;
class StoreGateSvc;
class PileUpMergeSvc;
 
 
class PileUpStream
  : public AthMessaging
{
public:
  typedef IEvtSelector::Context EvtIterator;
 
 
  PileUpStream();
  PileUpStream(const PileUpStream& rhs) = delete;
  PileUpStream& operator=(const PileUpStream& rhs) = delete;
  PileUpStream(PileUpStream&& rhs);
  PileUpStream& operator=(PileUpStream&& rhs);
  PileUpStream(const std::string& name, 
           IEvtSelector* sel, 
           StoreGateSvc* store);
  PileUpStream(const std::string& name, 
           ISvcLocator* svcLoc,
           const std::string& selecName);
  PileUpStream(const std::string& name, 
           ISvcLocator* svcLoc,
           IEvtSelector* sel);
 
  virtual ~PileUpStream();
 
  inline const std::string& name() { return m_name; }
  inline IEvtSelector& selector() { return *p_sel; }
  inline EvtIterator& iterator() { return *p_iter; }
  inline StoreGateSvc& store() { return *p_SG; }
  inline const IEvtSelector& selector() const { return *p_sel; }
  inline const EvtIterator& iterator() const { return *p_iter; }
  inline const StoreGateSvc& store() const { return *p_SG; }
 
  const xAOD::EventInfo* nextEventPre(bool readRecord=true);
 
  bool nextEventPre_Passive(bool readRecord);
 
  bool setupStore();
  inline bool setupStore(bool ) { return setupStore();}
 
  StatusCode finalize();
 
  bool used() const {return m_used;}
  void setUsed() {m_used=true;}
  void resetUsed() {m_used=false;}
  bool hasRing() const { return m_hasRing; }
  unsigned int originalIRing() const { return m_iOriginalRing; }
  void setOriginalIRing(unsigned int iR) {
    if (!m_hasRing) {
      m_hasRing=true;
      m_iOriginalRing=iR; 
    }
  }
 
 
private:
  ISvcLocator* serviceLocator() { return p_svcLoc; }
 
  StatusCode nextRecordPre();
 
  StatusCode nextRecordPre_Passive();
 
  bool loadStore();
 
  void setActiveStore();
 
  //test for end of stream
  //  bool isNotEmpty() const;
 
  std::string m_name;
  ISvcLocator* p_svcLoc;
  IEvtSelector* p_sel;
  StoreGateSvc* p_SG;
  EvtIterator* p_iter; 
 
  PileUpMergeSvc* p_mergeSvc;
  
 
  bool m_ownEvtIterator; 
  bool m_neverLoaded;  
  bool m_ownStore;  
 
  bool m_used; 
  bool m_hasRing;
  unsigned int m_iOriginalRing; 
};
#endif // PILEUPSTREAM_PILEUPSTREAM_H