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

Inheritance diagram for LumiProducer:

Classes
struct	HLTData

struct	L1Data

struct	PerLSData

struct	PerRunData

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

	~LumiProducer () override

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

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndRuns () 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

std::vector< bool > const &	recordProvenanceList () 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)

TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...

	~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 &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

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 &	operator= (EDConsumerBase &&)=default

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

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

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

void	beginRun (edm::Run const &, edm::EventSetup const &) final

void	endRun (edm::Run const &, edm::EventSetup const &) final

void	endRunProduce (edm::Run &, edm::EventSetup const &) final

void	fillLSCache (unsigned int luminum)

bool	fillLumi (edm::LuminosityBlock &iLBlock)

void	fillRunCache (const coral::ISchema &schema, unsigned int runnumber)

std::string	getCurrentDataTag (const coral::ISchema &schema)

unsigned long long	getHltDataId (const coral::ISchema &schema, unsigned int runnumber)

unsigned long long	getLumiDataId (const coral::ISchema &schema, unsigned int runnumber)

unsigned long long	getTrgDataId (const coral::ISchema &schema, unsigned int runnumber)

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

XMLCh *	s2x (const std::string &input) const

const std::string	servletTranslation (const std::string &servlet) const

std::string	toParentString (const xercesc::DOMNode &nodeToConvert) const

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

std::string	x2s (const XMLCh *input) const

Private Attributes
unsigned long long	m_cachedhltdataid

unsigned long long	m_cachedlumidataid

unsigned int	m_cachedrun

unsigned long long	m_cachedtrgdataid

unsigned int	m_cachesize

std::string	m_connectStr

bool	m_isNullRun

std::map< unsigned int, PerLSData >	m_lscache

std::string	m_lumiversion

PerRunData	m_runcache

std::string	m_siteconfpath

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::ProducerBase
template<class ProductType >
BranchAliasSetterT< ProductType >	produces ()
	declare what type of product will make and with which optional label More...

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces ()

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces ()

BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<BranchType B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<Transition B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<class ProductType >
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

ProducesCollector	producesCollector ()

Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (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)

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

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

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

Detailed Description

Description: This class would load the luminosity object into a Luminosity Block

Implementation: The are two main steps, the first one retrieve the record of the luminosity data from the DB and the second loads the Luminosity Obj into the Lumi Block. (Actually in the initial implementation it is retrieving from the ParameterSet from the configuration file, the DB is not implemented yet)

Definition at line 80 of file LumiProducer.cc.

Constructor & Destructor Documentation

◆ LumiProducer()

LumiProducer::LumiProducer ( const edm::ParameterSet & )

explicit

◆ ~LumiProducer()

LumiProducer::~LumiProducer ( )

override

Definition at line 283 of file LumiProducer.cc.

283 {}

Member Function Documentation

◆ beginLuminosityBlockProduce()

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

finalprivate

Definition at line 425 of file LumiProducer.cc.

                                                                                                        {
   unsigned int runnumber = iLBlock.run();
   unsigned int luminum = iLBlock.luminosityBlock();
   //std::cout<<"beg of beginLuminosityBlock "<<luminum<<std::endl;
   //if is null run, fill empty values and return
   if (m_isNullRun) {
     iLBlock.put(std::make_unique<LumiSummary>());
     iLBlock.put(std::make_unique<LumiDetails>());
     return;
   }
   if (m_lscache.find(luminum) == m_lscache.end()) {
     //if runnumber is cached but LS is not, this is the first LS, fill LS cache to full capacity
     fillLSCache(luminum);
   }
   //here the presence of ls is guaranteed
   writeProductsForEntry(iLBlock, runnumber, luminum);
 }

References fillLSCache(), edm::LuminosityBlockBase::luminosityBlock(), m_isNullRun, m_lscache, edm::LuminosityBlock::put(), edm::LuminosityBlockBase::run(), cond::runnumber, and writeProductsForEntry().

◆ beginRun()

void LumiProducer::beginRun	(	edm::Run const &	run,
		edm::EventSetup const &	iSetup
	)

finalprivate

Definition at line 396 of file LumiProducer.cc.

                                                                           {
   unsigned int runnumber = run.run();
   if (m_cachedrun != runnumber) {
     //queries once per run
     m_cachedrun = 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);
     try {
       session->transaction().start(true);
       m_cachedlumidataid = getLumiDataId(session->nominalSchema(), runnumber);
       if (m_cachedlumidataid != 0) {  //if no lumi, do not bother other info
         m_cachedtrgdataid = getTrgDataId(session->nominalSchema(), runnumber);
         m_cachedhltdataid = getHltDataId(session->nominalSchema(), runnumber);
         fillRunCache(session->nominalSchema(), runnumber);
       } else {
         m_isNullRun = true;
       }
       session->transaction().commit();
     } catch (const coral::Exception& er) {
       session->transaction().rollback();
       throw cms::Exception("DatabaseError ") << er.what();
     }
   }
   //std::cout<<"end of beginRun "<<runnumber<<std::endl;
 }

References lumi::service::DBService::connectReadOnly(), Exception, fillRunCache(), getHltDataId(), getLumiDataId(), getTrgDataId(), edm::Service< T >::isAvailable(), m_cachedhltdataid, m_cachedlumidataid, m_cachedrun, m_cachedtrgdataid, m_connectStr, m_isNullRun, writedatasetfile::run, and cond::runnumber.

◆ endRun()

void LumiProducer::endRun	(	edm::Run const &	run,
		edm::EventSetup const &	iSetup
	)

finalprivate

Definition at line 442 of file LumiProducer.cc.

442 {}

◆ endRunProduce()

void LumiProducer::endRunProduce	(	edm::Run &	run,
		edm::EventSetup const &	iSetup
	)

finalprivate

Definition at line 443 of file LumiProducer.cc.

                                                                          {
   auto lsrh = std::make_unique<LumiSummaryRunHeader>();
   lsrh->swapL1Names(m_runcache.TRGBitNames);
   lsrh->swapHLTNames(m_runcache.HLTPathNames);
   run.put(std::move(lsrh));
   m_runcache.TRGBitNameToIndex.clear();
   m_runcache.HLTPathNameToIndex.clear();
 }

