a stream of events read from different selectors. More...

#include <MixingEventSelector.h>

Inheritance diagram for MixingEventSelector:

Collaboration diagram for MixingEventSelector:

Classes
class	Context
	dummy for now More...

class	Trigger
	a selector with an associated frequency More...

class	TriggerList
	the list of available selectors with their frequency range More...

Public Types
typedef std::list< SG::TransientAddress * >	tadList

typedef tadList::iterator	tadListIterator

Public Member Functions
	DeclareInterfaceID (IAddressProvider, 1, 0)

IEvtSelector implementation
virtual StatusCode	next (IEvtSelector::Context &refCtxt) const override

virtual StatusCode	createAddress (const IEvtSelector::Context &refCtxt, IOpaqueAddress *&) const override

virtual StatusCode	createContext (IEvtSelector::Context *&refpCtxt) const override

virtual StatusCode	last (IEvtSelector::Context &) const override

virtual StatusCode	next (IEvtSelector::Context &, int) const override

virtual StatusCode	previous (IEvtSelector::Context &) const override

virtual StatusCode	previous (IEvtSelector::Context &, int) const override

virtual StatusCode	rewind (IEvtSelector::Context &refCtxt) const override

virtual StatusCode	releaseContext (IEvtSelector::Context *&refCtxt) const override

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

IAddressProvider interface (forwarded to current Trigger)
virtual StatusCode	preLoadAddresses (StoreID::type storeID, IAddressProvider::tadList &tads) override
	get all addresses from Provider : Called before Begin Event More...

virtual StatusCode	loadAddresses (StoreID::type storeID, IAddressProvider::tadList &tads) override
	get all new addresses from Provider for this Event. More...

virtual StatusCode	updateAddress (StoreID::type storeID, SG::TransientAddress *tad, const EventContext &ctx) override
	update a transient Address The ctx argument will give the current event information. More...

IConverter implementation.
virtual const CLID &	objType () const override

virtual long	repSvcType () const override

virtual StatusCode	createObj (IOpaqueAddress pAddress, DataObject &refpObject) override
	Create the transient representation of an object. More...

virtual StatusCode	setDataProvider (IDataProviderSvc *pService) override

virtual SmartIF< IDataProviderSvc > &	dataProvider () const override

virtual StatusCode	setConversionSvc (IConversionSvc *pService) override

virtual SmartIF< IConversionSvc > &	conversionSvc () const override

virtual StatusCode	setAddressCreator (IAddressCreator *creator) override

virtual SmartIF< IAddressCreator > &	addressCreator () const override

virtual StatusCode	fillObjRefs (IOpaqueAddress pAddress, DataObject pObject) override

virtual StatusCode	updateObj (IOpaqueAddress pAddress, DataObject refpObject) override

virtual StatusCode	updateObjRefs (IOpaqueAddress pAddress, DataObject pObject) override

virtual StatusCode	createRep (DataObject pObject, IOpaqueAddress &refpAddress) override

virtual StatusCode	fillRepRefs (IOpaqueAddress pAddress, DataObject pObject) override

virtual StatusCode	updateRep (IOpaqueAddress pAddress, DataObject pObject) override

virtual StatusCode	updateRepRefs (IOpaqueAddress pAddress, DataObject pObject) override

Service implementation
virtual StatusCode	initialize () override

virtual StatusCode	finalize () override

void	setUpTriggerList (Gaudi::Details::PropertyBase &trigList)
	TriggerList property call-back. More...

void	decodeTrigger (std::string triggDescr)
	functor that creates a Trigger object and adds it to m_trigList More...

Private Attributes
Properties
StringProperty	m_statusFileName
	optional stream output snapshot More...

StringArrayProperty	m_triggerListProp
	the recipe More...

IntegerProperty	m_outputRunNumber

UnsignedLongArrayProperty	m_eventNumbers
	use these as event numbers More...

