#include <EventSelectorMuonCalibStream.h>

Inheritance diagram for EventSelectorMuonCalibStream:

Collaboration diagram for EventSelectorMuonCalibStream:

Public Member Functions
	EventSelectorMuonCalibStream (const std::string &name, ISvcLocator *svcloc)

	~EventSelectorMuonCalibStream ()

virtual StatusCode	initialize ()

virtual StatusCode	createContext (Context *&it) const

virtual StatusCode	next (Context &it) const

virtual StatusCode	next (Context &it, int jump) const

virtual StatusCode	previous (Context &it) const

virtual StatusCode	previous (Context &it, int jump) const

virtual StatusCode	last (Context &it) const

virtual StatusCode	rewind (Context &it) const

virtual StatusCode	createAddress (const Context &it, IOpaqueAddress *&iop) const

virtual StatusCode	releaseContext (Context *&it) const

virtual StatusCode	resetCriteria (const std::string &criteria, Context &context) const

Private Attributes
Gaudi::Property< int >	m_SkipEvents {this, "SkipEvents", 0, "Number of events to skip at the beginning"}

ServiceHandle< MuonCalibStreamInputSvc >	m_eventSource { this, "MuonCalibStreamInputSvc", "MuonCalibStreamFileInputSvc"}

ServiceHandle< IMuonCalibStreamDataProviderSvc >	m_dataProvider {this, "DataProvider", "MuonCalibStreamDataProviderSvc"}

EventContextMuonCalibStream *	m_beginIter

EventContextMuonCalibStream *	m_endIter

std::atomic< long >	m_NumEvents {0}

Detailed Description

Definition at line 25 of file EventSelectorMuonCalibStream.h.

Constructor & Destructor Documentation

◆ EventSelectorMuonCalibStream()

EventSelectorMuonCalibStream::EventSelectorMuonCalibStream	(	const std::string &	name,
		ISvcLocator *	svcloc
	)

Definition at line 21 of file EventSelectorMuonCalibStream.cxx.

                                                                                                      :
     base_class(name, svcloc),
     m_beginIter(nullptr),
     m_endIter(nullptr)
 {
     ATH_MSG_DEBUG("EventSelectorMuonCalibStream constructor");
 }

◆ ~EventSelectorMuonCalibStream()

EventSelectorMuonCalibStream::~EventSelectorMuonCalibStream ( )

Definition at line 30 of file EventSelectorMuonCalibStream.cxx.

                                                             {
     if (m_beginIter) delete m_beginIter;
     if (m_endIter) delete m_endIter;
 }

Member Function Documentation

◆ createAddress()

StatusCode EventSelectorMuonCalibStream::createAddress	(	const Context &	it,
		IOpaqueAddress *&	iop
	)		const

virtual

Definition at line 125 of file EventSelectorMuonCalibStream.cxx.

                                                                                                                 {
     ATH_MSG_DEBUG("EventSelectorMuonCalibStream::createAddress");
     const LVL2_MUON_CALIBRATION::CalibEvent *pre = m_eventSource->currentEvent();
     m_dataProvider->setNextEvent(pre);
     ATH_MSG_DEBUG("Calib Event cached in Data Provider ");
  
     iop = new MuonCalibStreamAddress(ClassID_traits<xAOD::EventInfo>::ID(), "EventInfo", ""); // change to xAOD::EventInfo key
     //iop = new MuonCalibStreamAddress(ClassID_traits<xAOD::EventInfo>::ID(), "MuonCalibStreamEventInfo", ""); // old key which need the conversion afterwards
     ATH_MSG_DEBUG("MuonCalibStreamAddress for MuonCalibStreamEventInfo created ");
  
     return (StatusCode::SUCCESS);
 }

◆ createContext()

StatusCode EventSelectorMuonCalibStream::createContext ( IEvtSelector::Context *& it ) const

virtual

Definition at line 53 of file EventSelectorMuonCalibStream.cxx.

                                                                                      {
     it = new EventContextMuonCalibStream(this);
     return (StatusCode::SUCCESS);
 }

◆ initialize()

StatusCode EventSelectorMuonCalibStream::initialize ( )

virtual