References LumiProducer::PerRunData::HLTPathNames, LumiProducer::PerRunData::HLTPathNameToIndex, m_runcache, eostools::move(), writedatasetfile::run, LumiProducer::PerRunData::TRGBitNames, and LumiProducer::PerRunData::TRGBitNameToIndex.

◆ fillLSCache()

void LumiProducer::fillLSCache ( unsigned int luminum )

private

Definition at line 519 of file LumiProducer.cc.

                                                    {
   //initialize cache
   if (m_isNullRun)
     return;
   m_lscache.clear();
   for (unsigned int n = luminum; n < luminum + m_cachesize; ++n) {
     PerLSData l;
     l.hltdata.reserve(250);
     l.l1data.reserve(192);
     l.bunchlumivalue.reserve(5);
     l.bunchlumierror.reserve(5);
     l.bunchlumiquality.reserve(5);
     l.beam1intensity.resize(3564, 0.0);
     l.beam2intensity.resize(3564, 0.0);
     m_lscache.insert(std::make_pair(n, l));
   }
   //queries once per cache refill
   //
   //select cmslsnum,instlumi,startorbit,numorbit,bxindex,beam1intensity,beam2intensity,bxlumivalue_occ1,bxlumivalue_occ2,bxlumivalue_et from lumisummaryv2 where cmslsnum>=:lsmin and cmslsnum<:lsmax and data_id=:lumidataid;
   //
   edm::Service<lumi::service::DBService> mydbservice;
   if (!mydbservice.isAvailable()) {
     throw cms::Exception("Non existing service lumi::service::DBService");
   }
   auto session = mydbservice->connectReadOnly(m_connectStr);
   try {
     session->transaction().start(true);
     coral::ISchema& schema = session->nominalSchema();
     coral::AttributeList lumisummaryBindVariables;
     lumisummaryBindVariables.extend("lsmin", typeid(unsigned int));
     lumisummaryBindVariables.extend("lsmax", typeid(unsigned int));
     lumisummaryBindVariables.extend("lumidataid", typeid(unsigned long long));
     lumisummaryBindVariables["lumidataid"].data<unsigned long long>() = m_cachedlumidataid;
     lumisummaryBindVariables["lsmin"].data<unsigned int>() = luminum;
     lumisummaryBindVariables["lsmax"].data<unsigned int>() = luminum + m_cachesize;
     coral::AttributeList lumisummaryOutput;
     lumisummaryOutput.extend("CMSLSNUM", typeid(unsigned int));
     lumisummaryOutput.extend("INSTLUMI", typeid(float));
     lumisummaryOutput.extend("STARTORBIT", typeid(unsigned int));
     lumisummaryOutput.extend("NUMORBIT", typeid(unsigned int));
     lumisummaryOutput.extend("CMSBXINDEXBLOB", typeid(coral::Blob));
     lumisummaryOutput.extend("BEAMINTENSITYBLOB_1", typeid(coral::Blob));
     lumisummaryOutput.extend("BEAMINTENSITYBLOB_2", typeid(coral::Blob));
     lumisummaryOutput.extend("BXLUMIVALUE_OCC1", typeid(coral::Blob));
     lumisummaryOutput.extend("BXLUMIVALUE_OCC2", typeid(coral::Blob));
     lumisummaryOutput.extend("BXLUMIVALUE_ET", typeid(coral::Blob));
     coral::IQuery* lumisummaryQuery = schema.newQuery();
     lumisummaryQuery->addToTableList(lumi::LumiNames::lumisummaryv2TableName());
     lumisummaryQuery->addToOutputList("CMSLSNUM");
     lumisummaryQuery->addToOutputList("INSTLUMI");
     lumisummaryQuery->addToOutputList("STARTORBIT");
     lumisummaryQuery->addToOutputList("NUMORBIT");
     lumisummaryQuery->addToOutputList("CMSBXINDEXBLOB");
     lumisummaryQuery->addToOutputList("BEAMINTENSITYBLOB_1");
     lumisummaryQuery->addToOutputList("BEAMINTENSITYBLOB_2");
     lumisummaryQuery->addToOutputList("BXLUMIVALUE_OCC1");
     lumisummaryQuery->addToOutputList("BXLUMIVALUE_OCC2");
     lumisummaryQuery->addToOutputList("BXLUMIVALUE_ET");
     lumisummaryQuery->setCondition("CMSLSNUM>=:lsmin AND CMSLSNUM<:lsmax AND DATA_ID=:lumidataid",
                                    lumisummaryBindVariables);
     lumisummaryQuery->defineOutput(lumisummaryOutput);
     coral::ICursor& lumisummarycursor = lumisummaryQuery->execute();
     unsigned int rowcounter = 0;
     while (lumisummarycursor.next()) {
       const coral::AttributeList& row = lumisummarycursor.currentRow();
       unsigned int cmslsnum = row["CMSLSNUM"].data<unsigned int>();
       //std::cout<<"cmslsnum "<<cmslsnum<<std::endl;
       PerLSData& lsdata = m_lscache[cmslsnum];
       lsdata.lumivalue = row["INSTLUMI"].data<float>();
       lsdata.lumierror = 0.0;
       lsdata.lumiquality = 0;
       lsdata.startorbit = row["STARTORBIT"].data<unsigned int>();
       lsdata.numorbit = row["NUMORBIT"].data<unsigned int>();
  
       if (!row["CMSBXINDEXBLOB"].isNull() && !row["BXLUMIVALUE_OCC1"].isNull()) {
         const coral::Blob& bxindexBlob = row["CMSBXINDEXBLOB"].data<coral::Blob>();
         const void* bxindex_StartAddress = bxindexBlob.startingAddress();
         short* bxindex = (short*)::malloc(bxindexBlob.size());
         const coral::Blob& beam1intensityBlob = row["BEAMINTENSITYBLOB_1"].data<coral::Blob>();
         const void* beam1intensityBlob_StartAddress = beam1intensityBlob.startingAddress();
         float* beam1intensity = (float*)::malloc(beam1intensityBlob.size());
         const coral::Blob& beam2intensityBlob = row["BEAMINTENSITYBLOB_2"].data<coral::Blob>();
         const void* beam2intensityBlob_StartAddress = beam2intensityBlob.startingAddress();
         float* beam2intensity = (float*)::malloc(beam2intensityBlob.size());
         std::memmove(bxindex, bxindex_StartAddress, bxindexBlob.size());
         std::memmove(beam1intensity, beam1intensityBlob_StartAddress, beam1intensityBlob.size());
         std::memmove(beam2intensity, beam2intensityBlob_StartAddress, beam2intensityBlob.size());
  
         unsigned int iMax = bxindexBlob.size() / sizeof(short);
         unsigned int lsb1Max = lsdata.beam1intensity.size();
         unsigned int lsb2Max = lsdata.beam2intensity.size();
         unsigned int ib1Max = beam1intensityBlob.size() / sizeof(float);
         unsigned int ib2Max = beam2intensityBlob.size() / sizeof(float);
         for (unsigned int i = 0; i < iMax; ++i) {
           unsigned int idx = bxindex[i];
           if (ib1Max > i && lsb1Max > idx) {
             lsdata.beam1intensity.at(idx) = beam1intensity[i];
           }
           if (ib2Max > i && lsb2Max > idx) {
             lsdata.beam2intensity.at(idx) = beam2intensity[i];
           }
         }
         ::free(bxindex);
         ::free(beam1intensity);
         ::free(beam2intensity);
  
         const coral::Blob& bxlumivalBlob_occ1 = row["BXLUMIVALUE_OCC1"].data<coral::Blob>();
         const void* bxlumival_occ1_StartAddress = bxlumivalBlob_occ1.startingAddress();
         float* bxlumival_occ1 = (float*)::malloc(bxlumivalBlob_occ1.size());
         std::memmove(bxlumival_occ1, bxlumival_occ1_StartAddress, bxlumivalBlob_occ1.size());
         std::vector<float> bxlumivalVec_occ1(bxlumival_occ1,
                                              bxlumival_occ1 + bxlumivalBlob_occ1.size() / sizeof(float));
         ::free(bxlumival_occ1);
         lsdata.bunchlumivalue.push_back(std::make_pair(std::string("OCC1"), bxlumivalVec_occ1));
         lsdata.bunchlumierror.push_back(std::make_pair(std::string("OCC1"), std::vector<float>(3564)));
         lsdata.bunchlumiquality.push_back(std::make_pair(std::string("OCC1"), std::vector<short>(3564)));
         const coral::Blob& bxlumivalBlob_occ2 = row["BXLUMIVALUE_OCC2"].data<coral::Blob>();
         const void* bxlumival_occ2_StartAddress = bxlumivalBlob_occ2.startingAddress();
         float* bxlumival_occ2 = (float*)::malloc(bxlumivalBlob_occ2.size());
         std::memmove(bxlumival_occ2, bxlumival_occ2_StartAddress, bxlumivalBlob_occ2.size());
         std::vector<float> bxlumivalVec_occ2(bxlumival_occ2,
                                              bxlumival_occ2 + bxlumivalBlob_occ1.size() / sizeof(float));
         ::free(bxlumival_occ2);
         lsdata.bunchlumivalue.push_back(std::make_pair(std::string("OCC2"), bxlumivalVec_occ2));
         lsdata.bunchlumierror.push_back(std::make_pair(std::string("OCC2"), std::vector<float>(3564)));
         lsdata.bunchlumiquality.push_back(std::make_pair(std::string("OCC2"), std::vector<short>(3564)));
  
         const coral::Blob& bxlumivalBlob_et = row["BXLUMIVALUE_ET"].data<coral::Blob>();
         const void* bxlumival_et_StartAddress = bxlumivalBlob_et.startingAddress();
         float* bxlumival_et = (float*)::malloc(bxlumivalBlob_et.size());
         std::memmove(bxlumival_et, bxlumival_et_StartAddress, bxlumivalBlob_et.size());
         std::vector<float> bxlumivalVec_et(bxlumival_et, bxlumival_et + bxlumivalBlob_et.size() / sizeof(float));
         ::free(bxlumival_et);
         lsdata.bunchlumivalue.push_back(std::make_pair(std::string("ET"), bxlumivalVec_et));
         lsdata.bunchlumierror.push_back(std::make_pair(std::string("ET"), std::vector<float>(3564)));
         lsdata.bunchlumiquality.push_back(std::make_pair(std::string("ET"), std::vector<short>(3564)));
       }
       ++rowcounter;
     }
     if (rowcounter == 0) {
       m_isNullRun = true;
       return;
     }
     delete lumisummaryQuery;
  
     //
     //select cmslsnum,deadtimecount,bitzerocount,bitzeroprescale,prescaleblob,trgcountblob from lstrg where cmslsnum >=:luminum and cmslsnum<:luminum+cachesize AND data_id=:trgdataid;
     //
     coral::AttributeList trgBindVariables;
     trgBindVariables.extend("lsmin", typeid(unsigned int));
     trgBindVariables.extend("lsmax", typeid(unsigned int));
     trgBindVariables.extend("trgdataid", typeid(unsigned long long));
     trgBindVariables["lsmin"].data<unsigned int>() = luminum;
     trgBindVariables["lsmax"].data<unsigned int>() = luminum + m_cachesize;
     trgBindVariables["trgdataid"].data<unsigned long long>() = m_cachedtrgdataid;
     coral::AttributeList trgOutput;
     trgOutput.extend("CMSLSNUM", typeid(unsigned int));
     trgOutput.extend("DEADTIMECOUNT", typeid(unsigned long long));
     trgOutput.extend("BITZEROCOUNT", typeid(unsigned int));
     trgOutput.extend("BITZEROPRESCALE", typeid(unsigned int));
     trgOutput.extend("PRESCALEBLOB", typeid(coral::Blob));
     trgOutput.extend("TRGCOUNTBLOB", typeid(coral::Blob));
  
     coral::IQuery* trgQuery = schema.newQuery();
     trgQuery->addToTableList(lumi::LumiNames::lstrgTableName());
     trgQuery->addToOutputList("CMSLSNUM");
     trgQuery->addToOutputList("DEADTIMECOUNT");
     trgQuery->addToOutputList("BITZEROCOUNT");
     trgQuery->addToOutputList("BITZEROPRESCALE");
     trgQuery->addToOutputList("PRESCALEBLOB");
     trgQuery->addToOutputList("TRGCOUNTBLOB");
     trgQuery->setCondition("CMSLSNUM>=:lsmin AND CMSLSNUM<:lsmax AND DATA_ID=:trgdataid", trgBindVariables);
     trgQuery->defineOutput(trgOutput);
     coral::ICursor& trgcursor = trgQuery->execute();
     while (trgcursor.next()) {
       const coral::AttributeList& row = trgcursor.currentRow();
       unsigned int cmslsnum = row["CMSLSNUM"].data<unsigned int>();
       PerLSData& lsdata = m_lscache[cmslsnum];
       lsdata.deadcount = row["DEADTIMECOUNT"].data<unsigned long long>();
       lsdata.bitzerocount = row["BITZEROCOUNT"].data<unsigned int>();
       lsdata.bitzeroprescale = row["BITZEROPRESCALE"].data<unsigned int>();
       if (!row["PRESCALEBLOB"].isNull()) {
         const coral::Blob& prescaleblob = row["PRESCALEBLOB"].data<coral::Blob>();
         const void* prescaleblob_StartAddress = prescaleblob.startingAddress();
         unsigned int* prescales = (unsigned int*)::malloc(prescaleblob.size());
         std::memmove(prescales, prescaleblob_StartAddress, prescaleblob.size());
         const coral::Blob& trgcountblob = row["TRGCOUNTBLOB"].data<coral::Blob>();
         const void* trgcountblob_StartAddress = trgcountblob.startingAddress();
         unsigned int* trgcounts = (unsigned int*)::malloc(trgcountblob.size());
         std::memmove(trgcounts, trgcountblob_StartAddress, trgcountblob.size());
         for (unsigned int i = 0; i < trgcountblob.size() / sizeof(unsigned int); ++i) {
           L1Data l1tmp;
           l1tmp.bitname = m_runcache.TRGBitNames[i];
           l1tmp.prescale = prescales[i];
           l1tmp.ratecount = trgcounts[i];
           lsdata.l1data.push_back(l1tmp);
         }
         ::free(prescales);
         ::free(trgcounts);
       }
     }
     delete trgQuery;
     //
     //select cmslsnum,hltcountblob,hltacceptblob,prescaleblob from hlt where cmslsnum >=:luminum and cmslsnum<=:luminum+cachesize and data_id=:hltdataid
     //
     coral::AttributeList hltBindVariables;
     hltBindVariables.extend("lsmin", typeid(unsigned int));
     hltBindVariables.extend("lsmax", typeid(unsigned int));
     hltBindVariables.extend("hltdataid", typeid(unsigned long long));
     hltBindVariables["lsmin"].data<unsigned int>() = luminum;
     hltBindVariables["lsmax"].data<unsigned int>() = luminum + m_cachesize;
     hltBindVariables["hltdataid"].data<unsigned long long>() = m_cachedhltdataid;
     coral::AttributeList hltOutput;
     hltOutput.extend("CMSLSNUM", typeid(unsigned int));
     hltOutput.extend("HLTCOUNTBLOB", typeid(coral::Blob));
     hltOutput.extend("HLTACCEPTBLOB", typeid(coral::Blob));
     hltOutput.extend("PRESCALEBLOB", typeid(coral::Blob));
     coral::IQuery* hltQuery = schema.newQuery();
     hltQuery->addToTableList(lumi::LumiNames::lshltTableName());
     hltQuery->addToOutputList("CMSLSNUM");
     hltQuery->addToOutputList("HLTCOUNTBLOB");
     hltQuery->addToOutputList("HLTACCEPTBLOB");
     hltQuery->addToOutputList("PRESCALEBLOB");
     hltQuery->setCondition("CMSLSNUM>=:lsmin AND CMSLSNUM<:lsmax AND DATA_ID=:hltdataid", hltBindVariables);
     hltQuery->defineOutput(hltOutput);
     coral::ICursor& hltcursor = hltQuery->execute();
     while (hltcursor.next()) {
       const coral::AttributeList& row = hltcursor.currentRow();
       unsigned int cmslsnum = row["CMSLSNUM"].data<unsigned int>();
       PerLSData& lsdata = m_lscache[cmslsnum];
       if (!row["PRESCALEBLOB"].isNull()) {
         const coral::Blob& hltprescaleblob = row["PRESCALEBLOB"].data<coral::Blob>();
         const void* hltprescaleblob_StartAddress = hltprescaleblob.startingAddress();
         unsigned int* hltprescales = (unsigned int*)::malloc(hltprescaleblob.size());
         std::memmove(hltprescales, hltprescaleblob_StartAddress, hltprescaleblob.size());
         const coral::Blob& hltcountblob = row["HLTCOUNTBLOB"].data<coral::Blob>();
         const void* hltcountblob_StartAddress = hltcountblob.startingAddress();
         unsigned int* hltcounts = (unsigned int*)::malloc(hltcountblob.size());
         std::memmove(hltcounts, hltcountblob_StartAddress, hltcountblob.size());
         const coral::Blob& hltacceptblob = row["HLTACCEPTBLOB"].data<coral::Blob>();
         const void* hltacceptblob_StartAddress = hltacceptblob.startingAddress();
         unsigned int* hltaccepts = (unsigned int*)::malloc(hltacceptblob.size());
         std::memmove(hltaccepts, hltacceptblob_StartAddress, hltacceptblob.size());
         unsigned int nhltaccepts = hltacceptblob.size() / sizeof(unsigned int);
         if (nhltaccepts > 0 && m_runcache.HLTPathNames.empty()) {
           edm::LogWarning("CorruptOrMissingHLTData")
               << "Got " << nhltaccepts << " hltaccepts, but the run chache is empty. hltdata will  not be written";
           break;
         }
  
         for (unsigned int i = 0; i < hltacceptblob.size() / sizeof(unsigned int); ++i) {
           HLTData hlttmp;
           hlttmp.pathname = m_runcache.HLTPathNames[i];
           hlttmp.prescale = hltprescales[i];
           hlttmp.l1passcount = hltcounts[i];
           hlttmp.acceptcount = hltaccepts[i];
           lsdata.hltdata.push_back(hlttmp);
         }
         ::free(hltprescales);
         ::free(hltcounts);
         ::free(hltaccepts);
       }
     }
     delete hltQuery;
     session->transaction().commit();
   } catch (const coral::Exception& er) {
     session->transaction().rollback();
     throw cms::Exception("DatabaseError ") << er.what();
   }
 }

