CreateLumiBlockCollectionFromFile Class Reference

#include <CreateLumiBlockCollectionFromFile.h>

Inheritance diagram for CreateLumiBlockCollectionFromFile:

Collaboration diagram for CreateLumiBlockCollectionFromFile:

Public Member Functions
	CreateLumiBlockCollectionFromFile (const std::string &name, ISvcLocator *pSvcLocator)
virtual StatusCode	initialize () override
virtual StatusCode	execute () override
virtual StatusCode	finalize () override
virtual void	handle (const Incident &incident) override
	Incident service handle listening for MetaDataStop. More...
virtual StatusCode	io_reinit () override
	Callback method to reinitialize the internal state of the component for I/O purposes (e.g. upon fork(2)) More...
virtual StatusCode	sysInitialize () override
	Override sysInitialize. More...
virtual const DataObjIDColl &	extraOutputDeps () const override
	Return the list of extra output dependencies. More...
ServiceHandle< StoreGateSvc > &	evtStore ()
	The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc. More...
const ServiceHandle< StoreGateSvc > &	evtStore () const
	The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc. More...
const ServiceHandle< StoreGateSvc > &	detStore () const
	The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc. More...
virtual StatusCode	sysStart () override
	Handle START transition. More...
virtual std::vector< Gaudi::DataHandle * >	inputHandles () const override
	Return this algorithm's input handles. More...
virtual std::vector< Gaudi::DataHandle * >	outputHandles () const override
	Return this algorithm's output handles. More...
Gaudi::Details::PropertyBase &	declareProperty (Gaudi::Property< T > &t)
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, SG::VarHandleKey &hndl, const std::string &doc, const SG::VarHandleKeyType &)
	Declare a new Gaudi property. More...
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, SG::VarHandleBase &hndl, const std::string &doc, const SG::VarHandleType &)
	Declare a new Gaudi property. More...
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, SG::VarHandleKeyArray &hndArr, const std::string &doc, const SG::VarHandleKeyArrayType &)
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, T &property, const std::string &doc, const SG::NotHandleType &)
	Declare a new Gaudi property. More...
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, T &property, const std::string &doc="none")
	Declare a new Gaudi property. More...
void	updateVHKA (Gaudi::Details::PropertyBase &)
MsgStream &	msg () const
MsgStream &	msg (const MSG::Level lvl) const
bool	msgLvl (const MSG::Level lvl) const

Protected Member Functions
void	renounceArray (SG::VarHandleKeyArray &handlesArray)
	remove all handles from I/O resolution More...
std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void >	renounce (T &h)
void	extraDeps_update_handler (Gaudi::Details::PropertyBase &ExtraDeps)
	Add StoreName to extra input/output deps as needed. More...

Private Types
typedef std::pair< uint32_t, uint32_t >	inOut
typedef std::map< IOVTime, inOut >	RLBMap
typedef ServiceHandle< StoreGateSvc >	StoreGateSvc_t

Private Member Functions
StatusCode	fillLumiBlockCollection ()
	Fill metaDataStore and ntuples. More...
uint32_t	getNEventsFromDb ()
Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleKeyType &)
	specialization for handling Gaudi::Property<SG::VarHandleKey> More...
Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleKeyArrayType &)
	specialization for handling Gaudi::Property<SG::VarHandleKeyArray> More...
Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleType &)
	specialization for handling Gaudi::Property<SG::VarHandleBase> More...
Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T > &t, const SG::NotHandleType &)
	specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray> More...

Private Attributes
SG::ReadHandleKey< xAOD::EventInfo >	m_eventInfoKey
SG::ReadCondHandleKey< CondAttrListCollection >	m_rchk
Gaudi::Property< std::string >	m_streamName
Gaudi::Property< std::string >	m_LBColl_name
Gaudi::Property< std::string >	m_unfinishedLBColl_name
Gaudi::Property< std::string >	m_suspectLBColl_name
Gaudi::Property< bool >	m_checkEventsExpected
RLBMap	m_LumiBlockInfo
uint32_t	m_lastRun
uint32_t	m_lastLumiBlock
IOVTime	m_lastIOVTime
ServiceHandle< StoreGateSvc >	m_metaStore
DataObjIDColl	m_extendedExtraObjects
StoreGateSvc_t	m_evtStore
	Pointer to StoreGate (event store by default) More...