Definition at line 36 of file EventSelectorMuonCalibStream.cxx.

                                                     {
     ATH_MSG_INFO("EventSelectorMuonCalibStream::initialize");
  
     // Check MuonCalibStreamCnvSvc
     ATH_CHECK( m_eventSource.retrieve() );
  
     ATH_CHECK( m_dataProvider.retrieve() );
  
     // Create the begin and end iterators for this selector.
     m_beginIter = new EventContextMuonCalibStream(this);
     // increment to get the new event in.
     //     ++(*m_beginIter);   ???
     m_endIter = new EventContextMuonCalibStream(0);
  
     return StatusCode::SUCCESS;
 }

◆ last()

StatusCode EventSelectorMuonCalibStream::last ( IEvtSelector::Context & it ) const

virtual

Definition at line 105 of file EventSelectorMuonCalibStream.cxx.

                                                                            {
     if (it.identifier() == m_endIter->identifier()) {
         ATH_MSG_DEBUG("last(): Last event in InputStream.");
         return (StatusCode::SUCCESS);
     }
     return (StatusCode::FAILURE);
 }

◆ next() [1/2]

StatusCode EventSelectorMuonCalibStream::next ( IEvtSelector::Context & it ) const

virtual

Definition at line 59 of file EventSelectorMuonCalibStream.cxx.

                                                                            {
     ATH_MSG_DEBUG(" EventSelectorMuonCalibStream::next m_NumEvents=" << m_NumEvents);
     for (;;) {
         const LVL2_MUON_CALIBRATION::CalibEvent *pre = m_eventSource->nextEvent();
         if (!pre) {
             // End of file
             it = *m_endIter;
             return StatusCode::FAILURE;
         }
         ++m_NumEvents;
  
         // Check if we are skipping events
         if (m_NumEvents > m_SkipEvents) {
             break;
         } else {
             ATH_MSG_DEBUG(" Skipping event " << m_NumEvents - 1);
         }
     }
  
     return StatusCode::SUCCESS;
 }

◆ next() [2/2]

StatusCode EventSelectorMuonCalibStream::next	(	IEvtSelector::Context &	ctxt,
		int	jump
	)		const

virtual

Definition at line 83 of file EventSelectorMuonCalibStream.cxx.

                                                                                        {
     ATH_MSG_DEBUG(" EventSelectorMuonCalibStream::next skipping events ==" << jump);
     if (jump > 0) {
         for (int i = 0; i < jump; ++i) {
             StatusCode status = next(ctxt);
             if (!status.isSuccess()) { return status; }
         }
         return StatusCode::SUCCESS;
     }
     return StatusCode::FAILURE;
 }

◆ previous() [1/2]

StatusCode EventSelectorMuonCalibStream::previous ( IEvtSelector::Context & it ) const

virtual

Definition at line 96 of file EventSelectorMuonCalibStream.cxx.

                                                                                {
     ATH_MSG_ERROR("EventSelectorMuonCalibStream::previous() not implemented");
     return (StatusCode::FAILURE);
 }

◆ previous() [2/2]

StatusCode EventSelectorMuonCalibStream::previous	(	IEvtSelector::Context &	it,
		int	jump
	)		const

virtual

Definition at line 102 of file EventSelectorMuonCalibStream.cxx.

102 { return (previous(it)); }

◆ releaseContext()

StatusCode EventSelectorMuonCalibStream::releaseContext ( IEvtSelector::Context *& it ) const

virtual

Definition at line 139 of file EventSelectorMuonCalibStream.cxx.

139 { return (StatusCode::SUCCESS); }

◆ resetCriteria()

StatusCode EventSelectorMuonCalibStream::resetCriteria	(	const std::string &	criteria,
		IEvtSelector::Context &	context
	)		const

virtual

Definition at line 114 of file EventSelectorMuonCalibStream.cxx.

                                                                                                          {
     return (StatusCode::SUCCESS);
 }

◆ rewind()

StatusCode EventSelectorMuonCalibStream::rewind ( IEvtSelector::Context & it ) const

virtual

Definition at line 119 of file EventSelectorMuonCalibStream.cxx.

                                                                              {
     ATH_MSG_ERROR("EventSelectorMuonCalibStream::rewind() not implemented");
     return (StatusCode::FAILURE);
 }