#include <DQMStore.h>

Classes
class	char_string

class	ConcurrentBooker

class	IBooker

class	IGetter

Public Types
enum	OpenRunDirs { KeepRunDirs, StripRunDirs }

enum	SaveReferenceTag { SaveWithoutReference, SaveWithReference, SaveWithReferenceForQTest }

Public Member Functions
MonitorElement *	book1D (char_string const &name, char_string const &title, int const nchX, double const lowX, double const highX)
	Book 1D histogram. More...

MonitorElement *	book1D (char_string const &name, char_string const &title, int nchX, float const *xbinsize)

MonitorElement *	book1D (char_string const &name, TH1F *h)
	Book 1D histogram by cloning an existing histogram. More...

MonitorElement *	book1DD (char_string const &name, char_string const &title, int nchX, double lowX, double highX)
	Book 1S histogram. More...

MonitorElement *	book1DD (char_string const &name, char_string const &title, int nchX, float const *xbinsize)

MonitorElement *	book1DD (char_string const &name, TH1D *h)
	Book 1D double histogram by cloning an existing histogram. More...

MonitorElement *	book1S (char_string const &name, char_string const &title, int nchX, double lowX, double highX)
	Book 1S histogram. More...

MonitorElement *	book1S (char_string const &name, char_string const &title, int nchX, float const *xbinsize)

MonitorElement *	book1S (char_string const &name, TH1S *h)
	Book 1S histogram by cloning an existing histogram. More...

