EvtIdModifierSvc Class Reference

#include <EvtIdModifierSvc.h>

Inheritance diagram for EvtIdModifierSvc:

Collaboration diagram for EvtIdModifierSvc:

Public Member Functions
	EvtIdModifierSvc (const std::string &name, ISvcLocator *pSvcLocator)
	Constructor with parameters: More...
virtual StatusCode	initialize () override
	Gaudi Service Implementation. More...
virtual std::vector< number_type >	run_number_list () const override
	return the (sorted) list of run-numbers which will be modified. More...
virtual void	modify_evtid (EventID &evt_id, event_number_t evt_index, bool consume_stream) override
	modify an EventID's lumi block content. More...

Private Member Functions
	EvtIdModifierSvc ()
	Default constructor: More...

Private Attributes
event_number_t	m_skippedEvents
	(prop) number of events skipped in the event selector More...
event_number_t	m_firstEvtIdx
	(prop) first event number at which we begin to modify event ids More...
std::vector< uint64_t >	m_evtNpletsProp
	(prop) list of n-plets (run-nbr, evt-nbr, time-stamp, lbk-nbr, nbr-of-events-per-lbk, mod-bit) More...
std::string	m_evtStoreName
	(prop) Name of the event store whose EventIDs will be modified. More...
std::vector< ItemModifier >	m_evtNplets
	db of list of ItemModifiers: (run-nbr, evt-nbr, time-stamp, lbk-nbr, nbr-of-events-per-lbk, mod-bit) More...
std::vector< event_number_t >	m_numEvtTotals
	Running total of numEvts before each modifier. More...

Detailed Description

Definition at line 39 of file EvtIdModifierSvc.h.

Constructor & Destructor Documentation

EvtIdModifierSvc() [1/2]

EvtIdModifierSvc::EvtIdModifierSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Constructor with parameters:

Definition at line 46 of file EvtIdModifierSvc.cxx.

    : base_class(name, pSvcLocator) {
 
  declareProperty("Modifiers", m_evtNpletsProp,
                  "A list of n-uplets "
                  "(RunNumber,EvtNbr,TimeStamp,LumiBlock,Nevents,ModBit).");
 
  declareProperty("EvtStoreName", m_evtStoreName = "StoreGateSvc",
                  "Name of the event store whose EventIDs will be modified.");
 
  declareProperty("SkipEvents", m_firstEvtIdx = 0,
                  "Number of events to skip before modifying EventInfos.");
  declareProperty("SkippedEvents", m_skippedEvents = 0,
                  "Number of events skipped in the EventSelector.");
}

EvtIdModifierSvc() [2/2]

EvtIdModifierSvc::EvtIdModifierSvc ( )

private

Default constructor:

Member Function Documentation

initialize()

StatusCode EvtIdModifierSvc::initialize ( )

overridevirtual

Gaudi Service Implementation.

Definition at line 65 of file EvtIdModifierSvc.cxx.

                                        {
  ATH_MSG_INFO("Initializing " << name() << "...");
 
  if (const auto nplets_prop_count = m_evtNpletsProp.size();
      nplets_prop_count > 0) {
    // they should be Nplets...
    if (nplets_prop_count % prop_per_nplet != 0) {
      ATH_MSG_ERROR("invalid list of n-plets (not divisible by "
                    << prop_per_nplet << ")" << endmsg << "check your joboptions !");
      return StatusCode::FAILURE;
    }
 
    m_evtNplets.reserve(nplets_prop_count / prop_per_nplet);
    for (std::size_t i = 0; i < nplets_prop_count; i += prop_per_nplet) {
      m_evtNplets.push_back({
          // clang-format off
          .runnbr    = static_cast<number_type>(   m_evtNpletsProp[i + 0]),
          .evtnbr    = static_cast<event_number_t>(m_evtNpletsProp[i + 1]),
          .timestamp = static_cast<number_type>(   m_evtNpletsProp[i + 2]),
          .lbknbr    = static_cast<number_type>(   m_evtNpletsProp[i + 3]),
          .nevts     = static_cast<event_number_t>(m_evtNpletsProp[i + 4]),
          .flags     = static_cast<int>(           m_evtNpletsProp[i + 5])
          // clang-format on
      });
    }
  }
 
  // initialize running total of nevts
  m_numEvtTotals.clear();
  event_number_t sum = 0;
  for (const ItemModifier& elem : m_evtNplets) {
    sum += elem.nevts;
    m_numEvtTotals.push_back(sum);
  }
 
  if (msgLvl(MSG::DEBUG)) {
    msg(MSG::DEBUG) << "store being modified: [" << m_evtStoreName << "]"
                    << endmsg << "evtid-modifiers: [ ";
    for (const ItemModifier& elem : m_evtNplets) {
      msg(MSG::DEBUG) << "[" << elem.runnbr << ", " << elem.evtnbr << ", "
                      << elem.timestamp << ", " << elem.lbknbr << ", "
                      << elem.nevts << ", flags=0x" << std::hex << elem.flags
                      << std::dec << "], ";
    }
    msg(MSG::DEBUG) << "]" << endmsg;
  }
 
  return StatusCode::SUCCESS;
}