StringProperty	m_mergedEventInfoKey
	SG key of MergedEventInfo. More...

ToolHandleArray< IAthenaSelectorTool >	m_helperTools

TriggerList	m_trigList
	the ingredients More...

structors
	MixingEventSelector (const std::string &name, ISvcLocator *svc)

virtual	~MixingEventSelector ()

bool	validTrigger () const

trigger list management
TriggerList::iterator	m_pCurrentTrigger
	the current trigger More...

TriggerList::iterator	setCurrentTrigger () const
	choose current trigger at random. Actually modifies state (use mutables) More...

TriggerList::iterator	currentTrigger () const
	"intelligent" accessor to the above More...

event number management
typedef ServiceHandle< StoreGateSvc >	StoreGateSvc_t

unsigned long	m_eventPos
	the internal event number More...

StoreGateSvc_t	m_pEventStore

ServiceHandle< IAtRndmGenSvc >	m_atRndmSvc

StringProperty	m_randomStreamName

CLHEP::RandFlat *	m_chooseRangeRand

unsigned long	getEventNo () const
	setup and lookup m_evtsNotUsedSoFar. Returns next event no More...

Detailed Description

a stream of events read from different selectors.

Each source contains a particular event type ("trigger"). We want to mix the triggers according to a recipe specified via the "TriggerList" property

Mixer.TriggerList += {"50% BSelector", "20 % MinBiasSelec"};

The algorithms downstream of the"mixer" will see events coming at random according to this admixture.
The "OutputRunNumber" property allows to assign a new run number to the events.

Mixer.OutputRun=1234;

The event number can be randomized to mimic the behaviour of the processing farms. So

Mixer.EventRandomRange=100;

will shuffle the first 100 events, then move to the second hundred, etc

Definition at line 68 of file MixingEventSelector.h.

Member Typedef Documentation

◆ StoreGateSvc_t

typedef ServiceHandle<StoreGateSvc> MixingEventSelector::StoreGateSvc_t

private

Definition at line 257 of file MixingEventSelector.h.

◆ tadList

typedef std::list<SG::TransientAddress*> IAddressProvider::tadList

inherited

Definition at line 32 of file IAddressProvider.h.

◆ tadListIterator

typedef tadList::iterator IAddressProvider::tadListIterator

inherited

Definition at line 33 of file IAddressProvider.h.

Constructor & Destructor Documentation

◆ MixingEventSelector()

MixingEventSelector::MixingEventSelector	(	const std::string &	name,
		ISvcLocator *	svc
	)

Definition at line 47 of file MixingEventSelector.cxx.

                                                                              :
   extends<AthService, IEvtSelector, IConverter>(name,svc),
   m_helperTools(this),
   m_trigList(), m_pCurrentTrigger(m_trigList.end()),
   m_eventPos(0), 
   m_pEventStore( "StoreGateSvc", name ),
   m_atRndmSvc("AtRndmGenSvc", name),
   m_randomStreamName("MixingEventSelectorStream"),
   m_chooseRangeRand(nullptr)
 {
   declareProperty("TriggerList", m_triggerListProp,
           "list of triggers (streams) to be used. Format is SelectorType/SelectorName:firstEventToUse:lastEventToUse. One assumes events are consecutively numbered.");
   m_triggerListProp.declareUpdateHandler(&MixingEventSelector::setUpTriggerList, this);
   declareProperty("OutputRunNumber", m_outputRunNumber=123456789);
   declareProperty("EventNumbers", m_eventNumbers, 
           "list of event numbers to be used for output stream. If list empty or not long enough, event numbers are assigned consucutively after last one in list");
   declareProperty("StreamStatusFileName", m_statusFileName=string(),
           "Name of the file recording the last event used and how many were available for each stream. Default is to produce no file." ); //no out
   declareProperty("MergedEventInfoKey", 
           m_mergedEventInfoKey=string("MergedEventInfo"),
           "StoreGate key for output (merged) event info object. Default is MergedEventInfo ");
   declareProperty("RndmGenSvc", m_atRndmSvc, "IAtRndmGenSvc controlling the order with which events are takes from streams");
   declareProperty("RndmStreamName", m_randomStreamName, "IAtRndmGenSvc stream used as engine for our random distributions");   
   declareProperty("HelperTools", m_helperTools, "a collection of selector tools");
  
 }

