EventSelectorMuonCalibStream Class Reference

#include <EventSelectorMuonCalibStream.h>

Inheritance diagram for EventSelectorMuonCalibStream:

Collaboration diagram for EventSelectorMuonCalibStream:

Public Member Functions
	EventSelectorMuonCalibStream (const 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
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
MsgStream &	msg () const
MsgStream &	msg (const MSG::Level lvl) const
bool	msgLvl (const MSG::Level lvl) const

Private Attributes
string	m_eventSourceName
EventContextMuonCalibStream *	m_beginIter
EventContextMuonCalibStream *	m_endIter
MuonCalibStreamInputSvc *	m_eventSource
IMuonCalibStreamDataProviderSvc *	m_dataProvider
int	m_SkipEvents
long m_NumEvents	ATLAS_THREAD_SAFE = 0

Detailed Description

Definition at line 26 of file EventSelectorMuonCalibStream.h.

Constructor & Destructor Documentation

EventSelectorMuonCalibStream()

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

Definition at line 22 of file EventSelectorMuonCalibStream.cxx.

                                                                                                  :
    AthService(name, svcloc),
    m_beginIter(nullptr),
    m_endIter(nullptr),
    m_eventSource(nullptr),
    m_dataProvider(nullptr),
    m_SkipEvents(0),
    m_NumEvents(0) {
    ATH_MSG_DEBUG("EventSelectorMuonCalibStream constructor");
    m_eventSourceName = "MuonCalibStreamFileInputSvc";
    m_SkipEvents = 0;
    declareProperty("MuonCalibStreamInputSvc", m_eventSourceName);
    declareProperty("SkipEvents", m_SkipEvents);
}

~EventSelectorMuonCalibStream()

EventSelectorMuonCalibStream::~EventSelectorMuonCalibStream

(

)

Definition at line 38 of file EventSelectorMuonCalibStream.cxx.

                                                            {
    // if(m_eventSource) m_eventSource->release();
    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 141 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 69 of file EventSelectorMuonCalibStream.cxx.

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

initialize()

StatusCode EventSelectorMuonCalibStream::initialize ( )

virtual

Definition at line 45 of file EventSelectorMuonCalibStream.cxx.

                                                    {
    ATH_MSG_INFO("EventSelectorMuonCalibStream::initialize");
    // Check MuonCalibStreamCnvSvc
    IService *svc;
    ATH_CHECK(serviceLocator()->getService(m_eventSourceName, svc));
 
    m_eventSource = dynamic_cast<MuonCalibStreamInputSvc *>(svc);
    if (m_eventSource == 0) {
        ATH_MSG_ERROR("Cannot cast to MuonCalibStreamInputSvc");
        return StatusCode::FAILURE;
    }
    m_eventSource->addRef();
 
    ATH_CHECK(service("MuonCalibStreamDataProviderSvc", m_dataProvider));
 
    // 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 121 of file EventSelectorMuonCalibStream.cxx.

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

msg() [1/2]

MsgStream& AthCommonMsg< Service >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                {
    return this->msgStream();
  }

msg() [2/2]

MsgStream& AthCommonMsg< Service >::msg ( const MSG::Level  lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                  {
    return this->msgStream(lvl);
  }

msgLvl()

bool AthCommonMsg< Service >::msgLvl ( const MSG::Level  lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                               {
    return this->msgLevel(lvl);
  }

next() [1/2]

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

virtual

Definition at line 75 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 99 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 112 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 118 of file EventSelectorMuonCalibStream.cxx.

{ return (previous(it)); }

queryInterface()

StatusCode EventSelectorMuonCalibStream::queryInterface ( const InterfaceID &  riid, void **  ppvInterface  )

virtual

Definition at line 158 of file EventSelectorMuonCalibStream.cxx.

                                                                                                    {
    if (riid == IEvtSelector::interfaceID()) {
        *ppvInterface = (IEvtSelector *)this;
    } else if (riid == IProperty::interfaceID()) {
        *ppvInterface = (IProperty *)this;
    } else {
        return AthService::queryInterface(riid, ppvInterface);
    }
 
    addRef();
    return StatusCode::SUCCESS;
}

releaseContext()

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

virtual

Definition at line 155 of file EventSelectorMuonCalibStream.cxx.

{ return (StatusCode::SUCCESS); }

resetCriteria()

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

virtual

Definition at line 130 of file EventSelectorMuonCalibStream.cxx.

                                                                                                         {
    return (StatusCode::SUCCESS);
}

rewind()

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

virtual

Definition at line 135 of file EventSelectorMuonCalibStream.cxx.

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

Member Data Documentation

ATLAS_THREAD_SAFE

long m_NumEvents EventSelectorMuonCalibStream::ATLAS_THREAD_SAFE = 0

mutableprivate

Definition at line 68 of file EventSelectorMuonCalibStream.h.

m_beginIter

EventContextMuonCalibStream* EventSelectorMuonCalibStream::m_beginIter

private

Definition at line 59 of file EventSelectorMuonCalibStream.h.

m_dataProvider

IMuonCalibStreamDataProviderSvc* EventSelectorMuonCalibStream::m_dataProvider

private

Definition at line 62 of file EventSelectorMuonCalibStream.h.

m_endIter

EventContextMuonCalibStream* EventSelectorMuonCalibStream::m_endIter

private

Definition at line 60 of file EventSelectorMuonCalibStream.h.

m_eventSource

MuonCalibStreamInputSvc* EventSelectorMuonCalibStream::m_eventSource

private

Definition at line 61 of file EventSelectorMuonCalibStream.h.

m_eventSourceName

string EventSelectorMuonCalibStream::m_eventSourceName

private

Definition at line 58 of file EventSelectorMuonCalibStream.h.

m_SkipEvents

int EventSelectorMuonCalibStream::m_SkipEvents

private

Definition at line 64 of file EventSelectorMuonCalibStream.h.

---

The documentation for this class was generated from the following files:

• EventSelectorMuonCalibStream.h
• EventSelectorMuonCalibStream.cxx