modify_evtid()

void EvtIdModifierSvc::modify_evtid ( EventID &  evt_id, event_number_t  evt_index, bool  consume_stream  )

overridevirtual

modify an EventID's lumi block content.

modify an EventID's content.

Definition at line 138 of file EvtIdModifierSvc.cxx.

                                                         {
  // Left in to match old observable behaviour:
  // only when consuming stream is required do we check for a matching
  // current StoreGate name (ie: typically the case of being called from a T/P
  // cnv)
  if (consume_stream) {
    StoreGateSvc* active = StoreGateSvc::currentStoreGate();
    if (!active) {
      ATH_MSG_INFO("could not retrieve the active evtstore - bailing out");
      return;
    }
 
    const std::string& evtStoreName = active->name();
    ATH_MSG_DEBUG("active store: [" << evtStoreName << "]");
    if (evtStoreName != m_evtStoreName) {
      return;
    }
  }
 
  ATH_MSG_DEBUG("evtid before massaging: " << "(" << evt_id.run_number() << ", "
                                           << evt_id.event_number() << ", "
                                           << evt_id.time_stamp() << ", "
                                           << evt_id.lumi_block() << ")");
 
  // event skipping
  std::int64_t idx =
      std::int64_t(evt_index) + m_skippedEvents - std::int64_t(m_firstEvtIdx);
  std::int64_t idx_looped = idx % m_numEvtTotals.back();
  ATH_MSG_DEBUG("Got event idx " << evt_index << " --(account for skipping)--> "
                                 << idx << " --(modulo #modifiers)--> "
                                 << idx_looped);
  if (idx < 0) {
    ATH_MSG_DEBUG("skip event");
    return;
  }
 
  // Account for events skipped in
  std::size_t mod_idx = std::upper_bound(m_numEvtTotals.cbegin(),
                                         m_numEvtTotals.cend(), idx_looped) -
                        m_numEvtTotals.cbegin();
  ItemModifier current = m_evtNplets[mod_idx];
  ATH_MSG_DEBUG("Unique modifier index " << mod_idx
                                         << " (LB: " << current.lbknbr << ")");
  if (mod_idx >= m_numEvtTotals.size()) {
    // Shouldn't happen
    ATH_MSG_ERROR("Somehow run out of modifiers");
    return;
  }
 
  if (current.flags & ModFlag::RUNNBR) {
    evt_id.set_run_number(current.runnbr);
  }
  if (current.flags & ModFlag::EVTNBR) {
    evt_id.set_event_number(current.evtnbr);
  }
  if (current.flags & ModFlag::TIMESTAMP) {
    evt_id.set_time_stamp(current.timestamp);
  }
  if (current.flags & ModFlag::LBKNBR) {
    evt_id.set_lumi_block(current.lbknbr);
  }
 
  ATH_MSG_DEBUG("evtid after  massaging: " << "(" << evt_id.run_number() << ", "
                                           << evt_id.event_number() << ", "
                                           << evt_id.time_stamp() << ", "
                                           << evt_id.lumi_block() << ")");
}

run_number_list()

std::vector< number_type > EvtIdModifierSvc::run_number_list ( ) const

overridevirtual

return the (sorted) list of run-numbers which will be modified.

Definition at line 121 of file EvtIdModifierSvc.cxx.

                                                               {
  std::set<number_type> runs;
 
  for (const ItemModifier& elem : m_evtNplets) {
    if (elem.flags & ModFlag::RUNNBR) {
      runs.insert(elem.runnbr);
    }
  }
  return std::vector(runs.begin(), runs.end());
}

Member Data Documentation

m_evtNplets

std::vector<ItemModifier> EvtIdModifierSvc::m_evtNplets

private

db of list of ItemModifiers: (run-nbr, evt-nbr, time-stamp, lbk-nbr, nbr-of-events-per-lbk, mod-bit)

Definition at line 91 of file EvtIdModifierSvc.h.

m_evtNpletsProp

std::vector<uint64_t> EvtIdModifierSvc::m_evtNpletsProp

private

(prop) list of n-plets (run-nbr, evt-nbr, time-stamp, lbk-nbr, nbr-of-events-per-lbk, mod-bit)

Definition at line 84 of file EvtIdModifierSvc.h.

m_evtStoreName

std::string EvtIdModifierSvc::m_evtStoreName

private

(prop) Name of the event store whose EventIDs will be modified.

Definition at line 87 of file EvtIdModifierSvc.h.

m_firstEvtIdx

event_number_t EvtIdModifierSvc::m_firstEvtIdx

private

(prop) first event number at which we begin to modify event ids

Definition at line 80 of file EvtIdModifierSvc.h.

m_numEvtTotals

std::vector<event_number_t> EvtIdModifierSvc::m_numEvtTotals

private

Running total of numEvts before each modifier.

Definition at line 94 of file EvtIdModifierSvc.h.

m_skippedEvents

event_number_t EvtIdModifierSvc::m_skippedEvents

private

(prop) number of events skipped in the event selector

Definition at line 78 of file EvtIdModifierSvc.h.

---

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

• EvtIdModifierSvc.h
• EvtIdModifierSvc.cxx