◆ ~MixingEventSelector()

MixingEventSelector::~MixingEventSelector ( )

virtual

Definition at line 74 of file MixingEventSelector.cxx.

74 {

75 }

Member Function Documentation

◆ addressCreator()

SmartIF< IAddressCreator > & MixingEventSelector::addressCreator ( ) const

overridevirtual

Definition at line 590 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ conversionSvc()

SmartIF< IConversionSvc > & MixingEventSelector::conversionSvc ( ) const

overridevirtual

Definition at line 582 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ createAddress()

StatusCode MixingEventSelector::createAddress	(	const IEvtSelector::Context &	refCtxt,
		IOpaqueAddress *&	pAddr
	)		const

overridevirtual

Definition at line 258 of file MixingEventSelector.cxx.

                                                  { 
   pAddr=nullptr;
   if (!validTrigger()) return StatusCode::FAILURE;
  
   FORWARD___DEBUG( createAddress )
   return (currentTrigger()->createAddress(pAddr).isSuccess() &&
           pAddr != nullptr) ? StatusCode::SUCCESS : StatusCode::FAILURE;
 }

◆ createContext()

StatusCode MixingEventSelector::createContext ( IEvtSelector::Context *& refpCtxt ) const

overridevirtual

Definition at line 210 of file MixingEventSelector.cxx.

                                                                                {
   pctxt=nullptr;
   if (!validTrigger()) return StatusCode::FAILURE;
   TriggerList::iterator iTr(m_trigList.begin());
   StatusCode sc(StatusCode::FAILURE);
   while (iTr != m_trigList.end() && (sc=(iTr++)->createContext(pctxt)).isSuccess()) ;
   return sc;
 }

◆ createObj()

StatusCode MixingEventSelector::createObj	(	IOpaqueAddress *	pAddress,
		DataObject *&	refpObject
	)

overridevirtual

Create the transient representation of an object.

The transient representation is created by loading the persistent object using the source information contained in the address.

Returns: Status code indicating success or failure

Parameters

pAddress	Opaque address information to retrieve the requested object from the store in order to produce the transient object.
refpObject	Reference to location of pointer of the created object.

Definition at line 543 of file MixingEventSelector.cxx.

 {
   const EventInfo* pEInfo(nullptr);
   if (!(m_pEventStore->retrieve(pEInfo)).isSuccess()) {
     ATH_MSG_ERROR 
       ("addMergedEventInfo: event store does not contain "\
        "an EventInfo object!");
     return StatusCode::RECOVERABLE;
   }
  
   // copy the original event to a new MergedEventInfo
   auto mei = std::make_unique<MergedEventInfo> (*pEInfo,
                                                 m_outputRunNumber,
                                                 getEventNo());
   refpObject = SG::asStorable (std::move (mei));
  
  
   //finally slam a new EventID in place of the old! HACK!!!  FIXME!!
   (const_cast<EventInfo*>(pEInfo))->setEventID(
                      new EventID(m_outputRunNumber, getEventNo()));
  
   return StatusCode::SUCCESS;
 }

◆ createRep()

StatusCode MixingEventSelector::createRep	(	DataObject *	pObject,
		IOpaqueAddress *&	refpAddress
	)

overridevirtual

Definition at line 606 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ currentTrigger()

MixingEventSelector::TriggerList::iterator MixingEventSelector::currentTrigger ( ) const

private

"intelligent" accessor to the above

