TrigEventSelectorByteStream Class Reference

online implementation of IEvtSelector for ByteStream More...

#include <TrigEventSelectorByteStream.h>

Inheritance diagram for TrigEventSelectorByteStream:

Collaboration diagram for TrigEventSelectorByteStream:

Classes
class	Context
	Event Selector context for TrigEventSelectorByteStream. More...

Public Member Functions
	TrigEventSelectorByteStream (const std::string &name, ISvcLocator *svcLoc)
	Standard constructor.
virtual	~TrigEventSelectorByteStream ()
	Standard destructor.
virtual StatusCode	initialize () override
virtual StatusCode	finalize () override
virtual StatusCode	createContext (IEvtSelector::Context *&c) const override
virtual StatusCode	next (IEvtSelector::Context &c) const override
virtual StatusCode	next (IEvtSelector::Context &c, int jump) const override
virtual StatusCode	previous (IEvtSelector::Context &c) const override
virtual StatusCode	previous (IEvtSelector::Context &c, int jump) const override
virtual StatusCode	last (IEvtSelector::Context &refContext) const override
virtual StatusCode	rewind (IEvtSelector::Context &c) const override
virtual StatusCode	createAddress (const IEvtSelector::Context &c, IOpaqueAddress *&iop) const override
virtual StatusCode	releaseContext (IEvtSelector::Context *&c) const override
virtual StatusCode	resetCriteria (const std::string &cr, IEvtSelector::Context &c) const override

Private Attributes
ServiceHandle< IByteStreamInputSvc >	m_eventSource
ServiceHandle< StoreGateSvc >	m_evtStore

Detailed Description

online implementation of IEvtSelector for ByteStream

Definition at line 20 of file TrigEventSelectorByteStream.h.

Constructor & Destructor Documentation

TrigEventSelectorByteStream()

TrigEventSelectorByteStream::TrigEventSelectorByteStream	(	const std::string &	name,
		ISvcLocator *	svcLoc )

Standard constructor.

Definition at line 22 of file TrigEventSelectorByteStream.cxx.

: base_class(name, svcLoc),
  m_eventSource("ByteStreamInputSvc", name),
  m_evtStore("StoreGateSvc", name) {
  declareProperty("ByteStreamInputSvc", m_eventSource);
}

~TrigEventSelectorByteStream()

TrigEventSelectorByteStream::~TrigEventSelectorByteStream ( )

virtual

Standard destructor.

Definition at line 32 of file TrigEventSelectorByteStream.cxx.

{}

Member Function Documentation

createAddress()

StatusCode TrigEventSelectorByteStream::createAddress ( const IEvtSelector::Context & c, IOpaqueAddress *& iop ) const

overridevirtual

Definition at line 136 of file TrigEventSelectorByteStream.cxx.

{
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
 
  // Get the EventContext via event store because the interface doesn't allow passing it explicitly as an argument
  // and we don't want to use ThreadLocalContext. Don't use ReadHandle here because it calls ThreadLocalContext if
  // not given a context (which we want to retrieve).
  const EventContext* eventContext = nullptr;
  ATH_CHECK(m_evtStore->retrieve(eventContext));
 
  // Create and record ByteStreamAddress for xAOD::EventInfo
  CxxUtils::RefCountedPtr<ByteStreamAddress> addr
    (new ByteStreamAddress(ClassID_traits<xAOD::EventInfo>::ID(), "EventInfo", ""));
  addr->setEventContext(*eventContext);
  iop = addr.get();
  ATH_CHECK(m_evtStore->recordAddress("EventInfo",std::move(addr)));
  ATH_MSG_DEBUG("Recorded new ByteStreamAddress for xAOD::EventInfo with event context " << *eventContext);
 
  // Create and record ByteStreamAddress for xAOD::EventAuxInfo
  CxxUtils::RefCountedPtr<ByteStreamAddress> auxaddr
    (new ByteStreamAddress(ClassID_traits<xAOD::EventAuxInfo>::ID(), "EventInfoAux.", ""));
  auxaddr->setEventContext(*eventContext);
  ATH_CHECK(m_evtStore->recordAddress("EventInfoAux.", std::move(auxaddr)));
  ATH_MSG_DEBUG("Recorded new ByteStreamAddress for xAOD::EventAuxInfo with event context " << *eventContext);
 
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return StatusCode::SUCCESS;
}

createContext()

StatusCode TrigEventSelectorByteStream::createContext ( IEvtSelector::Context *& c ) const

overridevirtual

Definition at line 118 of file TrigEventSelectorByteStream.cxx.

{
  c = new TrigEventSelectorByteStream::Context(this);
  return StatusCode::SUCCESS;
}

finalize()

StatusCode TrigEventSelectorByteStream::finalize ( )

overridevirtual

Definition at line 51 of file TrigEventSelectorByteStream.cxx.

{
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
  if (m_eventSource.release().isFailure()) {
    ATH_MSG_WARNING("Cannot release the event source service");
  }
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return StatusCode::SUCCESS;
}

