#include <MonitorElementsDb.h>

Public Types
typedef dqm::legacy::DQMStore	DQMStore

typedef dqm::legacy::MonitorElement	MonitorElement

Public Member Functions
	MonitorElementsDb (const edm::ParameterSet &ps, std::string &xmlFile)
	Constructors. More...

virtual	~MonitorElementsDb ()
	Destructor. More...

Protected Member Functions
void	analyze (const edm::Event &e, const edm::EventSetup &c, coral::ISessionProxy *s)
	Analyze. More...

void	beginJob (void)

void	endJob (void)

void	htmlOutput (std::string &htmlDir)

void	startSession (void)

Private Attributes
DQMStore *	dqmStore_

int	ievt_

std::vector< DB_ME >	MEinfo_

std::vector< MonitorElement * >	MEs_

MonitorXMLParser *	parser_

std::string	prefixME_

std::string	xmlFile_

Friends
class	EcalBarrelMonitorDbModule

Detailed Description

Definition at line 25 of file MonitorElementsDb.h.

Member Typedef Documentation

◆ DQMStore

typedef dqm::legacy::DQMStore MonitorElementsDb::DQMStore

Definition at line 30 of file MonitorElementsDb.h.

◆ MonitorElement

typedef dqm::legacy::MonitorElement MonitorElementsDb::MonitorElement

Definition at line 29 of file MonitorElementsDb.h.

Constructor & Destructor Documentation

◆ MonitorElementsDb()

MonitorElementsDb::MonitorElementsDb	(	const edm::ParameterSet &	ps,
		std::string &	xmlFile
	)

Constructors.

Definition at line 32 of file MonitorElementsDb.cc.

                                                                                   {
   xmlFile_ = xmlFile;
  
   dqmStore_ = edm::Service<DQMStore>().operator->();
  
   prefixME_ = ps.getUntrackedParameter<std::string>("prefixME", "");
  
   if (dqmStore_) {
     dqmStore_->setCurrentFolder(prefixME_);
  
     parser_ = new MonitorXMLParser(xmlFile_);
     try {
       parser_->load();
     } catch (std::runtime_error const &e) {
       delete parser_;
       parser_ = nullptr;
       std::cerr << "Error loading parser: " << e.what() << std::endl;
     }
  
     if (parser_)
       MEinfo_ = parser_->getDB_ME();
  
     for (unsigned int i = 0; i < MEinfo_.size(); i++) {
       MonitorElement *tmp;
       tmp = nullptr;
       if (strcmp(MEinfo_[i].type.c_str(), "th1d") == 0) {
         tmp = dqmStore_->book1D(MEinfo_[i].title, MEinfo_[i].title, MEinfo_[i].xbins, MEinfo_[i].xfrom, MEinfo_[i].xto);
       } else if (strcmp(MEinfo_[i].type.c_str(), "th2d") == 0) {
         tmp = dqmStore_->book2D(MEinfo_[i].title,
                                 MEinfo_[i].title,
                                 MEinfo_[i].xbins,
                                 MEinfo_[i].xfrom,
                                 MEinfo_[i].xto,
                                 MEinfo_[i].ybins,
                                 MEinfo_[i].yfrom,
                                 MEinfo_[i].yto);
       } else if (strcmp(MEinfo_[i].type.c_str(), "tprofile") == 0) {
         tmp = dqmStore_->bookProfile(MEinfo_[i].title,
                                      MEinfo_[i].title,
                                      MEinfo_[i].xbins,
                                      MEinfo_[i].xfrom,
                                      MEinfo_[i].xto,
                                      MEinfo_[i].ybins,
                                      MEinfo_[i].yfrom,
                                      MEinfo_[i].yto);
       } else if (strcmp(MEinfo_[i].type.c_str(), "tprofile2d") == 0) {
         tmp = dqmStore_->bookProfile2D(MEinfo_[i].title,
                                        MEinfo_[i].title,
                                        MEinfo_[i].xbins,
                                        MEinfo_[i].xfrom,
                                        MEinfo_[i].xto,
                                        MEinfo_[i].ybins,
                                        MEinfo_[i].yfrom,
                                        MEinfo_[i].yto,
                                        MEinfo_[i].zbins,
                                        MEinfo_[i].zfrom,
                                        MEinfo_[i].zto);
       }
  
       MEs_.push_back(tmp);
     }
   }
  
   ievt_ = 0;
 }

References dqm::implementation::IBooker::book1D(), dqm::implementation::IBooker::book2D(), dqm::implementation::IBooker::bookProfile(), dqm::implementation::IBooker::bookProfile2D(), EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0::cerr, dqmStore_, MillePedeFileConverter_cfg::e, MonitorXMLParser::getDB_ME(), edm::ParameterSet::getUntrackedParameter(), mps_fire::i, ievt_, MonitorXMLParser::load(), MEinfo_, MEs_, parser_, prefixME_, dqm::implementation::DQMStore::setCurrentFolder(), AlCaHLTBitMon_QueryRunRegistry::string, runGCPTkAlMap::title, createJobs::tmp, fw3dlego::xbins, xmlFile_, and globals_cff::zbins.