Definition at line 336 of file MixingEventSelector.cxx.

                                           { 
   return ( validTrigger() ? m_pCurrentTrigger : setCurrentTrigger() ); 
 }

◆ dataProvider()

SmartIF< IDataProviderSvc > & MixingEventSelector::dataProvider ( ) const

overridevirtual

Definition at line 574 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ DeclareInterfaceID()

IAddressProvider::DeclareInterfaceID	(	IAddressProvider	,
		1	,
		0
	)

inherited

◆ decodeTrigger()

void MixingEventSelector::decodeTrigger ( std::string triggDescr )

functor that creates a Trigger object and adds it to m_trigList

Definition at line 138 of file MixingEventSelector.cxx.

                                                     {
   //all this would be much more readable without error reporting...
   typedef  tokenizer<char_separator<char> > Tokenizer;
   Tokenizer tokens(triggDescr, char_separator<char>(" :"));
   //we need exactly three tokens: selector name, first and last event 2 B read
   if ( (distance(tokens.begin(), tokens.end()) == 3) ||
        (distance(tokens.begin(), tokens.end()) == 3) ){
     Tokenizer::iterator iToken(tokens.begin());
     try {
       ListItem selTN(*iToken++);
       const bool CREATEIF(true);
       //get selector
       IEvtSelector* pSelector(nullptr);
       if ((serviceLocator()->service(selTN.type(), selTN.name(), pSelector, CREATEIF)).isSuccess()) {
     //must be an address provider
     if (nullptr != dynamic_cast<IEvtSelector*>(pSelector) ) {
       //FIXME     if (!pSelector.done()) {
         //try to add to trig list
         unsigned int firstEvt(boost::lexical_cast<unsigned int>(*iToken++));
         unsigned int lastEvt(boost::lexical_cast<unsigned int>(*iToken));
         if (m_trigList.add(Trigger(pSelector, firstEvt, lastEvt))) {
           if (msgLvl(MSG::DEBUG)) {
         INamedInterface *pNamed(dynamic_cast<INamedInterface*>(pSelector));
         if (nullptr != pNamed) {
           msg() << "decodeTrigger: added selector " << pNamed->name() 
             << " first event to be read " << firstEvt
             << " last event to be read " << lastEvt << endmsg;
         }
           }
         } else {
           ATH_MSG_ERROR 
         ("decodeTrigger: Selector [" 
          << selTN.type() << '/' << selTN.name() 
          << "] not added");
         } //can add to range
 //    } else {
 //      log << MSG::ERROR << "decodeTrigger: Selector [" 
 //      << selTN.type() << '/' << selTN.name() 
 //      << "] is empty, not added" << endmsg;
 //    } //selector empty
     } else {
       ATH_MSG_ERROR
         ("decodeTrigger: Selector [" 
          << selTN.type() << '/' << selTN.name() 
          << "] not an IEvtSelector, not added");
     } //is address provider
       } else {
         ATH_MSG_ERROR 
       ("decodeTrigger: Selector [" 
        << selTN.type() << '/' << selTN.name() 
        << "] can not be found or created");
       } //selector available
     } catch (const boost::bad_lexical_cast& e) {
       ATH_MSG_ERROR
     ("decodeTrigger: Can't cast ["<< *iToken 
      << "] to double(frequency). SKIPPING");
     } //can cast to frequency
   } else {
     ATH_MSG_ERROR
       ("decodeTrigger: Badly formatted descriptor [" 
        << triggDescr << "]. SKIPPING");
   } //can parse property string
 }

◆ fillObjRefs()

StatusCode MixingEventSelector::fillObjRefs	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject
	)

overridevirtual

Definition at line 594 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ fillRepRefs()

StatusCode MixingEventSelector::fillRepRefs	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject
	)

overridevirtual

Definition at line 610 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ finalize()

StatusCode MixingEventSelector::finalize ( )

overridevirtual