References LumiProducer::HLTData::acceptcount, LumiProducer::L1Data::bitname, lumi::service::DBService::connectReadOnly(), Exception, dqmMemoryStats::float, LumiProducer::PerRunData::HLTPathNames, mps_fire::i, charmTagsComputerCvsB_cfi::idx, createfilelist::int, edm::Service< T >::isAvailable(), cmsLHEtoEOSManager::l, LumiProducer::HLTData::l1passcount, lumi::LumiNames::lshltTableName(), lumi::LumiNames::lstrgTableName(), lumi::LumiNames::lumisummaryv2TableName(), m_cachedhltdataid, m_cachedlumidataid, m_cachedtrgdataid, m_cachesize, m_connectStr, m_isNullRun, m_lscache, m_runcache, dqmiodumpmetadata::n, LumiProducer::HLTData::pathname, LumiProducer::HLTData::prescale, LumiProducer::L1Data::prescale, hltrates_dqm_sourceclient-live_cfg::prescales, LumiProducer::L1Data::ratecount, AlCaHLTBitMon_QueryRunRegistry::string, and LumiProducer::PerRunData::TRGBitNames.

Referenced by beginLuminosityBlockProduce().

◆ fillLumi()

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

private

◆ fillRunCache()

void LumiProducer::fillRunCache	(	const coral::ISchema &	schema,
		unsigned int	runnumber
	)

