ATLAS Offline Software
Classes | List of all members
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. 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
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 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

unsigned long m_eventPos {0}
 the internal event number More...
 
ServiceHandle< StoreGateSvc > m_pEventStore
 
std::unique_ptr< 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 69 of file MixingEventSelector.h.

Constructor & Destructor Documentation

◆ MixingEventSelector()

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

Definition at line 47 of file MixingEventSelector.cxx.

47  :
48  base_class(name,svc),
49  m_pCurrentTrigger(m_trigList.end()),
50  m_pEventStore( "StoreGateSvc", name )
51 {
52 }

◆ ~MixingEventSelector()

MixingEventSelector::~MixingEventSelector ( )
virtual

Definition at line 54 of file MixingEventSelector.cxx.

54  {
55 }

Member Function Documentation

◆ addressCreator()

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

Definition at line 551 of file MixingEventSelector.cxx.

552 {
553  std::abort();
554 }

◆ conversionSvc()

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

Definition at line 543 of file MixingEventSelector.cxx.

544 {
545  std::abort();
546 }

◆ createAddress()

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

Definition at line 220 of file MixingEventSelector.cxx.

221  {
222  pAddr=nullptr;
223  if (!validTrigger()) return StatusCode::FAILURE;
224 
225  FORWARD___DEBUG( createAddress )
226  return (currentTrigger()->createAddress(pAddr).isSuccess() &&
227  pAddr != nullptr) ? StatusCode::SUCCESS : StatusCode::FAILURE;
228 }

◆ createContext()

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

Definition at line 172 of file MixingEventSelector.cxx.

172  {
173  pctxt=nullptr;
174  if (!validTrigger()) return StatusCode::FAILURE;
175  TriggerList::iterator iTr(m_trigList.begin());
176  StatusCode sc(StatusCode::FAILURE);
177  while (iTr != m_trigList.end() && (sc=(iTr++)->createContext(pctxt)).isSuccess()) ;
178  return sc;
179 }

◆ 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
pAddressOpaque address information to retrieve the requested object from the store in order to produce the transient object.
refpObjectReference to location of pointer of the created object.

Definition at line 504 of file MixingEventSelector.cxx.

506 {
507  const EventInfo* pEInfo(nullptr);
508  if (!(m_pEventStore->retrieve(pEInfo)).isSuccess()) {
509  ATH_MSG_ERROR
510  ("addMergedEventInfo: event store does not contain "\
511  "an EventInfo object!");
512  return StatusCode::RECOVERABLE;
513  }
514 
515  // copy the original event to a new MergedEventInfo
516  auto mei = std::make_unique<MergedEventInfo> (*pEInfo,
517  m_outputRunNumber,
518  getEventNo());
519  refpObject = SG::asStorable (std::move (mei));
520 
521 
522  //finally slam a new EventID in place of the old! HACK!!! FIXME!!
523  (const_cast<EventInfo*>(pEInfo))->setEventID(
524  new EventID(m_outputRunNumber, getEventNo()));
525 
526  return StatusCode::SUCCESS;
527 }

◆ createRep()

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

Definition at line 567 of file MixingEventSelector.cxx.

568 {
569  std::abort();
570 }

◆ currentTrigger()

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

"intelligent" accessor to the above

Definition at line 298 of file MixingEventSelector.cxx.

298  {
299  return ( validTrigger() ? m_pCurrentTrigger : setCurrentTrigger() );
300 }

◆ dataProvider()

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

Definition at line 535 of file MixingEventSelector.cxx.

536 {
537  std::abort();
538 }

◆ decodeTrigger()

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

functor that creates a Trigger object and adds it to m_trigList

Definition at line 114 of file MixingEventSelector.cxx.