Definition at line 103 of file MixingEventSelector.cxx.

                               {
   ATH_MSG_DEBUG ("Finalizing " << name());
  
   StatusCode sc(StatusCode::SUCCESS);
   std::vector<ToolHandle<IAthenaSelectorTool> >::iterator 
     i(m_helperTools.begin()), iE(m_helperTools.end());
   while (i != iE) ((*i++)->preFinalize()).ignore();
  
   const std::string& fname(m_statusFileName.value());
   ofstream outfile(fname.c_str());
   if ( outfile ) {
     TriggerList::const_iterator i(m_trigList.begin());
     TriggerList::const_iterator iEnd(m_trigList.end());
     while (i != iEnd) outfile << (*i++).toString();
   }  else if (!fname.empty()) {
     ATH_MSG_WARNING("unable to open trigger list status file " << fname);
   }
  
   m_helperTools.release().ignore();
  
   return sc;
  
 }

◆ getEventNo()

unsigned long MixingEventSelector::getEventNo ( ) const

private

setup and lookup m_evtsNotUsedSoFar. Returns next event no

Definition at line 305 of file MixingEventSelector.cxx.

                                                     {
   return ( (m_eventNumbers.value().size() > m_eventPos) ?
        m_eventNumbers.value()[m_eventPos] :
        m_eventPos );      
 }

◆ initialize()

StatusCode MixingEventSelector::initialize ( )

overridevirtual

Definition at line 78 of file MixingEventSelector.cxx.

                                 {
   ATH_MSG_INFO ("Initializing " << name());
  
 // defer this (it triggers a init loop via PPS 
 //   if (!m_pEventStore.retrieve().isSuccess()) 
 //     return StatusCode::FAILURE;
  
   //setup random stream
   CLHEP::HepRandomEngine* collEng(m_atRndmSvc->GetEngine(m_randomStreamName.value()));
   if(nullptr == collEng ) {
     ATH_MSG_ERROR ("can not get random stream " << m_randomStreamName.value());
     return StatusCode::FAILURE;
   }
   //flat distribution in [0,1] range
   m_chooseRangeRand = new CLHEP::RandFlat(*(collEng), 0.0, 1.0);
  
   StatusCode sc= m_helperTools.retrieve();
   std::vector<ToolHandle<IAthenaSelectorTool> >::iterator 
     i(m_helperTools.begin()), iE(m_helperTools.end());
   while (sc.isSuccess() && (i != iE)) sc = (*i++)->postInitialize();
  
   return sc;
 }

◆ last()

StatusCode MixingEventSelector::last ( IEvtSelector::Context & ) const

overridevirtual

Definition at line 497 of file MixingEventSelector.cxx.

                                                                {
   return StatusCode::FAILURE;
 }

◆ loadAddresses()

StatusCode MixingEventSelector::loadAddresses	(	StoreID::type	,
		IAddressProvider::tadList &
	)

overridevirtual

get all new addresses from Provider for this Event.

Reimplemented from IAddressProvider.

Definition at line 275 of file MixingEventSelector.cxx.

 {
   if (storeID != StoreID::EVENT_STORE && storeID != StoreID::PILEUP_STORE)
     return StatusCode::SUCCESS;
  
   CLID mclid = ClassID_traits<MergedEventInfo>::ID();
   if (!m_pEventStore->contains (mclid, m_mergedEventInfoKey)) {
     // We create the DataProxy here rather than relying on ProxyProvideSvc
     // to do it because we want to set a non-default dataloader on the proxy.
     SG::TransientAddress tad (mclid,
                               m_mergedEventInfoKey,
                               new GenericAddress (0, mclid),
                               false);
     auto dp = std::make_unique<SG::DataProxy> (std::move(tad),
                                                this,
                                                true);
     ATH_CHECK( m_pEventStore->addToStore (mclid, dp.release()) );
   }
   return StatusCode::SUCCESS;
 }

◆ next() [1/2]