initialize()

StatusCode TrigEventSelectorByteStream::initialize ( )

overridevirtual

Definition at line 37 of file TrigEventSelectorByteStream.cxx.

{
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
 
  ATH_CHECK(m_eventSource.retrieve());
  ATH_CHECK(m_evtStore.retrieve());
 
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return StatusCode::SUCCESS;
}

last()

StatusCode TrigEventSelectorByteStream::last ( IEvtSelector::Context & refContext ) const

overridevirtual

Definition at line 187 of file TrigEventSelectorByteStream.cxx.

{
  TRIGEVENTSELECTORBYTESTREAM_UNIMPL
}

next() [1/2]

StatusCode TrigEventSelectorByteStream::next ( IEvtSelector::Context & c ) const

overridevirtual

Definition at line 65 of file TrigEventSelectorByteStream.cxx.

{
  ATH_MSG_VERBOSE("start of " << __FUNCTION__);
 
  // RawEvent is a typedef for FullEventFragment
  const RawEvent* ptrRawEvent = nullptr;
 
  // Try to get the next event from the event source
  try {
    ptrRawEvent = m_eventSource->nextEvent();
  }
  catch (const hltonl::Exception::NoMoreEvents& e) {
    ATH_MSG_INFO(e.what());
    throw; // rethrow NoMoreEvents
  }
  catch (const hltonl::Exception::NoEventsTemporarily& e) {
    ATH_MSG_DEBUG(e.what());
    throw; // rethrow NoEventsTemporarily
  }
  catch (const hltonl::Exception::EventSourceCorrupted& e) {
    ATH_MSG_ERROR(e.what());
    throw; // rethrow EventSourceCorrupted
  }
  catch (const hltonl::Exception::MissingCTPFragment& e) {
    ATH_MSG_INFO(e.what());
    throw; // rethrow MissingCTPFragment
  }
  catch (const hltonl::Exception::BadCTPFragment& e) {
    ATH_MSG_INFO(e.what());
    throw; // rethrow BadCTPFragment
  }
  catch (const std::exception& e) {
    ATH_MSG_ERROR("Failed to get next event from the event source, std::exception caught: " << e.what());
    return StatusCode::FAILURE;
  }
  catch (...) {
    ATH_MSG_ERROR("Failed to get next event from the event source, unknown exception caught");
    return StatusCode::FAILURE;
  }
 
  // Check if something was returned
  if (ptrRawEvent == nullptr) {
    ATH_MSG_ERROR("Failed to get next event from the event source, nullptr returned");
    return StatusCode::FAILURE;
  }
 
  ATH_MSG_VERBOSE("end of " << __FUNCTION__);
  return StatusCode::SUCCESS;
}

next() [2/2]

StatusCode TrigEventSelectorByteStream::next ( IEvtSelector::Context & c, int jump ) const

overridevirtual

Definition at line 172 of file TrigEventSelectorByteStream.cxx.

{
  TRIGEVENTSELECTORBYTESTREAM_UNIMPL
}

previous() [1/2]

StatusCode TrigEventSelectorByteStream::previous ( IEvtSelector::Context & c ) const

overridevirtual

Definition at line 177 of file TrigEventSelectorByteStream.cxx.

{
  TRIGEVENTSELECTORBYTESTREAM_UNIMPL
}

previous() [2/2]

StatusCode TrigEventSelectorByteStream::previous ( IEvtSelector::Context & c, int jump ) const

overridevirtual

Definition at line 182 of file TrigEventSelectorByteStream.cxx.

{
  TRIGEVENTSELECTORBYTESTREAM_UNIMPL
}

releaseContext()

StatusCode TrigEventSelectorByteStream::releaseContext ( IEvtSelector::Context *& c ) const

overridevirtual

Definition at line 127 of file TrigEventSelectorByteStream.cxx.

{
  // this does nothing
  return StatusCode::SUCCESS;
}

resetCriteria()

StatusCode TrigEventSelectorByteStream::resetCriteria ( const std::string & cr, IEvtSelector::Context & c ) const

overridevirtual

Definition at line 197 of file TrigEventSelectorByteStream.cxx.

{
  TRIGEVENTSELECTORBYTESTREAM_UNIMPL
}

rewind()

StatusCode TrigEventSelectorByteStream::rewind ( IEvtSelector::Context & c ) const

overridevirtual

Definition at line 192 of file TrigEventSelectorByteStream.cxx.

{
  TRIGEVENTSELECTORBYTESTREAM_UNIMPL
}

Member Data Documentation

m_eventSource

ServiceHandle<IByteStreamInputSvc> TrigEventSelectorByteStream::m_eventSource

private

Definition at line 64 of file TrigEventSelectorByteStream.h.

m_evtStore

ServiceHandle<StoreGateSvc> TrigEventSelectorByteStream::m_evtStore

private

Definition at line 66 of file TrigEventSelectorByteStream.h.

---

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

• TrigEventSelectorByteStream.h
• TrigEventSelectorByteStream.cxx