114  {
115  //all this would be much more readable without error reporting...
116  typedef tokenizer<char_separator<char> > Tokenizer;
117  Tokenizer tokens(triggDescr, char_separator<char>(" :"));
118  //we need exactly three tokens: selector name, first and last event 2 B read
119  if ( (distance(tokens.begin(), tokens.end()) == 3) ||
120  (distance(tokens.begin(), tokens.end()) == 3) ){
121  Tokenizer::iterator iToken(tokens.begin());
122  try {
123  Gaudi::Utils::TypeNameString selTN(*iToken++);
124  //get selector
125  SmartIF<IEvtSelector> pSelector(serviceLocator()->service(selTN));
126  if (pSelector) {
127  //FIXME if (!pSelector.done()) {
128  //try to add to trig list
129  unsigned int firstEvt(boost::lexical_cast<unsigned int>(*iToken++));
130  unsigned int lastEvt(boost::lexical_cast<unsigned int>(*iToken));
131  if (m_trigList.add(Trigger(pSelector, firstEvt, lastEvt))) {
132  if (msgLvl(MSG::DEBUG)) {
133  SmartIF<INamedInterface> pNamed(pSelector);
134  if (pNamed) {
135  msg() << "decodeTrigger: added selector " << pNamed->name()
136  << " first event to be read " << firstEvt
137  << " last event to be read " << lastEvt << endmsg;
138  }
139  }
140  } else {
141  ATH_MSG_ERROR
142  ("decodeTrigger: Selector ["
143  << selTN.type() << '/' << selTN.name()
144  << "] not added");
145  } //can add to range
146  } else {
147  ATH_MSG_ERROR
148  ("decodeTrigger: Selector ["
149  << selTN.type() << '/' << selTN.name()
150  << "] can not be found or created");
151  } //selector available
152  } catch (const boost::bad_lexical_cast& e) {
153  ATH_MSG_ERROR
154  ("decodeTrigger: Can't cast ["<< *iToken
155  << "] to double(frequency). SKIPPING");
156  } //can cast to frequency
157  } else {
158  ATH_MSG_ERROR
159  ("decodeTrigger: Badly formatted descriptor ["
160  << triggDescr << "]. SKIPPING");
161  } //can parse property string
162 }

◆ fillObjRefs()

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

Definition at line 555 of file MixingEventSelector.cxx.

556 {
557  std::abort();
558 }

◆ fillRepRefs()

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

Definition at line 571 of file MixingEventSelector.cxx.

572 {
573  std::abort();
574 }

◆ finalize()

StatusCode MixingEventSelector::finalize ( )
overridevirtual

Definition at line 83 of file MixingEventSelector.cxx.

83  {
84  ATH_MSG_DEBUG ("Finalizing " << name());
85 
86  for (ToolHandle<IAthenaSelectorTool>& tool : m_helperTools) {
87  tool->preFinalize().ignore();
88  }
89 
90  const std::string& fname(m_statusFileName.value());
91  ofstream outfile(fname.c_str());
92  if ( outfile ) {
93  TriggerList::const_iterator i(m_trigList.begin());
94  TriggerList::const_iterator iEnd(m_trigList.end());
95  while (i != iEnd) outfile << (*i++).toString();
96  } else if (!fname.empty()) {
97  ATH_MSG_WARNING("unable to open trigger list status file " << fname);
98  }
99 
100  return StatusCode::SUCCESS;
101 }

◆ getEventNo()

unsigned long MixingEventSelector::getEventNo ( ) const
private

setup and lookup m_evtsNotUsedSoFar. Returns next event no

Definition at line 267 of file MixingEventSelector.cxx.

267  {
268  return ( (m_eventNumbers.value().size() > m_eventPos) ?
269  m_eventNumbers.value()[m_eventPos] :
270  m_eventPos );
271 }

◆ initialize()

StatusCode MixingEventSelector::initialize ( )
overridevirtual

Definition at line 58 of file MixingEventSelector.cxx.

58  {
59  ATH_MSG_INFO ("Initializing " << name());
60 
61 // defer this (it triggers a init loop via PPS
62 // if (!m_pEventStore.retrieve().isSuccess())
63 // return StatusCode::FAILURE;
64 
65  //setup random stream
66  CLHEP::HepRandomEngine* collEng(m_atRndmSvc->GetEngine(m_randomStreamName.value()));
67  if(nullptr == collEng ) {
68  ATH_MSG_ERROR ("can not get random stream " << m_randomStreamName.value());
69  return StatusCode::FAILURE;
70  }
71  //flat distribution in [0,1] range
72  m_chooseRangeRand = std::make_unique<CLHEP::RandFlat>(*(collEng), 0.0, 1.0);
73 
74  ATH_CHECK( m_helperTools.retrieve() );
75  for (ToolHandle<IAthenaSelectorTool>& tool : m_helperTools) {
76  ATH_CHECK( tool->postInitialize() );
77  }
78 
79  return StatusCode::SUCCESS;
80 }