StatusCode MixingEventSelector::next	(	IEvtSelector::Context &	,
		int
	)		const

overridevirtual

Definition at line 500 of file MixingEventSelector.cxx.

                                                                     {
   return StatusCode::FAILURE;
 }

◆ next() [2/2]

StatusCode MixingEventSelector::next ( IEvtSelector::Context & refCtxt ) const

overridevirtual

Definition at line 220 of file MixingEventSelector.cxx.

                                                       {
   StatusCode sc(StatusCode::FAILURE);
   do {
 #ifdef DEBUG_OUTPUT_STATUS
     TriggerList::const_iterator i(m_trigList.begin()); 
     TriggerList::const_iterator iEnd(m_trigList.end());
     while (i != iEnd) outfile2 << (*i++).toString();  //output status
 #endif
     setCurrentTrigger();
     sc = currentTrigger()->next();
     if (sc.isFailure()){
       m_trigList.remove(m_pCurrentTrigger);
       continue;  // we have to add  "continue;" after "m_trigList.remove(m_pCurrentTrigger);
     }
   } while ((sc.isFailure() || currentTrigger()->done()) &&  !m_trigList.empty() );
   // use !m_trigList.empty() to replace validTrigger(), which is not working well
  
   std::vector<ToolHandle<IAthenaSelectorTool> >::const_iterator 
     i(m_helperTools.begin()), iE(m_helperTools.end());
   while (i != iE) ((*i++)->preNext()).ignore();
  
   ++m_eventPos;
   FORWARD___DEBUG( next );  
  
   i=m_helperTools.begin(); iE=m_helperTools.end();
   while (sc.isSuccess() && (i != iE)) {
     sc =(*i)->postNext();
     if (sc.isRecoverable()) 
       ATH_MSG_INFO("Request skipping event from: " << (*i)->name());
     else if (sc.isFailure()) 
       ATH_MSG_WARNING((*i)->name() << ":postNext failed");
     ++i;
   }
   return sc;
 }

◆ objType()

const CLID & MixingEventSelector::objType ( ) const

overridevirtual

Definition at line 522 of file MixingEventSelector.cxx.

 {
   return ClassID_traits<EventInfo>::ID();
 }

◆ preLoadAddresses()

StatusCode MixingEventSelector::preLoadAddresses	(	StoreID::type	,
		IAddressProvider::tadList &
	)

overridevirtual

get all addresses from Provider : Called before Begin Event

Reimplemented from IAddressProvider.

Definition at line 269 of file MixingEventSelector.cxx.

                                                                    {
     return StatusCode::SUCCESS;
 }

◆ previous() [1/2]

StatusCode MixingEventSelector::previous ( IEvtSelector::Context & ) const

overridevirtual

Definition at line 503 of file MixingEventSelector.cxx.

                                                                    {
   return StatusCode::FAILURE;
 }

◆ previous() [2/2]

StatusCode MixingEventSelector::previous	(	IEvtSelector::Context &	,
		int
	)		const

overridevirtual

Definition at line 506 of file MixingEventSelector.cxx.

                                                                        {
   return StatusCode::FAILURE;
 }

◆ releaseContext()

StatusCode MixingEventSelector::releaseContext ( IEvtSelector::Context *& refCtxt ) const

overridevirtual

Definition at line 512 of file MixingEventSelector.cxx.

                                                                           {
   return  StatusCode::FAILURE;
 }

◆ repSvcType()

long MixingEventSelector::repSvcType ( ) const

overridevirtual

Definition at line 526 of file MixingEventSelector.cxx.

 {
   return 0;
 }

◆ resetCriteria()

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

overridevirtual

Definition at line 515 of file MixingEventSelector.cxx.

                                                      {
   return StatusCode::FAILURE;
 }

◆ rewind()

StatusCode MixingEventSelector::rewind ( IEvtSelector::Context & refCtxt ) const

overridevirtual