◆ ~MonitorElementsDb()

MonitorElementsDb::~MonitorElementsDb ( )

virtual

Destructor.

Definition at line 98 of file MonitorElementsDb.cc.

98 { delete parser_; }

References parser_.

Member Function Documentation

◆ analyze()

void MonitorElementsDb::analyze	(	const edm::Event &	e,
		const edm::EventSetup &	c,
		coral::ISessionProxy *	s
	)

protected

Analyze.

Definition at line 104 of file MonitorElementsDb.cc.

                                                                                                       {
   ievt_++;
  
   bool atLeastAQuery;
   atLeastAQuery = false;
  
   std::vector<std::string> vars;
  
   if (session) {
     for (unsigned int i = 0; i < MEinfo_.size(); i++) {
       // i-th ME...
  
       if (MEs_[i] != nullptr && (ievt_ % MEinfo_[i].ncycle) == 0) {
         MEs_[i]->Reset();
  
         vars.clear();
  
         try {
           atLeastAQuery = true;
  
           session->transaction().start(true);
  
           coral::ISchema &schema = session->nominalSchema();
  
           coral::IQuery *query = schema.newQuery();
  
           for (unsigned int j = 0; j < MEinfo_[i].queries.size(); j++) {
             if (strcmp(MEinfo_[i].queries[j].query.c_str(), "addToTableList") == 0) {
               query->addToTableList(MEinfo_[i].queries[j].arg);
             } else if (strcmp(MEinfo_[i].queries[j].query.c_str(), "addToOutputList") == 0) {
               query->addToOutputList(MEinfo_[i].queries[j].arg, MEinfo_[i].queries[j].alias);
               vars.push_back(MEinfo_[i].queries[j].alias);
             } else if (strcmp(MEinfo_[i].queries[j].query.c_str(), "setCondition") == 0) {
               query->setCondition(MEinfo_[i].queries[j].arg, coral::AttributeList());
             } else if (strcmp(MEinfo_[i].queries[j].query.c_str(), "addToOrderList") == 0) {
               query->addToOrderList(MEinfo_[i].queries[j].arg);
             }
           }
  
           coral::ICursor &cursor = query->execute();
  
           unsigned int k = 0;
  
           while (cursor.next() && k < MEinfo_[i].loop) {
             // while ( cursor.next() ) {
  
             const coral::AttributeList &row = cursor.currentRow();
  
             std::vector<float> vvars;
             vvars.clear();
             for (unsigned int l = 0; l < vars.size(); l++) {
               if (!vars[l].empty()) {
                 vvars.push_back(row[vars[l]].data<float>());
               }
             }
             if (vvars.size() == 2) {
               // std::cout << k << " -- " << vvars[0] << " -- " << vvars[1] <<
               // std::endl;
               MEs_[i]->Fill(vvars[0], vvars[1]);
             } else if (vvars.size() == 3) {
               // std::cout << k << " -- " << vvars[0] << " -- " << vvars[1] << "
               // -- " << vvars[2] << std::endl;
               MEs_[i]->Fill(vvars[0], vvars[1], vvars[2]);
             } else if (vvars.size() == 4) {
               // std::cout << k << " -- " << vvars[0] << " -- " << vvars[1] << "
               // -- " << vvars[2] << " -- " << vvars[3] << std::endl;
               MEs_[i]->Fill(vvars[0], vvars[1], vvars[2], vvars[3]);
             } else {
               std::cerr << "Too many variables to plot..." << std::endl;
               exit(1);
             }
  
             k++;
           }
  
           delete query;
  
         } catch (coral::Exception &e) {
           std::cerr << "CORAL Exception : " << e.what() << std::endl;
         } catch (std::exception &e) {
           std::cerr << "Standard C++ exception : " << e.what() << std::endl;
         }
       }
     }
  
     if (atLeastAQuery)
       session->transaction().commit();
   }
 }

References SiStripOfflineCRack_cfg::alias, EcnaPython_AdcPeg12_S1_10_R170298_1_0_150_Dee0::cerr, MillePedeFileConverter_cfg::e, relativeConstraints::empty, cppFunctionSkipper::exception, Exception, beamvalidation::exit(), mps_fire::i, ievt_, dqmiolumiharvest::j, dqmdumpme::k, cmsLHEtoEOSManager::l, MEinfo_, MEs_, and contentValuesFiles::query.

Referenced by EcalBarrelMonitorDbModule::analyze().

◆ beginJob()

void MonitorElementsDb::beginJob ( void )

protected

Definition at line 100 of file MonitorElementsDb.cc.

100 { ievt_ = 0; }

References ievt_.

Referenced by EcalBarrelMonitorDbModule::beginJob().

◆ endJob()

void MonitorElementsDb::endJob ( void )

protected

Definition at line 102 of file MonitorElementsDb.cc.

102 { std::cout << "MonitorElementsDb: analyzed " << ievt_ << " events" << std::endl; }

References gather_cfg::cout, and ievt_.

