#include <RecoLuminosity/LumiProducer/src/ExpressLumiProducer.cc>

Inheritance diagram for ExpressLumiProducer:

Classes
struct	PerLSData

Public Member Functions
	ExpressLumiProducer (const edm::ParameterSet &)

	~ExpressLumiProducer () override

Public Member Functions inherited from edm::one::EDProducer< edm::BeginLuminosityBlockProducer >
	EDProducer ()=default

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

bool	hasAbilityToProduceInLumis () const final

bool	hasAbilityToProduceInRuns () const final

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

Public Member Functions inherited from edm::one::EDProducerBase
	EDProducerBase ()

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~EDProducerBase () override

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

	~ProducerBase () noexcept(false) override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

virtual	~EDConsumerBase () noexcept(false)

Private Member Functions
void	beginLuminosityBlockProduce (edm::LuminosityBlock &iLBlock, edm::EventSetup const &iSetup) final

void	fillLSCache (unsigned int runnum, unsigned int luminum)

bool	fillLumi (edm::LuminosityBlock &iLBlock)

unsigned int	maxavailableLSforRun (coral::ISchema &schema, const std::string &tablename, unsigned int runnumber)

void	produce (edm::Event &, const edm::EventSetup &) final

void	writeEmptyProductForEntry (edm::LuminosityBlock &iLBlock)

void	writeProductsForEntry (edm::LuminosityBlock &iLBlock, unsigned int luminum)

Private Attributes
unsigned int	m_cachedrun

unsigned int	m_cachesize

std::string	m_connectStr

bool	m_isNullRun

std::map< unsigned int, PerLSData >	m_lscache

