EvtIdModifierSvc Class Reference

#include <EvtIdModifierSvc.h>

Inheritance diagram for EvtIdModifierSvc:

Collaboration diagram for EvtIdModifierSvc:

Public Types
using	number_type = EventIDBase::number_type

Public Member Functions
	EvtIdModifierSvc (const std::string &name, ISvcLocator *pSvcLocator)
	Constructor with parameters: More...
virtual StatusCode	initialize () override
	Gaudi Service Implementation. More...
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface) override
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...
MsgStream &	msg () const
MsgStream &	msg (const MSG::Level lvl) const
bool	msgLvl (const MSG::Level lvl) const

Static Public Member Functions
static const InterfaceID &	interfaceID ()

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

Friends
class	SvcFactory< EvtIdModifierSvc >

Detailed Description

Definition at line 41 of file EvtIdModifierSvc.h.

Member Typedef Documentation

number_type

using IEvtIdModifierSvc::number_type = EventIDBase::number_type

inherited

Definition at line 42 of file IEvtIdModifierSvc.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.

    : ::AthService(name, pSvcLocator) {
  //
  // Property declaration
  //
  // declareProperty( "Property", m_nProperty );
 
  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 69 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;
}

interfaceID()

const InterfaceID & EvtIdModifierSvc::interfaceID ( )

inlinestatic

Definition at line 109 of file EvtIdModifierSvc.h.

                                                        {
  return IEvtIdModifierSvc::interfaceID();
}

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.

Implements IEvtIdModifierSvc.

Definition at line 159 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() << ")");
}

msg() [1/2]

MsgStream& AthCommonMsg< Service >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                {
    return this->msgStream();
  }

msg() [2/2]

MsgStream& AthCommonMsg< Service >::msg ( const MSG::Level  lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                  {
    return this->msgStream(lvl);
  }

msgLvl()

bool AthCommonMsg< Service >::msgLvl ( const MSG::Level  lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                               {
    return this->msgLevel(lvl);
  }

queryInterface()

StatusCode EvtIdModifierSvc::queryInterface ( const InterfaceID &  riid, void **  ppvInterface  )

overridevirtual

Definition at line 124 of file EvtIdModifierSvc.cxx.

                                                                 {
  if (IEvtIdModifierSvc::interfaceID().versionMatch(riid)) {
    *ppvInterface = dynamic_cast<IEvtIdModifierSvc*>(this);
  } else {
    // Interface is not directly available : try out a base class
    return ::AthService::queryInterface(riid, ppvInterface);
  }
  addRef();
  return StatusCode::SUCCESS;
}

run_number_list()

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

overridevirtual

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

Implements IEvtIdModifierSvc.

Definition at line 142 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());
}

Friends And Related Function Documentation

SvcFactory< EvtIdModifierSvc >

friend class SvcFactory< EvtIdModifierSvc >

friend

Definition at line 38 of file EvtIdModifierSvc.h.

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 99 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 92 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 95 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 88 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 102 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 86 of file EvtIdModifierSvc.h.

---

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

• EvtIdModifierSvc.h
• EvtIdModifierSvc.cxx