Definition at line 509 of file MixingEventSelector.cxx.

                                                                  {
   return StatusCode::FAILURE;
 }

◆ setAddressCreator()

StatusCode MixingEventSelector::setAddressCreator ( IAddressCreator * creator )

overridevirtual

Definition at line 586 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ setConversionSvc()

StatusCode MixingEventSelector::setConversionSvc ( IConversionSvc * pService )

overridevirtual

Definition at line 578 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ setCurrentTrigger()

MixingEventSelector::TriggerList::iterator MixingEventSelector::setCurrentTrigger ( ) const

private

choose current trigger at random. Actually modifies state (use mutables)

Definition at line 313 of file MixingEventSelector.cxx.

                                              { 
   //we look for the first trigger which is not done
   do {
     //if called before initialize, choose the last trigger in list
     unsigned int iTrig = (nullptr != m_chooseRangeRand) ?
       (unsigned int)(m_chooseRangeRand->fire() * double(m_trigList.todo())) :
       m_trigList.todo();
     m_pCurrentTrigger = m_trigList.elementInRange(iTrig);
   } while (validTrigger() && m_pCurrentTrigger->done() && 
        m_trigList.remove(m_pCurrentTrigger)); //remove a done trigger
  
   //printouts
   if (!validTrigger()) {
     ATH_MSG_INFO ("setCurrentTrigger: end of input");
   } else {
     ATH_MSG_DEBUG ("setCurrentTrigger: now using selector " 
            << currentTrigger()->name());
   }
  
   return m_pCurrentTrigger;
 }

◆ setDataProvider()

StatusCode MixingEventSelector::setDataProvider ( IDataProviderSvc * pService )

overridevirtual

Definition at line 570 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ setUpTriggerList()

void MixingEventSelector::setUpTriggerList ( Gaudi::Details::PropertyBase & trigList )

TriggerList property call-back.

Decode TriggerList, obtain selector ptrs and store them alongside fractions in m_trigList

Definition at line 129 of file MixingEventSelector.cxx.

                                                                {
   using std::placeholders::_1;
   m_trigList = TriggerList();
   for_each(m_triggerListProp.value().begin(), m_triggerListProp.value().end(),  
        bind(&MixingEventSelector::decodeTrigger, this, _1));
   setCurrentTrigger();
 }

◆ updateAddress()

StatusCode MixingEventSelector::updateAddress	(	StoreID::type	storeID,
		SG::TransientAddress *	pTAd,
		const EventContext &	ctx
	)

overridevirtual

update a transient Address The ctx argument will give the current event information.

If we're not dealing with an event store (conditions, etc), then the context will be empty (default-initialized).

Implements IAddressProvider.

Definition at line 298 of file MixingEventSelector.cxx.

                                                         {
   return StatusCode::FAILURE;
 }

◆ updateObj()

StatusCode MixingEventSelector::updateObj	(	IOpaqueAddress *	pAddress,
		DataObject *	refpObject
	)

overridevirtual

Definition at line 598 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ updateObjRefs()

StatusCode MixingEventSelector::updateObjRefs	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject
	)

overridevirtual

Definition at line 602 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ updateRep()

StatusCode MixingEventSelector::updateRep	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject
	)

overridevirtual

Definition at line 614 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ updateRepRefs()

StatusCode MixingEventSelector::updateRepRefs	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject
	)

overridevirtual

Definition at line 618 of file MixingEventSelector.cxx.

 {
   std::abort();
 }

◆ validTrigger()

bool MixingEventSelector::validTrigger ( ) const

inlineprivate

Definition at line 152 of file MixingEventSelector.h.

152 { return (m_trigList.end()!=m_pCurrentTrigger);}

Member Data Documentation

◆ m_atRndmSvc

ServiceHandle<IAtRndmGenSvc> MixingEventSelector::m_atRndmSvc

private

Definition at line 259 of file MixingEventSelector.h.