Additional Inherited Members
Public Types inherited from edm::one::EDProducerBase
typedef EDProducerBase	ModuleType

Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const , const char , edm::ProductResolverIndex >>

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Static Public Member Functions inherited from edm::one::EDProducerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<typename ESProduct , Transition Tr = Transition::Event>
auto	esConsumes (eventsetup::EventSetupRecordKey const &, ESInputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

Detailed Description

Description: A essource/esproducer for lumi values from DIP via runtime logger DB

Definition at line 61 of file ExpressLumiProducer.cc.

Constructor & Destructor Documentation

ExpressLumiProducer::ExpressLumiProducer ( const edm::ParameterSet & )

explicit

ExpressLumiProducer::~ExpressLumiProducer ( )

override

Definition at line 110 of file ExpressLumiProducer.cc.

110 {

111 }

Member Function Documentation

void ExpressLumiProducer::beginLuminosityBlockProduce	(	edm::LuminosityBlock &	iLBlock,
		edm::EventSetup const &	iSetup
	)

finalprivate

Definition at line 127 of file ExpressLumiProducer.cc.

References edm::LuminosityBlockBase::luminosityBlock(), edm::LuminosityBlockBase::run(), and findQualityFiles::v.

 {
   unsigned int currentrun=iLBlock.run();
   unsigned int currentls=iLBlock.luminosityBlock();
   //if is null run, fill empty values and return
   if(m_isNullRun){
     writeEmptyProductForEntry(iLBlock);
     return;
   }
   if(m_cachedrun!=currentrun){
     fillLSCache(currentrun,currentls);
   }else{
     if(m_lscache.find(currentls)==m_lscache.end()){
       //if runnumber is cached but LS is not, this is the first LS, fill LS cache to full capacity
       fillLSCache(currentrun,currentls);
     }
   }
   if( m_lscache.empty() ){
     writeEmptyProductForEntry(iLBlock);
     return;
   }
   unsigned int lstowriteout=0;
   if(m_lscache.find(currentls)==m_lscache.end()){//if the currentls is not in the cache
     std::vector<unsigned int> v;
     for(std::map<unsigned int,ExpressLumiProducer::PerLSData >::iterator it=m_lscache.begin();it!=m_lscache.end();++it){
       v.push_back(it->first);
     }
     lstowriteout=v.back();//last available
   }else{//if the current ls is cached
     lstowriteout=currentls;
   }
   //here the presence of ls is guaranteed
   //std::cout<<"writing "<<runnumber<<" "<<luminum<<std::endl;
   if(lstowriteout==0){
     writeEmptyProductForEntry(iLBlock);
   }else{
     writeProductsForEntry(iLBlock,lstowriteout); 
   }
 }

void ExpressLumiProducer::fillLSCache	(	unsigned int	runnum,
		unsigned int	luminum
	)

private

Definition at line 194 of file ExpressLumiProducer.cc.

                                                                                 {
   m_lscache.clear();
   m_cachedrun=runnumber;
   //
   //queries once per cache refill
   //
   //select lumisection,instlumi,delivlumi,livelumi from cms_runtime_logger.lumi_sections where lumisection>=:lsmin and lumisection<:lsmax and runnumber=:runnumber;
   //
   edm::Service<lumi::service::DBService> mydbservice;
   if( !mydbservice.isAvailable() ){
     throw cms::Exception("Non existing service lumi::service::DBService");
   }
   auto session=mydbservice->connectReadOnly(m_connectStr);
   coral::ITypeConverter& tconverter=session->typeConverter();
   tconverter.setCppTypeForSqlType(std::string("float"),std::string("FLOAT(63)"));
   tconverter.setCppTypeForSqlType(std::string("unsigned int"),std::string("NUMBER(10)"));
   tconverter.setCppTypeForSqlType(std::string("unsigned short"),std::string("NUMBER(1)"));
   unsigned int lsmin=1;
   unsigned int lsmax=currentlsnum;
   try{
     session->transaction().start(true);
     coral::ISchema& schema=session->nominalSchema();
     unsigned int maxavailableLS=maxavailableLSforRun(schema,std::string("LUMI_SECTIONS"),m_cachedrun);
     if(maxavailableLS!=0 && maxavailableLS<currentlsnum){
       lsmax=maxavailableLS;
     }else if(maxavailableLS==0){
       //this run not existing (yet)
       session->transaction().commit();
       return;
     }
     if(m_cachesize!=0){
       lsmin=(lsmax-m_cachesize)>0 ? (lsmax-m_cachesize+1) : 1;
     }
     for(unsigned int n=lsmin;n<=lsmax;++n){
       PerLSData l;
       std::vector<float> mytmp(3564,0.0);
       l.bunchlumivalue.swap(mytmp);
       std::vector<float> myerrtmp(3564,0.0);
       l.bunchlumierror.swap(myerrtmp);
       std::vector<short> myqtmp(3564,0);
       l.bunchlumiquality.swap(myqtmp);
       m_lscache.insert(std::make_pair(n,l));
     }
  
     coral::AttributeList lumisummaryBindVariables;
     lumisummaryBindVariables.extend("lsmin",typeid(unsigned int));
     lumisummaryBindVariables.extend("runnumber",typeid(unsigned int));
     lumisummaryBindVariables["runnumber"].data<unsigned int>()=m_cachedrun;
     lumisummaryBindVariables["lsmin"].data<unsigned int>()=lsmin;
     std::string conditionStr(" RUNNUMBER=:runnumber AND LUMISECTION>=:lsmin ");
     coral::AttributeList lumisummaryOutput;
     lumisummaryOutput.extend("LUMISECTION",typeid(unsigned int));
     lumisummaryOutput.extend("INSTLUMI",typeid(float));
     lumisummaryOutput.extend("DELIVLUMISECTION",typeid(float));
     lumisummaryOutput.extend("LIVELUMISECTION",typeid(float));
     lumisummaryOutput.extend("STARTORBIT",typeid(unsigned long long));
     if(m_cachesize!=0){
       lumisummaryBindVariables.extend("lsmax",typeid(unsigned int));
       conditionStr=conditionStr+"AND LUMISECTION<=:lsmax";
       lumisummaryBindVariables["lsmax"].data<unsigned int>()=lsmax;      
     }
     coral::IQuery* lumisummaryQuery=schema.newQuery();
     lumisummaryQuery->addToTableList(std::string("LUMI_SECTIONS"));
     lumisummaryQuery->addToOutputList("LUMISECTION");
     lumisummaryQuery->addToOutputList("INSTLUMI");
     lumisummaryQuery->addToOutputList("DELIVLUMISECTION");
     lumisummaryQuery->addToOutputList("LIVELUMISECTION");
     lumisummaryQuery->addToOutputList("STARTORBIT");
     lumisummaryQuery->setCondition(conditionStr,lumisummaryBindVariables);
     lumisummaryQuery->defineOutput(lumisummaryOutput);
     coral::ICursor& lumisummarycursor=lumisummaryQuery->execute();
     unsigned int rowcounter=0;
     while( lumisummarycursor.next() ){
       const coral::AttributeList& row=lumisummarycursor.currentRow();
       unsigned int lsnum=row["LUMISECTION"].data<unsigned int>();
       float instlumi=0.0;
       if(!row["INSTLUMI"].isNull()){
     instlumi=row["INSTLUMI"].data<float>();//Hz/ub
       }
       float deadfrac=1.0;
       float intgdellumi=0.0;
       float intgreclumi=0.0;
       unsigned long long startorbit=0;
       if(!row["DELIVLUMISECTION"].isNull()){
     intgdellumi=row["DELIVLUMISECTION"].data<float>()*1000.0;//convert to /ub
       }
       if(!row["LIVELUMISECTION"].isNull()){
     intgreclumi=row["LIVELUMISECTION"].data<float>()*1000.0;//convert to /ub
       }
       if(intgdellumi>0){
     deadfrac=1.0-intgreclumi/intgdellumi;
       }
       if(!row["STARTORBIT"].isNull()){
     startorbit=row["STARTORBIT"].data<unsigned long long>();//convert to /ub
       }
       unsigned long long deadcount=deadfrac*10000.0;
       unsigned long long bitzerocount=10000.0;
       PerLSData& lsdata=m_lscache[lsnum];
       lsdata.lsnum=lsnum;
       lsdata.lumivalue=instlumi; 
       lsdata.deadcount=deadcount;
       lsdata.bitzerocount=bitzerocount;
       lsdata.startorbit=startorbit;
       lsdata.numorbit=262144;
       ++rowcounter;
     }
     if (rowcounter==0){
       m_isNullRun=true;
     }
     delete lumisummaryQuery;
     if(m_isNullRun) return;
     //
     //queries once per cache refill
     //
     //select lumisection,bunch,bunchlumi from cms_runtime_logger.bunch_lumi_sections where lumisection>=:lsmin and lumisection<:lsmax and runnumber=:runnumber;
     //
     coral::AttributeList lumidetailBindVariables;
     lumidetailBindVariables.extend("lsmin",typeid(unsigned int));
     lumidetailBindVariables.extend("runnumber",typeid(unsigned int));
     lumidetailBindVariables["runnumber"].data<unsigned int>()=m_cachedrun;
     lumidetailBindVariables["lsmin"].data<unsigned int>()=lsmin;
     std::string detailconditionStr(" RUNNUMBER=:runnumber AND LUMISECTION>=:lsmin AND BUNCHLUMI>0 ");
     coral::AttributeList lumidetailOutput;
     lumidetailOutput.extend("LUMISECTION",typeid(unsigned int));
     lumidetailOutput.extend("BUNCH",typeid(unsigned int));
     lumidetailOutput.extend("BUNCHLUMI",typeid(float));
     if(m_cachesize!=0){
       lumidetailBindVariables.extend("lsmax",typeid(unsigned int));
       detailconditionStr=detailconditionStr+"AND LUMISECTION<=:lsmax";
       lumidetailBindVariables["lsmax"].data<unsigned int>()=lsmax;      
     }
     coral::IQuery* lumidetailQuery=schema.newQuery();
     lumidetailQuery->addToTableList(std::string("BUNCH_LUMI_SECTIONS"));
     lumidetailQuery->addToOutputList("LUMISECTION");
     lumidetailQuery->addToOutputList("BUNCH");
     lumidetailQuery->addToOutputList("BUNCHLUMI");
     lumidetailQuery->setCondition(detailconditionStr,lumidetailBindVariables);
     lumidetailQuery->defineOutput(lumidetailOutput);
     coral::ICursor& lumidetailcursor=lumidetailQuery->execute();
     while( lumidetailcursor.next() ){
       const coral::AttributeList& row=lumidetailcursor.currentRow();
       unsigned int lsnum=row["LUMISECTION"].data<unsigned int>();
       unsigned int bxidx=row["BUNCH"].data<unsigned int>();
       float bxlumi=row["BUNCHLUMI"].data<float>();//Hz/ub
       m_lscache[lsnum].bunchlumivalue[bxidx]=bxlumi;
     }
     delete lumidetailQuery;
     session->transaction().commit();
   }catch(const coral::Exception& er){
     session->transaction().rollback();
     throw cms::Exception("DatabaseError ")<<er.what();
   }
 }

bool ExpressLumiProducer::fillLumi ( edm::LuminosityBlock & iLBlock )

private

unsigned int ExpressLumiProducer::maxavailableLSforRun	(	coral::ISchema &	schema,
		const std::string &	tablename,
		unsigned int	runnumber
	)

private

select max(lumisection) as maxavailable from cms_runtime_logger.lumi_sections where runnumber=:runnumber;

Definition at line 168 of file ExpressLumiProducer.cc.

References mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                               {
   unsigned int result=0;
   coral::AttributeList bindVariables;
   bindVariables.extend("runnumber",typeid(unsigned int));
   bindVariables["runnumber"].data<unsigned int>()=runnumber;
   std::string conditionStr("RUNNUMBER=:runnumber");
   coral::AttributeList MyOutput;
   MyOutput.extend("maxavailablels",typeid(unsigned int));
   coral::IQuery* myQuery=schema.newQuery();
   myQuery->addToTableList(tablename);
   myQuery->addToOutputList("max(LUMISECTION)","maxavailablels");
   myQuery->setCondition(conditionStr,bindVariables);
   myQuery->defineOutput(MyOutput);
   coral::ICursor& mycursor=myQuery->execute();
   while( mycursor.next() ){
     const coral::AttributeList& row=mycursor.currentRow();
     if(!row["maxavailablels"].isNull()){
       result=row["maxavailablels"].data<unsigned int>();
     }
   }
   return result;
 }

void ExpressLumiProducer::produce	(	edm::Event &	e,
		const edm::EventSetup &	iSetup
	)

finalprivate

Definition at line 117 of file ExpressLumiProducer.cc.

118 {

119 }

void ExpressLumiProducer::writeEmptyProductForEntry ( edm::LuminosityBlock & iLBlock )

private

Definition at line 122 of file ExpressLumiProducer.cc.

References edm::LuminosityBlock::put().

                                                                          {
   iLBlock.put(std::make_unique<LumiSummary>());
   iLBlock.put(std::make_unique<LumiDetails>());
 }

void ExpressLumiProducer::writeProductsForEntry	(	edm::LuminosityBlock &	iLBlock,
		unsigned int	luminum
	)

private

Definition at line 348 of file ExpressLumiProducer.cc.

                                                                                            {
   //std::cout<<"writing runnumber,luminum "<<runnumber<<" "<<luminum<<std::endl;
   auto pIn1 = std::make_unique<LumiSummary>();
   auto pIn2 = std::make_unique<LumiDetails>();
   if(m_isNullRun){
     pIn1->setLumiVersion("DIP");
     pIn2->setLumiVersion("DIP");
     iLBlock.put(std::move(pIn1));
     iLBlock.put(std::move(pIn2));
     return;
   }
   PerLSData& lsdata=m_lscache[luminum];
   pIn1->setLumiVersion("DIP");
   pIn1->setLumiData(lsdata.lumivalue,0.0,0.0);
   pIn1->setDeadCount(lsdata.deadcount);
   pIn1->setBitZeroCount(lsdata.bitzerocount);
   pIn1->setlsnumber(lsdata.lsnum);
   pIn1->setOrbitData(lsdata.startorbit,lsdata.numorbit);
 
   pIn2->setLumiVersion("DIP");
   pIn2->fill(LumiDetails::kOCC1,lsdata.bunchlumivalue,lsdata.bunchlumierror,lsdata.bunchlumiquality);
   iLBlock.put(std::move(pIn1));
   iLBlock.put(std::move(pIn2));
 }

Member Data Documentation

unsigned int ExpressLumiProducer::m_cachedrun

private

Definition at line 93 of file ExpressLumiProducer.cc.

unsigned int ExpressLumiProducer::m_cachesize

private

Definition at line 95 of file ExpressLumiProducer.cc.

std::string ExpressLumiProducer::m_connectStr

private

Definition at line 92 of file ExpressLumiProducer.cc.

bool ExpressLumiProducer::m_isNullRun

private

Definition at line 94 of file ExpressLumiProducer.cc.

std::map< unsigned int,PerLSData > ExpressLumiProducer::m_lscache

private

Definition at line 96 of file ExpressLumiProducer.cc.

Classes

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation