MixingEventSelector Class Reference

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 Member Functions
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
virtual StatusCode	loadAddresses (StoreID::type storeID, IAddressProvider::tadList &tads) override
virtual StatusCode	updateAddress (StoreID::type storeID, SG::TransientAddress *tad, const EventContext &ctx) override
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.
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.
void	decodeTrigger (std::string triggDescr)
	functor that creates a Trigger object and adds it to m_trigList

Private Attributes
Properties
Gaudi::Property< std::string >	m_statusFileName
Gaudi::Property< std::vector< std::string > >	m_triggerListProp
Gaudi::Property< int >	m_outputRunNumber {this, "OutputRunNumber", 123456789}
Gaudi::Property< std::vector< unsigned long > >	m_eventNumbers
Gaudi::Property< std::string >	m_mergedEventInfoKey
Gaudi::Property< std::string >	m_randomStreamName
ToolHandleArray< IAthenaSelectorTool >	m_helperTools
ServiceHandle< IAtRndmGenSvc >	m_atRndmSvc
TriggerList	m_trigList
	the ingredients

trigger list management
TriggerList::iterator	m_pCurrentTrigger
	the current trigger
TriggerList::iterator	setCurrentTrigger () const
	choose current trigger at random. Actually modifies state (use mutables)
TriggerList::iterator	currentTrigger () const
	"intelligent" accessor to the above

event number management
unsigned long	m_eventPos {0}
	the internal event number
ServiceHandle< StoreGateSvc >	m_pEventStore
std::unique_ptr< CLHEP::RandFlat >	m_chooseRangeRand
unsigned long	getEventNo () const
	setup and lookup m_evtsNotUsedSoFar. Returns next event no

structors
	MixingEventSelector (const std::string &name, ISvcLocator *svc)
virtual	~MixingEventSelector ()
bool	validTrigger () const

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 69 of file MixingEventSelector.h.

Constructor & Destructor Documentation

MixingEventSelector()

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

Definition at line 46 of file MixingEventSelector.cxx.

                                                                             :
  base_class(name,svc),
  m_pCurrentTrigger(m_trigList.end()),
  m_pEventStore( "StoreGateSvc", name )
{
}

~MixingEventSelector()

MixingEventSelector::~MixingEventSelector ( )

virtual

Definition at line 53 of file MixingEventSelector.cxx.

                                          { 
}

Member Function Documentation

addressCreator()

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

overridevirtual

Definition at line 552 of file MixingEventSelector.cxx.

{
  std::abort();
}

conversionSvc()

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

overridevirtual

Definition at line 544 of file MixingEventSelector.cxx.

{
  std::abort();
}

createAddress()

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

overridevirtual

Definition at line 221 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 173 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 505 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 568 of file MixingEventSelector.cxx.

{
  std::abort();
}

currentTrigger()

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

private

"intelligent" accessor to the above

Definition at line 299 of file MixingEventSelector.cxx.

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

dataProvider()

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

overridevirtual

Definition at line 536 of file MixingEventSelector.cxx.

{
  std::abort();
}

decodeTrigger()

void MixingEventSelector::decodeTrigger

(

std::string

triggDescr

)

functor that creates a Trigger object and adds it to m_trigList