private

Definition at line 451 of file LumiProducer.cc.

                                                                                   {
   if (m_lumiversion.empty()) {
     m_lumiversion = getCurrentDataTag(schema);
   }
   std::cout << "lumi tag version 2 " << m_lumiversion << std::endl;
   if (m_cachedtrgdataid != 0) {
     coral::AttributeList trgBindVariables;
     trgBindVariables.extend("trgdataid", typeid(unsigned long long));
     trgBindVariables["trgdataid"].data<unsigned long long>() = m_cachedtrgdataid;
     //std::cout<<"cached trgdataid "<<m_cachedtrgdataid<<std::endl;
     coral::AttributeList trgOutput;
     trgOutput.extend("bitzeroname", typeid(std::string));
     trgOutput.extend("bitnameclob", typeid(std::string));
     coral::IQuery* trgQuery = schema.newQuery();
     trgQuery->addToTableList(lumi::LumiNames::trgdataTableName());
     trgQuery->addToOutputList("BITZERONAME");
     trgQuery->addToOutputList("BITNAMECLOB");
     trgQuery->setCondition("DATA_ID=:trgdataid", trgBindVariables);
     trgQuery->defineOutput(trgOutput);
     coral::ICursor& trgcursor = trgQuery->execute();
     while (trgcursor.next()) {
       const coral::AttributeList& row = trgcursor.currentRow();
       m_runcache.bitzeroname = row["bitzeroname"].data<std::string>();
       //std::cout<<"bitzeroname "<<m_runcache.bitzeroname<<std::endl;
       std::string bitnames = row["bitnameclob"].data<std::string>();
       boost::char_separator<char> sep(",");
       boost::tokenizer<boost::char_separator<char> > tokens(bitnames, sep);
       for (boost::tokenizer<boost::char_separator<char> >::iterator tok_it = tokens.begin(); tok_it != tokens.end();
            ++tok_it) {
         m_runcache.TRGBitNames.push_back(*tok_it);
       }
       for (unsigned int i = 0; i < m_runcache.TRGBitNames.size(); ++i) {
         m_runcache.TRGBitNameToIndex.insert(std::make_pair(m_runcache.TRGBitNames.at(i), i));
       }
     }
     delete trgQuery;
   }
   if (m_cachedhltdataid != 0) {
     //
     //select pathnameclob from hltdata where data_id=:hltdataid
     //
     coral::AttributeList hltBindVariables;
     hltBindVariables.extend("hltdataid", typeid(unsigned long long));
     hltBindVariables["hltdataid"].data<unsigned long long>() = m_cachedhltdataid;
     coral::AttributeList hltOutput;
     hltOutput.extend("PATHNAMECLOB", typeid(std::string));
     coral::IQuery* hltQuery = schema.newQuery();
     hltQuery->addToTableList(lumi::LumiNames::hltdataTableName());
     hltQuery->addToOutputList("PATHNAMECLOB");
     hltQuery->setCondition("DATA_ID=:hltdataid", hltBindVariables);
     hltQuery->defineOutput(hltOutput);
     coral::ICursor& hltcursor = hltQuery->execute();
     while (hltcursor.next()) {
       const coral::AttributeList& row = hltcursor.currentRow();
       std::string pathnames = row["PATHNAMECLOB"].data<std::string>();
       boost::char_separator<char> sep(",");
       boost::tokenizer<boost::char_separator<char> > tokens(pathnames, sep);
       for (boost::tokenizer<boost::char_separator<char> >::iterator tok_it = tokens.begin(); tok_it != tokens.end();
            ++tok_it) {
         m_runcache.HLTPathNames.push_back(*tok_it);
       }
       for (unsigned int i = 0; i < m_runcache.HLTPathNames.size(); ++i) {
         m_runcache.HLTPathNameToIndex.insert(std::make_pair(m_runcache.HLTPathNames.at(i), i));
       }
     }
     delete hltQuery;
   }
 }