◆ last()

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

Definition at line 458 of file MixingEventSelector.cxx.

458  {
459  return StatusCode::FAILURE;
460 }

◆ loadAddresses()

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

Definition at line 237 of file MixingEventSelector.cxx.

239 {
240  if (storeID != StoreID::EVENT_STORE && storeID != StoreID::PILEUP_STORE)
241  return StatusCode::SUCCESS;
242 
243  CLID mclid = ClassID_traits<MergedEventInfo>::ID();
244  if (!m_pEventStore->contains (mclid, m_mergedEventInfoKey)) {
245  // We create the DataProxy here rather than relying on ProxyProvideSvc
246  // to do it because we want to set a non-default dataloader on the proxy.
247  SG::TransientAddress tad (mclid,
248  m_mergedEventInfoKey,
249  new GenericAddress (0, mclid),
250  false);
251  auto dp = std::make_unique<SG::DataProxy> (std::move(tad),
252  this,
253  true);
254  ATH_CHECK( m_pEventStore->addToStore (mclid, dp.release()) );
255  }
256  return StatusCode::SUCCESS;
257 }

◆ next() [1/2]

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

Definition at line 461 of file MixingEventSelector.cxx.

461  {
462  return StatusCode::FAILURE;
463 }

◆ next() [2/2]

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

Definition at line 182 of file MixingEventSelector.cxx.

182  {
183  StatusCode sc(StatusCode::FAILURE);
184  do {
185 #ifdef DEBUG_OUTPUT_STATUS
186  TriggerList::const_iterator i(m_trigList.begin());
187  TriggerList::const_iterator iEnd(m_trigList.end());
188  while (i != iEnd) outfile2 << (*i++).toString(); //output status
189 #endif
190  setCurrentTrigger();
191  sc = currentTrigger()->next();
192  if (sc.isFailure()){
193  m_trigList.remove(m_pCurrentTrigger);
194  continue; // we have to add "continue;" after "m_trigList.remove(m_pCurrentTrigger);
195  }
196  } while ((sc.isFailure() || currentTrigger()->done()) && !m_trigList.empty() );
197  // use !m_trigList.empty() to replace validTrigger(), which is not working well
198 
199  std::vector<ToolHandle<IAthenaSelectorTool> >::const_iterator
200  i(m_helperTools.begin()), iE(m_helperTools.end());
201  while (i != iE) ((*i++)->preNext()).ignore();
202 
203  ++m_eventPos;
204  FORWARD___DEBUG( next );
205 
206  i=m_helperTools.begin(); iE=m_helperTools.end();
207  while (sc.isSuccess() && (i != iE)) {
208  sc =(*i)->postNext();
209  if (sc.isRecoverable())
210  ATH_MSG_INFO("Request skipping event from: " << (*i)->name());
211  else if (sc.isFailure())
212  ATH_MSG_WARNING((*i)->name() << ":postNext failed");
213  ++i;
214  }
215  return sc;
216 }

◆ objType()

const CLID & MixingEventSelector::objType ( ) const
overridevirtual

Definition at line 483 of file MixingEventSelector.cxx.

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

◆ preLoadAddresses()

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

Definition at line 231 of file MixingEventSelector.cxx.

232  {
233  return StatusCode::SUCCESS;
234 }

◆ previous() [1/2]

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

Definition at line 464 of file MixingEventSelector.cxx.

464  {
465  return StatusCode::FAILURE;
466 }

◆ previous() [2/2]

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

Definition at line 467 of file MixingEventSelector.cxx.

467  {
468  return StatusCode::FAILURE;
469 }

◆ releaseContext()

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

Definition at line 473 of file MixingEventSelector.cxx.

473  {
474  return StatusCode::FAILURE;
475 }

◆ repSvcType()

long MixingEventSelector::repSvcType ( ) const
overridevirtual

Definition at line 487 of file MixingEventSelector.cxx.