Referenced by EcalBarrelMonitorDbModule::endJob().

◆ htmlOutput()

void MonitorElementsDb::htmlOutput ( std::string & htmlDir )

protected

Definition at line 194 of file MonitorElementsDb.cc.

                                                      {
   gStyle->SetOptStat(0);
   gStyle->SetOptFit();
   gStyle->SetPalette(1, nullptr);
  
   for (unsigned int i = 0; i < MEinfo_.size(); i++) {
     if (MEs_[i] != nullptr && (ievt_ % MEinfo_[i].ncycle) == 0) {
       TCanvas *c1;
       int n = MEinfo_[i].xbins > MEinfo_[i].ybins ? int(round(float(MEinfo_[i].xbins) / float(MEinfo_[i].ybins)))
                                                   : int(round(float(MEinfo_[i].ybins) / float(MEinfo_[i].xbins)));
       if (MEinfo_[i].xbins > MEinfo_[i].ybins) {
         c1 = new TCanvas("c1", "dummy", 400 * n, 400);
       } else {
         c1 = new TCanvas("c1", "dummy", 400, 400 * n);
       }
       c1->SetGrid();
       c1->cd();
  
       const double histMax = 1.e15;
  
       TObject *ob = const_cast<MonitorElement *>(MEs_[i])->getRootObject();
       if (ob) {
         if (dynamic_cast<TH1F *>(ob)) {
           TH1F *h = dynamic_cast<TH1F *>(ob);
           h->Draw();
         } else if (dynamic_cast<TH2F *>(ob)) {
           TH2F *h = dynamic_cast<TH2F *>(ob);
           if (h->GetMaximum(histMax) > 1.e4) {
             gPad->SetLogz(1);
           } else {
             gPad->SetLogz(0);
           }
           h->Draw("colz");
         } else if (dynamic_cast<TProfile *>(ob)) {
           TProfile *h = dynamic_cast<TProfile *>(ob);
           if (h->GetMaximum(histMax) > 1.e4) {
             gPad->SetLogz(1);
           } else {
             gPad->SetLogz(0);
           }
           h->Draw("colz");
         }
       }
  
       c1->Update();
       std::string name = htmlDir + "/" + MEinfo_[i].title + ".png";
       c1->SaveAs(name.c_str());
  
       delete c1;
     }
   }
 }

References alignmentValidation::c1, mps_fire::i, ievt_, createfilelist::int, MEinfo_, MEs_, dqmiodumpmetadata::n, Skims_PA_cff::name, AlCaHLTBitMon_QueryRunRegistry::string, and fw3dlego::xbins.

Referenced by EcalBarrelMonitorDbModule::analyze().

◆ startSession()

void MonitorElementsDb::startSession ( void )

protected

Friends And Related Function Documentation

◆ EcalBarrelMonitorDbModule

friend class EcalBarrelMonitorDbModule

friend

Definition at line 26 of file MonitorElementsDb.h.

Member Data Documentation

◆ dqmStore_

DQMStore* MonitorElementsDb::dqmStore_

private

Definition at line 60 of file MonitorElementsDb.h.

Referenced by MonitorElementsDb().

◆ ievt_

int MonitorElementsDb::ievt_

private

Definition at line 59 of file MonitorElementsDb.h.

Referenced by analyze(), beginJob(), endJob(), htmlOutput(), and MonitorElementsDb().

◆ MEinfo_

std::vector<DB_ME> MonitorElementsDb::MEinfo_

private

Definition at line 57 of file MonitorElementsDb.h.

Referenced by analyze(), htmlOutput(), and MonitorElementsDb().

◆ MEs_

std::vector<MonitorElement *> MonitorElementsDb::MEs_

private

Definition at line 58 of file MonitorElementsDb.h.

Referenced by analyze(), htmlOutput(), and MonitorElementsDb().

◆ parser_

MonitorXMLParser* MonitorElementsDb::parser_

private

Definition at line 56 of file MonitorElementsDb.h.

Referenced by MonitorElementsDb(), valtools.webpage::parseArgs(), batchmanager.BatchManager::ParseOptions(), and ~MonitorElementsDb().

◆ prefixME_

std::string MonitorElementsDb::prefixME_

private

Definition at line 54 of file MonitorElementsDb.h.

Referenced by MonitorElementsDb().

◆ xmlFile_

std::string MonitorElementsDb::xmlFile_

private

Definition at line 55 of file MonitorElementsDb.h.

Referenced by MonitorElementsDb().

Public Types

Public Member Functions

Protected Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ DQMStore

◆ MonitorElement

Constructor & Destructor Documentation

◆ MonitorElementsDb()

◆ ~MonitorElementsDb()

Member Function Documentation

◆ analyze()

◆ beginJob()

◆ endJob()

◆ htmlOutput()

◆ startSession()

Friends And Related Function Documentation

◆ EcalBarrelMonitorDbModule

Member Data Documentation

◆ dqmStore_

◆ ievt_

◆ MEinfo_

◆ MEs_

◆ parser_

◆ prefixME_

◆ xmlFile_