References LumiProducer::PerRunData::bitzeroname, gather_cfg::cout, getCurrentDataTag(), lumi::LumiNames::hltdataTableName(), LumiProducer::PerRunData::HLTPathNames, LumiProducer::PerRunData::HLTPathNameToIndex, mps_fire::i, m_cachedhltdataid, m_cachedtrgdataid, m_lumiversion, m_runcache, AlCaHLTBitMon_QueryRunRegistry::string, LumiProducer::PerRunData::TRGBitNames, LumiProducer::PerRunData::TRGBitNameToIndex, and lumi::LumiNames::trgdataTableName().

Referenced by beginRun().

◆ getCurrentDataTag()

std::string LumiProducer::getCurrentDataTag ( const coral::ISchema & schema )

private

Definition at line 366 of file LumiProducer.cc.

                                                                     {
   //select tagid,tagname from tags
   std::string result;
   std::map<unsigned long long, std::string> alltags;
   coral::IQuery* tagQuery = schema.newQuery();
   tagQuery->addToTableList(lumi::LumiNames::tagsTableName());
   tagQuery->addToOutputList("TAGID");
   tagQuery->addToOutputList("TAGNAME");
   coral::AttributeList tagoutput;
   tagoutput.extend("TAGID", typeid(unsigned long long));
   tagoutput.extend("TAGNAME", typeid(std::string));
   tagQuery->defineOutput(tagoutput);
   coral::ICursor& tagcursor = tagQuery->execute();
   while (tagcursor.next()) {
     const coral::AttributeList& row = tagcursor.currentRow();
     unsigned long long tagid = row["TAGID"].data<unsigned long long>();
     const std::string tagname = row["TAGNAME"].data<std::string>();
     alltags.insert(std::make_pair(tagid, tagname));
   }
   delete tagQuery;
   unsigned long long maxid = 0;
   for (std::map<unsigned long long, std::string>::iterator it = alltags.begin(); it != alltags.end(); ++it) {
     if (it->first > maxid) {
       maxid = it->first;
     }
   }
   result = alltags[maxid];
   return result;
 }

References mps_fire::result, AlCaHLTBitMon_QueryRunRegistry::string, createPayload::tagname, and lumi::LumiNames::tagsTableName().

Referenced by fillRunCache().

◆ getHltDataId()

unsigned long long LumiProducer::getHltDataId	(	const coral::ISchema &	schema,
		unsigned int	runnumber
	)

private

Definition at line 340 of file LumiProducer.cc.

                                                                                                 {
   //
   //select max(data_id) from hltdata where runnum=:runnum
   //
   unsigned long long hltdataid = 0;
   coral::AttributeList bindVariables;
   bindVariables.extend("runnum", typeid(unsigned int));
   bindVariables["runnum"].data<unsigned int>() = runnumber;
   coral::AttributeList hltidOutput;
   hltidOutput.extend("hltdataid", typeid(unsigned long long));
   coral::IQuery* hltQuery = schema.newQuery();
   hltQuery->addToTableList(lumi::LumiNames::hltdataTableName());
   hltQuery->addToOutputList("MAX(DATA_ID)", "hltdataid");
   hltQuery->setCondition("RUNNUM=:runnum", bindVariables);
   hltQuery->defineOutput(hltidOutput);
   coral::ICursor& hltcursor = hltQuery->execute();
   while (hltcursor.next()) {
     const coral::AttributeList& row = hltcursor.currentRow();
     if (!row["hltdataid"].isNull()) {
       hltdataid = row["hltdataid"].data<unsigned long long>();
     }
   }
   delete hltQuery;
   return hltdataid;
 }

References lumi::LumiNames::hltdataTableName(), and cond::runnumber.

Referenced by beginRun().

◆ getLumiDataId()

unsigned long long LumiProducer::getLumiDataId	(	const coral::ISchema &	schema,
		unsigned int	runnumber
	)

private

Definition at line 289 of file LumiProducer.cc.

                                                                                                  {
   //
   //select max(data_id) from lumidata where runnum=:runnum
   //
   //std::count<<"entering getLumiDataId "<<std::endl;
   unsigned long long lumidataid = 0;
   coral::AttributeList bindVariables;
   bindVariables.extend("runnum", typeid(unsigned int));
   bindVariables["runnum"].data<unsigned int>() = runnumber;
   coral::AttributeList lumiidOutput;
   lumiidOutput.extend("lumidataid", typeid(unsigned long long));
   coral::IQuery* lumiQuery = schema.newQuery();
   lumiQuery->addToTableList(lumi::LumiNames::lumidataTableName());
   lumiQuery->addToOutputList("MAX(DATA_ID)", "lumidataid");
   lumiQuery->setCondition("RUNNUM=:runnum", bindVariables);
   lumiQuery->defineOutput(lumiidOutput);
   coral::ICursor& lumicursor = lumiQuery->execute();
   while (lumicursor.next()) {
     const coral::AttributeList& row = lumicursor.currentRow();
     if (!row["lumidataid"].isNull()) {
       lumidataid = row["lumidataid"].data<unsigned long long>();
     }
   }
   delete lumiQuery;
   return lumidataid;
 }

References lumi::LumiNames::lumidataTableName(), and cond::runnumber.

Referenced by beginRun().

◆ getTrgDataId()

unsigned long long LumiProducer::getTrgDataId	(	const coral::ISchema &	schema,
		unsigned int	runnumber
	)

private