Definition at line 113 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());
      Gaudi::Utils::TypeNameString selTN(*iToken++);
      //get selector
      SmartIF<IEvtSelector> pSelector(serviceLocator()->service(selTN));
      if (pSelector) {
        //FIXME   if (!pSelector.done()) {
        //try to add to trig list
        unsigned int firstEvt{};
        unsigned int lastEvt{};
        auto string1 = *iToken++;
        auto string2 = *iToken;
        auto [ptr1, ec1] = std::from_chars(string1.data(), string1.data() + string1.size(), firstEvt);
        auto [ptr2, ec2] = std::from_chars(string2.data(), string2.data() + string2.size(), lastEvt);
        if ( ec1 != std::errc() || ec2 != std::errc() ) {
          ATH_MSG_ERROR("decodeTrigger: Can't cast ["<< string1 << " " << string2  << "] to double(frequency). SKIPPING");
        } else {
        if (m_trigList.add(Trigger(pSelector, firstEvt, lastEvt))) {
          if (msgLvl(MSG::DEBUG)) {
            SmartIF<INamedInterface> pNamed(pSelector);
            if (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 {
        ATH_MSG_ERROR 
          ("decodeTrigger: Selector ["
           << selTN.type() << '/' << selTN.name()
           << "] can not be found or created");
      } //selector available
  } 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 556 of file MixingEventSelector.cxx.

{
  std::abort();
}

fillRepRefs()

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

overridevirtual

Definition at line 572 of file MixingEventSelector.cxx.

{
  std::abort();
}

finalize()

StatusCode MixingEventSelector::finalize ( )

overridevirtual

Definition at line 82 of file MixingEventSelector.cxx.

                              {
  ATH_MSG_DEBUG ("Finalizing " << name());
 
  for (ToolHandle<IAthenaSelectorTool>& tool : m_helperTools) {
    tool->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);
  }
 
  return StatusCode::SUCCESS;
}

getEventNo()

unsigned long MixingEventSelector::getEventNo ( ) const

private

setup and lookup m_evtsNotUsedSoFar. Returns next event no

Definition at line 268 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 57 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 = std::make_unique<CLHEP::RandFlat>(*(collEng), 0.0, 1.0);
 
  ATH_CHECK( m_helperTools.retrieve() );
  for (ToolHandle<IAthenaSelectorTool>& tool : m_helperTools) {
    ATH_CHECK( tool->postInitialize() );
  }
 
  return StatusCode::SUCCESS;
}

last()

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

overridevirtual

Definition at line 459 of file MixingEventSelector.cxx.

                                                               {
  return StatusCode::FAILURE;
}

loadAddresses()

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

overridevirtual

Definition at line 238 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 462 of file MixingEventSelector.cxx.

                                                                    {
  return StatusCode::FAILURE;
}

next() [2/2]

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

overridevirtual

Definition at line 183 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 484 of file MixingEventSelector.cxx.

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

preLoadAddresses()

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

overridevirtual

Definition at line 232 of file MixingEventSelector.cxx.

                                                                   {
    return StatusCode::SUCCESS;
}

previous() [1/2]

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

overridevirtual

Definition at line 465 of file MixingEventSelector.cxx.

                                                                   {
  return StatusCode::FAILURE;
}

previous() [2/2]

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

overridevirtual

Definition at line 468 of file MixingEventSelector.cxx.

                                                                       {
  return StatusCode::FAILURE;
}

releaseContext()

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

overridevirtual

Definition at line 474 of file MixingEventSelector.cxx.

                                                                          {
  return  StatusCode::FAILURE;
}

repSvcType()

long MixingEventSelector::repSvcType ( ) const

overridevirtual

Definition at line 488 of file MixingEventSelector.cxx.

{
  return 0;
}

resetCriteria()

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

overridevirtual

Definition at line 477 of file MixingEventSelector.cxx.

                                                     {
  return StatusCode::FAILURE;
}

rewind()

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

overridevirtual

Definition at line 471 of file MixingEventSelector.cxx.

                                                                 {
  return StatusCode::FAILURE;
}

setAddressCreator()

StatusCode MixingEventSelector::setAddressCreator ( IAddressCreator * creator )

overridevirtual

Definition at line 548 of file MixingEventSelector.cxx.

{
  std::abort();
}

setConversionSvc()

StatusCode MixingEventSelector::setConversionSvc ( IConversionSvc * pService )

overridevirtual

Definition at line 540 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 276 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 532 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 104 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 * tad, const EventContext & ctx )

overridevirtual

Definition at line 261 of file MixingEventSelector.cxx.

                                                        {
  return StatusCode::FAILURE;
}

updateObj()

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

overridevirtual

Definition at line 560 of file MixingEventSelector.cxx.

{
  std::abort();
}

updateObjRefs()

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

overridevirtual

Definition at line 564 of file MixingEventSelector.cxx.

{
  std::abort();
}

updateRep()

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

overridevirtual

Definition at line 576 of file MixingEventSelector.cxx.

{
  std::abort();
}

updateRepRefs()

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

overridevirtual

Definition at line 580 of file MixingEventSelector.cxx.

{
  std::abort();
}

validTrigger()

bool MixingEventSelector::validTrigger ( ) const

inlineprivate

Definition at line 152 of file MixingEventSelector.h.

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

Member Data Documentation

m_atRndmSvc

ServiceHandle<IAtRndmGenSvc> MixingEventSelector::m_atRndmSvc

private

Initial value:

{this, "RndmGenSvc", "AtRndmGenSvc",
    "IAtRndmGenSvc controlling the order with which events are takes from streams"}

Definition at line 178 of file MixingEventSelector.h.

                                          {this, "RndmGenSvc", "AtRndmGenSvc",
    "IAtRndmGenSvc controlling the order with which events are takes from streams"};

m_chooseRangeRand

std::unique_ptr<CLHEP::RandFlat> MixingEventSelector::m_chooseRangeRand

private

Definition at line 277 of file MixingEventSelector.h.

m_eventNumbers

Gaudi::Property<std::vector<unsigned long> > MixingEventSelector::m_eventNumbers

private

Initial value:

{this, "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."}

Definition at line 165 of file MixingEventSelector.h.

                                                        {this, "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."};

m_eventPos

unsigned long MixingEventSelector::m_eventPos {0}

mutableprivate

the internal event number

Definition at line 274 of file MixingEventSelector.h.

{0};       

m_helperTools

ToolHandleArray<IAthenaSelectorTool> MixingEventSelector::m_helperTools

private

Initial value:

{this, "HelperTools", {},
    "Collection of selector tools"}

Definition at line 175 of file MixingEventSelector.h.

                                                    {this, "HelperTools", {},
    "Collection of selector tools"};

m_mergedEventInfoKey

Gaudi::Property<std::string> MixingEventSelector::m_mergedEventInfoKey

private

Initial value:

{this, "MergedEventInfoKey", "MergedEventInfo",
    "StoreGate key for output (merged) event info object. Default is MergedEventInfo"}

Definition at line 169 of file MixingEventSelector.h.

                                               {this, "MergedEventInfoKey", "MergedEventInfo",
    "StoreGate key for output (merged) event info object. Default is MergedEventInfo"};

m_outputRunNumber

Gaudi::Property<int> MixingEventSelector::m_outputRunNumber {this, "OutputRunNumber", 123456789}

private

Definition at line 163 of file MixingEventSelector.h.

{this, "OutputRunNumber", 123456789};

m_pCurrentTrigger

TriggerList::iterator MixingEventSelector::m_pCurrentTrigger

mutableprivate

the current trigger

Definition at line 266 of file MixingEventSelector.h.

m_pEventStore

ServiceHandle<StoreGateSvc> MixingEventSelector::m_pEventStore

private

Definition at line 276 of file MixingEventSelector.h.

m_randomStreamName

Gaudi::Property<std::string> MixingEventSelector::m_randomStreamName

private

Initial value:

{this, "RndmStreamName", "MixingEventSelectorStream",
    "IAtRndmGenSvc stream used as engine for our random distributions"}

Definition at line 172 of file MixingEventSelector.h.

                                             {this, "RndmStreamName", "MixingEventSelectorStream",
    "IAtRndmGenSvc stream used as engine for our random distributions"};

m_statusFileName

Gaudi::Property<std::string> MixingEventSelector::m_statusFileName

private

Initial value:

{this, "StreamStatusFileName", {},
    "Name of the file recording the last event used and how many were available for each stream. Default is to produce no file."}

Definition at line 156 of file MixingEventSelector.h.

                                           {this, "StreamStatusFileName", {},
    "Name of the file recording the last event used and how many were available for each stream. Default is to produce no file."};

m_triggerListProp

Gaudi::Property<std::vector<std::string> > MixingEventSelector::m_triggerListProp

private

Initial value:

{this, "TriggerList", {}, &MixingEventSelector::setUpTriggerList,
    "List of triggers (streams) to be used. Format is SelectorType/SelectorName:firstEventToUse:lastEventToUse. "
    "One assumes events are consecutively numbered."}

Definition at line 159 of file MixingEventSelector.h.

                                                       {this, "TriggerList", {}, &MixingEventSelector::setUpTriggerList,
    "List of triggers (streams) to be used. Format is SelectorType/SelectorName:firstEventToUse:lastEventToUse. "
    "One assumes events are consecutively numbered."};

m_trigList

TriggerList MixingEventSelector::m_trigList

mutableprivate

the ingredients

Definition at line 260 of file MixingEventSelector.h.

---

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

• MixingEventSelector.h
• MixingEventSelector.cxx