488 {
489  return 0;
490 }

◆ resetCriteria()

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

Definition at line 476 of file MixingEventSelector.cxx.

477  {
478  return StatusCode::FAILURE;
479 }

◆ rewind()

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

Definition at line 470 of file MixingEventSelector.cxx.

470  {
471  return StatusCode::FAILURE;
472 }

◆ setAddressCreator()

StatusCode MixingEventSelector::setAddressCreator ( IAddressCreator *  creator)
overridevirtual

Definition at line 547 of file MixingEventSelector.cxx.

548 {
549  std::abort();
550 }

◆ setConversionSvc()

StatusCode MixingEventSelector::setConversionSvc ( IConversionSvc *  pService)
overridevirtual

Definition at line 539 of file MixingEventSelector.cxx.

540 {
541  std::abort();
542 }

◆ setCurrentTrigger()

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

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

Definition at line 275 of file MixingEventSelector.cxx.

275  {
276  //we look for the first trigger which is not done
277  do {
278  //if called before initialize, choose the last trigger in list
279  unsigned int iTrig = (nullptr != m_chooseRangeRand) ?
280  (unsigned int)(m_chooseRangeRand->fire() * double(m_trigList.todo())) :
281  m_trigList.todo();
282  m_pCurrentTrigger = m_trigList.elementInRange(iTrig);
283  } while (validTrigger() && m_pCurrentTrigger->done() &&
284  m_trigList.remove(m_pCurrentTrigger)); //remove a done trigger
285 
286  //printouts
287  if (!validTrigger()) {
288  ATH_MSG_INFO ("setCurrentTrigger: end of input");
289  } else {
290  ATH_MSG_DEBUG ("setCurrentTrigger: now using selector "
291  << currentTrigger()->name());
292  }
293 
294  return m_pCurrentTrigger;
295 }

◆ setDataProvider()

StatusCode MixingEventSelector::setDataProvider ( IDataProviderSvc *  pService)
overridevirtual

Definition at line 531 of file MixingEventSelector.cxx.

532 {
533  std::abort();
534 }

◆ 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 105 of file MixingEventSelector.cxx.

105  {
106  using std::placeholders::_1;
107  m_trigList = TriggerList();
108  for_each(m_triggerListProp.value().begin(), m_triggerListProp.value().end(),
109  bind(&MixingEventSelector::decodeTrigger, this, _1));
110  setCurrentTrigger();
111 }

◆ updateAddress()

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

Definition at line 260 of file MixingEventSelector.cxx.

261  {
262  return StatusCode::FAILURE;
263 }

◆ updateObj()

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

Definition at line 559 of file MixingEventSelector.cxx.

560 {
561  std::abort();
562 }

◆ updateObjRefs()

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

Definition at line 563 of file MixingEventSelector.cxx.

564 {
565  std::abort();
566 }

◆ updateRep()

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

Definition at line 575 of file MixingEventSelector.cxx.

576 {
577  std::abort();
578 }

◆ updateRepRefs()

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

Definition at line 579 of file MixingEventSelector.cxx.

580 {
581  std::abort();
582 }

◆ 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
Initial value:
{this, "RndmGenSvc", "AtRndmGenSvc",
"IAtRndmGenSvc controlling the order with which events are takes from streams"}

Definition at line 178 of file MixingEventSelector.h.

◆ 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.

◆ m_eventPos

unsigned long MixingEventSelector::m_eventPos {0}
mutableprivate

the internal event number

Definition at line 274 of file MixingEventSelector.h.

◆ m_helperTools

ToolHandleArray<IAthenaSelectorTool> MixingEventSelector::m_helperTools
private
Initial value:
{this, "HelperTools", {},
"Collection of selector tools"}

Definition at line 175 of file MixingEventSelector.h.

◆ 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.

◆ m_outputRunNumber

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

Definition at line 163 of file MixingEventSelector.h.

◆ 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.

◆ 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.

◆ 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.