Definition at line 315 of file LumiProducer.cc.

                                                                                                 {
   //
   //select max(data_id) from trgdata where runnum=:runnum
   //
   unsigned long long trgdataid = 0;
   coral::AttributeList bindVariables;
   bindVariables.extend("runnum", typeid(unsigned int));
   bindVariables["runnum"].data<unsigned int>() = runnumber;
   coral::AttributeList trgidOutput;
   trgidOutput.extend("trgdataid", typeid(unsigned long long));
   coral::IQuery* trgQuery = schema.newQuery();
   trgQuery->addToTableList(lumi::LumiNames::trgdataTableName());
   trgQuery->addToOutputList("MAX(DATA_ID)", "trgdataid");
   trgQuery->setCondition("RUNNUM=:runnum", bindVariables);
   trgQuery->defineOutput(trgidOutput);
   coral::ICursor& trgcursor = trgQuery->execute();
   while (trgcursor.next()) {
     const coral::AttributeList& row = trgcursor.currentRow();
     if (!row["trgdataid"].isNull()) {
       trgdataid = row["trgdataid"].data<unsigned long long>();
     }
   }
   delete trgQuery;
   return trgdataid;
 }

References cond::runnumber, and lumi::LumiNames::trgdataTableName().

Referenced by beginRun().

◆ produce()

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

finalprivatevirtual

Implements edm::one::EDProducerBase.

Definition at line 288 of file LumiProducer.cc.

288 {}

◆ s2x()

XMLCh * LumiProducer::s2x ( const std::string & input ) const

private

Definition at line 167 of file LumiProducer.cc.

                                                     {
   XMLCh* buff = xercesc::XMLString::transcode(temp.c_str());
   return buff;
 }

References groupFilesInBlocks::temp.

Referenced by servletTranslation().

◆ servletTranslation()

const std::string LumiProducer::servletTranslation ( const std::string & servlet ) const

private

Definition at line 196 of file LumiProducer.cc.

                                                                                {
   std::string frontierConnect;
   std::string realconnect;
   cms::concurrency::xercesInitialize();
   std::unique_ptr<xercesc::XercesDOMParser> parser(new xercesc::XercesDOMParser);
   try {
     parser->setValidationScheme(xercesc::XercesDOMParser::Val_Auto);
     parser->setDoNamespaces(false);
     parser->parse(m_siteconfpath.c_str());
     xercesc::DOMDocument* doc = parser->getDocument();
     if (!doc) {
       return "";
     }
  
     xercesc::DOMNodeList* frontierConnectList = doc->getElementsByTagName(s2x("frontier-connect"));
     if (frontierConnectList->getLength() > 0) {
       xercesc::DOMElement* frontierConnectElement = static_cast<xercesc::DOMElement*>(frontierConnectList->item(0));
       frontierConnect = toParentString(*frontierConnectElement);
     }
     // Replace the last component of every "serverurl=" piece (up to the
     //   next close-paren) with the servlet
     std::string::size_type nextparen = 0;
     std::string::size_type serverurl, lastslash;
     std::string complexstr = "";
     while ((serverurl = frontierConnect.find("(serverurl=", nextparen)) != std::string::npos) {
       realconnect.append(frontierConnect, nextparen, serverurl - nextparen);
       nextparen = frontierConnect.find(')', serverurl);
       lastslash = frontierConnect.rfind('/', nextparen);
       realconnect.append(frontierConnect, serverurl, lastslash - serverurl + 1);
       realconnect.append(servlet);
     }
     realconnect.append(frontierConnect, nextparen, frontierConnect.length() - nextparen);
   } catch (xercesc::DOMException& e) {
   }
   return realconnect;
 }

References common_cff::doc, MillePedeFileConverter_cfg::e, m_siteconfpath, writedatasetfile::parser, s2x(), AlCaHLTBitMon_QueryRunRegistry::string, toParentString(), and cms::concurrency::xercesInitialize().

◆ toParentString()

std::string LumiProducer::toParentString ( const xercesc::DOMNode & nodeToConvert ) const

private

Definition at line 172 of file LumiProducer.cc.

                                                                                 {
   std::ostringstream oss;
   xercesc::DOMNodeList* childList = nodeToConvert.getChildNodes();
  
   unsigned int numNodes = childList->getLength();
   for (unsigned int i = 0; i < numNodes; ++i) {
     xercesc::DOMNode* childNode = childList->item(i);
     if (childNode->getNodeType() != xercesc::DOMNode::ELEMENT_NODE)
       continue;
     xercesc::DOMElement* child = static_cast<xercesc::DOMElement*>(childNode);
     xercesc::DOMNamedNodeMap* attributes = child->getAttributes();
     unsigned int numAttributes = attributes->getLength();
     for (unsigned int j = 0; j < numAttributes; ++j) {
       xercesc::DOMNode* attributeNode = attributes->item(j);
       if (attributeNode->getNodeType() != xercesc::DOMNode::ATTRIBUTE_NODE)
         continue;
       xercesc::DOMAttr* attribute = static_cast<xercesc::DOMAttr*>(attributeNode);
  
       oss << "(" << x2s(child->getTagName()) << x2s(attribute->getName()) << "=" << x2s(attribute->getValue()) << ")";
     }
   }
   return oss.str();
 }

References mps_fire::i, dqmiolumiharvest::j, and x2s().

Referenced by servletTranslation().

◆ writeProductsForEntry()

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

private