StoreGateSvc_t	m_detStore
	Pointer to StoreGate (detector store by default) More...
std::vector< SG::VarHandleKeyArray * >	m_vhka
bool	m_varHandleArraysDeclared

Detailed Description

Definition at line 35 of file CreateLumiBlockCollectionFromFile.h.

Member Typedef Documentation

inOut

typedef std::pair<uint32_t,uint32_t> CreateLumiBlockCollectionFromFile::inOut

private

Definition at line 96 of file CreateLumiBlockCollectionFromFile.h.

RLBMap

typedef std::map<IOVTime,inOut> CreateLumiBlockCollectionFromFile::RLBMap

private

Definition at line 97 of file CreateLumiBlockCollectionFromFile.h.

StoreGateSvc_t

typedef ServiceHandle<StoreGateSvc> AthCommonDataStore< AthCommonMsg< Algorithm > >::StoreGateSvc_t

privateinherited

Definition at line 388 of file AthCommonDataStore.h.

Constructor & Destructor Documentation

CreateLumiBlockCollectionFromFile()

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

Definition at line 18 of file CreateLumiBlockCollectionFromFile.cxx.

  : AthAlgorithm(name, pSvcLocator)
  , m_lastRun(9999999)
  , m_lastLumiBlock(9999999)
  , m_lastIOVTime(0)
  , m_metaStore("StoreGateSvc/MetaDataStore", name)
{
}

Member Function Documentation

declareGaudiProperty() [1/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Algorithm > >::declareGaudiProperty ( Gaudi::Property< T > &  hndl, const SG::VarHandleKeyArrayType &    )

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKeyArray>

Definition at line 170 of file AthCommonDataStore.h.

  {
    return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                       hndl.value(), 
                                                       hndl.documentation());
 
  }

declareGaudiProperty() [2/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Algorithm > >::declareGaudiProperty ( Gaudi::Property< T > &  hndl, const SG::VarHandleKeyType &    )

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKey>

Definition at line 156 of file AthCommonDataStore.h.

  {
    return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                       hndl.value(), 
                                                       hndl.documentation());
 
  }

declareGaudiProperty() [3/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Algorithm > >::declareGaudiProperty ( Gaudi::Property< T > &  hndl, const SG::VarHandleType &    )

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleBase>

Definition at line 184 of file AthCommonDataStore.h.

  {
    return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                       hndl.value(), 
                                                       hndl.documentation());
  }