◆ m_chooseRangeRand

CLHEP::RandFlat* MixingEventSelector::m_chooseRangeRand

private

Definition at line 261 of file MixingEventSelector.h.

◆ m_eventNumbers

UnsignedLongArrayProperty MixingEventSelector::m_eventNumbers

private

use these as event numbers

Definition at line 158 of file MixingEventSelector.h.

◆ m_eventPos

unsigned long MixingEventSelector::m_eventPos

mutableprivate

the internal event number

Definition at line 255 of file MixingEventSelector.h.

◆ m_helperTools

ToolHandleArray<IAthenaSelectorTool> MixingEventSelector::m_helperTools

private

Definition at line 160 of file MixingEventSelector.h.

◆ m_mergedEventInfoKey

StringProperty MixingEventSelector::m_mergedEventInfoKey

private

SG key of MergedEventInfo.

Definition at line 159 of file MixingEventSelector.h.

◆ m_outputRunNumber

IntegerProperty MixingEventSelector::m_outputRunNumber

private

Definition at line 157 of file MixingEventSelector.h.

◆ m_pCurrentTrigger

TriggerList::iterator MixingEventSelector::m_pCurrentTrigger

mutableprivate

the current trigger

Definition at line 247 of file MixingEventSelector.h.

◆ m_pEventStore

StoreGateSvc_t MixingEventSelector::m_pEventStore

mutableprivate

Definition at line 258 of file MixingEventSelector.h.

◆ m_randomStreamName

StringProperty MixingEventSelector::m_randomStreamName

private

Definition at line 260 of file MixingEventSelector.h.

◆ m_statusFileName

StringProperty MixingEventSelector::m_statusFileName

private

optional stream output snapshot

Definition at line 155 of file MixingEventSelector.h.

◆ m_triggerListProp

StringArrayProperty MixingEventSelector::m_triggerListProp

private

the recipe

Definition at line 156 of file MixingEventSelector.h.

◆ m_trigList

TriggerList MixingEventSelector::m_trigList

mutableprivate

the ingredients

Definition at line 241 of file MixingEventSelector.h.

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

Classes

Public Types

Public Member Functions

Private Attributes

structors

trigger list management

event number management

Detailed Description

Member Typedef Documentation

◆ StoreGateSvc_t

◆ tadList

◆ tadListIterator

Constructor & Destructor Documentation

◆ MixingEventSelector()

◆ ~MixingEventSelector()

Member Function Documentation

◆ addressCreator()

◆ conversionSvc()

◆ createAddress()

◆ createContext()

◆ createObj()

◆ createRep()

◆ currentTrigger()

◆ dataProvider()

◆ DeclareInterfaceID()

◆ decodeTrigger()

◆ fillObjRefs()

◆ fillRepRefs()

◆ finalize()

◆ getEventNo()

◆ initialize()

◆ last()

◆ loadAddresses()

◆ next() [1/2]

◆ next() [2/2]

◆ objType()

◆ preLoadAddresses()

◆ previous() [1/2]

◆ previous() [2/2]

◆ releaseContext()

◆ repSvcType()

◆ resetCriteria()

◆ rewind()

◆ setAddressCreator()

◆ setConversionSvc()

◆ setCurrentTrigger()

◆ setDataProvider()

◆ setUpTriggerList()

◆ updateAddress()

◆ updateObj()

◆ updateObjRefs()

◆ updateRep()

◆ updateRepRefs()

◆ validTrigger()

Member Data Documentation

◆ m_atRndmSvc

◆ m_chooseRangeRand

◆ m_eventNumbers

◆ m_eventPos

◆ m_helperTools

◆ m_mergedEventInfoKey

◆ m_outputRunNumber

◆ m_pCurrentTrigger

◆ m_pEventStore

◆ m_randomStreamName

◆ m_statusFileName

◆ m_triggerListProp

◆ m_trigList