Definition at line 789 of file LumiProducer.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("-1");
     pIn2->setLumiVersion("-1");
     iLBlock.put(std::move(pIn1));
     iLBlock.put(std::move(pIn2));
     return;
   }
   PerLSData& lsdata = m_lscache[luminum];
   pIn1->setLumiData(lsdata.lumivalue, lsdata.lumierror, lsdata.lumiquality);
   pIn1->setDeadCount(lsdata.deadcount);
   if (!lsdata.l1data.empty()) {
     //std::cout<<"bitzerocount "<<lsdata.bitzerocount<<std::endl;
     //std::cout<<"bitzeroprescale "<<lsdata.bitzeroprescale<<std::endl;
     //std::cout<<"product "<<lsdata.bitzerocount*lsdata.bitzeroprescale<<std::endl;
     pIn1->setBitZeroCount(lsdata.bitzerocount * lsdata.bitzeroprescale);
   }
   pIn1->setlsnumber(luminum);
   pIn1->setOrbitData(lsdata.startorbit, lsdata.numorbit);
   std::vector<LumiSummary::L1> l1temp;
   for (std::vector<L1Data>::iterator it = lsdata.l1data.begin(); it != lsdata.l1data.end(); ++it) {
     LumiSummary::L1 trgtmp;
     trgtmp.triggernameidx = m_runcache.TRGBitNameToIndex[it->bitname];
     trgtmp.prescale = it->prescale;
     l1temp.push_back(trgtmp);
   }
   std::vector<LumiSummary::HLT> hlttemp;
   for (std::vector<HLTData>::iterator it = lsdata.hltdata.begin(); it != lsdata.hltdata.end(); ++it) {
     LumiSummary::HLT hlttmp;
     hlttmp.pathnameidx = m_runcache.HLTPathNameToIndex[it->pathname];
     ;
     hlttmp.prescale = it->prescale;
     hlttemp.push_back(hlttmp);
   }
   pIn1->swapL1Data(l1temp);
   pIn1->swapHLTData(hlttemp);
   pIn1->setLumiVersion(m_lumiversion);
   pIn2->fillBeamIntensities(lsdata.beam1intensity, lsdata.beam2intensity);
   for (unsigned int i = 0; i < lsdata.bunchlumivalue.size(); ++i) {
     std::string algoname = lsdata.bunchlumivalue[i].first;
     if (algoname == "OCC1") {
       pIn2->fill(LumiDetails::kOCC1,
                  lsdata.bunchlumivalue[i].second,
                  lsdata.bunchlumierror[i].second,
                  lsdata.bunchlumiquality[i].second);
     } else if (algoname == "OCC2") {
       pIn2->fill(LumiDetails::kOCC2,
                  lsdata.bunchlumivalue[i].second,
                  lsdata.bunchlumierror[i].second,
                  lsdata.bunchlumiquality[i].second);
     } else if (algoname == "ET") {
       pIn2->fill(LumiDetails::kET,
                  lsdata.bunchlumivalue[i].second,
                  lsdata.bunchlumierror[i].second,
                  lsdata.bunchlumiquality[i].second);
     } else if (algoname == "PLT") {
       pIn2->fill(LumiDetails::kPLT,
                  lsdata.bunchlumivalue[i].second,
                  lsdata.bunchlumierror[i].second,
                  lsdata.bunchlumiquality[i].second);
     }
   }
   pIn2->setLumiVersion(m_lumiversion);
   iLBlock.put(std::move(pIn1));
   iLBlock.put(std::move(pIn2));
 }

Referenced by beginLuminosityBlockProduce().

◆ x2s()

std::string LumiProducer::x2s ( const XMLCh * input ) const

private

Definition at line 162 of file LumiProducer.cc.

                                                           {
   std::string tmp(xercesc::XMLString::transcode(toTranscode));
   return tmp;
 }

References AlCaHLTBitMon_QueryRunRegistry::string, and createJobs::tmp.

Referenced by toParentString().

Member Data Documentation

◆ m_cachedhltdataid

unsigned long long LumiProducer::m_cachedhltdataid

private

Definition at line 151 of file LumiProducer.cc.

Referenced by beginRun(), fillLSCache(), and fillRunCache().

◆ m_cachedlumidataid

unsigned long long LumiProducer::m_cachedlumidataid

private

Definition at line 149 of file LumiProducer.cc.

Referenced by beginRun(), and fillLSCache().

◆ m_cachedrun

unsigned int LumiProducer::m_cachedrun

private

Definition at line 148 of file LumiProducer.cc.

Referenced by beginRun().

◆ m_cachedtrgdataid

unsigned long long LumiProducer::m_cachedtrgdataid

private

Definition at line 150 of file LumiProducer.cc.

Referenced by beginRun(), fillLSCache(), and fillRunCache().

◆ m_cachesize

unsigned int LumiProducer::m_cachesize

private

Definition at line 155 of file LumiProducer.cc.

Referenced by fillLSCache().

◆ m_connectStr

std::string LumiProducer::m_connectStr

private

Definition at line 145 of file LumiProducer.cc.

Referenced by beginRun(), and fillLSCache().

◆ m_isNullRun

bool LumiProducer::m_isNullRun

private

Definition at line 154 of file LumiProducer.cc.

Referenced by beginLuminosityBlockProduce(), beginRun(), fillLSCache(), and writeProductsForEntry().

◆ m_lscache

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

private

Definition at line 153 of file LumiProducer.cc.

Referenced by beginLuminosityBlockProduce(), fillLSCache(), and writeProductsForEntry().

◆ m_lumiversion

std::string LumiProducer::m_lumiversion

private

Definition at line 146 of file LumiProducer.cc.

Referenced by fillRunCache(), and writeProductsForEntry().

◆ m_runcache

PerRunData LumiProducer::m_runcache

private

Definition at line 152 of file LumiProducer.cc.

Referenced by endRunProduce(), fillLSCache(), fillRunCache(), and writeProductsForEntry().

◆ m_siteconfpath

std::string LumiProducer::m_siteconfpath

private

Definition at line 147 of file LumiProducer.cc.

Referenced by servletTranslation().

Classes

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ LumiProducer()

◆ ~LumiProducer()

Member Function Documentation

◆ beginLuminosityBlockProduce()

◆ beginRun()

◆ endRun()

◆ endRunProduce()

◆ fillLSCache()

◆ fillLumi()

◆ fillRunCache()

◆ getCurrentDataTag()

◆ getHltDataId()

◆ getLumiDataId()

◆ getTrgDataId()

◆ produce()

◆ s2x()

◆ servletTranslation()

◆ toParentString()

◆ writeProductsForEntry()

◆ x2s()

Member Data Documentation

◆ m_cachedhltdataid

◆ m_cachedlumidataid

◆ m_cachedrun

◆ m_cachedtrgdataid

◆ m_cachesize

◆ m_connectStr

◆ m_isNullRun

◆ m_lscache

◆ m_lumiversion

◆ m_runcache

◆ m_siteconfpath