declareGaudiProperty() [4/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Algorithm > >::declareGaudiProperty ( Gaudi::Property< T > &  t, const SG::NotHandleType &    )

inlineprivateinherited

specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray>

Definition at line 199 of file AthCommonDataStore.h.

  {
    return PBASE::declareProperty(t);
  }

declareProperty() [1/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Algorithm > >::declareProperty ( const std::string &  name, SG::VarHandleBase &  hndl, const std::string &  doc, const SG::VarHandleType &    )

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
hndl	Object holding the property value.
doc	Documentation string for the property.

This is the version for types that derive from SG::VarHandleBase. The property value object is put on the input and output lists as appropriate; then we forward to the base class.

Definition at line 245 of file AthCommonDataStore.h.

  {
    this->declare(hndl.vhKey());
    hndl.vhKey().setOwner(this);
 
    return PBASE::declareProperty(name,hndl,doc);
  }

declareProperty() [2/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Algorithm > >::declareProperty ( const std::string &  name, SG::VarHandleKey &  hndl, const std::string &  doc, const SG::VarHandleKeyType &    )

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
hndl	Object holding the property value.
doc	Documentation string for the property.

This is the version for types that derive from SG::VarHandleKey. The property value object is put on the input and output lists as appropriate; then we forward to the base class.

Definition at line 221 of file AthCommonDataStore.h.

  {
    this->declare(hndl);
    hndl.setOwner(this);
 
    return PBASE::declareProperty(name,hndl,doc);
  }

declareProperty() [3/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Algorithm > >::declareProperty ( const std::string &  name, SG::VarHandleKeyArray &  hndArr, const std::string &  doc, const SG::VarHandleKeyArrayType &    )

inlineinherited

Definition at line 259 of file AthCommonDataStore.h.

  {
 
    // std::ostringstream ost;
    // ost << Algorithm::name() << " VHKA declareProp: " << name 
    //     << " size: " << hndArr.keys().size() 
    //     << " mode: " << hndArr.mode() 
    //     << "  vhka size: " << m_vhka.size()
    //     << "\n";
    // debug() << ost.str() << endmsg;
 
    hndArr.setOwner(this);
    m_vhka.push_back(&hndArr);
 
    Gaudi::Details::PropertyBase* p =  PBASE::declareProperty(name, hndArr, doc);
    if (p != 0) {
      p->declareUpdateHandler(&AthCommonDataStore<PBASE>::updateVHKA, this);
    } else {
      ATH_MSG_ERROR("unable to call declareProperty on VarHandleKeyArray " 
                    << name);
    }
 
    return p;
 
  }

declareProperty() [4/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Algorithm > >::declareProperty ( const std::string &  name, T &  property, const std::string &  doc, const SG::NotHandleType &    )

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
property	Object holding the property value.
doc	Documentation string for the property.

This is the generic version, for types that do not derive from SG::VarHandleKey. It just forwards to the base class version of declareProperty.

Definition at line 333 of file AthCommonDataStore.h.

  {
    return PBASE::declareProperty(name, property, doc);
  }

declareProperty() [5/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Algorithm > >::declareProperty ( const std::string &  name, T &  property, const std::string &  doc = "none"  )

inlineinherited

Declare a new Gaudi property.

Parameters

name	Name of the property.
property	Object holding the property value.
doc	Documentation string for the property.

This dispatches to either the generic declareProperty or the one for VarHandle/Key/KeyArray.

Definition at line 352 of file AthCommonDataStore.h.

  {
    typedef typename SG::HandleClassifier<T>::type htype;
    return declareProperty (name, property, doc, htype());
  }

declareProperty() [6/6]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Algorithm > >::declareProperty ( Gaudi::Property< T > &  t )

inlineinherited

Definition at line 145 of file AthCommonDataStore.h.

                                                                 {
    typedef typename SG::HandleClassifier<T>::type htype;
    return AthCommonDataStore<PBASE>::declareGaudiProperty(t, htype());
  }

detStore()

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Algorithm > >::detStore ( ) const

inlineinherited

The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 95 of file AthCommonDataStore.h.

{ return m_detStore; }

evtStore() [1/2]

ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Algorithm > >::evtStore ( )

inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 85 of file AthCommonDataStore.h.

{ return m_evtStore; }

evtStore() [2/2]

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Algorithm > >::evtStore ( ) const

inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 90 of file AthCommonDataStore.h.

{ return m_evtStore; }

execute()

StatusCode CreateLumiBlockCollectionFromFile::execute ( )

overridevirtual

Definition at line 61 of file CreateLumiBlockCollectionFromFile.cxx.

{
  ATH_MSG_VERBOSE( "execute()" );
 
  // Check for event header
  SG::ReadHandle<xAOD::EventInfo> evt(m_eventInfoKey);
 
  // check is only useful for serial running; remove when MT scheduler used
  if(!evt.isValid()) {
    ATH_MSG_FATAL("Failed to retrieve "<< m_eventInfoKey.key());
    return StatusCode::FAILURE;
  }
 
  if(m_lastRun!=evt->runNumber() ||
     m_lastLumiBlock!=evt->lumiBlock()) {
 
    IOVTime iovtime(evt->runNumber(),evt->lumiBlock());
    RLBMap::iterator mitr;
    mitr=m_LumiBlockInfo.find(iovtime);
    if (mitr==m_LumiBlockInfo.end()) {
      uint32_t nEvents = getNEventsFromDb();
      ATH_MSG_INFO( "Fill LumiBlockInfo with NEvents="<<nEvents);
      inOut lbInOut(nEvents,1);
      m_LumiBlockInfo[iovtime] = lbInOut;
    }
    else {
      m_LumiBlockInfo[iovtime].second++;
    }
 
    m_lastRun=evt->runNumber();
    m_lastLumiBlock=evt->lumiBlock();
    m_lastIOVTime=iovtime;
  }
  else {
    m_LumiBlockInfo[m_lastIOVTime].second++;
  }
  
  return StatusCode::SUCCESS;
}

extraDeps_update_handler()

void AthCommonDataStore< AthCommonMsg< Algorithm > >::extraDeps_update_handler ( Gaudi::Details::PropertyBase &  ExtraDeps )

protectedinherited

Add StoreName to extra input/output deps as needed.

use the logic of the VarHandleKey to parse the DataObjID keys supplied via the ExtraInputs and ExtraOuputs Properties to add the StoreName if it's not explicitly given

extraOutputDeps()

const DataObjIDColl & AthAlgorithm::extraOutputDeps ( ) const

overridevirtualinherited

Return the list of extra output dependencies.

This list is extended to include symlinks implied by inheritance relations.

Definition at line 50 of file AthAlgorithm.cxx.

{
  // If we didn't find any symlinks to add, just return the collection
  // from the base class.  Otherwise, return the extended collection.
  if (!m_extendedExtraObjects.empty()) {
    return m_extendedExtraObjects;
  }
  return Algorithm::extraOutputDeps();
}

fillLumiBlockCollection()

StatusCode CreateLumiBlockCollectionFromFile::fillLumiBlockCollection ( )

private

Fill metaDataStore and ntuples.

Definition at line 112 of file CreateLumiBlockCollectionFromFile.cxx.

{
  // Create the LumiBlockCollection
 
  std::unique_ptr<xAOD::LumiBlockRangeContainer> piovComplete = std::make_unique<xAOD::LumiBlockRangeContainer>();
  std::unique_ptr<xAOD::LumiBlockRangeAuxContainer> piovCompleteAux = std::make_unique<xAOD::LumiBlockRangeAuxContainer>();
  piovComplete->setStore( piovCompleteAux.get() );
 
  std::unique_ptr<xAOD::LumiBlockRangeContainer> piovUnfinished = std::make_unique<xAOD::LumiBlockRangeContainer>();
  std::unique_ptr<xAOD::LumiBlockRangeAuxContainer> piovUnfinishedAux = std::make_unique<xAOD::LumiBlockRangeAuxContainer>();
  piovUnfinished->setStore( piovUnfinishedAux.get() );
 
  std::unique_ptr<xAOD::LumiBlockRangeContainer> piovSuspect = std::make_unique<xAOD::LumiBlockRangeContainer>();
  std::unique_ptr<xAOD::LumiBlockRangeAuxContainer> piovSuspectAux = std::make_unique<xAOD::LumiBlockRangeAuxContainer>();
  piovSuspect->setStore( piovSuspectAux.get() );
 
  for (std::pair<const IOVTime, inOut>& p : m_LumiBlockInfo) {
    xAOD::LumiBlockRange* iovr = new xAOD::LumiBlockRange();
 
    // Decide which collection it goes into depending on whether the LB is complete
    // =============================================================================
    // Suspect LB's have more events read than the DB says should be there
    if(!m_checkEventsExpected || p.second.second == p.second.first) {
      piovComplete->push_back(iovr);
    }
    else if(p.second.second > p.second.first) {
      piovSuspect->push_back(iovr);
    }
    else {
      piovUnfinished->push_back(iovr);
    }
    iovr->setStartRunNumber(p.first.run());
    iovr->setStartLumiBlockNumber(p.first.event());
    iovr->setStopRunNumber(p.first.run());
    iovr->setStopLumiBlockNumber(p.first.event());
    iovr->setEventsExpected(p.second.first);
    iovr->setEventsSeen(p.second.second);
  }
 
  if(!piovComplete->empty()) {
    ATH_MSG_INFO( "Number of Complete LumiBlocks:" << piovComplete->size() );
    for(const xAOD::LumiBlockRange* lbr : *piovComplete) {
      ATH_MSG_INFO("\t [ ("
           << lbr->startRunNumber()  << "," << lbr->startLumiBlockNumber()
           << "):("
           << lbr->startRunNumber()  << "," << lbr->startLumiBlockNumber()
           << ") eventsSeen = " << lbr->eventsSeen()
           << ", eventsExpected = " << lbr->eventsExpected()
           << " ]");
    }
  }
 
  if(!piovUnfinished->empty()) {
    ATH_MSG_INFO( "Number of Unfinished LumiBlocks:" << piovUnfinished->size() );
    for(const xAOD::LumiBlockRange* lbr : *piovUnfinished) {
      ATH_MSG_INFO("\t [ ("
           << lbr->startRunNumber()  << "," << lbr->startLumiBlockNumber()
           << "):("
           << lbr->startRunNumber()  << "," << lbr->startLumiBlockNumber()
           << ") eventsSeen = " << lbr->eventsSeen()
           << ", eventsExpected = " << lbr->eventsExpected()
           << " ]");
    }
  }
 
  if(!piovSuspect->empty()) {
    ATH_MSG_INFO( "Number of Suspect LumiBlocks:"  << piovSuspect->size() );
    for(const xAOD::LumiBlockRange* lbr : *piovSuspect) {
      ATH_MSG_INFO("\t [ ("
           << lbr->startRunNumber()  << "," << lbr->startLumiBlockNumber()
           << "):("
           << lbr->startRunNumber()  << "," << lbr->startLumiBlockNumber()
           << ") eventsSeen = " << lbr->eventsSeen()
           << ", eventsExpected = " << lbr->eventsExpected()
           << " ]");
    }
  }
 
  // Store the LumiBlockCollection in the metadata store
  // =======================================================
  if(!piovComplete->empty()) {
    ATH_CHECK( m_metaStore->record( std::move(piovComplete), m_LBColl_name ) );
    ATH_CHECK( m_metaStore->record( std::move(piovCompleteAux), m_LBColl_name + "Aux." ) );
  }
  
  if(!piovUnfinished->empty()) {
    ATH_CHECK( m_metaStore->record( std::move(piovUnfinished), m_unfinishedLBColl_name ) );
    ATH_CHECK( m_metaStore->record( std::move(piovUnfinishedAux), m_unfinishedLBColl_name + "Aux." ) );
  }
 
  if(!piovSuspect->empty()) {
    ATH_CHECK( m_metaStore->record( std::move(piovSuspect), m_suspectLBColl_name ) );
    ATH_CHECK( m_metaStore->record( std::move(piovSuspectAux), m_suspectLBColl_name + "Aux." ) );
  }
  
  // Then clear m_LumiBlockInfo.  This is in case we decide to store the 
  // LBColl separately for each input or output file. 
  m_LumiBlockInfo.clear();
  return StatusCode::SUCCESS;
}

finalize()

StatusCode CreateLumiBlockCollectionFromFile::finalize ( )

overridevirtual

Definition at line 103 of file CreateLumiBlockCollectionFromFile.cxx.

{
  ATH_MSG_VERBOSE( "finalize()" );
  return StatusCode::SUCCESS;
}

getNEventsFromDb()

uint32_t CreateLumiBlockCollectionFromFile::getNEventsFromDb ( )

private

Definition at line 231 of file CreateLumiBlockCollectionFromFile.cxx.

{
  uint32_t nEvents{0};
 
  if (m_streamName.empty()) return nEvents;
 
  SG::ReadCondHandle<CondAttrListCollection> attrListColl(m_rchk);
 
  CondAttrListCollection::const_iterator it = attrListColl->begin();
  CondAttrListCollection::const_iterator last  = attrListColl->end();
  CondAttrListCollection::const_iterator match  = attrListColl->end();
  for (; it != last; ++it) {
    if (attrListColl->name_size()>0) {
      CondAttrListCollection::name_const_iterator nitr=attrListColl->chanNamePair((*it).first);
      int chan = (*it).first;
      std::string theName = nitr->second;        
      ATH_MSG_INFO( "channel " << chan << " name " << theName);
      if(theName==m_streamName) {
        match=it;
        break;
      }         
    }
  }
  // Make sure we found it
  if (match == last) {
    ATH_MSG_INFO( "Stream " << m_streamName << " not found in /GLOBAL/FILECOUNT/PROMPT !" );
    return nEvents;
  }
 
  // OK, get number of events
  const coral::AttributeList& attrList = (*match).second;
 
  // Check data availability
  if (attrList["NEventRec"].isNull()) {
    ATH_MSG_INFO( " NEventRec not in database. Set it to 0 " );
    return nEvents;
  }
 
  cool::Int32 nev = attrList["NEventRec"].data<cool::Int32>();
  nEvents = (uint32_t) nev;
  ATH_MSG_INFO( "database returns NEventRec=" << nev );
 
  return nEvents;
}

handle()

void CreateLumiBlockCollectionFromFile::handle ( const Incident &  incident )

overridevirtual

Incident service handle listening for MetaDataStop.

Definition at line 215 of file CreateLumiBlockCollectionFromFile.cxx.

{
  if(inc.type() == "MetaDataStop") {
    ATH_MSG_INFO(  " finishUp: write lumiblocks to meta data store " );
    if(!m_LumiBlockInfo.empty()) {
      if(fillLumiBlockCollection().isFailure()) {
    ATH_MSG_ERROR( "Could not fill lumiblock collections" );
      }
    }
  }
  else {
    ATH_MSG_INFO( "Unknown Incident: " << inc.type() );
  }
}

initialize()

StatusCode CreateLumiBlockCollectionFromFile::initialize ( )

overridevirtual

Definition at line 28 of file CreateLumiBlockCollectionFromFile.cxx.

{
  ATH_MSG_INFO( "initialize() and create listeners" );
 
  ATH_CHECK(m_eventInfoKey.initialize());
  ATH_CHECK(m_rchk.initialize(!m_streamName.empty()));
 
  ATH_CHECK( m_metaStore.retrieve() );
 
  // Set to be listener for MetaDataStop
  ServiceHandle<IIncidentSvc> incSvc("IncidentSvc", this->name());
  ATH_CHECK( incSvc.retrieve() );
  incSvc->addListener(this, "MetaDataStop", 50); // pri has to be > 20 to be 
                                                 // before MetaDataSvc and AthenaOutputStream.
 
  ServiceHandle<IIoComponentMgr> ioMgr("IoComponentMgr", this->name());
  ATH_CHECK( ioMgr.retrieve() );
  if (!ioMgr->io_register(this).isSuccess()) {
    ATH_MSG_FATAL("Could not register myself with the IoComponentMgr");
    return(StatusCode::FAILURE);
  }
  
  m_LumiBlockInfo.clear();
 
  if(m_streamName.empty()) {
    ATH_MSG_INFO( "No streamName specified" );
  }
 
  return StatusCode::SUCCESS;
}

inputHandles()

virtual std::vector<Gaudi::DataHandle*> AthCommonDataStore< AthCommonMsg< Algorithm > >::inputHandles ( ) const

overridevirtualinherited

Return this algorithm's input handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

io_reinit()

StatusCode CreateLumiBlockCollectionFromFile::io_reinit ( )

overridevirtual

Callback method to reinitialize the internal state of the component for I/O purposes (e.g. upon fork(2))

Definition at line 277 of file CreateLumiBlockCollectionFromFile.cxx.

                                                        {
  ATH_MSG_INFO("I/O reinitialization...");
  m_LumiBlockInfo.clear();
  m_lastRun = 9999999;
  m_lastLumiBlock = 9999999;
 
  return StatusCode::SUCCESS;
}

msg() [1/2]

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

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                {
    return this->msgStream();
  }

msg() [2/2]

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

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                  {
    return this->msgStream(lvl);
  }

msgLvl()

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

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                               {
    return this->msgLevel(lvl);
  }

outputHandles()

virtual std::vector<Gaudi::DataHandle*> AthCommonDataStore< AthCommonMsg< Algorithm > >::outputHandles ( ) const

overridevirtualinherited

Return this algorithm's output handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

renounce()

std::enable_if_t<std::is_void_v<std::result_of_t<decltype(&T::renounce)(T)> > && !std::is_base_of_v<SG::VarHandleKeyArray, T> && std::is_base_of_v<Gaudi::DataHandle, T>, void> AthCommonDataStore< AthCommonMsg< Algorithm > >::renounce ( T &  h )

inlineprotectedinherited

Definition at line 380 of file AthCommonDataStore.h.

  {
    h.renounce();
    PBASE::renounce (h);
  }

renounceArray()

void AthCommonDataStore< AthCommonMsg< Algorithm > >::renounceArray ( SG::VarHandleKeyArray &  handlesArray )

inlineprotectedinherited

remove all handles from I/O resolution

Definition at line 364 of file AthCommonDataStore.h.

                                                          {
    handlesArray.renounce();
  }

sysInitialize()

StatusCode AthAlgorithm::sysInitialize ( )

overridevirtualinherited

Override sysInitialize.

Override sysInitialize from the base class.

Loop through all output handles, and if they're WriteCondHandles, automatically register them and this Algorithm with the CondSvc

Scan through all outputHandles, and if they're WriteCondHandles, register them with the CondSvc

Reimplemented from AthCommonDataStore< AthCommonMsg< Algorithm > >.

Reimplemented in AthAnalysisAlgorithm, AthFilterAlgorithm, PyAthena::Alg, and AthHistogramAlgorithm.

Definition at line 66 of file AthAlgorithm.cxx.

                                       {
  StatusCode sc=AthCommonDataStore<AthCommonMsg<Algorithm>>::sysInitialize();
 
  if (sc.isFailure()) {
    return sc;
  }
  ServiceHandle<ICondSvc> cs("CondSvc",name());
  for (auto h : outputHandles()) {
    if (h->isCondition() && h->mode() == Gaudi::DataHandle::Writer) {
      // do this inside the loop so we don't create the CondSvc until needed
      if ( cs.retrieve().isFailure() ) {
        ATH_MSG_WARNING("no CondSvc found: won't autoreg WriteCondHandles");
        return StatusCode::SUCCESS;
      }
      if (cs->regHandle(this,*h).isFailure()) {
        sc = StatusCode::FAILURE;
        ATH_MSG_ERROR("unable to register WriteCondHandle " << h->fullKey()
                      << " with CondSvc");
      }
    }
  }
  return sc;
}

sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< Algorithm > >::sysStart ( )

overridevirtualinherited

Handle START transition.

We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.

updateVHKA()

void AthCommonDataStore< AthCommonMsg< Algorithm > >::updateVHKA ( Gaudi::Details::PropertyBase &  )

inlineinherited

Definition at line 308 of file AthCommonDataStore.h.

                                               {
    // debug() << "updateVHKA for property " << p.name() << " " << p.toString() 
    //         << "  size: " << m_vhka.size() << endmsg;
    for (auto &a : m_vhka) {
      std::vector<SG::VarHandleKey*> keys = a->keys();
      for (auto k : keys) {
        k->setOwner(this);
      }
    }
  }

Member Data Documentation

m_checkEventsExpected

Gaudi::Property<bool> CreateLumiBlockCollectionFromFile::m_checkEventsExpected

private

Initial value:

{this
      ,"checkEventsExpected"
      ,true
      ,"Should we read the database?"}

Definition at line 89 of file CreateLumiBlockCollectionFromFile.h.

m_detStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Algorithm > >::m_detStore

privateinherited

Pointer to StoreGate (detector store by default)

Definition at line 393 of file AthCommonDataStore.h.

m_eventInfoKey

SG::ReadHandleKey<xAOD::EventInfo> CreateLumiBlockCollectionFromFile::m_eventInfoKey

private

Initial value:

{this
      ,"EventInfoKey"
      ,"EventInfo"
      ,"RHK for EventInfo"}

Definition at line 59 of file CreateLumiBlockCollectionFromFile.h.

m_evtStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Algorithm > >::m_evtStore

privateinherited

Pointer to StoreGate (event store by default)

Definition at line 390 of file AthCommonDataStore.h.

m_extendedExtraObjects

DataObjIDColl AthAlgorithm::m_extendedExtraObjects

privateinherited

Definition at line 79 of file AthAlgorithm.h.

m_lastIOVTime

IOVTime CreateLumiBlockCollectionFromFile::m_lastIOVTime

private

Definition at line 102 of file CreateLumiBlockCollectionFromFile.h.

m_lastLumiBlock

uint32_t CreateLumiBlockCollectionFromFile::m_lastLumiBlock

private

Definition at line 101 of file CreateLumiBlockCollectionFromFile.h.

m_lastRun

uint32_t CreateLumiBlockCollectionFromFile::m_lastRun

private

Definition at line 100 of file CreateLumiBlockCollectionFromFile.h.

m_LBColl_name

Gaudi::Property<std::string> CreateLumiBlockCollectionFromFile::m_LBColl_name

private

Initial value:

{this
      ,"LBCollName"
      ,"LumiBlocks"
      ,"Complete LumiBlock collection name"}

Definition at line 74 of file CreateLumiBlockCollectionFromFile.h.

m_LumiBlockInfo

RLBMap CreateLumiBlockCollectionFromFile::m_LumiBlockInfo

private

Definition at line 98 of file CreateLumiBlockCollectionFromFile.h.

m_metaStore

ServiceHandle<StoreGateSvc> CreateLumiBlockCollectionFromFile::m_metaStore

private

Definition at line 104 of file CreateLumiBlockCollectionFromFile.h.

m_rchk

SG::ReadCondHandleKey<CondAttrListCollection> CreateLumiBlockCollectionFromFile::m_rchk

private

Initial value:

{this
      ,"GlobalFileCountKey"
      ,"/GLOBAL/FILECOUNT/PROMPT"
      ,"RCHK for condition data" }

Definition at line 64 of file CreateLumiBlockCollectionFromFile.h.

m_streamName

Gaudi::Property<std::string> CreateLumiBlockCollectionFromFile::m_streamName

private

Initial value:

{this
      ,"streamName"
      ,""
      ,"Stream name"}

Definition at line 69 of file CreateLumiBlockCollectionFromFile.h.

m_suspectLBColl_name

Gaudi::Property<std::string> CreateLumiBlockCollectionFromFile::m_suspectLBColl_name

private

Initial value:

{this
      ,"suspectLBCollName"
      ,"SuspectLumiBlocks"
      ,"Suspicious LumiBlock collection name"}

Definition at line 84 of file CreateLumiBlockCollectionFromFile.h.

m_unfinishedLBColl_name

Gaudi::Property<std::string> CreateLumiBlockCollectionFromFile::m_unfinishedLBColl_name

private

Initial value:

{this
      ,"unfinishedLBCollName"
      ,"IncompleteLumiBlocks"
      ,"Incomplete LumiBlock collection name"}

Definition at line 79 of file CreateLumiBlockCollectionFromFile.h.

m_varHandleArraysDeclared

bool AthCommonDataStore< AthCommonMsg< Algorithm > >::m_varHandleArraysDeclared

privateinherited

Definition at line 399 of file AthCommonDataStore.h.

m_vhka

std::vector<SG::VarHandleKeyArray*> AthCommonDataStore< AthCommonMsg< Algorithm > >::m_vhka

privateinherited

Definition at line 398 of file AthCommonDataStore.h.

---

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

• CreateLumiBlockCollectionFromFile.h
• CreateLumiBlockCollectionFromFile.cxx