◆ 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:
xAOD::iterator
JetConstituentVector::iterator iterator
Definition: JetConstituentVector.cxx:68
MixingEventSelector::m_pCurrentTrigger
TriggerList::iterator m_pCurrentTrigger
the current trigger
Definition: MixingEventSelector.h:266
AllowedVariables::e
e
Definition: AsgElectronSelectorTool.cxx:37
TileDCSDataPlotter.dp
dp
Definition: TileDCSDataPlotter.py:842
MixingEventSelector::m_trigList
TriggerList m_trigList
the ingredients
Definition: MixingEventSelector.h:260
MixingEventSelector::m_atRndmSvc
ServiceHandle< IAtRndmGenSvc > m_atRndmSvc
Definition: MixingEventSelector.h:178
ATH_MSG_INFO
#define ATH_MSG_INFO(x)
Definition: AthMsgStreamMacros.h:31
MixingEventSelector::TriggerList::remove
bool remove(iterator)
Definition: MixingEventSelector.cxx:321
MixingEventSelector::m_statusFileName
Gaudi::Property< std::string > m_statusFileName
Definition: MixingEventSelector.h:156
SG::TransientAddress
Definition: TransientAddress.h:32
MixingEventSelector::m_eventNumbers
Gaudi::Property< std::vector< unsigned long > > m_eventNumbers
Definition: MixingEventSelector.h:165
MixingEventSelector::TriggerList::end
iterator end()
Definition: MixingEventSelector.h:251
MixingEventSelector::TriggerList::empty
bool empty() const
Definition: MixingEventSelector.h:254
MixingEventSelector::TriggerList::todo
unsigned int todo() const
Definition: MixingEventSelector.h:256
beamspotman.tokens
tokens
Definition: beamspotman.py:1282
MixingEventSelector::next
virtual StatusCode next(IEvtSelector::Context &refCtxt) const override
Definition: MixingEventSelector.cxx:182
MixingEventSelector::currentTrigger
TriggerList::iterator currentTrigger() const
"intelligent" accessor to the above
Definition: MixingEventSelector.cxx:298
MixingEventSelector::getEventNo
unsigned long getEventNo() const
setup and lookup m_evtsNotUsedSoFar. Returns next event no
Definition: MixingEventSelector.cxx:267
MixingEventSelector::m_eventPos
unsigned long m_eventPos
the internal event number
Definition: MixingEventSelector.h:274
AthenaPoolTestRead.sc
sc
Definition: AthenaPoolTestRead.py:27
MixingEventSelector::m_helperTools
ToolHandleArray< IAthenaSelectorTool > m_helperTools
Definition: MixingEventSelector.h:175
MixingEventSelector::TriggerList::elementInRange
iterator elementInRange(unsigned int)
Definition: MixingEventSelector.cxx:368
SG::asStorable
DataObject * asStorable(SG::DataObjectSharedPtr< T > pObject)
Definition: DataObjectSharedPtr.h:65
DiTauMassTools::ignore
void ignore(T &&)
Definition: PhysicsAnalysis/TauID/DiTauMassTools/DiTauMassTools/HelperFunctions.h:58
MixingEventSelector::decodeTrigger
void decodeTrigger(std::string triggDescr)
functor that creates a Trigger object and adds it to m_trigList
Definition: MixingEventSelector.cxx:114
MixingEventSelector::TriggerList::iterator
std::vector< Trigger >::iterator iterator
Definition: MixingEventSelector.h:247
Amg::toString
std::string toString(const Translation3D &translation, int precision=4)
GeoPrimitvesToStringConverter.
Definition: GeoPrimitivesToStringConverter.h:40
ATH_MSG_ERROR
#define ATH_MSG_ERROR(x)
Definition: AthMsgStreamMacros.h:33
MixingEventSelector::m_chooseRangeRand
std::unique_ptr< CLHEP::RandFlat > m_chooseRangeRand
Definition: MixingEventSelector.h:277
StoreID::PILEUP_STORE
@ PILEUP_STORE
Definition: StoreID.h:31
lumiFormat.i
int i
Definition: lumiFormat.py:85
CP::DetailSelectionExprParser::Tokenizer
boost::tokenizer< Separator > Tokenizer
Definition: SelectionExprParser.h:34
MixingEventSelector::m_randomStreamName
Gaudi::Property< std::string > m_randomStreamName
Definition: MixingEventSelector.h:172
MixingEventSelector::m_pEventStore
ServiceHandle< StoreGateSvc > m_pEventStore
Definition: MixingEventSelector.h:276
endmsg
#define endmsg
Definition: AnalysisConfig_Ntuple.cxx:63
EL::StatusCode
::StatusCode StatusCode
StatusCode definition for legacy code.
Definition: PhysicsAnalysis/D3PDTools/EventLoop/EventLoop/StatusCode.h:22
ATH_MSG_DEBUG
#define ATH_MSG_DEBUG(x)
Definition: AthMsgStreamMacros.h:29
FORWARD___DEBUG
#define FORWARD___DEBUG(METHOD)
Definition: MixingEventSelector.cxx:165
ATH_CHECK
#define ATH_CHECK
Definition: AthCheckMacros.h:40
MixingEventSelector::TriggerList::begin
iterator begin()
Definition: MixingEventSelector.h:250
Handler::svc
AthROOTErrorHandlerSvc * svc
Definition: AthROOTErrorHandlerSvc.cxx:10
xAOD::double
double
Definition: CompositeParticle_v1.cxx:159
MixingEventSelector::setCurrentTrigger
TriggerList::iterator setCurrentTrigger() const
choose current trigger at random. Actually modifies state (use mutables)
Definition: MixingEventSelector.cxx:275
CLID
uint32_t CLID
The Class ID type.
Definition: Event/xAOD/xAODCore/xAODCore/ClassID_traits.h:47
python.TriggerAnalysisConfig.Trigger
def Trigger(seq)
Definition: TriggerAnalysisConfig.py:263
name
std::string name
Definition: Control/AthContainers/Root/debug.cxx:240
MixingEventSelector::setUpTriggerList
void setUpTriggerList(Gaudi::Details::PropertyBase &trigList)
TriggerList property call-back.
Definition: MixingEventSelector.cxx:105
EventInfo
This class provides general information about an event. Event information is provided by the accessor...
Definition: EventInfo/EventInfo/EventInfo.h:43
AtlCoolConsole.tool
tool
Definition: AtlCoolConsole.py:452
python.AthDsoLogger.fname
string fname
Definition: AthDsoLogger.py:66
MixingEventSelector::TriggerList::add
bool add(const Trigger &)
Definition: MixingEventSelector.cxx:303
MixingEventSelector::TriggerList::const_iterator
std::vector< Trigger >::const_iterator const_iterator
Definition: MixingEventSelector.h:246
ATH_MSG_WARNING
#define ATH_MSG_WARNING(x)
Definition: AthMsgStreamMacros.h:32
DEBUG
#define DEBUG
Definition: page_access.h:11
EventID
This class provides a unique identification for each event, in terms of run/event number and/or a tim...
Definition: EventID.h:35
MixingEventSelector::createAddress
virtual StatusCode createAddress(const IEvtSelector::Context &refCtxt, IOpaqueAddress *&) const override
Definition: MixingEventSelector.cxx:220
ClassID_traits::ID
static CLID ID()
Definition: Control/AthenaKernel/AthenaKernel/ClassID_traits.h:44
StoreID::EVENT_STORE
@ EVENT_STORE
Definition: StoreID.h:26
PrepareReferenceFile.outfile
outfile
Definition: PrepareReferenceFile.py:42
Amg::distance
float distance(const Amg::Vector3D &p1, const Amg::Vector3D &p2)
calculates the distance between two point in 3D space
Definition: GeoPrimitivesHelpers.h:54
python.AutoConfigFlags.msg
msg
Definition: AutoConfigFlags.py:7
MixingEventSelector::m_mergedEventInfoKey
Gaudi::Property< std::string > m_mergedEventInfoKey
Definition: MixingEventSelector.h:169
MixingEventSelector::validTrigger
bool validTrigger() const
Definition: MixingEventSelector.h:152
MixingEventSelector::m_outputRunNumber
Gaudi::Property< int > m_outputRunNumber
Definition: MixingEventSelector.h:163
MixingEventSelector::m_triggerListProp
Gaudi::Property< std::vector< std::string > > m_triggerListProp
Definition: MixingEventSelector.h:159
Generated on Mon Sep 1 2025 21:42:01 for ATLAS Offline Software by   doxygen 1.8.18