MonitorElement *	book2D (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2D histogram. More...

MonitorElement *	book2D (char_string const &name, char_string const &title, int nchX, float const xbinsize, int nchY, float const ybinsize)

MonitorElement *	book2D (char_string const &name, TH2F *h)
	Book 2D histogram by cloning an existing histogram. More...

MonitorElement *	book2DD (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2D histogram. More...

MonitorElement *	book2DD (char_string const &name, char_string const &title, int nchX, float const xbinsize, int nchY, float const ybinsize)

MonitorElement *	book2DD (char_string const &name, TH2D *h)
	Book 2DS histogram by cloning an existing histogram. More...

MonitorElement *	book2S (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2S histogram. More...

MonitorElement *	book2S (char_string const &name, char_string const &title, int nchX, float const xbinsize, int nchY, float const ybinsize)

MonitorElement *	book2S (char_string const &name, TH2S *h)
	Book 2DS histogram by cloning an existing histogram. More...

MonitorElement *	book3D (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, int nchZ, double lowZ, double highZ)
	Book 3D histogram. More...

MonitorElement *	book3D (char_string const &name, TH3F *h)
	Book 3D histogram by cloning an existing histogram. More...

template<typename iFunc >
void	bookConcurrentTransaction (iFunc f, uint32_t run)

MonitorElement *	bookFloat (char_string const &name)
	Book float. More...

MonitorElement *	bookInt (char_string const &name)
	Book int. More...

MonitorElement *	bookProfile (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, char const *option="s")

MonitorElement *	bookProfile (char_string const &name, char_string const &title, int nchX, double lowX, double highX, double lowY, double highY, char const *option="s")

MonitorElement *	bookProfile (char_string const &name, char_string const &title, int nchX, double const xbinsize, int nchY, double lowY, double highY, char const option="s")

MonitorElement *	bookProfile (char_string const &name, char_string const &title, int nchX, double const xbinsize, double lowY, double highY, char const option="s")

MonitorElement *	bookProfile (char_string const &name, TProfile *h)
	Book TProfile by cloning an existing profile. More...

MonitorElement *	bookProfile2D (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, double lowZ, double highZ, char const *option="s")

MonitorElement *	bookProfile2D (char_string const &name, char_string const &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, int nchZ, double lowZ, double highZ, char const *option="s")

MonitorElement *	bookProfile2D (char_string const &name, TProfile2D *h)
	Book TProfile2D by cloning an existing profile. More...

MonitorElement *	bookString (char_string const &name, char_string const &value)
	Book string. More...

template<typename iFunc >
void	bookTransaction (iFunc f, uint32_t run, uint32_t moduleId, bool canSaveByLumi)

void	cd ()
	go to top directory (ie. root) More...

void	cd (std::string const &subdir)
	cd to subdirectory (if there) More...

void	cloneLumiHistograms (uint32_t run, uint32_t lumi, uint32_t moduleId)

void	cloneRunHistograms (uint32_t run, uint32_t moduleId)

bool	containsAnyMonitorable (std::string const &path) const

QCriterion *	createQTest (std::string const &algoname, std::string const &qtname)

void	deleteUnusedLumiHistograms (uint32_t run, uint32_t lumi)

bool	dirExists (std::string const &path) const
	true if directory exists More...

void	disableSoftReset (MonitorElement *me)

	DQMStore (edm::ParameterSet const &pset, edm::ActivityRegistry &)

	DQMStore (edm::ParameterSet const &pset)

	DQMStore (DQMStore const &)=delete

MonitorElement *	get (std::string const &path) const
	get ME from full pathname (e.g. "my/long/dir/my_histo") More...

std::vector< MonitorElement * >	get (unsigned int tag) const
	get all MonitorElements tagged as <tag> More...

std::vector< MonitorElement * >	getAllContents (std::string const &path, uint32_t runNumber=0, uint32_t lumi=0) const

std::vector< MonitorElement * >	getContents (std::string const &path) const

std::vector< MonitorElement * >	getContents (std::string const &path, unsigned int tag) const
	same as above for tagged MonitorElements More...

void	getContents (std::vector< std::string > &into, bool showContents=true) const

std::vector< MonitorElement * >	getMatchingContents (std::string const &pattern, lat::Regexp::Syntax syntaxType=lat::Regexp::Wildcard) const

std::vector< std::string >	getMEs () const
	get list of (non-dir) MEs of current directory More...

QCriterion *	getQCriterion (std::string const &qtname) const

int	getStatus (std::string const &path="") const

std::vector< std::string >	getSubdirs () const

void	goUp ()
	equivalent to "cd .." More...

bool	isCollate () const

bool	load (std::string const &filename, OpenRunDirs stripdirs=StripRunDirs, bool fileMustExist=true)

template<typename iFunc >
void	meBookerGetter (iFunc f)

bool	mtEnabled ()

bool	open (std::string const &filename, bool overwrite=false, std::string const &path="", std::string const &prepend="", OpenRunDirs stripdirs=KeepRunDirs, bool fileMustExist=true)

DQMStore &	operator= (DQMStore const &)=delete

std::string const &	pwd () const

void	removeContents ()
	erase all monitoring elements in current directory (not including subfolders); More...

void	removeContents (std::string const &dir)
	remove all monitoring elements from directory; More...

void	removeElement (std::string const &name)

void	removeElement (std::string const &dir, std::string const &name, bool warning=true)

void	rmdir (std::string const &fullpath)

void	runQTests ()

void	save (std::string const &filename, std::string const &path="", std::string const &pattern="", std::string const &rewrite="", uint32_t run=0, uint32_t lumi=0, SaveReferenceTag ref=SaveWithReference, int minStatus=dqm::qstatus::STATUS_OK, std::string const &fileupdate="RECREATE")

void	savePB (std::string const &filename, std::string const &path="", uint32_t run=0, uint32_t lumi=0)

void	scaleElements ()

void	setCurrentFolder (std::string const &fullpath)

void	setVerbose (unsigned level)

void	showDirStructure () const

void	softReset (MonitorElement *me)

void	tag (MonitorElement *me, unsigned int myTag)

void	tag (std::string const &path, unsigned int myTag)
	tag ME specified by full pathname (e.g. "my/long/dir/my_histo") More...

void	tagAllContents (std::string const &path, unsigned int myTag)

void	tagContents (std::string const &path, unsigned int myTag)
	tag all children of folder (does NOT include subfolders) More...

void	useQTest (std::string const &dir, std::string const &qtname)

int	useQTestByMatch (std::string const &pattern, std::string const &qtname)
	attach quality test <qc> to monitor elements matching <pattern>. More...

	~DQMStore ()

Private Types
using	MEMap = std::set< MonitorElement >

using	QAMap = std::map< std::string, QCriterion ()(std::string const &)>

using	QCMap = std::map< std::string, QCriterion * >

using	QTestSpec = std::pair< fastmatch , QCriterion >

using	QTestSpecs = std::list< QTestSpec >

Private Member Functions
MonitorElement *	book1D_ (std::string const &dir, std::string const &name, TH1F *h)
	Book 1D histogram based on TH1F. More...

MonitorElement *	book1DD_ (std::string const &dir, std::string const &name, TH1D *h)
	Book 1D histogram based on TH1D. More...

MonitorElement *	book1S_ (std::string const &dir, std::string const &name, TH1S *h)
	Book 1D histogram based on TH1S. More...

MonitorElement *	book2D_ (std::string const &dir, std::string const &name, TH2F *h)
	Book 2D histogram based on TH2F. More...

MonitorElement *	book2DD_ (std::string const &dir, std::string const &name, TH2D *h)
	Book 2D histogram based on TH2D. More...

MonitorElement *	book2S_ (std::string const &dir, std::string const &name, TH2S *h)
	Book 2D histogram based on TH2S. More...

MonitorElement *	book3D_ (std::string const &dir, std::string const &name, TH3F *h)
	Book 3D histogram based on TH3F. More...

MonitorElement *	book_ (std::string const &dir, std::string const &name, char const *context)

template<class HISTO , class COLLATE >
MonitorElement *	book_ (std::string const &dir, std::string const &name, char const context, int kind, HISTO h, COLLATE collate)

MonitorElement *	bookFloat_ (std::string const &dir, std::string const &name)
	Book float. More...

MonitorElement *	bookInt_ (std::string const &dir, std::string const &name)
	Book int. More...

MonitorElement *	bookProfile2D_ (std::string const &dir, std::string const &name, TProfile2D *h)
	Book 2D profile histogram based on TProfile2D. More...

MonitorElement *	bookProfile_ (std::string const &dir, std::string const &name, TProfile *h)
	Book profile histogram based on TProfile. More...

MonitorElement *	bookString_ (std::string const &dir, std::string const &name, std::string const &value)
	Book string. More...

bool	cdInto (std::string const &path) const

bool	extract (TObject *obj, std::string const &dir, bool overwrite, bool collateHistograms)

TObject *	extractNextObject (TBufferFile &) const

MonitorElement *	findObject (uint32_t run, uint32_t lumi, uint32_t moduleId, std::string const &dir, std::string const &name) const

void	forceReset ()

void	get_info (dqmstorepb::ROOTFilePB_Histo const &, std::string &dirname, std::string &objname, TObject **obj)

MonitorElement *	initialise (MonitorElement *me, std::string const &path)

void	initializeFrom (const edm::ParameterSet &)

bool	isCollateME (MonitorElement *me) const

void	makeDirectory (std::string const &path)

void	postGlobalBeginLumi (const edm::GlobalContext &)

void	print_trace (std::string const &dir, std::string const &name)

unsigned int	readDirectory (TFile *file, bool overwrite, std::string const &path, std::string const &prepend, std::string const &curdir, OpenRunDirs stripdirs)

bool	readFile (std::string const &filename, bool overwrite=false, std::string const &path="", std::string const &prepend="", OpenRunDirs stripdirs=StripRunDirs, bool fileMustExist=true)

bool	readFilePB (std::string const &filename, bool overwrite=false, std::string const &path="", std::string const &prepend="", OpenRunDirs stripdirs=StripRunDirs, bool fileMustExist=true)

void	reset ()

void	saveMonitorElementRangeToPB (std::string const &dir, unsigned int run, MEMap::const_iterator begin, MEMap::const_iterator end, dqmstorepb::ROOTFilePB &file, unsigned int &counter)

void	saveMonitorElementRangeToROOT (std::string const &dir, std::string const &refpath, SaveReferenceTag ref, int minStatus, unsigned int run, MEMap::const_iterator begin, MEMap::const_iterator end, TFile &file, unsigned int &counter)

void	saveMonitorElementToPB (MonitorElement const &me, dqmstorepb::ROOTFilePB &file)

void	saveMonitorElementToROOT (MonitorElement const &me, TFile &file)

void	setAccumulate (MonitorElement *me, bool flag)

Static Private Member Functions
static bool	checkBinningMatches (MonitorElement me, TH1 h, unsigned verbose)

static void	collate1D (MonitorElement me, TH1F h, unsigned verbose)

static void	collate1DD (MonitorElement me, TH1D h, unsigned verbose)

static void	collate1S (MonitorElement me, TH1S h, unsigned verbose)

static void	collate2D (MonitorElement me, TH2F h, unsigned verbose)

static void	collate2DD (MonitorElement me, TH2D h, unsigned verbose)

static void	collate2S (MonitorElement me, TH2S h, unsigned verbose)

static void	collate3D (MonitorElement me, TH3F h, unsigned verbose)

static void	collateProfile (MonitorElement me, TProfile h, unsigned verbose)

static void	collateProfile2D (MonitorElement me, TProfile2D h, unsigned verbose)

Private Attributes
std::mutex	book_mutex_

bool	canSaveByLumi_ {false}

bool	collateHistograms_ {false}

MEMap	data_

std::set< std::string >	dirs_

bool	doSaveByLumi_ {false}

bool	enableMultiThread_ {false}

bool	forceResetOnBeginLumi_ {false}

bool	LSbasedMode_

uint32_t	moduleId_ {}

std::string	pwd_ {}

QAMap	qalgos_

QCMap	qtests_

QTestSpecs	qtestspecs_

std::string	readSelectedDirectory_ {}

bool	reset_ {false}

uint32_t	run_ {}

double	scaleFlag_

std::unique_ptr< std::ostream >	stream_ {nullptr}

unsigned	verbose_ {1}

unsigned	verboseQT_ {1}

Friends
class	DQMArchiver

class	DQMFileSaver

class	DQMNet

class	DQMRootOutputModule

class	DQMRootSource

class	DQMService

class	DQMStoreExample

class	edm::DQMHttpSource

class	MEtoEDMConverter

Detailed Description

Definition at line 76 of file DQMStore.h.

Member Typedef Documentation

using DQMStore::MEMap = std::set<MonitorElement>

private

Definition at line 607 of file DQMStore.h.

using DQMStore::QAMap = std::map<std::string, QCriterion* (*)(std::string const&)>

private

Definition at line 609 of file DQMStore.h.

using DQMStore::QCMap = std::map<std::string, QCriterion*>

private

Definition at line 608 of file DQMStore.h.

using DQMStore::QTestSpec = std::pair<fastmatch*, QCriterion*>

private

Definition at line 605 of file DQMStore.h.

using DQMStore::QTestSpecs = std::list<QTestSpec>

private

Definition at line 606 of file DQMStore.h.

Member Enumeration Documentation

enum DQMStore::OpenRunDirs

Enumerator
KeepRunDirs
StripRunDirs

Definition at line 83 of file DQMStore.h.

                    {
     KeepRunDirs,
     StripRunDirs
   };

enum DQMStore::SaveReferenceTag

Enumerator
SaveWithoutReference
SaveWithReference
SaveWithReferenceForQTest

Definition at line 78 of file DQMStore.h.

                         {
     SaveWithoutReference,
     SaveWithReference,
     SaveWithReferenceForQTest
   };

Constructor & Destructor Documentation

DQMStore::DQMStore	(	edm::ParameterSet const &	pset,
		edm::ActivityRegistry &	ar
	)

Definition at line 367 of file DQMStore.cc.

References enableMultiThread_, forceReset(), forceResetOnBeginLumi_, edm::service::SystemBounds::maxNumberOfStreams(), postGlobalBeginLumi(), and muonDTDigis_cfi::pset.

   : DQMStore{pset}
 {
   ar.preallocateSignal_.connect([this](edm::service::SystemBounds const& iBounds) {
       if(iBounds.maxNumberOfStreams() > 1 ) {
         enableMultiThread_ = true;
       }
     });
   if(pset.getUntrackedParameter<bool>("forceResetOnBeginRun",false)) {
     ar.watchPostSourceRun([this](edm::RunIndex){ forceReset(); });
   }
   if(pset.getUntrackedParameter<bool>("forceResetOnBeginLumi",false) && enableMultiThread_ == false) {
 #if !WITHOUT_CMS_FRAMEWORK
     forceResetOnBeginLumi_ = true;
     ar.watchPreSourceLumi([this](edm::LuminosityBlockIndex){ forceReset(); });
 #endif
   }
   ar.watchPostGlobalBeginLumi(this, &DQMStore::postGlobalBeginLumi);
 }

DQMStore::DQMStore ( edm::ParameterSet const & pset )

Definition at line 387 of file DQMStore.cc.

References initializeFrom().

 {
   initializeFrom(pset);
 }

DQMStore::~DQMStore ( )

Definition at line 392 of file DQMStore.cc.

References qtests_, and qtestspecs_.

Referenced by meBookerGetter().

 {
   for (auto& qtest : qtests_)
     delete qtest.second;
 
   for (auto& qtestspec : qtestspecs_)
     delete qtestspec.first;
 }

DQMStore::DQMStore ( DQMStore const & )

delete

Member Function Documentation

MonitorElement * DQMStore::book1D	(	char_string const &	name,
		char_string const &	title,
		int const	nchX,
		double const	lowX,
		double const	highX
	)

Book 1D histogram.

Definition at line 1098 of file DQMStore.cc.

References book1D_(), and pwd_.

Referenced by DQMFEDIntegrityClient::beginJob(), ConverterTester::beginJob(), SimplePhotonAnalyzer::beginJob(), StripValidationPlots::beginJob(), APVValidationPlots::beginJob(), MuonAlignment::beginJob(), MEtoMEComparitor::book(), book1DD(), SiStripBaseCondObjDQM::bookCumulMEs(), TrackerOfflineValidationSummary::bookHarvestingHists(), PixelVTXMonitor::bookHistograms(), DQMLumiMonitor::bookHistograms(), SiStripBaseCondObjDQM::bookProfileMEs(), SiStripBaseCondObjDQM::bookSummaryCumulMEs(), dqmRegisterHistogram(), HarvestingAnalyzer::endJob(), HLTScalersClient::endLuminosityBlock(), GlobalHitsProdHistStripper::endRun(), SiStripQualityDQM::fillGrandSummaryMEs(), SiStripSummaryCreator::getSummaryME(), HLTScalersClient::HLTScalersClient(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::initializeDQMHistograms(), LaserDQM::initMonitors(), L1ScalersClient::L1ScalersClient(), and MonitorElementsDb::MonitorElementsDb().

 {
   return book1D_(pwd_, name, new TH1F(name, title, nchX, lowX, highX));
 }

MonitorElement* DQMStore::book1D	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		float const *	xbinsize
	)

MonitorElement * DQMStore::book1D	(	char_string const &	name,
		TH1F *	h
	)

Book 1D histogram by cloning an existing histogram.

Definition at line 1130 of file DQMStore.cc.

References book1D_(), and pwd_.

 {
   return book1D_(pwd_, name, static_cast<TH1F*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book1D_	(	std::string const &	dir,
		std::string const &	name,
		TH1F *	h
	)

private

Book 1D histogram based on TH1F.

Definition at line 1077 of file DQMStore.cc.

References book_(), collate1D(), and MonitorElement::DQM_KIND_TH1F.

Referenced by book1D(), book1DD(), and extract().

 {
   return book_(dir, name, "book1D", MonitorElement::DQM_KIND_TH1F, h, collate1D);
 }

MonitorElement * DQMStore::book1DD	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX
	)

Book 1S histogram.

Definition at line 1114 of file DQMStore.cc.

References book1D(), book1D_(), book1DD_(), pwd_, and fftjetcommon_cfi::title.

Referenced by MEtoMEComparitor::book().

 {
   return book1DD_(pwd_, name, new TH1D(name, title, nchX, lowX, highX));
 }

MonitorElement* DQMStore::book1DD	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		float const *	xbinsize
	)

MonitorElement * DQMStore::book1DD	(	char_string const &	name,
		TH1D *	h
	)

Book 1D double histogram by cloning an existing histogram.

Definition at line 1144 of file DQMStore.cc.

References book1DD_(), and pwd_.

 {
   return book1DD_(pwd_, name, static_cast<TH1D*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book1DD_	(	std::string const &	dir,
		std::string const &	name,
		TH1D *	h
	)

private

Book 1D histogram based on TH1D.

Definition at line 1091 of file DQMStore.cc.

References book_(), collate1DD(), and MonitorElement::DQM_KIND_TH1D.

Referenced by book1DD(), and extract().

 {
   return book_(dir, name, "book1DD", MonitorElement::DQM_KIND_TH1D, h, collate1DD);
 }

MonitorElement * DQMStore::book1S	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX
	)

Book 1S histogram.

Definition at line 1106 of file DQMStore.cc.

References book1S_(), and pwd_.

Referenced by MEtoMEComparitor::book(), and dqmRegisterHistogram().

 {
   return book1S_(pwd_, name, new TH1S(name, title, nchX, lowX, highX));
 }

MonitorElement* DQMStore::book1S	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		float const *	xbinsize
	)

MonitorElement * DQMStore::book1S	(	char_string const &	name,
		TH1S *	h
	)

Book 1S histogram by cloning an existing histogram.

Definition at line 1137 of file DQMStore.cc.

References book1S_(), and pwd_.

 {
   return book1S_(pwd_, name, static_cast<TH1S*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book1S_	(	std::string const &	dir,
		std::string const &	name,
		TH1S *	h
	)

private

Book 1D histogram based on TH1S.

Definition at line 1084 of file DQMStore.cc.

References book_(), collate1S(), and MonitorElement::DQM_KIND_TH1S.

Referenced by book1S(), and extract().

 {
   return book_(dir, name, "book1S", MonitorElement::DQM_KIND_TH1S, h, collate1S);
 }

MonitorElement * DQMStore::book2D	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY
	)

Book 2D histogram.

Definition at line 1173 of file DQMStore.cc.

References book2D_(), and pwd_.

Referenced by DQMFEDIntegrityClient::beginJob(), ConverterTester::beginJob(), APVValidationPlots::beginJob(), StripValidationPlots::beginJob(), MuonAlignment::beginJob(), book2DD(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), dqmRegisterHistogram(), EgHLTOfflineSummaryClient::getEgHLTSumHist_(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::initializeDQMHistograms(), L1ScalersClient::L1ScalersClient(), and MonitorElementsDb::MonitorElementsDb().

 {
   return book2D_(pwd_, name, new TH2F(name, title,
                                              nchX, lowX, highX,
                                              nchY, lowY, highY));
 }

MonitorElement* DQMStore::book2D	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		float const *	xbinsize,
		int	nchY,
		float const *	ybinsize
	)

MonitorElement * DQMStore::book2D	(	char_string const &	name,
		TH2F *	h
	)

Book 2D histogram by cloning an existing histogram.

Definition at line 1224 of file DQMStore.cc.

References book2D_(), and pwd_.

 {
   return book2D_(pwd_, name, static_cast<TH2F*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book2D_	(	std::string const &	dir,
		std::string const &	name,
		TH2F *	h
	)

private

Book 2D histogram based on TH2F.

Definition at line 1152 of file DQMStore.cc.

References book_(), collate2D(), and MonitorElement::DQM_KIND_TH2F.

Referenced by book2D(), book2DD(), and extract().

 {
   return book_(dir, name, "book2D", MonitorElement::DQM_KIND_TH2F, h, collate2D);
 }

MonitorElement * DQMStore::book2DD	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY
	)

Book 2D histogram.

Definition at line 1195 of file DQMStore.cc.

References book2D(), book2D_(), book2DD_(), book2S(), book2S_(), and pwd_.

 {
   return book2DD_(pwd_, name, new TH2D(name, title,
                                               nchX, lowX, highX,
                                               nchY, lowY, highY));
 }

MonitorElement* DQMStore::book2DD	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		float const *	xbinsize,
		int	nchY,
		float const *	ybinsize
	)

MonitorElement * DQMStore::book2DD	(	char_string const &	name,
		TH2D *	h
	)

Book 2DS histogram by cloning an existing histogram.

Definition at line 1238 of file DQMStore.cc.

References book2DD_(), and pwd_.

 {
   return book2DD_(pwd_, name, static_cast<TH2D*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book2DD_	(	std::string const &	dir,
		std::string const &	name,
		TH2D *	h
	)

private

Book 2D histogram based on TH2D.

Definition at line 1166 of file DQMStore.cc.

References book_(), collate2DD(), and MonitorElement::DQM_KIND_TH2D.

Referenced by book2DD(), and extract().

 {
   return book_(dir, name, "book2DD", MonitorElement::DQM_KIND_TH2D, h, collate2DD);
 }

MonitorElement * DQMStore::book2S	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY
	)

Book 2S histogram.

Definition at line 1184 of file DQMStore.cc.

References book2S_(), and pwd_.

Referenced by book2DD(), and dqmRegisterHistogram().

 {
   return book2S_(pwd_, name, new TH2S(name, title,
                                              nchX, lowX, highX,
                                              nchY, lowY, highY));
 }

MonitorElement* DQMStore::book2S	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		float const *	xbinsize,
		int	nchY,
		float const *	ybinsize
	)

MonitorElement * DQMStore::book2S	(	char_string const &	name,
		TH2S *	h
	)

Book 2DS histogram by cloning an existing histogram.

Definition at line 1231 of file DQMStore.cc.

References book2S_(), and pwd_.

 {
   return book2S_(pwd_, name, static_cast<TH2S*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book2S_	(	std::string const &	dir,
		std::string const &	name,
		TH2S *	h
	)

private

Book 2D histogram based on TH2S.

Definition at line 1159 of file DQMStore.cc.

References book_(), collate2S(), and MonitorElement::DQM_KIND_TH2S.

Referenced by book2DD(), book2S(), and extract().

 {
   return book_(dir, name, "book2S", MonitorElement::DQM_KIND_TH2S, h, collate2S);
 }

MonitorElement * DQMStore::book3D	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		int	nchZ,
		double	lowZ,
		double	highZ
	)

Book 3D histogram.

Definition at line 1253 of file DQMStore.cc.

References book3D_(), and pwd_.

Referenced by ConverterTester::beginJob(), and dqmRegisterHistogram().

 {
   return book3D_(pwd_, name, new TH3F(name, title,
                                              nchX, lowX, highX,
                                              nchY, lowY, highY,
                                              nchZ, lowZ, highZ));
 }

MonitorElement * DQMStore::book3D	(	char_string const &	name,
		TH3F *	h
	)

Book 3D histogram by cloning an existing histogram.

Definition at line 1266 of file DQMStore.cc.

References book3D_(), and pwd_.

 {
   return book3D_(pwd_, name, static_cast<TH3F*>(source->Clone(name)));
 }

MonitorElement * DQMStore::book3D_	(	std::string const &	dir,
		std::string const &	name,
		TH3F *	h
	)

private

Book 3D histogram based on TH3F.

Definition at line 1246 of file DQMStore.cc.

References book_(), collate3D(), and MonitorElement::DQM_KIND_TH3F.

Referenced by book3D(), and extract().

 {
   return book_(dir, name, "book3D", MonitorElement::DQM_KIND_TH3F, h, collate3D);
 }

MonitorElement * DQMStore::book_	(	std::string const &	dir,
		std::string const &	name,
		char const *	context
	)

private

Definition at line 980 of file DQMStore.cc.

References gather_cfg::cout, data_, dirs_, findObject(), moduleId_, eostools::move(), dataset::name, callgraph::path, print_trace(), run_, AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by book1D_(), book1DD_(), book1S_(), book2D_(), book2DD_(), book2S_(), book3D_(), bookFloat_(), bookInt_(), bookProfile2D_(), bookProfile_(), and bookString_().

 {
   assert(name.find('/') == std::string::npos);
   if (verbose_ > 3)
     print_trace(dir, name);
 
   // Check if the request monitor element already exists.
   if (MonitorElement* me = findObject(run_, 0, moduleId_, dir, name)) {
     if (verbose_ > 1) {
       std::string path;
       mergePath(path, dir, name);
 
       std::cout << "DQMStore: "
                 << context << ": monitor element '"
                 << path << "' already exists, resetting" << std::endl;
     }
     me->Reset();
     return me;
   }
   else {
     // Create it and return for initialisation.
     assert(dirs_.count(dir));
     MonitorElement proto(&*dirs_.find(dir), name, run_, moduleId_);
     // this is used only for Int/String/Float. We don't save these by lumi by
     // default, since we can't merge them properly.
     return &const_cast<MonitorElement&>(*data_.insert(std::move(proto)).first);
   }
 }

template<class HISTO , class COLLATE >

MonitorElement * DQMStore::book_	(	std::string const &	dir,
		std::string const &	name,
		char const *	context,
		int	kind,
		HISTO *	h,
		COLLATE	collate
	)

private

Definition at line 904 of file DQMStore.cc.

References MonitorElement::addQReport(), canSaveByLumi_, collateHistograms_, gather_cfg::cout, MonitorElement::data_, data_, dir, dirs_, doSaveByLumi_, DQMNet::DQM_PROP_HAS_REFERENCE, findObject(), DQMNet::CoreObject::flags, h, initialise(), callgraph::kind, moduleId_, eostools::move(), dataset::name, MonitorElement::object_, callgraph::path, print_trace(), lumiQueryAPI::q, qtestspecs_, MonitorElement::reference_, MonitorElement::Reset(), run_, MonitorElement::setLumiFlag(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

 {
   assert(name.find('/') == std::string::npos);
   if (verbose_ > 3)
     print_trace(dir, name);
   std::string path;
   mergePath(path, dir, name);
 
   // Put us in charge of h.
   h->SetDirectory(nullptr);
 
   // Check if the request monitor element already exists.
   MonitorElement* me = findObject(run_, 0, moduleId_, dir, name);
   if (me) {
     if (collateHistograms_) {
       collate(me, h, verbose_);
       delete h;
       return me;
     }
     else {
       if (verbose_ > 1)
         std::cout << "DQMStore: "
                   << context << ": monitor element '"
                   << path << "' already exists, collating" << std::endl;
       me->Reset();
       collate(me, h, verbose_);
       delete h;
       return me;
     }
   }
   else {
     // Create and initialise core object.
     assert(dirs_.count(dir));
     MonitorElement proto(&*dirs_.find(dir), name, run_, moduleId_);
     if (doSaveByLumi_ && canSaveByLumi_) {
       // for legacy (not DQMEDAnalyzer) this is not save.
       proto.setLumiFlag(); // default to per-lumi mode for all non-legacy MEs.
     }
     me = const_cast<MonitorElement&>(*data_.insert(std::move(proto)).first)
       .initialise((MonitorElement::Kind)kind, h);
 
     // Initialise quality test information.
     for (auto const& q : qtestspecs_) {
       if (q.first->match(path))
         me->addQReport(q.second);
     }
 
     // If we just booked a (plain) MonitorElement, and there is a reference
     // MonitorElement with the same name, link the two together.
     // The other direction is handled by the extract method.
     std::string refdir;
     refdir.reserve(s_referenceDirName.size() + dir.size() + 1);
     refdir += s_referenceDirName;
     refdir += '/';
     refdir += dir;
     MonitorElement* referenceME = findObject(0, 0, 0, refdir, name);
     if (referenceME) {
       // We have booked a new MonitorElement with a specific dir and name.
       // Then, if we can find the corresponding MonitorElement in the reference
       // dir we assign the object_ of the reference MonitorElement to the
       // reference_ property of our new MonitorElement.
       me->data_.flags |= DQMNet::DQM_PROP_HAS_REFERENCE;
       me->reference_ = referenceME->object_;
     }
 
     // Return the monitor element.
     return me;
   }
 }

template<typename iFunc >

void DQMStore::bookConcurrentTransaction	(	iFunc	f,
		uint32_t	run
	)

inline

Definition at line 266 of file DQMStore.h.

References book_mutex_, enableMultiThread_, f, writedatasetfile::run, and run_.

   {
     std::lock_guard<std::mutex> guard(book_mutex_);
     /* Set the run_ member only if enableMultiThread is enabled */
     if (enableMultiThread_) {
       run_ = run;
     }
     ConcurrentBooker booker(this);
     f(booker);
 
     /* Reset the run_ member only if enableMultiThread is enabled */
     if (enableMultiThread_) {
       run_ = 0;
     }
   }

MonitorElement * DQMStore::bookFloat ( char_string const & name )

Book float.

Definition at line 1048 of file DQMStore.cc.

References bookFloat_(), and pwd_.

Referenced by DQMFEDIntegrityClient::beginJob(), ConverterTester::beginJob(), DQMDaqInfo::beginJob(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), SiStripDaqInfo::bookStatus(), SiStripDcsInfo::bookStatus(), EgHLTOfflineSummaryClient::runClient_(), and DQMFileSaver::saveForOffline().

 {
   return bookFloat_(pwd_, name);
 }

MonitorElement * DQMStore::bookFloat_	(	std::string const &	dir,
		std::string const &	name
	)

private

Book float.

Definition at line 1035 of file DQMStore.cc.

References book_(), collateHistograms_, MonitorElement::DQM_KIND_REAL, MonitorElement::Fill(), findObject(), MonitorElement::initialise(), moduleId_, and run_.

Referenced by bookFloat(), and extract().

 {
   if (collateHistograms_) {
     if (MonitorElement* me = findObject(run_, 0, moduleId_, dir, name)) {
       me->Fill(0.);
       return me;
     }
   }
   return book_(dir, name, "bookFloat")->initialise(MonitorElement::DQM_KIND_REAL);
 }

MonitorElement * DQMStore::bookInt ( char_string const & name )

Book int.

Definition at line 1027 of file DQMStore.cc.

References bookInt_(), and pwd_.

Referenced by SiStripDcsInfo::addBadModules(), ConverterTester::beginJob(), FineDelayTask::book(), SiStripQualityChecker::fillFaultyModuleStatus(), and SiStripDaqInfo::findExcludedModule().

 {
   return bookInt_(pwd_, name);
 }

MonitorElement * DQMStore::bookInt_	(	std::string const &	dir,
		std::string const &	name
	)

private

Book int.

Definition at line 1014 of file DQMStore.cc.

References book_(), collateHistograms_, MonitorElement::DQM_KIND_INT, MonitorElement::Fill(), findObject(), MonitorElement::initialise(), moduleId_, and run_.

Referenced by bookInt(), and extract().

 {
   if (collateHistograms_) {
     if (MonitorElement* me = findObject(run_, 0, moduleId_, dir, name)) {
       me->Fill(0);
       return me;
     }
   }
   return book_(dir, name, "bookInt")->initialise(MonitorElement::DQM_KIND_INT);
 }

MonitorElement * DQMStore::bookProfile	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		char const *	option = `"s"`
	)

Book profile. Option is one of: " ", "s" (default), "i", "G" (see TProfile::BuildOptions). The number of channels in Y is disregarded in a profile plot.

Definition at line 1285 of file DQMStore.cc.

References bookProfile_(), and pwd_.

Referenced by ConverterTester::beginJob(), StripValidationPlots::beginJob(), SiStripLAProfileBooker::beginRun(), DQMLumiMonitor::bookHistograms(), SiStripBaseCondObjDQM::bookSummaryMEs(), SiStripBaseCondObjDQM::bookSummaryProfileMEs(), dqmRegisterHistogram(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::initializeDQMHistograms(), and MonitorElementsDb::MonitorElementsDb().

 {
   return bookProfile_(pwd_, name, new TProfile(name, title,
                                                       nchX, lowX, highX,
                                                       lowY, highY,
                                                       option));
 }

MonitorElement * DQMStore::bookProfile	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		double	lowY,
		double	highY,
		char const *	option = `"s"`
	)

Book profile. Option is one of: " ", "s" (default), "i", "G" (see TProfile::BuildOptions). The number of channels in Y is disregarded in a profile plot.

Definition at line 1300 of file DQMStore.cc.

References bookProfile_(), and pwd_.

 {
   return bookProfile_(pwd_, name, new TProfile(name, title,
                                                       nchX, lowX, highX,
                                                       lowY, highY,
                                                       option));
 }

MonitorElement * DQMStore::bookProfile	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double const *	xbinsize,
		int	nchY,
		double	lowY,
		double	highY,
		char const *	option = `"s"`
	)

Book variable bin profile. Option is one of: " ", "s" (default), "i", "G" (see TProfile::BuildOptions). The number of channels in Y is disregarded in a profile plot.

Definition at line 1315 of file DQMStore.cc.

References bookProfile_(), and pwd_.

 {
   return bookProfile_(pwd_, name, new TProfile(name, title,
                                                       nchX, xbinsize,
                                                       lowY, highY,
                                                       option));
 }

MonitorElement * DQMStore::bookProfile	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double const *	xbinsize,
		double	lowY,
		double	highY,
		char const *	option = `"s"`
	)

Book variable bin profile. Option is one of: " ", "s" (default), "i", "G" (see TProfile::BuildOptions). The number of channels in Y is disregarded in a profile plot.

Definition at line 1330 of file DQMStore.cc.

References bookProfile_(), and pwd_.

 {
   return bookProfile_(pwd_, name, new TProfile(name, title,
                                                       nchX, xbinsize,
                                                       lowY, highY,
                                                       option));
 }

MonitorElement * DQMStore::bookProfile	(	char_string const &	name,
		TProfile *	h
	)

Book TProfile by cloning an existing profile.

Definition at line 1343 of file DQMStore.cc.

References bookProfile_(), and pwd_.

 {
   return bookProfile_(pwd_, name, static_cast<TProfile*>(source->Clone(name)));
 }

MonitorElement * DQMStore::bookProfile2D	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		double	lowZ,
		double	highZ,
		char const *	option = `"s"`
	)

Book 2-D profile. Option is one of: " ", "s" (default), "i", "G" (see TProfile2D::BuildOptions). The number of channels in Z is disregarded in a 2-D profile.

Definition at line 1379 of file DQMStore.cc.

References bookProfile2D_(), and pwd_.

Referenced by ConverterTester::beginJob(), DQMLumiMonitor::bookHistograms(), dqmRegisterHistogram(), and MonitorElementsDb::MonitorElementsDb().

 {
   return bookProfile2D_(pwd_, name, new TProfile2D(name, title,
                                                           nchX, lowX, highX,
                                                           nchY, lowY, highY,
                                                           lowZ, highZ,
                                                           option));
 }

MonitorElement * DQMStore::bookProfile2D	(	char_string const &	name,
		char_string const &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		int	nchZ,
		double	lowZ,
		double	highZ,
		char const *	option = `"s"`
	)

Book 2-D profile. Option is one of: " ", "s" (default), "i", "G" (see TProfile2D::BuildOptions). The number of channels in Z is disregarded in a 2-D profile.

Definition at line 1362 of file DQMStore.cc.

References bookProfile2D_(), and pwd_.

 {
   return bookProfile2D_(pwd_, name, new TProfile2D(name, title,
                                                           nchX, lowX, highX,
                                                           nchY, lowY, highY,
                                                           lowZ, highZ,
                                                           option));
 }

MonitorElement * DQMStore::bookProfile2D	(	char_string const &	name,
		TProfile2D *	h
	)

Book TProfile2D by cloning an existing profile.

Definition at line 1394 of file DQMStore.cc.

References bookProfile2D_(), and pwd_.

 {
   return bookProfile2D_(pwd_, name, static_cast<TProfile2D*>(source->Clone(name)));
 }

MonitorElement * DQMStore::bookProfile2D_	(	std::string const &	dir,
		std::string const &	name,
		TProfile2D *	h
	)

private

Book 2D profile histogram based on TProfile2D.

Definition at line 1351 of file DQMStore.cc.

References book_(), collateProfile2D(), and MonitorElement::DQM_KIND_TPROFILE2D.

Referenced by bookProfile2D(), and extract().

 {
   return book_(dir, name, "bookProfile2D",
                MonitorElement::DQM_KIND_TPROFILE2D,
                h, collateProfile2D);
 }

MonitorElement * DQMStore::bookProfile_	(	std::string const &	dir,
		std::string const &	name,
		TProfile *	h
	)

private

Book profile histogram based on TProfile.

Definition at line 1274 of file DQMStore.cc.

References book_(), collateProfile(), and MonitorElement::DQM_KIND_TPROFILE.

Referenced by bookProfile(), and extract().

 {
   return book_(dir, name, "bookProfile",
                MonitorElement::DQM_KIND_TPROFILE,
                h, collateProfile);
 }

MonitorElement * DQMStore::bookString	(	char_string const &	name,
		char_string const &	value
	)

Book string.

Definition at line 1069 of file DQMStore.cc.

References bookString_(), and pwd_.

Referenced by DQMFileReader::beginJob(), ConverterTester::beginJob(), and DQMFileSaver::saveForOffline().

 {
   return bookString_(pwd_, name, value);
 }

MonitorElement * DQMStore::bookString_	(	std::string const &	dir,
		std::string const &	name,
		std::string const &	value
	)

private

Book string.

Definition at line 1056 of file DQMStore.cc.

References book_(), collateHistograms_, MonitorElement::DQM_KIND_STRING, findObject(), MonitorElement::initialise(), moduleId_, and run_.

Referenced by bookString(), and extract().

 {
   if (collateHistograms_) {
     if (MonitorElement* me = findObject(run_, 0, moduleId_, dir, name))
       return me;
   }
   return book_(dir, name, "bookString")->initialise(MonitorElement::DQM_KIND_STRING, value);
 }

template<typename iFunc >

void DQMStore::bookTransaction	(	iFunc	f,
		uint32_t	run,
		uint32_t	moduleId,
		bool	canSaveByLumi
	)

inline

Definition at line 243 of file DQMStore.h.

References book_mutex_, canSaveByLumi_, enableMultiThread_, f, moduleId_, writedatasetfile::run, and run_.

   {
     std::lock_guard<std::mutex> guard(book_mutex_);
     /* Set the run number and module id only if multithreading is enabled */
     if (enableMultiThread_) {
       run_ = run;
       moduleId_ = moduleId;
       canSaveByLumi_ = canSaveByLumi;
     }
     IBooker booker{this};
     f(booker);
 
     /* Reset the run number and module id only if multithreading is enabled */
     if (enableMultiThread_) {
       run_ = 0;
       moduleId_ = 0;
       canSaveByLumi_ = false;
     }
   }

void DQMStore::cd ( )

go to top directory (ie. root)

Definition at line 546 of file DQMStore.cc.

References setCurrentFolder().

Referenced by SiStripDcsInfo::addBadModules(), DQMFileReader::beginJob(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), SiStripDcsInfo::bookStatus(), SiStripDaqInfo::bookStatus(), SiStripTrackerMapCreator::createForOffline(), SiStripTrackerMapCreator::createInfoFile(), SiStripSummaryCreator::createSummary(), SiStripActionExecutor::createSummary(), SiStripActionExecutor::createSummaryOffline(), APVValidationPlots::endJob(), StripValidationPlots::endJob(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::extractBadAPVSandStrips(), SiStripQualityChecker::fillDetectorStatus(), SiStripQualityChecker::fillDetectorStatusAtLumi(), SiStripQualityChecker::fillFaultyModuleStatus(), SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripCertificationInfo::fillSiStripCertificationMEs(), SiStripCertificationInfo::fillSiStripCertificationMEsAtLumi(), SiStripQualityChecker::fillSubDetStatus(), SiStripSummaryCreator::fillSummaryHistos(), SiStripDaqInfo::findExcludedModule(), dqm_interfaces.DQMcommunicator::get_root_objects_list_recursive(), dqm_interfaces.DQMcommunicator::get_root_objects_names_list_recursive(), dqm_interfaces.DQMcommunicator::get_root_objects_recursive(), SiStripTrackerMapCreator::getDetectorFlagAndComment(), SiStripUtility::getModuleFolderList(), SiStripBadModuleFedErrESSource::getProcessedEvents(), SiStripSummaryCreator::getSummaryME(), SiStripUtility::getTopFolderPath(), SiStripUtility::goToDir(), SiStripActionExecutor::printFaultyModuleList(), readFilePB(), DQMFileSaver::saveForOffline(), DQMFileSaver::saveForOnline(), SiStripTrackerMapCreator::setTkMapFromHistogram(), and dqm_interfaces.DirWalkerFile::walk().

 {
   setCurrentFolder("");
 }

void DQMStore::cd ( std::string const & subdir )

cd to subdirectory (if there)

Definition at line 553 of file DQMStore.cc.

References clean, dirExists(), raiseDQMError(), setCurrentFolder(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by dqm_interfaces.DQMcommunicator::get_root_objects_list_recursive(), dqm_interfaces.DQMcommunicator::get_root_objects_names_list_recursive(), dqm_interfaces.DQMcommunicator::get_root_objects_recursive(), and dqm_interfaces.DirWalkerFile::walk().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(subdir, clean, cleaned);
 
   if (! dirExists(*cleaned))
     raiseDQMError("DQMStore", "Cannot 'cd' into non-existent directory '%s'",
                   cleaned->c_str());
 
   setCurrentFolder(*cleaned);
 }

bool DQMStore::cdInto ( std::string const & path ) const

private

Use this for saving monitoring objects in ROOT files with dir structure; cd into directory (create first if it doesn't exist); returns success flag

Definition at line 2314 of file DQMStore.cc.

References end, connectstrParser::o, raiseDQMError(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by save().

 {
   assert(! path.empty());
 
   // Find the first path component.
   size_t start = 0;
   size_t end = path.find('/', start);
   if (end == std::string::npos)
     end = path.size();
 
   while (true) {
     // Check if this subdirectory component exists.  If yes, make sure
     // it is actually a subdirectory.  Otherwise create or cd into it.
     std::string part(path, start, end-start);
     TObject* o = gDirectory->Get(part.c_str());
     if (o && ! dynamic_cast<TDirectory*>(o))
       raiseDQMError("DQMStore", "Attempt to create directory '%s' in a file"
                     " fails because the part '%s' already exists and is not"
                     " directory", path.c_str(), part.c_str());
     else if (! o)
       gDirectory->mkdir(part.c_str());
 
     if (! gDirectory->cd(part.c_str()))
       raiseDQMError("DQMStore", "Attempt to create directory '%s' in a file"
                     " fails because could not cd into subdirectory '%s'",
                     path.c_str(), part.c_str());
 
     // Stop if we reached the end, ignoring any trailing '/'.
     if (end+1 >= path.size())
       break;
 
     // Find the next path component.
     start = end+1;
     end = path.find('/', start);
     if (end == std::string::npos)
       end = path.size();
   }
 
   return true;
 }

bool DQMStore::checkBinningMatches	(	MonitorElement *	me,
		TH1 *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1403 of file DQMStore.cc.

References MonitorElement::CheckBinLabels(), gather_cfg::cout, MonitorElement::getFullname(), and MonitorElement::getTH1().

Referenced by collate1D(), collate1DD(), collate1S(), collate2D(), collate2DD(), collate2S(), collate3D(), collateProfile(), collateProfile2D(), utils.BinToBin::do_test(), and utils.BinToBin1percent::do_test().

 {
   if (me->getTH1()->GetNbinsX() != h->GetNbinsX()
       || me->getTH1()->GetNbinsY() != h->GetNbinsY()
       || me->getTH1()->GetNbinsZ() != h->GetNbinsZ()
       || me->getTH1()->GetXaxis()->GetXmin() != h->GetXaxis()->GetXmin()
       || me->getTH1()->GetYaxis()->GetXmin() != h->GetYaxis()->GetXmin()
       || me->getTH1()->GetZaxis()->GetXmin() != h->GetZaxis()->GetXmin()
       || me->getTH1()->GetXaxis()->GetXmax() != h->GetXaxis()->GetXmax()
       || me->getTH1()->GetYaxis()->GetXmax() != h->GetYaxis()->GetXmax()
       || me->getTH1()->GetZaxis()->GetXmax() != h->GetZaxis()->GetXmax()
       || !MonitorElement::CheckBinLabels((TAxis*)me->getTH1()->GetXaxis(),(TAxis*)h->GetXaxis())
       || !MonitorElement::CheckBinLabels((TAxis*)me->getTH1()->GetYaxis(),(TAxis*)h->GetYaxis())
       || !MonitorElement::CheckBinLabels((TAxis*)me->getTH1()->GetZaxis(),(TAxis*)h->GetZaxis())) {
     if(verbose > 0)
       std::cout << "*** DQMStore: WARNING:"
                 << "checkBinningMatches: different binning - cannot add object '"
                 << h->GetName() << "' of type "
                 << h->IsA()->GetName() << " to existing ME: '"
                 << me->getFullname() << "'\n";
     return false;
   }
   return true;
 }

void DQMStore::cloneLumiHistograms	(	uint32_t	run,
		uint32_t	lumi,
		uint32_t	moduleId
	)

Clone the lumisection-based histograms from the 'global' ones (which have lumi = 0) into per-lumi ones (with the lumi number) and reset the global ones. The per-lumi histograms can be saved by the output modules, and will be deleted at the beginninng of the next lumisection.

Definition at line 1920 of file DQMStore.cc.

References book_mutex_, clone(), gather_cfg::cout, data_, MillePedeFileConverter_cfg::e, mps_fire::i, LSbasedMode_, eostools::move(), HcalObjRepresent::Reset(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

 {
   if (verbose_ > 1) {
     std::cout << "DQMStore::cloneLumiHistograms - Preparing lumi histograms for run: "
               << run << ", lumi: " << lumi << ", module: " << moduleId << std::endl;
   }
 
   // acquire the global lock since this accesses the undelying data structure
   std::lock_guard<std::mutex> guard(book_mutex_);
 
   // MEs are sorted by (run, lumi, stream id, module id, directory, name)
   // lumi deafults to 0
   // stream id is always 0
   std::string null_str("");
   auto i = data_.lower_bound(MonitorElement(&null_str, null_str, run, moduleId));
   auto e = data_.lower_bound(MonitorElement(&null_str, null_str, run, moduleId + 1));
   // we will later modify data_, so better do two passes.
   auto tobehandled = std::vector<MonitorElement const*>();
   for (; i != e; ++i) {
     tobehandled.push_back(&*i);
   }
   for (auto i : tobehandled) {
     // handle only lumisection-based histograms
     if (not LSbasedMode_ and not i->getLumiFlag())
       continue;
 
     // clone the lumisection-based histograms
     MonitorElement clone{*i};
     clone.globalize();
     clone.setLumi(lumi);
     clone.markToDelete();
     data_.insert(std::move(clone));
 
     // reset the ME for the next lumisection
     const_cast<MonitorElement*>(&*i)->Reset();
   }
 }

void DQMStore::cloneRunHistograms	(	uint32_t	run,
		uint32_t	moduleId
	)

Same as above, but for run histograms.

Definition at line 1962 of file DQMStore.cc.

References book_mutex_, clone(), gather_cfg::cout, data_, MillePedeFileConverter_cfg::e, mps_fire::i, LSbasedMode_, eostools::move(), or, HcalObjRepresent::Reset(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

 {
   if (verbose_ > 1) {
     std::cout << "DQMStore::cloneRunHistograms - Preparing run histograms for run: "
               << run << ", module: " << moduleId << std::endl;
   }
 
   // acquire the global lock since this accesses the undelying data structure
   std::lock_guard<std::mutex> guard(book_mutex_);
 
   // MEs are sorted by (run, lumi, stream id, module id, directory, name)
   // lumi deafults to 0
   // stream id is always 0
   std::string null_str("");
   auto i = data_.lower_bound(MonitorElement(&null_str, null_str, run, moduleId));
   auto e = data_.lower_bound(MonitorElement(&null_str, null_str, run, moduleId + 1));
   // we will later modify data_, so better do two passes.
   auto tobehandled = std::vector<MonitorElement const*>();
   for (; i != e; ++i) {
     tobehandled.push_back(&*i);
   }
   for (auto i : tobehandled) {
     // handle only non lumisection-based histograms
     if (LSbasedMode_ or i->getLumiFlag())
       continue;
 
     // clone the lumisection-based histograms
     MonitorElement clone{*i};
     clone.globalize();
     clone.markToDelete();
     data_.insert(std::move(clone));
 
     // reset the ME for the next lumisection
     const_cast<MonitorElement*>(&*i)->Reset();
   }
 }

void DQMStore::collate1D	(	MonitorElement *	me,
		TH1F *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1429 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH1F().

Referenced by book1D_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH1F()->Add(h);
 }

void DQMStore::collate1DD	(	MonitorElement *	me,
		TH1D *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1443 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH1D().

Referenced by book1DD_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH1D()->Add(h);
 }

void DQMStore::collate1S	(	MonitorElement *	me,
		TH1S *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1436 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH1S().

Referenced by book1S_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH1S()->Add(h);
 }

void DQMStore::collate2D	(	MonitorElement *	me,
		TH2F *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1450 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH2F().

Referenced by book2D_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH2F()->Add(h);
 }

void DQMStore::collate2DD	(	MonitorElement *	me,
		TH2D *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1464 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH2D().

Referenced by book2DD_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH2D()->Add(h);
 }

void DQMStore::collate2S	(	MonitorElement *	me,
		TH2S *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1457 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH2S().

Referenced by book2S_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH2S()->Add(h);
 }

void DQMStore::collate3D	(	MonitorElement *	me,
		TH3F *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1471 of file DQMStore.cc.

References checkBinningMatches(), and MonitorElement::getTH3F().

Referenced by book3D_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose))
     me->getTH3F()->Add(h);
 }

void DQMStore::collateProfile	(	MonitorElement *	me,
		TProfile *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1478 of file DQMStore.cc.

References MonitorElement::addProfiles(), checkBinningMatches(), and MonitorElement::getTProfile().

Referenced by bookProfile_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose)) {
     TProfile* meh = me->getTProfile();
     me->addProfiles(h, meh, meh, 1, 1);
   }
 }

void DQMStore::collateProfile2D	(	MonitorElement *	me,
		TProfile2D *	h,
		unsigned	verbose
	)

staticprivate

Definition at line 1487 of file DQMStore.cc.

References MonitorElement::addProfiles(), checkBinningMatches(), and MonitorElement::getTProfile2D().

Referenced by bookProfile2D_(), and extract().

 {
   if (checkBinningMatches(me,h,verbose)) {
     TProfile2D* meh = me->getTProfile2D();
     me->addProfiles(h, meh, meh, 1, 1);
   }
 }

bool DQMStore::containsAnyMonitorable ( std::string const & path ) const

true if directory (or any subfolder at any level below it) contains at least one monitorable element

Definition at line 1603 of file DQMStore.cc.

References data_, MillePedeFileConverter_cfg::e, mps_fire::i, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by DQMStore::IGetter::removeElement().

 {
   MonitorElement proto(&path, std::string());
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   return (i != e && isSubdirectory(path, *i->data_.dirname));
 }

QCriterion * DQMStore::createQTest	(	std::string const &	algoname,
		std::string const &	qtname
	)

create quality test with unique name <qtname> (analogous to ME name); quality test can then be attached to ME with useQTest method (<algo_name> must match one of known algorithms)

Definition at line 3163 of file DQMStore.cc.

References mps_fire::i, qalgos_, qtests_, raiseDQMError(), QCriterion::setVerbose(), and verboseQT_.

 {
   if (qtests_.count(qtname))
     raiseDQMError("DQMStore", "Attempt to create duplicate quality test '%s'",
                   qtname.c_str());
 
   auto i = qalgos_.find(algoname);
   if (i == qalgos_.end())
     raiseDQMError("DQMStore", "Cannot create a quality test using unknown"
                   " algorithm '%s'", algoname.c_str());
 
   QCriterion* qc = i->second(qtname);
   qc->setVerbose(verboseQT_);
 
   qtests_[qtname] = qc;
   return qc;
 }

void DQMStore::deleteUnusedLumiHistograms	(	uint32_t	run,
		uint32_t	lumi
	)

Delete global histograms which are no longer in use. Such histograms are created at the end of each lumi and should be deleted after the last globalEndLuminosityBlock.

Definition at line 2005 of file DQMStore.cc.

References book_mutex_, gather_cfg::cout, data_, MillePedeFileConverter_cfg::e, enableMultiThread_, mps_fire::i, MonitorElement::setLumi(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by DQMFileSaver::globalEndLuminosityBlock().

 {
   if (!enableMultiThread_)
     return;
 
   std::lock_guard<std::mutex> guard(book_mutex_);
 
   std::string null_str("");
   MonitorElement proto(&null_str, null_str, run, 0);
   proto.setLumi(lumi);
 
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
 
   while (i != e) {
     if (i->data_.moduleId != 0)
       break;
     if (i->data_.lumi != lumi)
       break;
     if (i->data_.run != run)
       break;
     if (not i->markedToDelete()) {
       ++i;
       continue;
     }
 
     if (verbose_ > 1) {
       std::cout << "DQMStore::deleteUnusedLumiHistograms: deleted monitor element '"
                 << *i->data_.dirname << "/" << i->data_.objname << "'"
                 << "flags " << i->data_.flags << "\n";
     }
 
     i = data_.erase(i);
   }
 }

bool DQMStore::dirExists ( std::string const & path ) const

true if directory exists

Definition at line 635 of file DQMStore.cc.

References dirs_.

Referenced by cd(), SiStripActionExecutor::createSummary(), SiStripQualityChecker::fillDetectorStatus(), SiStripQualityChecker::fillFaultyModuleStatus(), SiStripDaqInfo::findExcludedModule(), SiStripTrackerMapCreator::getDetectorFlagAndComment(), SiStripBadModuleFedErrESSource::getProcessedEvents(), SiStripUtility::getTopFolderPath(), SiStripActionExecutor::printFaultyModuleList(), scaleElements(), and SiStripTrackerMapCreator::setTkMapFromHistogram().

 {
   return dirs_.count(path) > 0;
 }

void DQMStore::disableSoftReset ( MonitorElement * me )

Definition at line 3288 of file DQMStore.cc.

References MonitorElement::disableSoftReset().

Referenced by ecaldqm::MESet::recoverStats().

 {
   if (me)
     me->disableSoftReset();
 }

bool DQMStore::extract	(	TObject *	obj,
		std::string const &	dir,
		bool	overwrite,
		bool	collateHistograms
	)

private

extract object (TH1F, TH2F, ...) from <to>; return success flag flag fromRemoteNode indicating if ME arrived from different node

Definition at line 2047 of file DQMStore.cc.

References MonitorElement::addQReport(), DQMNet::QValue::algorithm, book1D_(), book1DD_(), book1S_(), book2D_(), book2DD_(), book2S_(), book3D_(), bookFloat_(), bookInt_(), bookProfile2D_(), bookProfile_(), bookString_(), DQMNet::QValue::code, collate1D(), collate1DD(), collate1S(), collate2D(), collate2DD(), collate2S(), collate3D(), collateHistograms_, collateProfile(), collateProfile2D(), MonitorElement::copyFrom(), gather_cfg::cout, dot(), DQMNet::DQM_PROP_HAS_REFERENCE, MonitorElement::Fill(), findObject(), h, isCollateME(), callgraph::kind, label, funct::m, funct::master(), DQMNet::QValue::message, gen::n, MonitorElement::object_, DQMNet::QValue::qtname, DQMNet::QValue::qtresult, alignCSCRings::s, s_rxmeval(), MonitorElement::setEfficiencyFlag(), AlCaHLTBitMon_QueryRunRegistry::string, tag(), heppy_batch::val, and verbose_.

Referenced by readDirectory(), and readFilePB().

 {
   // NB: Profile histograms inherit from TH*D, checking order matters.
   MonitorElement *refcheck = nullptr;
   if (auto* h = dynamic_cast<TProfile*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = bookProfile_(dir, h->GetName(), (TProfile*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collateProfile(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TProfile2D*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = bookProfile2D_(dir, h->GetName(), (TProfile2D*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collateProfile2D(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH1F*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book1D_(dir, h->GetName(), (TH1F*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate1D(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH1S*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book1S_(dir, h->GetName(), (TH1S*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate1S(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH1D*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book1DD_(dir, h->GetName(), (TH1D*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate1DD(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH2F*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book2D_(dir, h->GetName(), (TH2F*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate2D(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH2S*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book2S_(dir, h->GetName(), (TH2S*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate2S(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH2D*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book2DD_(dir, h->GetName(), (TH2D*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate2DD(me, h, verbose_);
     refcheck = me;
   }
   else if (auto* h = dynamic_cast<TH3F*>(obj)) {
     MonitorElement* me = findObject(0, 0, 0, dir, h->GetName());
     if (! me)
       me = book3D_(dir, h->GetName(), (TH3F*) h->Clone());
     else if (overwrite)
       me->copyFrom(h);
     else if (isCollateME(me) || collateHistograms)
       collate3D(me, h, verbose_);
     refcheck = me;
   }
   else if (dynamic_cast<TObjString*>(obj)) {
     lat::RegexpMatch m;
     if (! s_rxmeval.match(obj->GetName(), 0, 0, &m)) {
       if (strstr(obj->GetName(), "CMSSW")) {
         if (verbose_)
           std::cout << "Input file version: " << obj->GetName() << std::endl;
         return true;
       }
       else if (strstr(obj->GetName(), "DQMPATCH")) {
         if (verbose_)
           std::cout << "DQM patch version: " << obj->GetName() << std::endl;
         return true;
       }
       else {
         std::cout << "*** DQMStore: WARNING: cannot extract object '"
                   << obj->GetName() << "' of type '"
                   << obj->IsA()->GetName() << "'\n";
         return false;
       }
     }
 
     std::string label = m.matchString(obj->GetName(), 1);
     std::string kind = m.matchString(obj->GetName(), 2);
     std::string value = m.matchString(obj->GetName(), 3);
 
     if (kind == "i") {
       MonitorElement* me = findObject(0, 0, 0, dir, label);
       if (! me || overwrite) {
         if (! me) me = bookInt_(dir, label);
         me->Fill(atoll(value.c_str()));
       }
     }
     else if (kind == "f") {
       MonitorElement* me = findObject(0, 0, 0, dir, label);
       if (! me || overwrite) {
         if (! me) me = bookFloat_(dir, label);
         me->Fill(atof(value.c_str()));
       }
     }
     else if (kind == "s") {
       MonitorElement* me = findObject(0, 0, 0, dir, label);
       if (! me)
         me = bookString_(dir, label, value);
       else if (overwrite)
         me->Fill(value);
     }
     else if (kind == "e") {
       MonitorElement* me = findObject(0, 0, 0, dir, label);
       if (! me) {
         std::cout << "*** DQMStore: WARNING: no monitor element '"
                   << label << "' in directory '"
                   << dir << "' to be marked as efficiency plot.\n";
         return false;
       }
       me->setEfficiencyFlag();
     }
     else if (kind == "t") {
       MonitorElement* me = findObject(0, 0, 0, dir, label);
       if (! me) {
         std::cout << "*** DQMStore: WARNING: no monitor element '"
                   << label << "' in directory '"
                   << dir << "' for a tag\n";
         return false;
       }
       errno = 0;
       char* endp = nullptr;
       unsigned long val = strtoul(value.c_str(), &endp, 10);
       if ((val == 0 && errno) || *endp || val > ~uint32_t(0)) {
         std::cout << "*** DQMStore: WARNING: cannot restore tag '"
                   << value << "' for monitor element '"
                   << label << "' in directory '"
                   << dir << "' - invalid value\n";
         return false;
       }
       tag(me, val);
     }
     else if (kind == "qr") {
       // Handle qreports, but skip them while reading in references.
       if (! isSubdirectory(s_referenceDirName, dir)) {
         size_t dot = label.find('.');
         if (dot == std::string::npos) {
           std::cout << "*** DQMStore: WARNING: quality report label in '" << label
                     << "' is missing a '.' and cannot be extracted\n";
           return false;
         }
 
         std::string mename (label, 0, dot);
         std::string qrname (label, dot+1, std::string::npos);
 
         m.reset();
         DQMNet::QValue qv;
         if (s_rxmeqr1.match(value, 0, 0, &m)) {
           qv.code = atoi(m.matchString(value, 1).c_str());
           qv.qtresult = strtod(m.matchString(value, 2).c_str(), nullptr);
           qv.message = m.matchString(value, 4);
           qv.qtname = qrname;
           qv.algorithm = m.matchString(value, 3);
         }
         else if (s_rxmeqr2.match(value, 0, 0, &m)) {
           qv.code = atoi(m.matchString(value, 1).c_str());
           qv.qtresult = 0; // unavailable in old format
           qv.message = m.matchString(value, 2);
           qv.qtname = qrname;
           // qv.algorithm unavailable in old format
         }
         else {
           std::cout << "*** DQMStore: WARNING: quality test value '"
                     << value << "' is incorrectly formatted\n";
           return false;
         }
 
         MonitorElement* me = findObject(0, 0, 0, dir, mename);
         if (! me) {
           std::cout << "*** DQMStore: WARNING: no monitor element '"
                     << mename << "' in directory '"
                     << dir << "' for quality test '"
                     << label << "'\n";
           return false;
         }
 
         me->addQReport(qv, /* FIXME: getQTest(qv.qtname)? */ nullptr);
       }
     }
     else {
       std::cout << "*** DQMStore: WARNING: cannot extract object '"
                 << obj->GetName() << "' of type '"
                 << obj->IsA()->GetName() << "'\n";
       return false;
     }
   }
   else if (auto* n = dynamic_cast<TNamed*>(obj)) {
     // For old DQM data.
     std::string s;
     s.reserve(6 + strlen(n->GetTitle()) + 2*strlen(n->GetName()));
     s += '<'; s += n->GetName(); s += '>';
     s += n->GetTitle();
     s += '<'; s += '/'; s += n->GetName(); s += '>';
     TObjString os(s.c_str());
     return extract(&os, dir, overwrite, collateHistograms_);
   }
   else {
     std::cout << "*** DQMStore: WARNING: cannot extract object '"
               << obj->GetName() << "' of type '" << obj->IsA()->GetName()
               << "' and with title '" << obj->GetTitle() << "'\n";
     return false;
   }
 
   // If we just read in a reference MonitorElement, and there is a
   // MonitorElement with the same name, link the two together.
   // The other direction is handled by the book() method.
   if (refcheck && isSubdirectory(s_referenceDirName, dir)) {
     std::string mdir(dir, s_referenceDirName.size()+1, std::string::npos);
     if (MonitorElement* master = findObject(0, 0, 0, mdir, obj->GetName())) {
       // We have extracted a MonitorElement, and it's located in the reference
       // dir. Then we find the corresponding MonitorElement in the
       // non-reference dir and assign the object_ of the reference
       // MonitorElement to the reference_ property of the corresponding
       // non-reference MonitorElement.
       master->data_.flags |= DQMNet::DQM_PROP_HAS_REFERENCE;
       master->reference_ = refcheck->object_;
     }
   }
 
   return true;
 }

TObject * DQMStore::extractNextObject ( TBufferFile & buf ) const

inlineprivate

Extract the next serialised ROOT object from buf. Returns null if there are no more objects in the buffer, or a null pointer was serialised at this location.

Definition at line 2974 of file DQMStore.cc.

Referenced by get_info().

 {
   if (buf.Length() == buf.BufferSize())
     return nullptr;
   buf.InitMap();
   void* ptr = buf.ReadObjectAny(nullptr);
   return reinterpret_cast<TObject*>(ptr);
 }

MonitorElement * DQMStore::findObject	(	uint32_t	run,
		uint32_t	lumi,
		uint32_t	moduleId,
		std::string const &	dir,
		std::string const &	name
	)		const

private

get MonitorElement <name> in directory <dir> (null if MonitorElement does not exist)

Definition at line 1739 of file DQMStore.cc.

References MonitorElement::data_, data_, dir, DQMNet::CoreObject::dirname, csvLumiCalc::lumi, DQMNet::CoreObject::lumi, DQMNet::CoreObject::moduleId, dataset::name, DQMNet::CoreObject::objname, raiseDQMError(), writedatasetfile::run, and DQMNet::CoreObject::run.

Referenced by book_(), bookFloat_(), bookInt_(), bookString_(), extract(), makeDirectory(), readFilePB(), and tag().

 {
   if (dir.find_first_not_of(s_safe) != std::string::npos)
     raiseDQMError("DQMStore", "Monitor element path name '%s' uses"
                   " unacceptable characters", dir.c_str());
   if (name.find_first_not_of(s_safe) != std::string::npos)
     raiseDQMError("DQMStore", "Monitor element path name '%s' uses"
                   " unacceptable characters", name.c_str());
 
   MonitorElement proto;
   proto.data_.dirname  = &dir;
   proto.data_.objname  = name;
   proto.data_.run      = run;
   proto.data_.lumi     = lumi;
   proto.data_.moduleId = moduleId;
 
   auto mepos = data_.find(proto);
   return (mepos == data_.end() ? nullptr
           : const_cast<MonitorElement *>(&*mepos));
 }

void DQMStore::forceReset ( )

private

Invoke this method after flushing all recently changed monitoring. Clears updated flag on all MEs and calls their Reset() method.

Definition at line 1864 of file DQMStore.cc.

References data_, forceResetOnBeginLumi_, funct::m, MonitorElement::Reset(), and reset_.

Referenced by DQMStore().

 {
   for (auto const& m : data_) {
     if (forceResetOnBeginLumi_ && (m.getLumiFlag() == false))
       continue;
     auto& me = const_cast<MonitorElement&>(m);
     me.Reset();
     me.resetUpdate();
   }
 
   reset_ = true;
 }

MonitorElement * DQMStore::get ( std::string const & path ) const

get ME from full pathname (e.g. "my/long/dir/my_histo")

Definition at line 1613 of file DQMStore.cc.

References data_, dir, dataset::name, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), SiStripDcsInfo::addBadModules(), TrackerOfflineValidationSummary::associateModuleHistsWithTree(), util.rrapi.RRApi::columns(), rrapi.RRApi::columns(), util.rrapi.RRApi::count(), rrapi.RRApi::count(), SiStripActionExecutor::createShiftReport(), util.rrapi.RRApi::data(), rrapi.RRApi::data(), dqmCopyRecursively(), HarvestingAnalyzer::endJob(), MuonAlignment::endJob(), L1ScalersClient::endLuminosityBlock(), HLTScalersClient::endLuminosityBlock(), TauDQMHistPlotter::endRun(), SiStripQualityChecker::fillDetectorStatusAtLumi(), SiStripQualityChecker::fillFaultyModuleStatus(), DQMFEDIntegrityClient::fillHistograms(), SiStripCertificationInfo::fillSiStripCertificationMEs(), SiStripCertificationInfo::fillSiStripCertificationMEsAtLumi(), PFDQMEventSelector::filter(), SiStripDaqInfo::findExcludedModule(), betterConfigParser.BetterConfigParser::getCompares(), SiStripTrackerMapCreator::getDetectorFlagAndComment(), EgHLTOfflineSummaryClient::getEgHLTSumHist_(), betterConfigParser.BetterConfigParser::getGeneral(), SiStripQualityChecker::getModuleStatus(), SiStripBadModuleFedErrESSource::getProcessedEvents(), betterConfigParser.BetterConfigParser::getResultingSection(), SiStripHistoPlotter::makePlot(), SiStripActionExecutor::printShiftHistoParameters(), QTestStatusChecker::processAlarms(), rrapi.RRApi::report(), util.rrapi.RRApi::report(), util.rrapi.RRApi::reports(), rrapi.RRApi::reports(), EgHLTOfflineSummaryClient::runClient_(), DQMFileSaver::saveForOffline(), DQMFileSaver::saveForOnline(), util.rrapi.RRApi::tables(), rrapi.RRApi::tables(), rrapi.RRApi::tags(), util.rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

 {
   std::string dir;
   std::string name;
   splitPath(dir, name, path);
   MonitorElement proto(&dir, name);
   auto mepos = data_.find(proto);
   return (mepos == data_.end() ? nullptr
           : const_cast<MonitorElement *>(&*mepos));
 }

std::vector< MonitorElement * > DQMStore::get ( unsigned int tag ) const

get all MonitorElements tagged as <tag>

Definition at line 1626 of file DQMStore.cc.

References data_, DQMNet::DQM_PROP_TAGGED, and mps_fire::result.

 {
   // FIXME: Use reverse map [tag -> path] / [tag -> dir]?
   std::vector<MonitorElement*> result;
   for (auto const& me : data_) {
     if ((me.data_.flags & DQMNet::DQM_PROP_TAGGED) && me.data_.tag == tag)
       result.push_back(const_cast<MonitorElement*>(&me));
   }
   return result;
 }

void DQMStore::get_info	(	dqmstorepb::ROOTFilePB_Histo const &	h,
		std::string &	dirname,
		std::string &	objname,
		TObject **	obj
	)

private

Definition at line 2983 of file DQMStore.cc.

References extractNextObject(), dqmstorepb::ROOTFilePB_Histo::full_pathname(), raiseDQMError(), dqmstorepb::ROOTFilePB_Histo::size(), pickleFileParser::slash, and dqmstorepb::ROOTFilePB_Histo::streamed_histo().

Referenced by readFilePB().

 {
   size_t slash = h.full_pathname().rfind('/');
   size_t dirpos = (slash == std::string::npos ? 0 : slash);
   size_t namepos = (slash == std::string::npos ? 0 : slash+1);
   dirname.assign(h.full_pathname(), 0, dirpos);
   objname.assign(h.full_pathname(), namepos, std::string::npos);
   TBufferFile buf(TBufferFile::kRead, h.size(),
                   (void*)h.streamed_histo().data(),
                   kFALSE);
   buf.Reset();
   *obj = extractNextObject(buf);
   if (!*obj) {
     raiseDQMError("DQMStore", "Error reading element:'%s'" , h.full_pathname().c_str());
   }
 }

std::vector< MonitorElement * > DQMStore::getAllContents	(	std::string const &	path,
		uint32_t	runNumber = `0`,
		uint32_t	lumi = `0`
	)		const

get vector with children of folder, including all subfolders + their children; must use an exact pathname

Definition at line 1767 of file DQMStore.cc.

References clean, data_, MillePedeFileConverter_cfg::e, enableMultiThread_, mps_fire::i, or, mps_fire::result, MonitorElement::setLumi(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by SiStripCalibLorentzAngle::algoBeginJob(), edmtest::DQMReferenceHistogramRootFileEventSetupAnalyzer::beginRun(), SiStripQualityHotStripIdentifierRoot::bookHistos(), StatisticsFilter::filter(), DQMStore::IGetter::removeElement(), DQMRootOutputModule::writeLuminosityBlock(), and DQMRootOutputModule::writeRun().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(path, clean, cleaned);
   MonitorElement proto(cleaned, std::string(), run, 0);
   proto.setLumi(lumi);
 
   std::vector<MonitorElement*> result;
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   for ( ; i != e && isSubdirectory(*cleaned, *i->data_.dirname); ++i) {
     if (run != 0) {
       if (i->data_.run > run // TODO[rovere]: pleonastic? first we encounter local ME of the same run ...
           || i->data_.moduleId != 0)
         break;
     }
     if (lumi != 0) {
       if (i->data_.lumi > lumi
           || i->data_.moduleId != 0)
         break;
     }
     if (run != 0 or lumi !=0) {
       assert(i->data_.moduleId == 0);
     }
     result.push_back(const_cast<MonitorElement*>(&*i));
   }
 
   if (enableMultiThread_) {
     //save legacy modules when running MT
     i = data_.begin();
     for ( ; i != e && isSubdirectory(*cleaned, *i->data_.dirname); ++i) {
       if (i->data_.run != 0 or i->data_.moduleId != 0)
         break;
       result.push_back(const_cast<MonitorElement*>(&*i));
     }
   }
 
   return result;
 }

std::vector< MonitorElement * > DQMStore::getContents ( std::string const & path ) const

get vector with all children of folder (does NOT include contents of subfolders)

Definition at line 1640 of file DQMStore.cc.

References clean, data_, MillePedeFileConverter_cfg::e, mps_fire::i, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripCertificationInfo::fillSiStripCertificationMEs(), SiStripQualityChecker::fillSubDetStatus(), SiStripSummaryCreator::fillSummaryHistos(), QTestStatusChecker::fullPathNames(), SiStripSummaryCreator::getSummaryME(), SiStripHistoPlotter::makeCondDBPlots(), SiStripActionExecutor::printFaultyModuleList(), SiStripTrackerMapCreator::setTkMapFromHistogram(), and showDirStructure().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(path, clean, cleaned);
   MonitorElement proto(cleaned, std::string());
 
   std::vector<MonitorElement*> result;
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   for ( ; i != e && isSubdirectory(*cleaned, *i->data_.dirname); ++i)
     if (*cleaned == *i->data_.dirname)
       result.push_back(const_cast<MonitorElement *>(&*i));
 
   return result;
 }

std::vector< MonitorElement * > DQMStore::getContents	(	std::string const &	path,
		unsigned int	tag
	)		const

same as above for tagged MonitorElements

Definition at line 1659 of file DQMStore.cc.

References clean, data_, DQMNet::DQM_PROP_TAGGED, MillePedeFileConverter_cfg::e, mps_fire::i, mps_fire::result, AlCaHLTBitMon_QueryRunRegistry::string, and tag().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(path, clean, cleaned);
   MonitorElement proto(cleaned, std::string());
 
   std::vector<MonitorElement*> result;
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   for ( ; i != e && isSubdirectory(*cleaned, *i->data_.dirname); ++i)
     if (*cleaned == *i->data_.dirname
         && (i->data_.flags & DQMNet::DQM_PROP_TAGGED)
         && i->data_.tag == tag)
       result.push_back(const_cast<MonitorElement *>(&*i));
 
   return result;
 }

void DQMStore::getContents	(	std::vector< std::string > &	into,
		bool	showContents = `true`
	)		const

get contents; return vector<string> of the form <dir pathname>="">:<obj1>,<obj2>,<obj3>; if showContents = false, change form to <dir pathname>="">: (useful for subscription requests; meant to imply "all contents")

Definition at line 1683 of file DQMStore.cc.

References data_, dir, dirs_, funct::m, and AlCaHLTBitMon_QueryRunRegistry::string.

 {
   into.clear();
   into.reserve(dirs_.size());
 
   auto me = data_.end();
   for (auto const& dir : dirs_)
   {
     MonitorElement proto(&dir, std::string());
     auto mi = data_.lower_bound(proto);
     auto m = mi;
     size_t sz = dir.size() + 2;
     size_t nfound = 0;
     for ( ; m != me && isSubdirectory(dir, *m->data_.dirname); ++m)
       if (dir == *m->data_.dirname)
       {
         sz += m->data_.objname.size() + 1;
         ++nfound;
       }
 
     if (! nfound)
       continue;
 
     auto istr
       = into.insert(into.end(), std::string());
 
     if (showContents)
     {
       istr->reserve(sz);
 
       *istr += dir;
       *istr += ':';
       for (sz = 0; mi != m; ++mi)
       {
         if (dir != *mi->data_.dirname)
           continue;
 
         if (sz > 0)
           *istr += ',';
 
         *istr += mi->data_.objname;
         ++sz;
       }
     }
     else
     {
       istr->reserve(dir.size() + 2);
       *istr += dir;
       *istr += ':';
     }
   }
 }

std::vector< MonitorElement * > DQMStore::getMatchingContents	(	std::string const &	pattern,
		lat::Regexp::Syntax	syntaxType = `lat::Regexp::Wildcard`
	)		const

get vector with children of folder, including all subfolders + their children; matches names against a wildcard pattern matched against the full ME path

Definition at line 1813 of file DQMStore.cc.

References data_, MillePedeFileConverter_cfg::e, callgraph::path, raiseDQMError(), mps_fire::result, corrVsCorr::rx, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by EgHLTOfflineSummaryClient::getQTestResults_(), and DQMFileSaver::saveForOnline().

 {
   lat::Regexp rx;
   try {
     rx = lat::Regexp(pattern, 0, syntaxType);
     rx.study();
   }
   catch (lat::Error& e) {
     raiseDQMError("DQMStore", "Invalid regular expression '%s': %s",
                   pattern.c_str(), e.explain().c_str());
   }
 
   std::string path;
   std::vector<MonitorElement *> result;
   for (auto const& me : data_) {
     path.clear();
     mergePath(path, *me.data_.dirname, me.data_.objname);
     if (rx.match(path))
       result.push_back(const_cast<MonitorElement*>(&me));
   }
 
   return result;
 }

std::vector< std::string > DQMStore::getMEs ( ) const

get list of (non-dir) MEs of current directory

Definition at line 1587 of file DQMStore.cc.

References data_, MillePedeFileConverter_cfg::e, mps_fire::i, pwd_, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by dqmCopyRecursively(), and DQMStore::IGetter::removeElement().

 {
   MonitorElement proto(&pwd_, std::string());
   std::vector<std::string> result;
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   for ( ; i != e && isSubdirectory(pwd_, *i->data_.dirname); ++i)
     if (pwd_ == *i->data_.dirname)
       result.push_back(i->getName());
 
   return result;
 }

QCriterion * DQMStore::getQCriterion ( std::string const & qtname ) const

get QCriterion corresponding to <qtname> (null pointer if QCriterion does not exist)

Definition at line 3152 of file DQMStore.cc.

References MillePedeFileConverter_cfg::e, mps_fire::i, and qtests_.

 {
   auto i = qtests_.find(qtname);
   auto e = qtests_.end();
   return (i == e ? nullptr : i->second);
 }

int DQMStore::getStatus ( std::string const & path = "" ) const

get "global" folder <path> status (one of:STATUS_OK, WARNING, ERROR, OTHER); returns most sever error, where ERROR > WARNING > OTHER > STATUS_OK; see Core/interface/QTestStatus.h for details on "OTHER"

Definition at line 3252 of file DQMStore.cc.

References clean, data_, dqm::qstatus::ERROR, dqm::qstatus::OTHER, mps_update::status, dqm::qstatus::STATUS_OK, AlCaHLTBitMon_QueryRunRegistry::string, and dqm::qstatus::WARNING.

Referenced by QTestStatusChecker::checkGlobalStatus().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(path, clean, cleaned);
 
   int status = dqm::qstatus::STATUS_OK;
   for (auto const& me : data_) {
     if (! cleaned->empty() && ! isSubdirectory(*cleaned, *me.data_.dirname))
       continue;
 
     if (me.hasError())
       return dqm::qstatus::ERROR;
     else if (me.hasWarning())
       status = dqm::qstatus::WARNING;
     else if (status < dqm::qstatus::WARNING
              && me.hasOtherReport())
       status = dqm::qstatus::OTHER;
   }
   return status;
 }

std::vector< std::string > DQMStore::getSubdirs ( ) const

get list of subdirectories of current directory

Definition at line 1564 of file DQMStore.cc.

References dirs_, MillePedeFileConverter_cfg::e, mps_fire::i, pwd_, and mps_fire::result.

Referenced by SiStripSummaryCreator::createSummary(), dqmCopyRecursively(), TauDQMFileLoader::endRun(), SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripQualityChecker::fillSubDetStatus(), SiStripSummaryCreator::fillSummaryHistos(), SiStripUtility::getModuleFolderList(), SiStripSummaryCreator::getSummaryME(), SiStripUtility::goToDir(), DQMStore::IGetter::removeElement(), DQMFileSaver::saveForOffline(), DQMFileSaver::saveForOnline(), and SiStripTrackerMapCreator::setTkMapFromHistogram().

 {
   std::vector<std::string> result;
   auto e = dirs_.end();
   auto i = dirs_.find(pwd_);
 
   // If we didn't find current directory, the tree is empty, so quit.
   if (i == e)
     return result;
 
   // Skip the current directory and then start looking for immediate
   // subdirectories in the dirs_ list.  Stop when we are no longer in
   // (direct or indirect) subdirectories of pwd_.  Note that we don't
   // "know" which order the set will sort A/B, A/B/C and A/D.
   while (++i != e && isSubdirectory(pwd_, *i))
     if (i->find('/', pwd_.size()+1) == std::string::npos)
       result.push_back(*i);
 
   return result;
 }

void DQMStore::goUp ( )

equivalent to "cd .."

Definition at line 582 of file DQMStore.cc.

References pwd_, and setCurrentFolder().

Referenced by SiStripSummaryCreator::createSummary(), SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripSummaryCreator::fillSummaryHistos(), SiStripUtility::getModuleFolderList(), SiStripSummaryCreator::getSummaryME(), SiStripUtility::goToDir(), and meBookerGetter().

 {
   size_t pos = pwd_.rfind('/');
   if (pos == std::string::npos)
     setCurrentFolder("");
   else
     setCurrentFolder(pwd_.substr(0, pos));
 }

MonitorElement* DQMStore::initialise	(	MonitorElement *	me,
		std::string const &	path
	)

private

Referenced by book_().

void DQMStore::initializeFrom ( const edm::ParameterSet & )

private

Definition at line 402 of file DQMStore.cc.

References collateHistograms_, gather_cfg::cout, doSaveByLumi_, enableMultiThread_, edm::ParameterSet::getUntrackedParameter(), LSbasedMode_, makeDirectory(), qalgos_, readFile(), reset(), scaleFlag_, AlCaHLTBitMon_QueryRunRegistry::string, StripRunDirs, verbose_, and verboseQT_.

Referenced by DQMStore().

 {
   makeDirectory("");
   reset();
 
   // set steerable parameters
   verbose_ = pset.getUntrackedParameter<int>("verbose", 0);
   if (verbose_ > 0)
     std::cout << "DQMStore: verbosity set to " << verbose_ << std::endl;
 
   verboseQT_ = pset.getUntrackedParameter<int>("verboseQT", 0);
   if (verbose_ > 0)
     std::cout << "DQMStore: QTest verbosity set to " << verboseQT_ << std::endl;
 
   collateHistograms_ = pset.getUntrackedParameter<bool>("collateHistograms", false);
   if (collateHistograms_)
     std::cout << "DQMStore: histogram collation is enabled\n";
 
   enableMultiThread_ = pset.getUntrackedParameter<bool>("enableMultiThread", false);
   if (enableMultiThread_)
     std::cout << "DQMStore: MultiThread option is enabled\n";
 
   LSbasedMode_ = pset.getUntrackedParameter<bool>("LSbasedMode", false);
   if (LSbasedMode_)
     std::cout << "DQMStore: LSbasedMode option is enabled\n";
 
   doSaveByLumi_ = pset.getUntrackedParameter<bool>("saveByLumi", false);
   if (doSaveByLumi_)
     std::cout << "DQMStore: saveByLumi option is enabled\n";
 
   std::string ref = pset.getUntrackedParameter<std::string>("referenceFileName", "");
   if (! ref.empty()) {
     std::cout << "DQMStore: using reference file '" << ref << "'\n";
     readFile(ref, true, "", s_referenceDirName, StripRunDirs, false);
   }
 
   initQCriterion<Comp2RefChi2>(qalgos_);
   initQCriterion<Comp2Ref2DChi2>(qalgos_);
   initQCriterion<Comp2RefKolmogorov>(qalgos_);
   initQCriterion<ContentsXRange>(qalgos_);
   initQCriterion<ContentsYRange>(qalgos_);
   initQCriterion<MeanWithinExpected>(qalgos_);
   initQCriterion<Comp2RefEqualH>(qalgos_);
   initQCriterion<DeadChannel>(qalgos_);
   initQCriterion<NoisyChannel>(qalgos_);
   initQCriterion<ContentSigma>(qalgos_);
   initQCriterion<ContentsWithinExpected>(qalgos_);
   initQCriterion<CompareToMedian>(qalgos_);
   initQCriterion<CompareLastFilledBin>(qalgos_);
   initQCriterion<CheckVariance>(qalgos_);
 
   scaleFlag_ = pset.getUntrackedParameter<double>("ScalingFlag", 0.0);
   if (verbose_ > 0)
     std::cout << "DQMStore: Scaling Flag set to " << scaleFlag_ << std::endl;
 }

bool DQMStore::isCollate ( ) const

Definition at line 3327 of file DQMStore.cc.

References collateHistograms_.

 {
   return collateHistograms_;
 }

bool DQMStore::isCollateME ( MonitorElement * me ) const

private

Definition at line 3336 of file DQMStore.cc.

References MonitorElement::data_, and DQMNet::CoreObject::dirname.

Referenced by extract().

 {
   return me && isSubdirectory(s_collateDirName, *me->data_.dirname);
 }

bool DQMStore::load	(	std::string const &	filename,
		OpenRunDirs	stripdirs = `StripRunDirs`,
		bool	fileMustExist = `true`
	)

public load root file <filename>, and copy MonitorElements; overwrite identical MonitorElements (default: true); set DQMStore.collateHistograms to true to sum several files note: by default this method strips off run dir structure

Definition at line 2898 of file DQMStore.cc.

References collateHistograms_, gather_cfg::cout, readFile(), readFilePB(), and verbose_.

Referenced by DQMFileReader::beginJob().

 {
   bool overwrite = true;
   if (collateHistograms_) overwrite = false;
   if (verbose_)
     {
       std::cout << "DQMStore::load: reading from file '" << filename << "'\n";
       if (collateHistograms_)
         std::cout << "DQMStore::load: in collate mode   " << "\n";
       else
         std::cout << "DQMStore::load: in overwrite mode   " << "\n";
     }
 
   if (!s_rxpbfile.match(filename, 0, 0))
     return readFile(filename, overwrite, "", "", stripdirs, fileMustExist);
   else
     return readFilePB(filename, overwrite, "", "", stripdirs, fileMustExist);
 }

void DQMStore::makeDirectory ( std::string const & path )

private

get folder corresponding to inpath wrt to root (create subdirs if necessary)

Definition at line 595 of file DQMStore.cc.

References dirs_, findObject(), dataset::name, raiseDQMError(), pickleFileParser::slash, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by initializeFrom(), readDirectory(), and setCurrentFolder().

 {
   std::string prev;
   std::string subdir;
   std::string name;
   prev.reserve(path.size());
   subdir.reserve(path.size());
   name.reserve(path.size());
   size_t prevname = 0;
   size_t slash = 0;
 
   while (true) {
     // Create this subdirectory component.
     subdir.clear();
     subdir.append(path, 0, slash);
     name.clear();
     name.append(subdir, prevname, std::string::npos);
     if (! prev.empty() && findObject(0, 0, 0, prev, name))
       raiseDQMError("DQMStore", "Attempt to create subdirectory '%s'"
                     " which already exists as a monitor element",
                     subdir.c_str());
 
     if (! dirs_.count(subdir))
       dirs_.insert(subdir);
 
     // Stop if we've reached the end (including possibly a trailing slash).
     if (slash+1 >= path.size())
       break;
 
     // Find the next slash, making sure we progress.  If reach the end,
     // process the last path component; the next loop round will terminate.
     prevname = slash ? slash+1 : slash;
     prev = subdir;
     if ((slash = path.find('/', ++slash)) == std::string::npos)
       slash = path.size();
   }
 }

template<typename iFunc >

void DQMStore::meBookerGetter ( iFunc f )

inline

Definition at line 288 of file DQMStore.h.

References hippyaddtobaddatafiles::cd(), CommonMethods::dirExists(), fastjetJetProducer_validation_cfg::DQMStore, f, goUp(), hcalDigis_cfi::level, callgraph::path, muonDTDigis_cfi::pset, alignCSCRings::pwd, setCurrentFolder(), setVerbose(), AlCaHLTBitMon_QueryRunRegistry::string, and ~DQMStore().

Referenced by DQMEDHarvester::endJob(), DQMEDHarvester::endLuminosityBlock(), TkHistoMap::loadTkHistoMap(), and TkHistoMap::TkHistoMap().

   {
     IBooker booker{this};
     IGetter getter{this};
     f(booker, getter);
   }

bool DQMStore::mtEnabled ( )

inline

Definition at line 477 of file DQMStore.h.

References estimatePileup2::algoname, HGCalValidator_cff::collateHistograms, dir, compare_using_db::dirname, fastjetJetProducer_validation_cfg::DQMStore, extract(), extractNextObject(), FrontierConditions_GlobalTag_cff::file, corrVsCorr::filename, RemoveAddSevLevel::flag, get_info(), h, callgraph::kind, dataset::name, hgcalPlots::obj, listBenchmarks::pattern, reset(), writedatasetfile::run, convertSQLiteXML::runNumber, and AlCaHLTBitMon_QueryRunRegistry::string.

477 { return enableMultiThread_; };

DQMStore::enableMultiThread_

bool enableMultiThread_

Definition: DQMStore.h:637

bool DQMStore::open	(	std::string const &	filename,
		bool	overwrite = `false`,
		std::string const &	onlypath = `""`,
		std::string const &	prepend = `""`,
		OpenRunDirs	stripdirs = `KeepRunDirs`,
		bool	fileMustExist = `true`
	)

public open/read root file <filename>, and copy MonitorElements; if flag=true, overwrite identical MonitorElements (default: false); if onlypath != "", read only selected directory if prepend !="", prepend string to path note: by default this method keeps the dir structure as in file and does not update monitor element references!

Definition at line 2883 of file DQMStore.cc.

References readFile().

Referenced by SiStripCalibLorentzAngle::algoBeginJob(), DQMFileReader::beginJob(), edmtest::DQMReferenceHistogramRootFileEventSetupAnalyzer::beginRun(), EcalCondDBWriter::EcalCondDBWriter(), TauDQMFileLoader::endRun(), Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::importConfig(), PFDQMEventSelector::openInputFile(), SiStripOfflineDQM::openInputFile(), BuildTrackerMapPlugin::read(), readFilePB(), savePB(), SiStripQualityHotStripIdentifierRoot::SiStripQualityHotStripIdentifierRoot(), and StatisticsFilter::StatisticsFilter().

 {
   return readFile(filename,overwrite,onlypath,prepend,stripdirs,fileMustExist);
 }

DQMStore& DQMStore::operator= ( DQMStore const & )

delete

void DQMStore::postGlobalBeginLumi ( const edm::GlobalContext & )

private

Called after all globalBeginLuminosityBlock. Reset global per-lumi MEs (or all MEs if LSbasedMode) so that they can be reused.

Definition at line 1886 of file DQMStore.cc.

References begin, data_, MillePedeFileConverter_cfg::e, end, mps_fire::i, LSbasedMode_, edm::GlobalContext::luminosityBlockID(), MonitorElement::Reset(), writedatasetfile::run, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by DQMStore().

 {
   static const std::string null_str("");
 
   auto const& lumiblock = gc.luminosityBlockID();
   uint32_t run = lumiblock.run();
 
   // find the range of non-legacy global MEs for the current run:
   // run != 0, lumi == 0 (implicit), stream id == 0, module id == 0
   const MonitorElement begin(&null_str, null_str, run, 0);
   const MonitorElement end(&null_str, null_str, run, 1);
   auto i = data_.lower_bound(begin);
   const auto e = data_.lower_bound(end);
   while (i != e) {
     auto& me = const_cast<MonitorElement&>(*i++);
     // skip per-run MEs
     if (not LSbasedMode_ and not me.getLumiFlag())
       continue;
     me.Reset();
     me.resetUpdate();
   }
 }

void DQMStore::print_trace	(	std::string const &	dir,
		std::string const &	name
	)

private

Definition at line 468 of file DQMStore.cc.

References mps_check::array, symbols::demangled, mps_fire::i, hcalDigis_cfi::level, funct::m, alignCSCRings::r, findQualityFiles::size, stream_, nano_cff::strings, and verbose_.

Referenced by book_().

 {
   // the access to the member stream_ is implicitely protected against
   // concurrency problems because the print_trace method is always called behind
   // a lock (see bookTransaction).
   if (!stream_)
     stream_ = std::make_unique<std::ofstream>("histogramBookingBT.log");
 
   void* array[10];
   size_t size;
   char** strings;
   int r = 0;
   lat::RegexpMatch m;
   m.reset();
 
   size = backtrace(array, 10);
   strings = backtrace_symbols(array, size);
 
   size_t level = 1;
   char* demangled = nullptr;
   for (; level < size; ++level) {
     if (!s_rxtrace.match(strings[level], 0, 0, &m)) continue;
     demangled = abi::__cxa_demangle(m.matchString(strings[level], 2).c_str(), nullptr, nullptr, &r);
     if (!demangled) continue;
     if (!s_rxself.match(demangled, 0, 0)) break;
     free(demangled);
     demangled = nullptr;
   }
 
   if (demangled != nullptr) {
     *stream_ << "\"" << dir << "/"
              << name << "\" "
              << (r ? m.matchString(strings[level], 2) : demangled) << " "
              << m.matchString(strings[level], 1) << "\n";
     free(demangled);
   } else {
     *stream_ << "Skipping "<< dir << "/" << name
              << " with stack size " << size << "\n";
   }
 
   /* In this case print the full stack trace, up to main or to the
    * maximum stack size, i.e. 10. */
   if (verbose_ > 4 || demangled == nullptr) {
     size_t i;
     m.reset();
 
     for (i = 0; i < size; ++i)
       if (s_rxtrace.match(strings[i], 0, 0, &m)) {
         char* demangled = abi::__cxa_demangle(m.matchString(strings[i], 2).c_str(), nullptr, nullptr, &r);
         *stream_ << "\t\t" << i << "/" << size << " "
                  << (r ? m.matchString(strings[i], 2) : demangled) << " "
                  << m.matchString(strings[i], 1) << std::endl;
         free (demangled);
       }
   }
   free (strings);
 }

std::string const & DQMStore::pwd ( ) const

return pathname of current directory

Definition at line 539 of file DQMStore.cc.

References pwd_.

Referenced by SiStripDcsInfo::addBadModules(), FineDelayTask::book(), LatencyTask::book(), SiStripTrackerMapCreator::createForOffline(), SiStripTrackerMapCreator::createInfoFile(), SiStripSummaryCreator::createSummary(), SiStripQualityChecker::fillDetectorStatus(), SiStripQualityChecker::fillDetectorStatusAtLumi(), SiStripQualityChecker::fillFaultyModuleStatus(), SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripCertificationInfo::fillSiStripCertificationMEs(), SiStripSummaryCreator::fillSummaryHistos(), SiStripDaqInfo::findExcludedModule(), SiStripUtility::getModuleFolderList(), SiStripQualityChecker::getModuleStatus(), SiStripSummaryCreator::getSummaryME(), SiStripUtility::getTopFolderPath(), SiStripUtility::goToDir(), SiStripActionExecutor::printFaultyModuleList(), and SiStripTrackerMapCreator::setTkMapFromHistogram().

 {
   return pwd_;
 }

unsigned int DQMStore::readDirectory	(	TFile *	file,
		bool	overwrite,
		std::string const &	onlypath,
		std::string const &	prepend,
		std::string const &	curdir,
		OpenRunDirs	stripdirs
	)

private

read ROOT objects from file <file> in directory <onlypath>; return total # of ROOT objects read

Definition at line 2737 of file DQMStore.cc.

References collateHistograms_, KineDebug3::count(), gather_cfg::cout, extract(), crabWrapper::key, makeDirectory(), GetRecoTauVFromDQM_MC_cff::next, hgcalPlots::obj, raiseDQMError(), createPayload::skip, AlCaHLTBitMon_QueryRunRegistry::string, StripRunDirs, and verbose_.

Referenced by readFile().

 {
   unsigned int ntot = 0;
   unsigned int count = 0;
 
   if (! file->cd(curdir.c_str()))
     raiseDQMError("DQMStore", "Failed to process directory '%s' while"
                   " reading file '%s'", curdir.c_str(), file->GetName());
 
   // Figure out current directory name, but strip out the top
   // directory into which we dump everything.
   std::string dirpart = curdir;
   if (dirpart.compare(0, s_monitorDirName.size(), s_monitorDirName) == 0) {
     if (dirpart.size() == s_monitorDirName.size())
       dirpart.clear();
     else if (dirpart[s_monitorDirName.size()] == '/')
       dirpart.erase(0, s_monitorDirName.size()+1);
   }
 
   // See if we are going to skip this directory.
   bool skip = (! onlypath.empty() && ! isSubdirectory(onlypath, dirpart));
 
   if (prepend == s_collateDirName ||
       prepend == s_referenceDirName ||
       stripdirs == StripRunDirs ) {
     // Remove Run # and RunSummary dirs
     // first look for Run summary,
     // if that is found and erased, also erase Run dir
     size_t slash = dirpart.find('/');
     size_t pos = dirpart.find("/Run summary");
     if (slash != std::string::npos && pos !=std::string::npos) {
       dirpart.erase(pos,12);
 
       pos = dirpart.find("Run ");
       size_t length = dirpart.find('/',pos+1)-pos+1;
       if (pos !=std::string::npos)
         dirpart.erase(pos,length);
     }
   }
 
   // If we are prepending, add it to the directory name,
   // and suppress reading of already existing reference histograms
   if (prepend == s_collateDirName ||
       prepend == s_referenceDirName) {
     size_t slash = dirpart.find('/');
     // If we are reading reference, skip previous reference.
     if (slash == std::string::npos   // skip if Reference is toplevel folder, i.e. no slash
         && slash+1+s_referenceDirName.size() == dirpart.size()
         && dirpart.compare(slash+1, s_referenceDirName.size(), s_referenceDirName) == 0)
       return 0;
 
     slash = dirpart.find('/');
     // Skip reading of EventInfo subdirectory.
     if (slash != std::string::npos
         && slash + 10 == dirpart.size()
         && dirpart.compare( slash+1 , 9 , "EventInfo") == 0) {
       if (verbose_)
         std::cout << "DQMStore::readDirectory: skipping '" << dirpart << "'\n";
       return 0;
     }
 
     // Add prefix.
     if (dirpart.empty())
       dirpart = prepend;
     else
       dirpart = prepend + '/' + dirpart;
   }
   else if (! prepend.empty()) {
     if (dirpart.empty())
       dirpart = prepend;
     else
       dirpart = prepend + '/' + dirpart;
   }
 
   // Loop over the contents of this directory in the file.
   // Post-pone string object handling to happen after other
   // objects have been read in so we are guaranteed to have
   // histograms by the time we read in quality tests and tags.
   TKey* key;
   TIter next (gDirectory->GetListOfKeys());
   std::list<TObject*> delayed;
   while ((key = (TKey*) next()))
     {
       std::unique_ptr<TObject> obj(key->ReadObj());
       if (dynamic_cast<TDirectory*>(obj.get())) {
         std::string subdir;
         subdir.reserve(curdir.size() + strlen(obj->GetName()) + 2);
         subdir += curdir;
         if (! curdir.empty())
           subdir += '/';
         subdir += obj->GetName();
 
         ntot += readDirectory(file, overwrite, onlypath, prepend, subdir, stripdirs);
       }
       else if (skip)
         ;
       else if (dynamic_cast<TObjString*>(obj.get())) {
         delayed.push_back(obj.release());
       }
       else {
         if (verbose_ > 2)
           std::cout << "DQMStore: reading object '" << obj->GetName()
                     << "' of type '" << obj->IsA()->GetName()
                     << "' from '" << file->GetName()
                     << "' into '" << dirpart << "'\n";
 
         makeDirectory(dirpart);
         if (extract(obj.get(), dirpart, overwrite, collateHistograms_))
           ++count;
       }
     }
 
   while (! delayed.empty()) {
     if (verbose_ > 2)
       std::cout << "DQMStore: reading object '" << delayed.front()->GetName()
                 << "' of type '" << delayed.front()->IsA()->GetName()
                 << "' from '" << file->GetName()
                 << "' into '" << dirpart << "'\n";
 
     makeDirectory(dirpart);
     if (extract(delayed.front(), dirpart, overwrite, collateHistograms_))
       ++count;
 
     delete delayed.front();
     delayed.pop_front();
   }
 
   if (verbose_ > 1)
     std::cout << "DQMStore: read " << count << '/' << ntot
               << " objects from directory '" << dirpart << "'\n";
 
   return ntot + count;
 }

bool DQMStore::readFile	(	std::string const &	filename,
		bool	overwrite = `false`,
		std::string const &	onlypath = `""`,
		std::string const &	prepend = `""`,
		OpenRunDirs	stripdirs = `StripRunDirs`,
		bool	fileMustExist = `true`
	)

private

private readFile <filename>, and copy MonitorElements; if flag=true, overwrite identical MonitorElements (default: false); if onlypath != "", read only selected directory if prepend !="", prepend string to path if StripRunDirs is set the run and run summary folders are erased.

Definition at line 2925 of file DQMStore.cc.

References gather_cfg::cout, data_, cppFunctionSkipper::exception, f, gen::n, raiseDQMError(), readDirectory(), and verbose_.

Referenced by initializeFrom(), load(), Vispa.Plugins.EventBrowser.EventBrowserTabController.EventBrowserTabController::navigate(), Vispa.Main.TabController.TabController::open(), open(), and Vispa.Main.TabController.TabController::refresh().

 {
 
   if (verbose_)
     std::cout << "DQMStore::readFile: reading from file '" << filename << "'\n";
 
   std::unique_ptr<TFile> f;
 
   try {
     f.reset(TFile::Open(filename.c_str()));
     if (! f.get() || f->IsZombie())
       raiseDQMError("DQMStore", "Failed to open file '%s'", filename.c_str());
   }
   catch (std::exception &) {
     if (fileMustExist)
       throw;
     else {
       if (verbose_)
         std::cout << "DQMStore::readFile: file '" << filename << "' does not exist, continuing\n";
       return false;
     }
   }
 
   unsigned n = readDirectory(f.get(), overwrite, onlypath, prepend, "", stripdirs);
   f->Close();
 
   for (auto const& me : data_)
     const_cast<MonitorElement &>(me).updateQReportStats();
 
   if (verbose_) {
     std::cout << "DQMStore::open: successfully read " << n
               << " objects from file '" << filename << "'";
     if (! onlypath.empty())
       std::cout << " from directory '" << onlypath << "'";
     if (! prepend.empty())
       std::cout << " into directory '" << prepend << "'";
     std::cout << std::endl;
   }
   return true;
 }

bool DQMStore::readFilePB	(	std::string const &	filename,
		bool	overwrite = `false`,
		std::string const &	path = `""`,
		std::string const &	prepend = `""`,
		OpenRunDirs	stripdirs = `StripRunDirs`,
		bool	fileMustExist = `true`
	)

private

Definition at line 3004 of file DQMStore.cc.

References cd(), gather_cfg::cout, MonitorElement::data_, DQMNet::DQM_PROP_LUMI, extract(), groupFilesInBlocks::fin, findObject(), DQMNet::CoreObject::flags, dqmstorepb::ROOTFilePB_Histo::flags(), get_info(), h, dqmstorepb::ROOTFilePB::histo(), dqmstorepb::ROOTFilePB::histo_size(), mps_fire::i, input, hgcalPlots::obj, open(), callgraph::path, raiseDQMError(), setCurrentFolder(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by load().

 {
   using google::protobuf::io::FileInputStream;
   using google::protobuf::io::FileOutputStream;
   using google::protobuf::io::GzipInputStream;
   using google::protobuf::io::GzipOutputStream;
   using google::protobuf::io::CodedInputStream;
   using google::protobuf::io::ArrayInputStream;
 
   if (verbose_)
     std::cout << "DQMStore::readFile: reading from file '" << filename << "'\n";
 
   int filedescriptor;
   if ((filedescriptor = ::open(filename.c_str(), O_RDONLY)) == -1) {
     if (fileMustExist)
       raiseDQMError("DQMStore", "Failed to open file '%s'", filename.c_str());
     else
       if (verbose_)
         std::cout << "DQMStore::readFile: file '" << filename << "' does not exist, continuing\n";
     return false;
   }
 
   dqmstorepb::ROOTFilePB dqmstore_message;
   FileInputStream fin(filedescriptor);
   GzipInputStream input(&fin);
   CodedInputStream input_coded(&input);
   input_coded.SetTotalBytesLimit(1024*1024*1024, -1);
   if (!dqmstore_message.ParseFromCodedStream(&input_coded)) {
     raiseDQMError("DQMStore", "Fatal parsing file '%s'", filename.c_str());
     return false;
   }
   ::close(filedescriptor);
 
   for (int i = 0; i < dqmstore_message.histo_size(); ++i) {
     std::string path;
     std::string objname;
 
     TObject* obj = nullptr;
     dqmstorepb::ROOTFilePB::Histo const& h = dqmstore_message.histo(i);
     get_info(h, path, objname, &obj);
 
     setCurrentFolder(path);
     if (obj) {
       /* Before calling the extract() check if histogram exists:
        * if it does - flags for the given monitor are already set (and merged)
        * else - set the flags after the histogram is created.
        */
       MonitorElement* me = findObject(0, 0, 0, path, objname);
 
       /* Run histograms should be collated and not overwritten,
        * Lumi histograms should be overwritten (and collate flag is not checked)
        */
       bool overwrite = h.flags() & DQMNet::DQM_PROP_LUMI;
       bool collate = !(h.flags() & DQMNet::DQM_PROP_LUMI);
       extract(static_cast<TObject*>(obj), path, overwrite, collate);
 
       if (me == nullptr) {
         me = findObject(0, 0, 0, path, objname);
         me->data_.flags = h.flags();
       }
 
       delete obj;
     }
   }
 
   cd();
   return true;
 }

void DQMStore::removeContents ( )

erase all monitoring elements in current directory (not including subfolders);

Definition at line 3118 of file DQMStore.cc.

References pwd_.

 {
   removeContents(pwd_);
 }

void DQMStore::removeContents ( std::string const & dir )

remove all monitoring elements from directory;

Definition at line 3104 of file DQMStore.cc.

References data_, MillePedeFileConverter_cfg::e, mps_fire::i, and AlCaHLTBitMon_QueryRunRegistry::string.

 {
   MonitorElement proto(&dir, std::string());
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   while (i != e && isSubdirectory(dir, *i->data_.dirname))
     if (dir == *i->data_.dirname)
       data_.erase(i++);
     else
       ++i;
 }

void DQMStore::removeElement ( std::string const & name )

erase monitoring element in current directory (opposite of book1D,2D,etc. action);

Definition at line 3126 of file DQMStore.cc.

References pwd_.

Referenced by MonitorElementsDb::endJob(), and TrackerOfflineValidationSummary::fillTree().

 {
   removeElement(pwd_, name);
 }

void DQMStore::removeElement	(	std::string const &	dir,
		std::string const &	name,
		bool	warning = `true`
	)

remove monitoring element from directory; if warning = true, print message if element does not exist

Definition at line 3134 of file DQMStore.cc.

References gather_cfg::cout, and data_.

 {
   MonitorElement proto(&dir, name);
   auto pos = data_.find(proto);
   if (pos != data_.end())
     data_.erase(pos);
   else if (warning) {
     std::cout << "DQMStore: WARNING: attempt to remove non-existent"
               << " monitor element '" << name << "' in '" << dir << "'\n";
   }
 }

void DQMStore::reset ( void )

private

Invoke this method after flushing all recently changed monitoring. Clears updated flag on all recently updated MEs and calls their Reset() method for those that have resetMe = true.

Definition at line 1844 of file DQMStore.cc.

References data_, funct::m, MonitorElement::Reset(), and reset_.

Referenced by DQMService::flushStandalone(), and initializeFrom().

 {
   for (auto const& m : data_) {
     auto& me = const_cast<MonitorElement&>(m);
     if (me.wasUpdated()) {
       if (me.resetMe())
         me.Reset();
       me.resetUpdate();
     }
   }
 
   reset_ = true;
 }

void DQMStore::rmdir ( std::string const & path )

delete directory and all contents; delete directory (all contents + subfolders);

Definition at line 3084 of file DQMStore.cc.

References clean, data_, dirs_, MillePedeFileConverter_cfg::e, mps_fire::i, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by dqmCopyRecursively().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(path, clean, cleaned);
   MonitorElement proto(cleaned, std::string());
 
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   while (i != e && isSubdirectory(*cleaned, *i->data_.dirname))
     data_.erase(i++);
 
   auto de = dirs_.end();
   auto di = dirs_.lower_bound(*cleaned);
   while (di != de && isSubdirectory(*cleaned, *di))
     dirs_.erase(di++);
 }

void DQMStore::runQTests ( )

run quality tests (also finds updated contents in last monitoring cycle, including newly added content)

Definition at line 3233 of file DQMStore.cc.

References gather_cfg::cout, data_, reset_, and verbose_.

 {
 
   if (verbose_ > 0)
     std::cout << "DQMStore: running runQTests() with reset = "
               << ( reset_ ? "true" : "false" ) << std::endl;
 
   // Apply quality tests to each monitor element, skipping references.
   for (auto const& me : data_)
     if (! isSubdirectory(s_referenceDirName, *me.data_.dirname))
       const_cast<MonitorElement &>(me).runQTests();
 
   reset_ = false;
 }

void DQMStore::save	(	std::string const &	filename,
		std::string const &	path = `""`,
		std::string const &	pattern = `""`,
		std::string const &	rewrite = `""`,
		uint32_t	run = `0`,
		uint32_t	lumi = `0`,
		SaveReferenceTag	ref = `SaveWithReference`,
		int	minStatus = `dqm::qstatus::STATUS_OK`,
		std::string const &	fileupdate = `"RECREATE"`
	)

save directory with monitoring objects into protobuf file <filename>; if directory="", save full monitoring structure

Definition at line 2465 of file DQMStore.cc.

References begin, book_mutex_, cdInto(), gather_cfg::cout, data_, dirs_, enableMultiThread_, end, f, FrontierConditions_GlobalTag_cff::file, LSbasedMode_, callgraph::path, raiseDQMError(), python.rootplot.root2matplotlib::replace(), saveMonitorElementRangeToROOT(), MonitorElement::setLumi(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by Vispa.Main.TabController.TabController::allowClose(), Vispa.Main.TabController.TabController::checkModificationTimestamp(), doSaveForOnline(), TauDQMSimpleFileSaver::endJob(), SiStripDigiValid::endJob(), TrackingTruthValid::endJob(), SiPixelDigiValid::endJob(), LaserDQM::endJob(), TrackerHitAnalyzer::endJob(), SiStripLAProfileBooker::endJob(), dEdxAnalyzer::endJob(), APVValidationPlots::endJob(), StripValidationPlots::endJob(), TrackEfficiencyMonitor::endJob(), LogMessageMonitor::endJob(), MuonAlignment::endJob(), SiStripMonitorQuality::endRun(), SiStripMonitorRawData::endRun(), SiStripMonitorPedestals::endRun(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::extractBadAPVSandStrips(), TkHistoMap::save(), DQMFileSaver::saveForFilterUnit(), DQMFileSaver::saveForOffline(), GlobalHitsProdHistStripper::~GlobalHitsProdHistStripper(), and SiPixelTrackingRecHitsValid::~SiPixelTrackingRecHitsValid().

 {
   // TFile flushes to disk with fsync() on every TDirectory written to
   // the file.  This makes DQM file saving painfully slow, and
   // ironically makes it _more_ likely the file saving gets
   // interrupted and corrupts the file.  The utility class below
   // simply ignores the flush synchronisation.
   class TFileNoSync : public TFile {
   public:
     TFileNoSync(char const* file, char const* opt) : TFile{file, opt} {}
     Int_t SysSync(Int_t) override { return 0; }
   };
 
   std::lock_guard<std::mutex> guard(book_mutex_);
 
   unsigned int nme = 0;
 
   // open output file, on 1st save recreate, later update
   if (verbose_) {
     std::cout << "DQMStore::save: Opening TFile '" << filename
               << "' with option '" << fileupdate << "'"
               << std::endl;
   }
 
   TFileNoSync f(filename.c_str(), fileupdate.c_str()); // open file
   if(f.IsZombie())
     raiseDQMError("DQMStore", "Failed to create/update file '%s'", filename.c_str());
   f.cd();
 
   // Construct a regular expression from the pattern string.
   std::unique_ptr<lat::Regexp> rxpat;
   if (not pattern.empty())
     rxpat = std::make_unique<lat::Regexp>(pattern);
 
   // Prepare a path for the reference object selection.
   std::string refpath;
   refpath.reserve(s_referenceDirName.size() + path.size() + 2);
   refpath += s_referenceDirName;
   if (not path.empty()) {
     refpath += '/';
     refpath += path;
   }
 
   // Loop over the directory structure.
   for (auto const& dir: dirs_) {
     // Check if we should process this directory.  We process the
     // requested part of the object tree, including references.
     if (not path.empty()
         and not isSubdirectory(refpath, dir)
         and not isSubdirectory(path, dir))
       continue;
 
     if (verbose_ > 1) {
       std::cout << "DQMStore::save: DQM folder " << dir << "/" << std::endl;
     }
 
     // Create the directory.
     gDirectory->cd("/");
     if (dir.empty())
       cdInto(s_monitorDirName);
     else if (rxpat.get())
       cdInto(s_monitorDirName + '/' + lat::StringOps::replace(dir, *rxpat, rewrite));
     else
       cdInto(s_monitorDirName + '/' + dir);
 
     // Loop over monitor elements in this directory.
     if (not enableMultiThread_) {
       MonitorElement proto(&dir, std::string(), run, 0);
       auto begin = data_.lower_bound(proto);
       auto end   = data_.end();
       saveMonitorElementRangeToROOT(dir, refpath, ref, minStatus, run, begin, end, f, nme);
     } else {
       // Restrict the loop to the monitor elements for the current lumisection
       MonitorElement proto(&dir, std::string(), run, 0);
       proto.setLumi(lumi);
       auto begin = data_.lower_bound(proto);
       proto.setLumi(lumi+1);
       auto end   = data_.lower_bound(proto);
       saveMonitorElementRangeToROOT(dir, refpath, ref, minStatus, run, begin, end, f, nme);
     }
 
     // In LSbasedMode, loop also over the (run, 0) global histograms;
     // these could be the merged global histrograms of their per-stream
     // counterparts after the streamEndRun transition - but they are not
     // produced in LSbasedMode.
     if (enableMultiThread_ and LSbasedMode_ and lumi != 0) {
       auto begin = data_.lower_bound(MonitorElement(&dir, std::string(), run, 0));
       auto end   = data_.lower_bound(MonitorElement(&dir, std::string(), run, 1));
       saveMonitorElementRangeToROOT(dir, refpath, ref, minStatus, run, begin, end, f, nme);
     }
   }
 
   f.Close();
 
   // Maybe make some noise.
   if (verbose_) {
     std::cout << "DQMStore::save: successfully wrote " << nme
               << " objects from path '" << path << "/"
               << "' into DQM file '" << filename << "'\n";
   }
 }

void DQMStore::saveMonitorElementRangeToPB	(	std::string const &	dir,
		unsigned int	run,
		MEMap::const_iterator	begin,
		MEMap::const_iterator	end,
		dqmstorepb::ROOTFilePB &	file,
		unsigned int &	counter
	)

private

Definition at line 2604 of file DQMStore.cc.

References counter, gather_cfg::cout, saveMonitorElementToPB(), and verbose_.

Referenced by savePB().

 {
   for (auto const& me: boost::make_iterator_range(begin, end)) {
     if (not isSubdirectory(dir, *me.data_.dirname))
       break;
 
     if (verbose_ > 1)
       std::cout << "DQMStore::savePB:"
                 << " run: " << me.run()
                 << " lumi: " << me.lumi()
                 << " lumiFlag: " << me.getLumiFlag()
                 << " moduleId: " << me.moduleId()
                 << " fullpathname: " << me.getFullname()
                 << " flags: " << std::hex << me.data_.flags
                 << std::endl;
 
     // Skip MonitorElements in a subdirectory of the current one.
     if (dir != *me.data_.dirname) {
       if (verbose_ > 1) {
         std::cout << "DQMStore::savePB: skipping monitor element in a subfolder of " << dir << "/" << std::endl;
       }
       continue;
     }
 
     // Handle reference histograms, with three distinct cases:
     // XXX not supported by protobuf files.
 
     if (verbose_ > 1) {
       std::cout << "DQMStore::savePB: saving monitor element" << std::endl;
     }
 
     saveMonitorElementToPB(me, file);
 
     // Count saved histograms
     ++counter;
   }
 }

void DQMStore::saveMonitorElementRangeToROOT	(	std::string const &	dir,
		std::string const &	refpath,
		SaveReferenceTag	ref,
		int	minStatus,
		unsigned int	run,
		MEMap::const_iterator	begin,
		MEMap::const_iterator	end,
		TFile &	file,
		unsigned int &	counter
	)

private

Definition at line 2385 of file DQMStore.cc.

References counter, gather_cfg::cout, funct::master(), SiStripPI::max, or, saveMonitorElementToROOT(), SaveWithoutReference, SaveWithReference, SaveWithReferenceForQTest, mps_update::status, AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by save().

 {
   for (auto const& me: boost::make_iterator_range(begin, end)) {
     if (not isSubdirectory(dir, *me.data_.dirname))
       break;
 
     if (verbose_ > 1)
       std::cout << "DQMStore::save:"
                 << " run: " << me.run()
                 << " lumi: " << me.lumi()
                 << " lumiFlag: " << me.getLumiFlag()
                 << " moduleId: " << me.moduleId()
                 << " fullpathname: " << me.getFullname()
                 << " flags: " << std::hex << me.data_.flags
                 << std::endl;
 
     // Skip MonitorElements in a subdirectory of the current one.
     if (dir != *me.data_.dirname) {
       if (verbose_ > 1) {
         std::cout << "DQMStore::save: skipping monitor element in a subfolder of " << dir << "/" << std::endl;
       }
       continue;
     }
 
     // Handle reference histograms, with three distinct cases:
     // 1) Skip all references entirely on saving.
     // 2) Blanket saving of all references.
     // 3) Save only references for monitor elements with qtests.
     // The latter two are affected by "path" sub-tree selection,
     // i.e. references are saved only in the selected tree part.
     if (isSubdirectory(refpath, *me.data_.dirname)) {
       if (ref == SaveWithoutReference)
         // Skip the reference entirely.
         continue;
       else if (ref == SaveWithReference)
         // Save all references regardless of qtests.
         ;
       else if (ref == SaveWithReferenceForQTest) {
         // Save only references for monitor elements with qtests
         // with an optional cut on minimum quality test result.
         int status = -1;
         std::string mname(me.getFullname(), s_referenceDirName.size()+1, std::string::npos);
         MonitorElement* master = get(mname);
         if (master)
           for (auto const& qreport : master->data_.qreports)
             status = std::max(status, qreport.code);
 
         if (not master or status < minStatus) {
           if (verbose_ > 1)
             std::cout << "DQMStore::save: skipping monitor element '"
                       << me.data_.objname << "' while saving, status is "
                       << status << ", required minimum status is "
                       << minStatus << std::endl;
           continue;
         }
       }
     }
 
     if (verbose_ > 1) {
       std::cout << "DQMStore::save: saving monitor element" << std::endl;
     }
 
     saveMonitorElementToROOT(me, file);
 
     // Count saved histograms
     ++counter;
   }
 }

void DQMStore::saveMonitorElementToPB	(	MonitorElement const &	me,
		dqmstorepb::ROOTFilePB &	file
	)

private

Definition at line 2576 of file DQMStore.cc.

References dqmstorepb::ROOTFilePB::add_histo(), edmScanValgrind::buffer, MonitorElement::data_, DQMNet::CoreObject::dirname, MonitorElement::DQM_KIND_TH1F, DQMNet::CoreObject::flags, trackerHits::histo, MonitorElement::kind(), resolutioncreator_cfi::object, MonitorElement::object_, DQMNet::CoreObject::objname, dqmstorepb::ROOTFilePB_Histo::set_flags(), dqmstorepb::ROOTFilePB_Histo::set_full_pathname(), dqmstorepb::ROOTFilePB_Histo::set_size(), dqmstorepb::ROOTFilePB_Histo::set_streamed_histo(), and MonitorElement::tagString().

Referenced by saveMonitorElementRangeToPB().

 {
   // Save the object.
   TBufferFile buffer(TBufferFile::kWrite);
   if (me.kind() < MonitorElement::DQM_KIND_TH1F) {
     TObjString object(me.tagString().c_str());
     buffer.WriteObject(&object);
   } else {
     buffer.WriteObject(me.object_);
   }
   dqmstorepb::ROOTFilePB::Histo & histo = * file.add_histo();
   histo.set_full_pathname(*me.data_.dirname + '/' + me.data_.objname);
   histo.set_flags(me.data_.flags);
   histo.set_size(buffer.Length());
   histo.set_streamed_histo((void const*)buffer.Buffer(), buffer.Length());
 
   // Save quality reports if this is not in reference section.
   // XXX not supported by protobuf files.
 
   // Save efficiency tag, if any.
   // XXX not supported by protobuf files.
 
   // Save tag if any.
   // XXX not supported by protobuf files.
 }

void DQMStore::saveMonitorElementToROOT	(	MonitorElement const &	me,
		TFile &	file
	)

private

Definition at line 2356 of file DQMStore.cc.

References MonitorElement::data_, DQMNet::CoreObject::dirname, MonitorElement::DQM_KIND_TH1F, DQMNet::DQM_PROP_EFFICIENCY_PLOT, DQMNet::DQM_PROP_TAGGED, MonitorElement::effLabelString(), DQMNet::CoreObject::flags, MonitorElement::kind(), MonitorElement::object_, DQMNet::CoreObject::qreports, MonitorElement::qualityTagString(), edmIntegrityCheck::report, MonitorElement::tagLabelString(), and MonitorElement::tagString().

Referenced by saveMonitorElementRangeToROOT().

 {
   // Save the object.
   if (me.kind() < MonitorElement::DQM_KIND_TH1F) {
     TObjString(me.tagString().c_str()).Write();
   } else {
     me.object_->Write();
   }
 
   // Save quality reports if this is not in reference section.
   if (not isSubdirectory(s_referenceDirName, *me.data_.dirname)) {
     for (auto const& report: me.data_.qreports) {
       TObjString(me.qualityTagString(report).c_str()).Write();
     }
   }
 
   // Save efficiency tag, if any.
   if (me.data_.flags & DQMNet::DQM_PROP_EFFICIENCY_PLOT) {
     TObjString(me.effLabelString().c_str()).Write();
   }
 
   // Save tag if any.
   if (me.data_.flags & DQMNet::DQM_PROP_TAGGED) {
     TObjString(me.tagLabelString().c_str()).Write();
   }
 }

void DQMStore::savePB	(	std::string const &	filename,
		std::string const &	path = `""`,
		uint32_t	run = `0`,
		uint32_t	lumi = `0`
	)

save directory with monitoring objects into protobuf file <filename>; if directory="", save full monitoring structure

Definition at line 2650 of file DQMStore.cc.

References begin, book_mutex_, gather_cfg::cout, data_, dirs_, enableMultiThread_, end, LSbasedMode_, open(), AlcaSiPixelAliHarvester0T_cff::options, saveMonitorElementRangeToPB(), MonitorElement::setLumi(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by doSaveForOnline(), DQMFileSaver::saveForFilterUnit(), and DQMFileSaver::saveForOfflinePB().

 {
   using google::protobuf::io::FileOutputStream;
   using google::protobuf::io::GzipOutputStream;
   using google::protobuf::io::StringOutputStream;
 
   std::lock_guard<std::mutex> guard(book_mutex_);
 
   unsigned int nme = 0;
 
   if (verbose_) {
     std::cout << "DQMStore::savePB: Opening PBFile '" << filename << "'"
               << std::endl;
   }
   dqmstorepb::ROOTFilePB dqmstore_message;
 
   // Loop over the directory structure.
   for (auto const& dir: dirs_) {
     // Check if we should process this directory.  We process the
     // requested part of the object tree, including references.
     if (not path.empty()
         and not isSubdirectory(path, dir))
       continue;
 
     if (verbose_ > 1) {
       std::cout << "DQMStore::savePB: DQM folder " << dir << "/" << std::endl;
     }
 
     // Loop over monitor elements in this directory.
     if (not enableMultiThread_) {
       MonitorElement proto(&dir, std::string(), run, 0);
       auto begin = data_.lower_bound(proto);
       auto end   = data_.end();
       saveMonitorElementRangeToPB(dir, run, begin, end, dqmstore_message, nme);
     } else {
       // Restrict the loop to the monitor elements for the current lumisection
       MonitorElement proto(&dir, std::string(), run, 0);
       proto.setLumi(lumi);
       auto begin = data_.lower_bound(proto);
       proto.setLumi(lumi+1);
       auto end   = data_.lower_bound(proto);
       saveMonitorElementRangeToPB(dir, run, begin, end, dqmstore_message, nme);
     }
 
     // In LSbasedMode, loop also over the (run, 0) global histograms;
     // these could be the merged global histrograms of their per-stream
     // counterparts after the streamEndRun transition - but they are not
     // produced in LSbasedMode.
     if (enableMultiThread_ and LSbasedMode_ and lumi != 0) {
       auto begin = data_.lower_bound(MonitorElement(&dir, std::string(), run, 0));
       auto end   = data_.lower_bound(MonitorElement(&dir, std::string(), run, 1));
       saveMonitorElementRangeToPB(dir, run, begin, end, dqmstore_message, nme);
     }
   }
 
   int filedescriptor = ::open(filename.c_str(),
                               O_WRONLY | O_CREAT | O_TRUNC,
                               S_IRUSR | S_IWUSR |
                               S_IRGRP | S_IWGRP |
                               S_IROTH);
   FileOutputStream file_stream(filedescriptor);
   GzipOutputStream::Options options;
   options.format = GzipOutputStream::GZIP;
   options.compression_level = 1;
   GzipOutputStream gzip_stream(&file_stream, options);
   dqmstore_message.SerializeToZeroCopyStream(&gzip_stream);
 
   // Flush the internal streams before closing the fd.
   gzip_stream.Close();
   file_stream.Close();
   ::close(filedescriptor);
 
   // Maybe make some noise.
   if (verbose_) {
     std::cout << "DQMStore::savePB: successfully wrote " << nme
               << " objects from path '" << path << "/"
               << "' into DQM file '" << filename << "'\n";
   }
 }

void DQMStore::scaleElements ( )

Invoke this method after flushing all recently changed monitoring. Clears updated flag on all MEs and calls their Reset() method.

Definition at line 3347 of file DQMStore.cc.

 {
   if (scaleFlag_ == 0.0) return;
   if (verbose_ > 0)
     std::cout << " =========== " << " ScaleFlag " << scaleFlag_ << std::endl;
   double factor = scaleFlag_;
   int events = 1;
   if (dirExists("Info/EventInfo")) {
     if ( scaleFlag_ == -1.0) {
       MonitorElement*  scale_me = get("Info/EventInfo/ScaleFactor");
       if (scale_me && scale_me->kind()==MonitorElement::DQM_KIND_REAL) factor = scale_me->getFloatValue();
     }
     MonitorElement*  event_me = get("Info/EventInfo/processedEvents");
     if (event_me && event_me->kind()==MonitorElement::DQM_KIND_INT) events = event_me->getIntValue();
   }
   factor = factor/(events*1.0);
 
   for (auto const& m : data_) {
     auto& me = const_cast<MonitorElement&>(m);
     switch (me.kind()) {
     case MonitorElement::DQM_KIND_TH1F:
       {
         me.getTH1F()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TH1S:
       {
         me.getTH1S()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TH1D:
       {
         me.getTH1D()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TH2F:
       {
         me.getTH2F()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TH2S:
       {
         me.getTH2S()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TH2D:
       {
         me.getTH2D()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TH3F:
       {
         me.getTH3F()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TPROFILE:
       {
         me.getTProfile()->Scale(factor);
         break;
       }
     case MonitorElement::DQM_KIND_TPROFILE2D:
       {
         me.getTProfile2D()->Scale(factor);
         break;
       }
     default:
       if (verbose_ > 0)
         std::cout << " The DQM object '" << me.getFullname() << "' is not scalable object " << std::endl;
       continue;
     }
   }
 }

void DQMStore::setAccumulate	(	MonitorElement *	me,
		bool	flag
	)

private

if true, will accumulate ME contents (over many periods) until method is called with flag = false again

Definition at line 3297 of file DQMStore.cc.

References MonitorElement::setAccumulate().

 {
   if (me)
     me->setAccumulate(flag);
 }

void DQMStore::setCurrentFolder ( std::string const & fullpath )

set the last directory in fullpath as the current directory(create if needed); to be invoked by user to specify directories for monitoring objects before booking; commands book1D (etc) & removeElement(name) imply elements in this directory!;

Definition at line 571 of file DQMStore.cc.

References clean, makeDirectory(), pwd_, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by SiStripDcsInfo::addBadModules(), DQMFileReader::beginJob(), L1ScalersClient::beginJob(), DQMFEDIntegrityClient::beginJob(), ConverterTester::beginJob(), APVValidationPlots::beginJob(), StripValidationPlots::beginJob(), DQMDaqInfo::beginJob(), MuonAlignment::beginJob(), HLTScalersClient::beginJob(), LatencyTask::book(), FineDelayTask::book(), CalibrationScanTask::book(), CalibrationTask::book(), MEtoMEComparitor::book(), TrackerOfflineValidationSummary::bookHarvestingHists(), PixelVTXMonitor::bookHistograms(), DQMLumiMonitor::bookHistograms(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), SiStripDcsInfo::bookStatus(), SiStripDaqInfo::bookStatus(), cd(), dqmCopyRecursively(), HarvestingAnalyzer::endJob(), HLTScalersClient::endLuminosityBlock(), TauDQMFileLoader::endRun(), GlobalHitsProdHistStripper::endRun(), SiStripQualityChecker::fillFaultyModuleStatus(), SiStripQualityDQM::fillGrandSummaryMEs(), TrackerOfflineValidationSummary::fillTree(), SiStripDaqInfo::findExcludedModule(), EgHLTOfflineSummaryClient::getEgHLTSumHist_(), goUp(), HLTScalersClient::HLTScalersClient(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::initializeDQMHistograms(), LaserDQM::initMonitors(), L1ScalersClient::L1ScalersClient(), meBookerGetter(), MonitorElementsDb::MonitorElementsDb(), readFilePB(), DQMStore::IGetter::removeElement(), EgHLTOfflineSummaryClient::runClient_(), DQMFileSaver::saveForOffline(), SiStripFolderOrganizer::setDetectorFolder(), SiPixelFolderOrganizer::setFedFolder(), SiStripFolderOrganizer::setLayerFolder(), SiPixelFolderOrganizer::setModuleFolder(), SiStripFolderOrganizer::setSiStripControlFolder(), SiStripFolderOrganizer::setSiStripFolder(), and SiStripFolderOrganizer::setSiStripTopControlFolder().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(fullpath, clean, cleaned);
   makeDirectory(*cleaned);
   pwd_ = *cleaned;
 }

void DQMStore::setVerbose ( unsigned level )

set verbose level (0 turns all non-error messages off)

Definition at line 531 of file DQMStore.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by TrackerHitAnalyzer::bookHistograms(), GlobalHitsProdHistStripper::GlobalHitsProdHistStripper(), HLTScalersClient::HLTScalersClient(), meBookerGetter(), and SiStripQualityHotStripIdentifierRoot::SiStripQualityHotStripIdentifierRoot().

532 {}

void DQMStore::showDirStructure ( ) const

Definition at line 3307 of file DQMStore.cc.

References relmon_rootfiles_spy::contents, popcon2dropbox::copy(), gather_cfg::cout, and getContents().

Referenced by TrackerHitAnalyzer::bookHistograms(), EcalBarrelMonitorDbModule::EcalBarrelMonitorDbModule(), dEdxAnalyzer::endJob(), LogMessageMonitor::endJob(), HLTScalersClient::endLuminosityBlock(), TauDQMFileLoader::endRun(), GlobalHitsProdHistStripper::GlobalHitsProdHistStripper(), and LaserDQM::initMonitors().

 {
   std::vector<std::string> contents;
   getContents(contents);
 
   std::cout << " ------------------------------------------------------------\n"
             << "                    Directory structure:                     \n"
             << " ------------------------------------------------------------\n";
 
   std::copy(contents.begin(), contents.end(),
             std::ostream_iterator<std::string>(std::cout, "\n"));
 
   std::cout << " ------------------------------------------------------------\n";
 }

void DQMStore::softReset ( MonitorElement * me )

reset contents (does not erase contents permanently) (makes copy of current contents; will be subtracted from future contents)

Definition at line 3280 of file DQMStore.cc.

References MonitorElement::softReset().

Referenced by ecaldqm::MESet::softReset().

 {
   if (me)
     me->softReset();
 }

void DQMStore::tag	(	MonitorElement *	me,
		unsigned int	myTag
	)

tag ME as <myTag> (myTag > 0)

Definition at line 1500 of file DQMStore.cc.

References MonitorElement::data_, DQMNet::DQM_PROP_TAGGED, DQMNet::CoreObject::flags, MonitorElement::getFullname(), raiseDQMError(), and DQMNet::CoreObject::tag.

Referenced by ConverterTester::beginJob(), SiStripBaseCondObjDQM::bookCumulMEs(), SiStripBaseCondObjDQM::bookProfileMEs(), SiStripBaseCondObjDQM::bookSummaryCumulMEs(), SiStripBaseCondObjDQM::bookSummaryMEs(), SiStripBaseCondObjDQM::bookSummaryProfileMEs(), extract(), getContents(), tag(), tagAllContents(), and tagContents().

 {
   if (! myTag)
     raiseDQMError("DQMStore", "Attempt to tag monitor element '%s'"
                   " with a zero tag", me->getFullname().c_str());
   if ((me->data_.flags & DQMNet::DQM_PROP_TAGGED) && myTag != me->data_.tag)
     raiseDQMError("DQMStore", "Attempt to tag monitor element '%s'"
                   " twice with multiple tags", me->getFullname().c_str());
 
   me->data_.tag = myTag;
   me->data_.flags |= DQMNet::DQM_PROP_TAGGED;
 }

void DQMStore::tag	(	std::string const &	path,
		unsigned int	myTag
	)

tag ME specified by full pathname (e.g. "my/long/dir/my_histo")

Definition at line 1515 of file DQMStore.cc.

References dir, findObject(), dataset::name, raiseDQMError(), AlCaHLTBitMon_QueryRunRegistry::string, and tag().

 {
   std::string dir;
   std::string name;
   splitPath(dir, name, path);
 
   if (MonitorElement* me = findObject(0, 0, 0, dir, name))
     tag(me, myTag);
   else
     raiseDQMError("DQMStore", "Attempt to tag non-existent monitor element"
                   " '%s' with tag %u", path.c_str(), myTag);
 
 }

void DQMStore::tagAllContents	(	std::string const &	path,
		unsigned int	myTag
	)

tag all children of folder, including all subfolders and their children; path must be an exact path name

Definition at line 1543 of file DQMStore.cc.

References clean, data_, MillePedeFileConverter_cfg::e, mps_fire::i, AlCaHLTBitMon_QueryRunRegistry::string, and tag().

 {
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(path, clean, cleaned);
   MonitorElement proto(cleaned, std::string());
 
   // FIXME: WILDCARDS? Old one supported them, but nobody seemed to use them.
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   while (i != e && isSubdirectory(*cleaned, *i->data_.dirname)) {
     tag(const_cast<MonitorElement*>(&*i), myTag);
     ++i;
   }
 }

void DQMStore::tagContents	(	std::string const &	path,
		unsigned int	myTag
	)

tag all children of folder (does NOT include subfolders)

Definition at line 1531 of file DQMStore.cc.

References data_, MillePedeFileConverter_cfg::e, mps_fire::i, AlCaHLTBitMon_QueryRunRegistry::string, and tag().

 {
   MonitorElement proto(&path, std::string());
   auto e = data_.end();
   auto i = data_.lower_bound(proto);
   for ( ; i != e && path == *i->data_.dirname; ++i)
     tag(const_cast<MonitorElement *>(&*i), myTag);
 }

void DQMStore::useQTest	(	std::string const &	dir,
		std::string const &	qtname
	)

attach quality test <qtname> to directory contents (need exact pathname without wildcards, e.g. A/B/C);

Definition at line 3184 of file DQMStore.cc.

References clean, raiseDQMError(), AlCaHLTBitMon_QueryRunRegistry::string, and useQTestByMatch().

 {
   // Clean the path
   std::string clean;
   std::string const* cleaned = nullptr;
   cleanTrailingSlashes(dir, clean, cleaned);
 
   // Validate the path.
   if (cleaned->find_first_not_of(s_safe) != std::string::npos)
     raiseDQMError("DQMStore", "Monitor element path name '%s'"
                   " uses unacceptable characters", cleaned->c_str());
 
   // Redirect to the pattern match version.
   useQTestByMatch(*cleaned + "/*", qtname);
 }

int DQMStore::useQTestByMatch	(	std::string const &	pattern,
		std::string const &	qtname
	)

attach quality test <qc> to monitor elements matching <pattern>.

Definition at line 3202 of file DQMStore.cc.

References data_, getQCriterion(), callgraph::path, qtestspecs_, raiseDQMError(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by QTestHandle::attachTests(), and useQTest().

 {
   QCriterion* qc = getQCriterion(qtname);
   if (! qc)
     raiseDQMError("DQMStore", "Cannot apply non-existent quality test '%s'",
                   qtname.c_str());
 
   auto* fm = new fastmatch(pattern);
 
   // Record the test for future reference.
   QTestSpec qts(fm, qc);
   qtestspecs_.push_back(qts);
 
   // Apply the quality test.
   std::string path;
   int cases = 0;
   for (auto const& me : data_) {
     path.clear();
     mergePath(path, *me.data_.dirname, me.data_.objname);
     if (fm->match(path)) {
       ++cases;
       const_cast<MonitorElement &>(me).addQReport(qts.second);
     }
   }
 
   //return the number of matched cases
   return cases;
 }

Friends And Related Function Documentation

friend class DQMArchiver

friend

Definition at line 662 of file DQMStore.h.

friend class DQMFileSaver

friend

Definition at line 666 of file DQMStore.h.

friend class DQMNet

friend

Definition at line 661 of file DQMStore.h.

friend class DQMRootOutputModule

friend

Definition at line 664 of file DQMStore.h.

friend class DQMRootSource

friend

Definition at line 665 of file DQMStore.h.

friend class DQMService

friend

Definition at line 660 of file DQMStore.h.

friend class DQMStoreExample

friend

Definition at line 663 of file DQMStore.h.

friend class edm::DQMHttpSource

friend

Definition at line 659 of file DQMStore.h.

friend class MEtoEDMConverter

friend

Definition at line 667 of file DQMStore.h.

Member Data Documentation

std::mutex DQMStore::book_mutex_

private

Definition at line 657 of file DQMStore.h.

Referenced by bookConcurrentTransaction(), bookTransaction(), cloneLumiHistograms(), cloneRunHistograms(), deleteUnusedLumiHistograms(), save(), and savePB().

bool DQMStore::canSaveByLumi_ {false}

private

Definition at line 644 of file DQMStore.h.

Referenced by book_(), and bookTransaction().

bool DQMStore::collateHistograms_ {false}

private

Definition at line 636 of file DQMStore.h.

Referenced by book_(), bookFloat_(), bookInt_(), bookString_(), extract(), initializeFrom(), isCollate(), load(), and readDirectory().

MEMap DQMStore::data_

private

Definition at line 650 of file DQMStore.h.

Referenced by book_(), cloneLumiHistograms(), cloneRunHistograms(), containsAnyMonitorable(), deleteUnusedLumiHistograms(), findObject(), DQMService::flushStandalone(), forceReset(), get(), getAllContents(), getContents(), getMatchingContents(), getMEs(), getStatus(), postGlobalBeginLumi(), readFile(), removeContents(), removeElement(), reset(), rmdir(), runQTests(), save(), savePB(), scaleElements(), tagAllContents(), tagContents(), and useQTestByMatch().

std::set<std::string> DQMStore::dirs_

private

Definition at line 651 of file DQMStore.h.

Referenced by book_(), dirExists(), getContents(), getSubdirs(), makeDirectory(), rmdir(), save(), and savePB().

bool DQMStore::doSaveByLumi_ {false}

private

Definition at line 646 of file DQMStore.h.

Referenced by book_(), and initializeFrom().

bool DQMStore::enableMultiThread_ {false}

private

Definition at line 637 of file DQMStore.h.

Referenced by DQMFileSaver::beginJob(), DQMRootOutputModule::beginJob(), bookConcurrentTransaction(), bookTransaction(), deleteUnusedLumiHistograms(), DQMStore(), getAllContents(), initializeFrom(), save(), and savePB().

bool DQMStore::forceResetOnBeginLumi_ {false}

private

Definition at line 639 of file DQMStore.h.

Referenced by DQMStore(), and forceReset().

bool DQMStore::LSbasedMode_

private

Definition at line 638 of file DQMStore.h.

Referenced by cloneLumiHistograms(), cloneRunHistograms(), initializeFrom(), postGlobalBeginLumi(), save(), and savePB().

uint32_t DQMStore::moduleId_ {}

private

Definition at line 642 of file DQMStore.h.

Referenced by book_(), bookFloat_(), bookInt_(), bookString_(), and bookTransaction().

DQMStore::pwd_ {}

private

Current directory.

Definition at line 649 of file DQMStore.h.

Referenced by book1D(), book1DD(), book1S(), book2D(), book2DD(), book2S(), book3D(), bookFloat(), bookInt(), bookProfile(), bookProfile2D(), bookString(), getMEs(), getSubdirs(), goUp(), pwd(), removeContents(), removeElement(), and setCurrentFolder().

DQMStore::qalgos_

private

Set of all the available quality test algorithms.

Definition at line 654 of file DQMStore.h.

Referenced by createQTest(), and initializeFrom().

DQMStore::qtests_

private

All the quality tests.

Definition at line 653 of file DQMStore.h.

Referenced by createQTest(), getQCriterion(), and ~DQMStore().

QTestSpecs DQMStore::qtestspecs_

private

Definition at line 655 of file DQMStore.h.

Referenced by book_(), useQTestByMatch(), and ~DQMStore().

DQMStore::readSelectedDirectory_ {}

private

If non-empty, read from file only selected directory.

Definition at line 640 of file DQMStore.h.

DQMStore::reset_ {false}

private

Flag used to print out a warning when calling quality tests. twice without having called reset() in between; to be reset in DQMOldReceiver::runQualityTests.

Definition at line 634 of file DQMStore.h.

Referenced by forceReset(), reset(), and runQTests().

uint32_t DQMStore::run_ {}

private

Definition at line 641 of file DQMStore.h.

Referenced by book_(), bookConcurrentTransaction(), bookFloat_(), bookInt_(), bookString_(), and bookTransaction().