DQMStore Class Reference

#include <DQMStore.h>

Classes
class	ConcurrentBooker
class	IBooker
class	IGetter

Public Types
enum	OpenRunDirs { KeepRunDirs, StripRunDirs }
enum	SaveReferenceTag { SaveWithoutReference, SaveWithReference, SaveWithReferenceForQTest }

Public Member Functions
MonitorElement *	book1D (const char *name, const char *title, int nchX, double lowX, double highX)
	Book 1D histogram. More...
MonitorElement *	book1D (const std::string &name, const std::string &title, int nchX, double lowX, double highX)
	Book 1D histogram. More...
MonitorElement *	book1D (const char *name, const char *title, int nchX, const float *xbinsize)
	Book 1D variable bin histogram. More...
MonitorElement *	book1D (const std::string &name, const std::string &title, int nchX, const float *xbinsize)
	Book 1D variable bin histogram. More...
MonitorElement *	book1D (const char *name, TH1F *h)
	Book 1D histogram by cloning an existing histogram. More...
MonitorElement *	book1D (const std::string &name, TH1F *h)
	Book 1D histogram by cloning an existing histogram. More...
MonitorElement *	book1DD (const char *name, const char *title, int nchX, double lowX, double highX)
	Book 1S histogram. More...
MonitorElement *	book1DD (const std::string &name, const std::string &title, int nchX, double lowX, double highX)
	Book 1S histogram. More...
MonitorElement *	book1DD (const char *name, const char *title, int nchX, const float *xbinsize)
MonitorElement *	book1DD (const std::string &name, const std::string &title, int nchX, const float *xbinsize)
MonitorElement *	book1DD (const char *name, TH1D *h)
	Book 1D double histogram by cloning an existing histogram. More...
MonitorElement *	book1DD (const std::string &name, TH1D *h)
	Book 1D double histogram by cloning an existing histogram. More...
MonitorElement *	book1S (const char *name, const char *title, int nchX, double lowX, double highX)
	Book 1S histogram. More...
MonitorElement *	book1S (const std::string &name, const std::string &title, int nchX, double lowX, double highX)
	Book 1S histogram. More...
MonitorElement *	book1S (const char *name, const char *title, int nchX, const float *xbinsize)
MonitorElement *	book1S (const std::string &name, const std::string &title, int nchX, const float *xbinsize)
MonitorElement *	book1S (const char *name, TH1S *h)
	Book 1S histogram by cloning an existing histogram. More...
MonitorElement *	book1S (const std::string &name, TH1S *h)
	Book 1S histogram by cloning an existing histogram. More...
MonitorElement *	book2D (const char *name, const char *title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2D histogram. More...
MonitorElement *	book2D (const std::string &name, const std::string &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2D histogram. More...
MonitorElement *	book2D (const char *name, const char *title, int nchX, const float *xbinsize, int nchY, const float *ybinsize)
	Book 2D variable bin histogram. More...
MonitorElement *	book2D (const std::string &name, const std::string &title, int nchX, const float *xbinsize, int nchY, const float *ybinsize)
	Book 2D variable bin histogram. More...
MonitorElement *	book2D (const char *name, TH2F *h)
	Book 2D histogram by cloning an existing histogram. More...
MonitorElement *	book2D (const std::string &name, TH2F *h)
	Book 2D histogram by cloning an existing histogram. More...
MonitorElement *	book2DD (const char *name, const char *title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2D double histogram. More...
MonitorElement *	book2DD (const std::string &name, const std::string &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2S histogram. More...
MonitorElement *	book2DD (const char *name, const char *title, int nchX, const float *xbinsize, int nchY, const float *ybinsize)
MonitorElement *	book2DD (const std::string &name, const std::string &title, int nchX, const float *xbinsize, int nchY, const float *ybinsize)
MonitorElement *	book2DD (const char *name, TH2D *h)
	Book 2DS histogram by cloning an existing histogram. More...
MonitorElement *	book2DD (const std::string &name, TH2D *h)
	Book 2DS histogram by cloning an existing histogram. More...
MonitorElement *	book2S (const char *name, const char *title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2S histogram. More...
MonitorElement *	book2S (const std::string &name, const std::string &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY)
	Book 2S histogram. More...
MonitorElement *	book2S (const char *name, const char *title, int nchX, const float *xbinsize, int nchY, const float *ybinsize)
	Book 2S variable bin histogram. More...
MonitorElement *	book2S (const std::string &name, const std::string &title, int nchX, const float *xbinsize, int nchY, const float *ybinsize)
	Book 2S variable bin histogram. More...
MonitorElement *	book2S (const char *name, TH2S *h)
	Book 2DS histogram by cloning an existing histogram. More...
MonitorElement *	book2S (const std::string &name, TH2S *h)
	Book 2DS histogram by cloning an existing histogram. More...
MonitorElement *	book3D (const char *name, const char *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 (const std::string &name, const std::string &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 (const char *name, TH3F *h)
	Book 3D histogram by cloning an existing histogram. More...
MonitorElement *	book3D (const std::string &name, TH3F *h)
	Book 3D histogram by cloning an existing histogram. More...
template<typename iFunc >
void	bookConcurrentTransaction (iFunc f, uint32_t run)
MonitorElement *	bookFloat (const char *name)
	Book float. More...
MonitorElement *	bookFloat (const std::string &name)
	Book float. More...
MonitorElement *	bookInt (const char *name)
	Book int. More...
MonitorElement *	bookInt (const std::string &name)
	Book int. More...
MonitorElement *	bookProfile (const char *name, const char *title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const std::string &name, const std::string &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const char *name, const char *title, int nchX, double lowX, double highX, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const std::string &name, const std::string &title, int nchX, double lowX, double highX, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const char *name, const char *title, int nchX, const double *xbinsize, int nchY, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const std::string &name, const std::string &title, int nchX, const double *xbinsize, int nchY, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const char *name, const char *title, int nchX, const double *xbinsize, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const std::string &name, const std::string &title, int nchX, const double *xbinsize, double lowY, double highY, const char *option="s")
MonitorElement *	bookProfile (const char *name, TProfile *h)
	Book TProfile by cloning an existing profile. More...
MonitorElement *	bookProfile (const std::string &name, TProfile *h)
	Book TProfile by cloning an existing profile. More...
MonitorElement *	bookProfile2D (const char *name, const char *title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, int nchZ, double lowZ, double highZ, const char *option="s")
MonitorElement *	bookProfile2D (const std::string &name, const std::string &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, int nchZ, double lowZ, double highZ, const char *option="s")
MonitorElement *	bookProfile2D (const char *name, const char *title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, double lowZ, double highZ, const char *option="s")
MonitorElement *	bookProfile2D (const std::string &name, const std::string &title, int nchX, double lowX, double highX, int nchY, double lowY, double highY, double lowZ, double highZ, const char *option="s")
MonitorElement *	bookProfile2D (const char *name, TProfile2D *h)
	Book TProfile2D by cloning an existing profile. More...
MonitorElement *	bookProfile2D (const std::string &name, TProfile2D *h)
	Book TProfile2D by cloning an existing profile. More...
MonitorElement *	bookString (const char *name, const char *value)
	Book string. More...
MonitorElement *	bookString (const std::string &name, const std::string &value)
	Book string. More...
template<typename iFunc >
void	bookTransaction (iFunc f, uint32_t run, uint32_t moduleId)
void	cd ()
	go to top directory (ie. root) More...
void	cd (const std::string &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 (const std::string &path) const
QCriterion *	createQTest (const std::string &algoname, const std::string &qtname)
void	deleteUnusedLumiHistograms (uint32_t run, uint32_t lumi)
bool	dirExists (const std::string &path) const
	true if directory exists More...
void	disableSoftReset (MonitorElement *me)
	DQMStore (const edm::ParameterSet &pset, edm::ActivityRegistry &)
	DQMStore (const edm::ParameterSet &pset)
MonitorElement *	get (const std::string &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 (const std::string &path, uint32_t runNumber=0, uint32_t lumi=0) const
std::vector< MonitorElement * >	getContents (const std::string &path) const
std::vector< MonitorElement * >	getContents (const std::string &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 (const std::string &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 (const std::string &qtname) const
int	getStatus (const std::string &path="") const
std::vector< std::string >	getSubdirs () const
void	goUp ()
	equivalent to "cd .." More...
bool	isCollate () const
bool	load (const std::string &filename, OpenRunDirs stripdirs=StripRunDirs, bool fileMustExist=true)
template<typename iFunc >
void	meBookerGetter (iFunc f)
bool	mtEnabled ()
bool	open (const std::string &filename, bool overwrite=false, const std::string &path="", const std::string &prepend="", OpenRunDirs stripdirs=KeepRunDirs, bool fileMustExist=true)
const std::string &	pwd () const
void	removeContents ()
	erase all monitoring elements in current directory (not including subfolders); More...
void	removeContents (const std::string &dir)
	remove all monitoring elements from directory; More...
void	removeElement (const std::string &name)
void	removeElement (const std::string &dir, const std::string &name, bool warning=true)
void	rmdir (const std::string &fullpath)
void	runQTests ()
void	save (const std::string &filename, const std::string &path="", const std::string &pattern="", const std::string &rewrite="", const uint32_t run=0, const uint32_t lumi=0, SaveReferenceTag ref=SaveWithReference, int minStatus=dqm::qstatus::STATUS_OK, const std::string &fileupdate="RECREATE")
void	savePB (const std::string &filename, const std::string &path="", const uint32_t run=0, const uint32_t lumi=0)
void	scaleElements ()
void	setCurrentFolder (const std::string &fullpath)
void	setVerbose (unsigned level)
void	showDirStructure () const
void	softReset (MonitorElement *me)
void	tag (MonitorElement *me, unsigned int myTag)
void	tag (const std::string &path, unsigned int myTag)
	tag ME specified by full pathname (e.g. "my/long/dir/my_histo") More...
void	tagAllContents (const std::string &path, unsigned int myTag)
void	tagContents (const std::string &path, unsigned int myTag)
	tag all children of folder (does NOT include subfolders) More...
void	useQTest (const std::string &dir, const std::string &qtname)
int	useQTestByMatch (const std::string &pattern, const std::string &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 *(*)(const std::string &)>
using	QCMap = std::map< std::string, QCriterion * >
using	QTestSpec = std::pair< fastmatch *, QCriterion * >
using	QTestSpecs = std::list< QTestSpec >

Private Member Functions
MonitorElement *	book1D_ (const std::string &dir, const std::string &name, TH1F *h)
	Book 1D histogram based on TH1F. More...
MonitorElement *	book1DD_ (const std::string &dir, const std::string &name, TH1D *h)
	Book 1D histogram based on TH1D. More...
MonitorElement *	book1S_ (const std::string &dir, const std::string &name, TH1S *h)
	Book 1D histogram based on TH1S. More...
MonitorElement *	book2D_ (const std::string &dir, const std::string &name, TH2F *h)
	Book 2D histogram based on TH2F. More...
MonitorElement *	book2DD_ (const std::string &dir, const std::string &name, TH2D *h)
	Book 2D histogram based on TH2D. More...
MonitorElement *	book2S_ (const std::string &dir, const std::string &name, TH2S *h)
	Book 2D histogram based on TH2S. More...
MonitorElement *	book3D_ (const std::string &dir, const std::string &name, TH3F *h)
	Book 3D histogram based on TH3F. More...
MonitorElement *	book_ (const std::string &dir, const std::string &name, const char *context)
template<class HISTO , class COLLATE >
MonitorElement *	book_ (const std::string &dir, const std::string &name, const char *context, int kind, HISTO *h, COLLATE collate)
MonitorElement *	bookFloat_ (const std::string &dir, const std::string &name)
	Book float. More...
MonitorElement *	bookInt_ (const std::string &dir, const std::string &name)
	Book int. More...
MonitorElement *	bookProfile2D_ (const std::string &dir, const std::string &name, TProfile2D *h)
	Book 2D profile histogram based on TProfile2D. More...
MonitorElement *	bookProfile_ (const std::string &dir, const std::string &name, TProfile *h)
	Book profile histogram based on TProfile. More...
MonitorElement *	bookString_ (const std::string &dir, const std::string &name, const std::string &value)
	Book string. More...
bool	cdInto (const std::string &path) const
	DQMStore (const DQMStore &)
bool	extract (TObject *obj, const std::string &dir, bool overwrite, bool collateHistograms)
TObject *	extractNextObject (TBufferFile &) const
MonitorElement *	findObject (const std::string &dir, const std::string &name, const uint32_t run=0, const uint32_t lumi=0, const uint32_t moduleId=0) const
void	forceReset ()
void	get_info (const dqmstorepb::ROOTFilePB_Histo &, std::string &dirname, std::string &objname, TObject **obj)
MonitorElement *	initialise (MonitorElement *me, const std::string &path)
void	initializeFrom (const edm::ParameterSet &)
bool	isCollateME (MonitorElement *me) const
void	makeDirectory (const std::string &path)
const DQMStore &	operator= (const DQMStore &)
void	postGlobalBeginLumi (const edm::GlobalContext &)
void	print_trace (const std::string &dir, const std::string &name)
unsigned int	readDirectory (TFile *file, bool overwrite, const std::string &path, const std::string &prepend, const std::string &curdir, OpenRunDirs stripdirs)
bool	readFile (const std::string &filename, bool overwrite=false, const std::string &path="", const std::string &prepend="", OpenRunDirs stripdirs=StripRunDirs, bool fileMustExist=true)
bool	readFilePB (const std::string &filename, bool overwrite=false, const std::string &path="", const std::string &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	collateHistograms_
MEMap	data_
std::set< std::string >	dirs_
bool	enableMultiThread_
bool	forceResetOnBeginLumi_
IBooker *	ibooker_
IGetter *	igetter_
bool	LSbasedMode_
uint32_t	moduleId_
std::string	pwd_
QAMap	qalgos_
QCMap	qtests_
QTestSpecs	qtestspecs_
std::string	readSelectedDirectory_
bool	reset_
uint32_t	run_
double	scaleFlag_
std::ofstream *	stream_
unsigned	verbose_
unsigned	verboseQT_

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 78 of file DQMStore.h.

Member Typedef Documentation

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

private

Definition at line 801 of file DQMStore.h.

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

private

Definition at line 803 of file DQMStore.h.

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

private

Definition at line 802 of file DQMStore.h.

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

private

Definition at line 799 of file DQMStore.h.

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

private

Definition at line 800 of file DQMStore.h.

Member Enumeration Documentation

enum DQMStore::OpenRunDirs

Enumerator
KeepRunDirs
StripRunDirs

Definition at line 87 of file DQMStore.h.

  {
    KeepRunDirs,
    StripRunDirs
  };

enum DQMStore::SaveReferenceTag

Enumerator
SaveWithoutReference
SaveWithReference
SaveWithReferenceForQTest

Definition at line 81 of file DQMStore.h.

  {
    SaveWithoutReference,
    SaveWithReference,
    SaveWithReferenceForQTest
  };

Constructor & Destructor Documentation

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

Definition at line 354 of file DQMStore.cc.

References edm::signalslot::Signal< T >::connect(), enableMultiThread_, forceReset(), forceResetOnBeginLumi_, edm::ParameterSet::getUntrackedParameter(), ibooker_, igetter_, initializeFrom(), edm::service::SystemBounds::maxNumberOfStreams(), postGlobalBeginLumi(), edm::ActivityRegistry::preallocateSignal_, edm::ActivityRegistry::watchPostGlobalBeginLumi(), edm::ActivityRegistry::watchPostSourceLumi(), and edm::ActivityRegistry::watchPostSourceRun().

  : verbose_ (1),
    verboseQT_ (1),
    reset_ (false),
    collateHistograms_ (false),
    enableMultiThread_(false),
    forceResetOnBeginLumi_(false),
    readSelectedDirectory_ (""),
    run_(0),
    moduleId_(0),
    stream_(nullptr),
    pwd_ (""),
    ibooker_(nullptr),
    igetter_(nullptr)
{
  if (!ibooker_)
    ibooker_ = new DQMStore::IBooker(this);
  if (!igetter_)
    igetter_ = new DQMStore::IGetter(this);
  initializeFrom(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) {
    forceResetOnBeginLumi_ = true;
    ar.watchPostSourceLumi([this](edm::LuminosityBlockIndex){ forceReset(); });
  }
  ar.watchPostGlobalBeginLumi(this, &DQMStore::postGlobalBeginLumi);
}

DQMStore::DQMStore

(

const edm::ParameterSet &

pset

)

Definition at line 390 of file DQMStore.cc.

References ibooker_, igetter_, and initializeFrom().

  : verbose_ (1),
    verboseQT_ (1),
    reset_ (false),
    collateHistograms_ (false),
    enableMultiThread_(false),
    readSelectedDirectory_ (""),
    run_(0),
    moduleId_(0),
    stream_(nullptr),
    pwd_ (""),
    ibooker_(nullptr),
    igetter_(nullptr)
{
  if (!ibooker_)
    ibooker_ = new DQMStore::IBooker(this);
  if (!igetter_)
    igetter_ = new DQMStore::IGetter(this);
  initializeFrom(pset);
}

DQMStore::~DQMStore

(

)

Definition at line 411 of file DQMStore.cc.

References qtests_, qtestspecs_, and stream_.

Referenced by meBookerGetter().

{
  for (auto & qtest : qtests_)
    delete qtest.second;

  for (auto & qtestspec : qtestspecs_)
    delete qtestspec.first;

  if (stream_)
    stream_->close();
  delete stream_;
}

DQMStore::DQMStore ( const DQMStore &  )

private

Member Function Documentation

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

Book 1D histogram.

Definition at line 882 of file DQMStore.cc.

References book1D_(), and pwd_.

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

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

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

Book 1D histogram.

Definition at line 890 of file DQMStore.cc.

References book1D_(), and pwd_.

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

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

Book 1D variable bin histogram.

Definition at line 930 of file DQMStore.cc.

References book1D_(), and pwd_.

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

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

Book 1D variable bin histogram.

Definition at line 938 of file DQMStore.cc.

References book1D_(), and pwd_.

{
  return book1D_(pwd_, name, new TH1F(name.c_str(), title.c_str(), nchX, xbinsize));
}

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

Book 1D histogram by cloning an existing histogram.

Definition at line 946 of file DQMStore.cc.

References book1D_(), and pwd_.

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

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

Book 1D histogram by cloning an existing histogram.

Definition at line 953 of file DQMStore.cc.

References book1D_(), and pwd_.

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

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

private

Book 1D histogram based on TH1F.

Definition at line 861 of file DQMStore.cc.

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

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

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

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

Book 1S histogram.

Definition at line 914 of file DQMStore.cc.

References book1DD_(), and pwd_.

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

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

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

Book 1S histogram.

Definition at line 922 of file DQMStore.cc.

References book1DD_(), and pwd_.

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

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

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

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

Book 1D double histogram by cloning an existing histogram.

Definition at line 974 of file DQMStore.cc.

References book1DD_(), and pwd_.

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

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

Book 1D double histogram by cloning an existing histogram.

Definition at line 981 of file DQMStore.cc.

References book1DD_(), and pwd_.

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

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

private

Book 1D histogram based on TH1D.

Definition at line 875 of file DQMStore.cc.

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

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

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

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

Book 1S histogram.

Definition at line 898 of file DQMStore.cc.

References book1S_(), and pwd_.

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

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

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

Book 1S histogram.

Definition at line 906 of file DQMStore.cc.

References book1S_(), and pwd_.

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

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

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

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

Book 1S histogram by cloning an existing histogram.

Definition at line 960 of file DQMStore.cc.

References book1S_(), and pwd_.

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

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

Book 1S histogram by cloning an existing histogram.

Definition at line 967 of file DQMStore.cc.

References book1S_(), and pwd_.

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

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

private

Book 1D histogram based on TH1S.

Definition at line 868 of file DQMStore.cc.

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

Referenced by book1S(), extract(), and mtEnabled().

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

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

Book 2D histogram.

Definition at line 1010 of file DQMStore.cc.

References book2D_(), and pwd_.

Referenced by DQMFEDIntegrityClient::beginJob(), ConverterTester::beginJob(), StripValidationPlots::beginJob(), APVValidationPlots::beginJob(), MuonAlignment::beginJob(), hcaldqm::ContainerSingle2D::book(), hcaldqm::Container2D::book(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), dqmRegisterHistogram(), DQMDcsInfoClient::endRun(), EgHLTOfflineSummaryClient::getEgHLTSumHist_(), SiStripBadAPVandHotStripAlgorithmFromClusterOccupancy::initializeDQMHistograms(), L1ScalersClient::L1ScalersClient(), meBookerGetter(), and MonitorElementsDb::MonitorElementsDb().

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

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

Book 2D histogram.

Definition at line 1021 of file DQMStore.cc.

References book2D_(), and pwd_.

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

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

Book 2D variable bin histogram.

Definition at line 1076 of file DQMStore.cc.

References book2D_(), and pwd_.

{
  return book2D_(pwd_, name, new TH2F(name, title,
                                     nchX, xbinsize, nchY, ybinsize));
}

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

Book 2D variable bin histogram.

Definition at line 1085 of file DQMStore.cc.

References book2D_(), and pwd_.

{
  return book2D_(pwd_, name, new TH2F(name.c_str(), title.c_str(),
                                     nchX, xbinsize, nchY, ybinsize));
}

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

Book 2D histogram by cloning an existing histogram.

Definition at line 1113 of file DQMStore.cc.

References book2D_(), and pwd_.

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

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

Book 2D histogram by cloning an existing histogram.

Definition at line 1120 of file DQMStore.cc.

References book2D_(), and pwd_.

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

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

private

Book 2D histogram based on TH2F.

Definition at line 989 of file DQMStore.cc.

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

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

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

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

Book 2D double histogram.

Definition at line 1054 of file DQMStore.cc.

References book2DD_(), and pwd_.

Referenced by meBookerGetter().

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

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

Book 2S histogram.

Definition at line 1065 of file DQMStore.cc.

References book2DD_(), and pwd_.

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

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

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

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

Book 2DS histogram by cloning an existing histogram.

Definition at line 1141 of file DQMStore.cc.

References book2DD_(), and pwd_.

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

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

Book 2DS histogram by cloning an existing histogram.

Definition at line 1148 of file DQMStore.cc.

References book2DD_(), and pwd_.

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

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

private

Book 2D histogram based on TH2D.

Definition at line 1003 of file DQMStore.cc.

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

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

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

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

Book 2S histogram.

Definition at line 1032 of file DQMStore.cc.

References book2S_(), and pwd_.

Referenced by dqmRegisterHistogram(), and meBookerGetter().

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

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

Book 2S histogram.

Definition at line 1043 of file DQMStore.cc.

References book2S_(), and pwd_.

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

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

Book 2S variable bin histogram.

Definition at line 1094 of file DQMStore.cc.

References book2S_(), and pwd_.

{

  return book2S_(pwd_, name, new TH2S(name, title,
                                     nchX, xbinsize, nchY, ybinsize));
}

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

Book 2S variable bin histogram.

Definition at line 1104 of file DQMStore.cc.

References book2S_(), and pwd_.

{
  return book2S_(pwd_, name, new TH2S(name.c_str(), title.c_str(),
                                     nchX, xbinsize, nchY, ybinsize));
}

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

Book 2DS histogram by cloning an existing histogram.

Definition at line 1127 of file DQMStore.cc.

References book2S_(), and pwd_.

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

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

Book 2DS histogram by cloning an existing histogram.

Definition at line 1134 of file DQMStore.cc.

References book2S_(), and pwd_.

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

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

private

Book 2D histogram based on TH2S.

Definition at line 996 of file DQMStore.cc.

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

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

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

MonitorElement * DQMStore::book3D	(	const char *	name,
		const char *	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 1163 of file DQMStore.cc.

References book3D_(), and pwd_.

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

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

MonitorElement * DQMStore::book3D	(	const std::string &	name,
		const std::string &	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 1176 of file DQMStore.cc.

References book3D_(), and pwd_.

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

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

Book 3D histogram by cloning an existing histogram.

Definition at line 1189 of file DQMStore.cc.

References book3D_(), and pwd_.

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

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

Book 3D histogram by cloning an existing histogram.

Definition at line 1196 of file DQMStore.cc.

References book3D_(), and pwd_.

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

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

private

Book 3D histogram based on TH3F.

Definition at line 1156 of file DQMStore.cc.

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

Referenced by book3D(), extract(), and mtEnabled().

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

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

private

Definition at line 737 of file DQMStore.cc.

References gather_cfg::cout, data_, dirs_, findObject(), mergePath(), 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_(), bookString_(), and mtEnabled().

{
  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(dir, name, run_, 0, moduleId_))
  {
    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_);
    return &const_cast<MonitorElement &>(*data_.insert(std::move(proto)).first);
  }
}

template<class HISTO , class COLLATE >

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

private

Definition at line 661 of file DQMStore.cc.

References collateHistograms_, gather_cfg::cout, data_, dir, dirs_, DQMNet::DQM_PROP_HAS_REFERENCE, findObject(), h, initialise(), callgraph::kind, mergePath(), moduleId_, eostools::move(), dataset::name, MonitorElement::object_, callgraph::path, print_trace(), qtestspecs_, MonitorElement::Reset(), run_, s_referenceDirName, 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(dir, name, run_, 0, moduleId_);
  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_);
    me = const_cast<MonitorElement &>(*data_.insert(std::move(proto)).first)
      .initialise((MonitorElement::Kind)kind, h);

    // Initialise quality test information.
    auto qi = qtestspecs_.begin();
    auto qe = qtestspecs_.end();
    for ( ; qi != qe; ++qi)
    {
        if ( qi->first->match(path) )
                me->addQReport(qi->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(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 374 of file DQMStore.h.

References book_mutex_, enableMultiThread_, f, findQualityFiles::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

(

const char *

name

)

Book float.

Definition at line 819 of file DQMStore.cc.

References bookFloat_(), and pwd_.

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

{ return bookFloat_(pwd_, name); }

MonitorElement * DQMStore::bookFloat

(

const std::string &

name

)

Book float.

Definition at line 824 of file DQMStore.cc.

References bookFloat_(), and pwd_.

{
  return bookFloat_(pwd_, name);
}

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

private

Book float.

Definition at line 802 of file DQMStore.cc.

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

Referenced by bookFloat(), extract(), and mtEnabled().

{
  if (collateHistograms_)
  {
    if (MonitorElement *me = findObject(dir, name, run_, 0, moduleId_))
    {
      me->Fill(0.);
      return me;
    }
  }

  return book_(dir, name, "bookFloat")
    ->initialise(MonitorElement::DQM_KIND_REAL);
}

MonitorElement * DQMStore::bookInt

(

const char *

name

)

Book int.

Definition at line 789 of file DQMStore.cc.

References bookInt_(), and pwd_.

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

{ return bookInt_(pwd_, name); }

MonitorElement * DQMStore::bookInt

(

const std::string &

name

)

Book int.

Definition at line 794 of file DQMStore.cc.

References bookInt_(), and pwd_.

{
  return bookInt_(pwd_, name);
}

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

private

Book int.

Definition at line 772 of file DQMStore.cc.

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

Referenced by bookInt(), extract(), and mtEnabled().

{
  if (collateHistograms_)
  {
    if (MonitorElement *me = findObject(dir, name, run_, 0, moduleId_))
    {
      me->Fill(0);
      return me;
    }
  }

  return book_(dir, name, "bookInt")
    ->initialise(MonitorElement::DQM_KIND_INT);
}

MonitorElement * DQMStore::bookProfile	(	const char *	name,
		const char *	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		const char *	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 1215 of file DQMStore.cc.

References bookProfile_(), and pwd_.

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

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

MonitorElement * DQMStore::bookProfile	(	const std::string &	name,
		const std::string &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		const char *	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 1230 of file DQMStore.cc.

References bookProfile_(), TSGForRoadSearch_cfi::option, and pwd_.

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

MonitorElement * DQMStore::bookProfile	(	const char *	name,
		const char *	title,
		int	nchX,
		double	lowX,
		double	highX,
		double	lowY,
		double	highY,
		const char *	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 1245 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	(	const std::string &	name,
		const std::string &	title,
		int	nchX,
		double	lowX,
		double	highX,
		double	lowY,
		double	highY,
		const char *	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 1260 of file DQMStore.cc.

References bookProfile_(), TSGForRoadSearch_cfi::option, and pwd_.

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

MonitorElement * DQMStore::bookProfile	(	const char *	name,
		const char *	title,
		int	nchX,
		const double *	xbinsize,
		int	nchY,
		double	lowY,
		double	highY,
		const char *	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 1275 of file DQMStore.cc.

References bookProfile_(), and pwd_.

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

MonitorElement * DQMStore::bookProfile	(	const std::string &	name,
		const std::string &	title,
		int	nchX,
		const double *	xbinsize,
		int	nchY,
		double	lowY,
		double	highY,
		const char *	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 1290 of file DQMStore.cc.

References bookProfile_(), TSGForRoadSearch_cfi::option, and pwd_.

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

MonitorElement * DQMStore::bookProfile	(	const char *	name,
		const char *	title,
		int	nchX,
		const double *	xbinsize,
		double	lowY,
		double	highY,
		const char *	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 1305 of file DQMStore.cc.

References bookProfile_(), and pwd_.

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

MonitorElement * DQMStore::bookProfile	(	const std::string &	name,
		const std::string &	title,
		int	nchX,
		const double *	xbinsize,
		double	lowY,
		double	highY,
		const char *	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 1320 of file DQMStore.cc.

References bookProfile_(), TSGForRoadSearch_cfi::option, and pwd_.

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

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

Book TProfile by cloning an existing profile.

Definition at line 1333 of file DQMStore.cc.

References bookProfile_(), and pwd_.

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

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

Book TProfile by cloning an existing profile.

Definition at line 1340 of file DQMStore.cc.

References bookProfile_(), and pwd_.

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

MonitorElement * DQMStore::bookProfile2D	(	const char *	name,
		const char *	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		int	nchZ,
		double	lowZ,
		double	highZ,
		const char *	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 1359 of file DQMStore.cc.

References bookProfile2D_(), and pwd_.

Referenced by ConverterTester::beginJob(), hcaldqm::ContainerSingleProf2D::book(), hcaldqm::ContainerProf2D::book(), DQMLumiMonitor::bookHistograms(), dqmRegisterHistogram(), meBookerGetter(), and MonitorElementsDb::MonitorElementsDb().

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

MonitorElement * DQMStore::bookProfile2D	(	const std::string &	name,
		const std::string &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		int	nchZ,
		double	lowZ,
		double	highZ,
		const char *	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 1376 of file DQMStore.cc.

References bookProfile2D_(), TSGForRoadSearch_cfi::option, and pwd_.

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

MonitorElement * DQMStore::bookProfile2D	(	const char *	name,
		const char *	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		double	lowZ,
		double	highZ,
		const char *	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 1393 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	(	const std::string &	name,
		const std::string &	title,
		int	nchX,
		double	lowX,
		double	highX,
		int	nchY,
		double	lowY,
		double	highY,
		double	lowZ,
		double	highZ,
		const char *	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 1410 of file DQMStore.cc.

References bookProfile2D_(), TSGForRoadSearch_cfi::option, and pwd_.

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

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

Book TProfile2D by cloning an existing profile.

Definition at line 1425 of file DQMStore.cc.

References bookProfile2D_(), and pwd_.

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

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

Book TProfile2D by cloning an existing profile.

Definition at line 1432 of file DQMStore.cc.

References bookProfile2D_(), and pwd_.

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

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

private

Book 2D profile histogram based on TProfile2D.

Definition at line 1348 of file DQMStore.cc.

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

Referenced by bookProfile2D(), extract(), and mtEnabled().

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

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

private

Book profile histogram based on TProfile.

Definition at line 1204 of file DQMStore.cc.

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

Referenced by bookProfile(), extract(), and mtEnabled().

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

MonitorElement * DQMStore::bookString	(	const char *	name,
		const char *	value
	)

Book string.

Definition at line 848 of file DQMStore.cc.

References bookString_(), and pwd_.

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

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

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

Book string.

Definition at line 853 of file DQMStore.cc.

References bookString_(), and pwd_.

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

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

private

Book string.

Definition at line 832 of file DQMStore.cc.

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

Referenced by bookString(), extract(), and mtEnabled().

{
  if (collateHistograms_)
  {
    if (MonitorElement *me = findObject(dir, name, run_, 0, moduleId_))
      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  )

inline

Definition at line 355 of file DQMStore.h.

References book_mutex_, enableMultiThread_, f, ibooker_, moduleId_, findQualityFiles::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;
    }
    f(*ibooker_);

    /* Reset the run number and module id only if multithreading is enabled */
    if (enableMultiThread_) {
      run_ = 0;
      moduleId_ = 0;
    }
  }

void DQMStore::cd

(

)

go to top directory (ie. root)

Definition at line 565 of file DQMStore.cc.

References setCurrentFolder().

Referenced by SiStripDcsInfo::addBadModules(), DQMFileReader::beginJob(), DQMDcsInfoClient::beginRun(), DQMStore::IBooker::bookProfile2D(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), SiStripDaqInfo::bookStatus(), SiStripDcsInfo::bookStatus(), SiStripTrackerMapCreator::createForOffline(), SiStripTrackerMapCreator::createInfoFile(), SiStripSummaryCreator::createSummary(), SiStripActionExecutor::createSummary(), SiStripActionExecutor::createSummaryOffline(), APVValidationPlots::endJob(), StripValidationPlots::endJob(), DQMDcsInfoClient::endRun(), 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(), meBookerGetter(), SiStripInformationExtractor::printAlarmList(), SiStripActionExecutor::printFaultyModuleList(), SiStripInformationExtractor::printNonGeomHistoList(), SiStripInformationExtractor::printSummaryHistoList(), readFilePB(), DQMStore::IGetter::removeElement(), DQMFileSaver::saveForOffline(), DQMFileSaver::saveForOnline(), SiStripTrackerMapCreator::setTkMapFromHistogram(), and dqm_interfaces.DirWalkerFile::walk().

{ setCurrentFolder(""); }

void DQMStore::cd

(

const std::string &

subdir

)

cd to subdirectory (if there)

Definition at line 570 of file DQMStore.cc.

References clean, cleanTrailingSlashes(), 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;
  const std::string *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 ( const std::string &  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 2396 of file DQMStore.cc.

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

Referenced by mtEnabled(), and 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 1441 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(), utils.BinToBin1percent::do_test(), and mtEnabled().

{
  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 1978 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_.

Referenced by mtEnabled().

{
  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));
  for (; i != e; ++i) {
    // 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 2015 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_.

Referenced by mtEnabled().

{
  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));
  for (; i != e; ++i) {
    // 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 1468 of file DQMStore.cc.

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

Referenced by book1D_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1482 of file DQMStore.cc.

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

Referenced by book1DD_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1475 of file DQMStore.cc.

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

Referenced by book1S_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1489 of file DQMStore.cc.

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

Referenced by book2D_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1503 of file DQMStore.cc.

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

Referenced by book2DD_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1496 of file DQMStore.cc.

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

Referenced by book2S_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1510 of file DQMStore.cc.

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

Referenced by book3D_(), extract(), and mtEnabled().

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

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

staticprivate

Definition at line 1517 of file DQMStore.cc.

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

Referenced by bookProfile_(), extract(), and mtEnabled().

{
  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 1527 of file DQMStore.cc.

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

Referenced by bookProfile2D_(), extract(), and mtEnabled().

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

bool DQMStore::containsAnyMonitorable

(

const std::string &

path

)

const

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

Definition at line 1645 of file DQMStore.cc.

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

Referenced by meBookerGetter(), and 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	(	const std::string &	algoname,
		const std::string &	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 3275 of file DQMStore.cc.

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

Referenced by QTestConfigure::EnableCheckVarianceTest(), QTestConfigure::EnableComp2Ref2DChi2Test(), QTestConfigure::EnableComp2RefChi2Test(), QTestConfigure::EnableComp2RefEqualHTest(), QTestConfigure::EnableComp2RefKolmogorovTest(), QTestConfigure::EnableCompareLastFilledBinTest(), QTestConfigure::EnableCompareToMedianTest(), QTestConfigure::EnableContentSigmaTest(), QTestConfigure::EnableContentsWithinExpectedTest(), QTestConfigure::EnableDeadChannelTest(), QTestConfigure::EnableMeanWithinExpectedTest(), QTestConfigure::EnableNoisyChannelTest(), QTestConfigure::EnableXRangeTest(), QTestConfigure::EnableYRangeTest(), and mtEnabled().

{
  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 2053 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(), and mtEnabled().

{
  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

(

const std::string &

path

)

const

true if directory exists

Definition at line 653 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 3409 of file DQMStore.cc.

References MonitorElement::disableSoftReset().

Referenced by meBookerGetter(), and ecaldqm::MESet::recoverStats().

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

bool DQMStore::extract ( TObject *  obj, const std::string &  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 2095 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(), isCollateME(), isSubdirectory(), callgraph::kind, diffTwoXMLs::label, funct::m, funct::master(), DQMNet::QValue::message, gen::n, MonitorElement::object_, DQMNet::QValue::qtname, DQMNet::QValue::qtresult, alignCSCRings::s, s_referenceDirName, s_rxmeqr1(), s_rxmeqr2(), 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(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(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(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(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(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(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(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(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(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(dir, label);
      if (! me || overwrite)
      {
        if (! me) me = bookInt_(dir, label);
        me->Fill(atoll(value.c_str()));
      }
    }
    else if (kind == "f")
    {
      MonitorElement *me = findObject(dir, label);
      if (! me || overwrite)
      {
        if (! me) me = bookFloat_(dir, label);
        me->Fill(atof(value.c_str()));
      }
    }
    else if (kind == "s")
    {
      MonitorElement *me = findObject(dir, label);
      if (! me)
        me = bookString_(dir, label, value);
      else if (overwrite)
        me->Fill(value);
    }
    else if (kind == "e")
    {
      MonitorElement *me = findObject(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(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(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(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 3086 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 ( const std::string &  dir, const std::string &  name, const uint32_t  run = 0, const uint32_t  lumi = 0, const uint32_t  moduleId = 0  ) const

private

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

Definition at line 1784 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(), DQMNet::CoreObject::run, findQualityFiles::run, and s_safe.

Referenced by book_(), bookFloat_(), bookInt_(), bookString_(), extract(), makeDirectory(), mtEnabled(), 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 1919 of file DQMStore.cc.

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

Referenced by DQMStore(), and mtEnabled().

{
  auto mi = data_.begin();
  auto me = data_.end();
  for ( ; mi != me; ++mi)
  {
    if (forceResetOnBeginLumi_ && ((*mi).getLumiFlag() == false))
      continue;
    auto &me = const_cast<MonitorElement &>(*mi);
    me.Reset();
    me.resetUpdate();
  }

  reset_ = true;
}

MonitorElement * DQMStore::get

(

const std::string &

path

)

const

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

Definition at line 1655 of file DQMStore.cc.

References data_, dir, dataset::name, splitPath(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), SiStripDcsInfo::addBadModules(), TrackerOfflineValidationSummary::associateModuleHistsWithTree(), RPCBxTest::beginRun(), CalibrationScanTask::book(), CalibrationTask::book(), 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(), DQMDcsInfoClient::endLuminosityBlock(), L1ScalersClient::endLuminosityBlock(), HLTScalersClient::endLuminosityBlock(), DQMDcsInfoClient::endRun(), 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(), hcaldqm::Container1D::load(), SiStripHistoPlotter::makePlot(), SiStripInformationExtractor::plotHistosFromLayout(), SiStripActionExecutor::printShiftHistoParameters(), QTestStatusChecker::processAlarms(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), rrapi.RRApi::reports(), util.rrapi.RRApi::reports(), EgHLTOfflineSummaryClient::runClient_(), DQMFileSaver::saveForOffline(), DQMFileSaver::saveForOnline(), util.rrapi.RRApi::tables(), rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), 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 1668 of file DQMStore.cc.

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

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), util.rrapi.RRApi::columns(), rrapi.RRApi::columns(), util.rrapi.RRApi::count(), rrapi.RRApi::count(), rrapi.RRApi::data(), util.rrapi.RRApi::data(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), rrapi.RRApi::report(), util.rrapi.RRApi::report(), rrapi.RRApi::reports(), util.rrapi.RRApi::reports(), 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().

{
  // 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 ( const dqmstorepb::ROOTFilePB_Histo &  h, std::string &  dirname, std::string &  objname, TObject **  obj  )

private

Definition at line 3094 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	(	const std::string &	path,
		uint32_t	run = 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 1812 of file DQMStore.cc.

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

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

{
  std::string clean;
  const std::string *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

(

const std::string &

path

)

const

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

Definition at line 1683 of file DQMStore.cc.

References clean, cleanTrailingSlashes(), data_, MillePedeFileConverter_cfg::e, mps_fire::i, isSubdirectory(), mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

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

{
  std::string clean;
  const std::string *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	(	const std::string &	path,
		unsigned int	tag
	)		const

same as above for tagged MonitorElements

Definition at line 1702 of file DQMStore.cc.

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

{
  std::string clean;
  const std::string *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 1726 of file DQMStore.cc.

References data_, dirs_, isSubdirectory(), funct::m, and AlCaHLTBitMon_QueryRunRegistry::string.

{
  into.clear();
  into.reserve(dirs_.size());

  auto me = data_.end();
  auto di = dirs_.begin();
  auto de = dirs_.end();
  for ( ; di != de; ++di)
  {
    MonitorElement proto(&*di, std::string());
    auto mi = data_.lower_bound(proto);
    auto m = mi;
    size_t sz = di->size() + 2;
    size_t nfound = 0;
    for ( ; m != me && isSubdirectory(*di, *m->data_.dirname); ++m)
      if (*di == *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 += *di;
      *istr += ':';
      for (sz = 0; mi != m; ++mi)
      {
        if (*di != *mi->data_.dirname)
          continue;

        if (sz > 0)
          *istr += ',';

        *istr += mi->data_.objname;
        ++sz;
      }
    }
    else
    {
      istr->reserve(di->size() + 2);
      *istr += *di;
      *istr += ':';
    }
  }
}

std::vector< MonitorElement * > DQMStore::getMatchingContents	(	const std::string &	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 1859 of file DQMStore.cc.

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

Referenced by EgHLTOfflineSummaryClient::getQTestResults_(), mtEnabled(), 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;
  auto i = data_.begin();
  auto e = data_.end();
  for ( ; i != e; ++i)
  {
    path.clear();
    mergePath(path, *i->data_.dirname, i->data_.objname);
    if (rx.match(path))
      result.push_back(const_cast<MonitorElement *>(&*i));
  }

  return result;
}

std::vector< std::string > DQMStore::getMEs

(

)

const

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

Definition at line 1629 of file DQMStore.cc.

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

Referenced by CalibrationScanTask::book(), CalibrationTask::book(), dqmCopyRecursively(), meBookerGetter(), 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

(

const std::string &

qtname

)

const

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

Definition at line 3264 of file DQMStore.cc.

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

Referenced by QTestConfigure::EnableCheckVarianceTest(), QTestConfigure::EnableComp2Ref2DChi2Test(), QTestConfigure::EnableComp2RefChi2Test(), QTestConfigure::EnableComp2RefEqualHTest(), QTestConfigure::EnableComp2RefKolmogorovTest(), QTestConfigure::EnableCompareLastFilledBinTest(), QTestConfigure::EnableCompareToMedianTest(), QTestConfigure::EnableContentSigmaTest(), QTestConfigure::EnableContentsWithinExpectedTest(), QTestConfigure::EnableDeadChannelTest(), QTestConfigure::EnableMeanWithinExpectedTest(), QTestConfigure::EnableNoisyChannelTest(), QTestConfigure::EnableXRangeTest(), QTestConfigure::EnableYRangeTest(), mtEnabled(), and useQTestByMatch().

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

int DQMStore::getStatus

(

const std::string &

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 3370 of file DQMStore.cc.

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

Referenced by QTestStatusChecker::checkGlobalStatus(), mtEnabled(), and SiStripInformationExtractor::printAlarmList().

{
  std::string clean;
  const std::string *cleaned = nullptr;
  cleanTrailingSlashes(path, clean, cleaned);

  int status = dqm::qstatus::STATUS_OK;
  auto mi = data_.begin();
  auto me = data_.end();
  for ( ; mi != me; ++mi)
  {
    if (! cleaned->empty() && ! isSubdirectory(*cleaned, *mi->data_.dirname))
      continue;

    if (mi->hasError())
      return dqm::qstatus::ERROR;
    else if (mi->hasWarning())
      status = dqm::qstatus::WARNING;
    else if (status < dqm::qstatus::WARNING
             && mi->hasOtherReport())
      status = dqm::qstatus::OTHER;
  }
  return status;
}

std::vector< std::string > DQMStore::getSubdirs

(

)

const

get list of subdirectories of current directory

Definition at line 1606 of file DQMStore.cc.

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

Referenced by SiStripSummaryCreator::createSummary(), dqmCopyRecursively(), TauDQMFileLoader::endRun(), SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripQualityChecker::fillSubDetStatus(), SiStripSummaryCreator::fillSummaryHistos(), SiStripUtility::getModuleFolderList(), SiStripSummaryCreator::getSummaryME(), SiStripUtility::goToDir(), meBookerGetter(), SiStripInformationExtractor::printAlarmList(), SiStripInformationExtractor::printNonGeomHistoList(), SiStripInformationExtractor::printSummaryHistoList(), 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 599 of file DQMStore.cc.

References pwd_, and setCurrentFolder().

Referenced by DQMStore::IBooker::bookProfile2D(), SiStripSummaryCreator::createSummary(), SiStripSummaryCreator::fillGrandSummaryHistos(), SiStripSummaryCreator::fillSummaryHistos(), SiStripUtility::getModuleFolderList(), SiStripSummaryCreator::getSummaryME(), SiStripUtility::goToDir(), meBookerGetter(), SiStripInformationExtractor::printAlarmList(), SiStripInformationExtractor::printNonGeomHistoList(), and SiStripInformationExtractor::printSummaryHistoList().

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

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

private

Referenced by book_(), and mtEnabled().

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

private

Definition at line 425 of file DQMStore.cc.

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

Referenced by DQMStore(), and mtEnabled().

                                                    {
  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";

  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 3448 of file DQMStore.cc.

References collateHistograms_.

Referenced by mtEnabled().

{
  return collateHistograms_;
}

bool DQMStore::isCollateME ( MonitorElement *  me ) const

private

Definition at line 3457 of file DQMStore.cc.

References MonitorElement::data_, DQMNet::CoreObject::dirname, isSubdirectory(), and s_collateDirName.

Referenced by extract(), and mtEnabled().

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

bool DQMStore::load	(	const std::string &	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 3004 of file DQMStore.cc.

References collateHistograms_, gather_cfg::cout, readFile(), readFilePB(), s_rxpbfile(), 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 ( const std::string &  path )

private

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

Definition at line 612 of file DQMStore.cc.

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

Referenced by initializeFrom(), mtEnabled(), 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(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 395 of file DQMStore.h.

References book1D(), book1DD(), book1S(), book2D(), book2DD(), book2S(), book3D(), bookFloat(), bookInt(), bookProfile(), bookProfile2D(), bookString(), cd(), containsAnyMonitorable(), dir, CommonMethods::dirExists(), disableSoftReset(), fastjetJetProducer_validation_cfg::DQMStore, f, corrVsCorr::filename, getContents(), getMEs(), getSubdirs(), goUp(), ibooker_, igetter_, KeepRunDirs, hcalDigis_cfi::level, svgfig::load(), PFRecoTauDiscriminationAgainstElectronDeadECAL_cfi::minStatus, dataset::name, open(), TSGForRoadSearch_cfi::option, callgraph::path, listBenchmarks::pattern, muonDTDigis_cfi::pset, alignCSCRings::pwd, removeContents(), removeElement(), rmdir(), findQualityFiles::run, cuy::save, savePB(), SaveWithReference, setCurrentFolder(), setVerbose(), softReset(), dqm::qstatus::STATUS_OK, AlCaHLTBitMon_QueryRunRegistry::string, StripRunDirs, GlobalPosition_Frontier_DevDB_cff::tag, tagAllContents(), tagContents(), fftjetcommon_cfi::title, and ~DQMStore().

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

                               {
    f(*ibooker_, *igetter_);
  }

bool DQMStore::mtEnabled ( )

inline

Definition at line 670 of file DQMStore.h.

References estimatePileup2::algoname, book1D_(), book1DD_(), book1S_(), book2D_(), book2DD_(), book2S_(), book3D_(), book_(), bookFloat_(), bookInt_(), bookProfile2D_(), bookProfile_(), bookString_(), cdInto(), checkBinningMatches(), cloneLumiHistograms(), cloneRunHistograms(), collate1D(), collate1DD(), collate1S(), collate2D(), collate2DD(), collate2S(), collate3D(), benchmark_cfg::collateHistograms, collateProfile(), collateProfile2D(), createQTest(), deleteUnusedLumiHistograms(), compare_using_db::dirname, fastjetJetProducer_validation_cfg::DQMStore, enableMultiThread_, extract(), extractNextObject(), FrontierConditions_GlobalTag_cff::file, findObject(), RemoveAddSevLevel::flag, forceReset(), get_info(), getAllContents(), getMatchingContents(), getQCriterion(), getStatus(), initialise(), initializeFrom(), isCollate(), isCollateME(), callgraph::kind, makeDirectory(), GetRecoTauVFromDQM_MC_cff::obj, operator=(), listBenchmarks::pattern, postGlobalBeginLumi(), print_trace(), readDirectory(), readFile(), readFilePB(), reset(), findQualityFiles::run, convertSQLiteXML::runNumber, runQTests(), scaleElements(), setAccumulate(), showDirStructure(), AlCaHLTBitMon_QueryRunRegistry::string, StripRunDirs, useQTest(), and useQTestByMatch().

{ return enableMultiThread_; };

bool DQMStore::open	(	const std::string &	filename,
		bool	overwrite = false,
		const std::string &	onlypath = "",
		const std::string &	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 2989 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(), meBookerGetter(), PFDQMEventSelector::openInputFile(), SiStripOfflineDQM::openInputFile(), BuildTrackerMapPlugin::read(), readFilePB(), savePB(), and StatisticsFilter::StatisticsFilter().

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

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

private

Referenced by DQMStore::ConcurrentBooker::ConcurrentBooker(), and mtEnabled().

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

private

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

Definition at line 1944 of file DQMStore.cc.

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

Referenced by DQMStore(), and mtEnabled().

{
  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 ( const std::string &  dir, const std::string &  name  )

private

Definition at line 487 of file DQMStore.cc.

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

Referenced by book_(), and mtEnabled().

{
  // 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_ = new 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);
}

const std::string & DQMStore::pwd

(

)

const

return pathname of current directory

Definition at line 560 of file DQMStore.cc.

References pwd_.

Referenced by SiStripDcsInfo::addBadModules(), CalibrationScanTask::book(), CalibrationTask::book(), LatencyTask::book(), FineDelayTask::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(), SiStripInformationExtractor::printAlarmList(), SiStripActionExecutor::printFaultyModuleList(), SiStripInformationExtractor::printNonGeomHistoList(), SiStripInformationExtractor::printSummaryHistoList(), and SiStripTrackerMapCreator::setTkMapFromHistogram().

{ return pwd_; }

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

private

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

Definition at line 2834 of file DQMStore.cc.

References collateHistograms_, KineDebug3::count(), gather_cfg::cout, extract(), isSubdirectory(), crabWrapper::key, makeDirectory(), GetRecoTauVFromDQM_MC_cff::next, GetRecoTauVFromDQM_MC_cff::obj, raiseDQMError(), s_collateDirName, s_monitorDirName, s_referenceDirName, createPayload::skip, pickleFileParser::slash, AlCaHLTBitMon_QueryRunRegistry::string, StripRunDirs, and verbose_.

Referenced by mtEnabled(), and 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 ( const std::string &  filename, bool  overwrite = false, const std::string &  onlypath = "", const std::string &  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 3031 of file DQMStore.cc.

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

Referenced by initializeFrom(), load(), mtEnabled(), 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();

  auto mi = data_.begin();
  auto me = data_.end();
  for ( ; mi != me; ++mi)
    const_cast<MonitorElement &>(*mi).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 ( const std::string &  filename, bool  overwrite = false, const std::string &  path = "", const std::string &  prepend = "", OpenRunDirs  stripdirs = StripRunDirs, bool  fileMustExist = true  )

private

Definition at line 3115 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(), dqmstorepb::ROOTFilePB::histo(), dqmstorepb::ROOTFilePB::histo_size(), mps_fire::i, input, GetRecoTauVFromDQM_MC_cff::obj, open(), callgraph::path, raiseDQMError(), setCurrentFolder(), AlCaHLTBitMon_QueryRunRegistry::string, and verbose_.

Referenced by load(), and mtEnabled().

{
  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;
    const dqmstorepb::ROOTFilePB::Histo &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(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(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 3230 of file DQMStore.cc.

References pwd_.

Referenced by meBookerGetter().

{
  removeContents(pwd_);
}

void DQMStore::removeContents

(

const std::string &

dir

)

remove all monitoring elements from directory;

Definition at line 3216 of file DQMStore.cc.

References data_, MillePedeFileConverter_cfg::e, mps_fire::i, isSubdirectory(), 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

(

const std::string &

name

)

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

Definition at line 3238 of file DQMStore.cc.

References pwd_.

Referenced by RPCBxTest::beginRun(), MonitorElementsDb::endJob(), DQMDcsInfoClient::endRun(), TrackerOfflineValidationSummary::fillTree(), and meBookerGetter().

{
  removeElement(pwd_, name);
}

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

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

Definition at line 3246 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 1895 of file DQMStore.cc.

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

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

{
  auto mi = data_.begin();
  auto me = data_.end();
  for ( ; mi != me; ++mi)
  {
    auto &me = const_cast<MonitorElement &>(*mi);
    if (mi->wasUpdated())
    {
      if (me.resetMe())
        me.Reset();
      me.resetUpdate();
    }
  }

  reset_ = true;
}

void DQMStore::rmdir

(

const std::string &

path

)

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

Definition at line 3196 of file DQMStore.cc.

References clean, cleanTrailingSlashes(), data_, dirs_, MillePedeFileConverter_cfg::e, mps_fire::i, isSubdirectory(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by dqmCopyRecursively(), and meBookerGetter().

{
  std::string clean;
  const std::string *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 3349 of file DQMStore.cc.

References gather_cfg::cout, data_, isSubdirectory(), reset_, MonitorElement::runQTests(), s_referenceDirName, and verbose_.

Referenced by mtEnabled().

{

  if (verbose_ > 0)
    std::cout << "DQMStore: running runQTests() with reset = "
              << ( reset_ ? "true" : "false" ) << std::endl;

  // Apply quality tests to each monitor element, skipping references.
  auto mi = data_.begin();
  auto me = data_.end();
  for ( ; mi != me; ++mi)
    if (! isSubdirectory(s_referenceDirName, *mi->data_.dirname))
      const_cast<MonitorElement &>(*mi).runQTests();

  reset_ = false;
}

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

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

Definition at line 2555 of file DQMStore.cc.

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

Referenced by Vispa.Main.TabController.TabController::allowClose(), CalibrationScanTask::checkAndSave(), CalibrationTask::checkAndSave(), Vispa.Main.TabController.TabController::checkModificationTimestamp(), doSaveForOnline(), TauDQMSimpleFileSaver::endJob(), TrackingTruthValid::endJob(), SiStripDigiValid::endJob(), SiPixelDigiValid::endJob(), LaserDQM::endJob(), SiStripLAProfileBooker::endJob(), dEdxAnalyzer::endJob(), TrackerHitAnalyzer::endJob(), StripValidationPlots::endJob(), TrackEfficiencyMonitor::endJob(), APVValidationPlots::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(const char *file, const char *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 2698 of file DQMStore.cc.

References counter, gather_cfg::cout, isSubdirectory(), 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 2470 of file DQMStore.cc.

References counter, gather_cfg::cout, MillePedeFileConverter_cfg::e, mps_fire::i, isSubdirectory(), funct::master(), SiStripPI::max, or, s_referenceDirName, 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 (size_t i = 0, e = master->data_.qreports.size(); i != e; ++i)
            status = std::max(status, master->data_.qreports[i].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 2669 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((const void*)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 2439 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, isSubdirectory(), MonitorElement::kind(), MonitorElement::object_, DQMNet::CoreObject::qreports, MonitorElement::qualityTagString(), edmIntegrityCheck::report, s_referenceDirName, 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	(	const std::string &	filename,
		const std::string &	path = "",
		const uint32_t	run = 0,
		const uint32_t	lumi = 0
	)

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

Definition at line 2746 of file DQMStore.cc.

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

Referenced by doSaveForOnline(), meBookerGetter(), 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 3465 of file DQMStore.cc.

References gather_cfg::cout, data_, dirExists(), MonitorElement::DQM_KIND_INT, MonitorElement::DQM_KIND_REAL, MonitorElement::DQM_KIND_TH1D, MonitorElement::DQM_KIND_TH1F, MonitorElement::DQM_KIND_TH1S, MonitorElement::DQM_KIND_TH2D, MonitorElement::DQM_KIND_TH2F, MonitorElement::DQM_KIND_TH2S, MonitorElement::DQM_KIND_TH3F, MonitorElement::DQM_KIND_TPROFILE, MonitorElement::DQM_KIND_TPROFILE2D, PatBasicFWLiteAnalyzer::events, MonitorElement::getFloatValue(), MonitorElement::getIntValue(), MonitorElement::kind(), scaleFlag_, and verbose_.

Referenced by mtEnabled().

{
  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);

  auto mi = data_.begin();
  auto me = data_.end();
  for ( ; mi != me; ++mi)
  {
    auto &me = const_cast<MonitorElement &>(*mi);
    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 3418 of file DQMStore.cc.

References MonitorElement::setAccumulate().

Referenced by mtEnabled().

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

void DQMStore::setCurrentFolder

(

const std::string &

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 588 of file DQMStore.cc.

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

Referenced by SiStripDcsInfo::addBadModules(), DQMFileReader::beginJob(), DQMFEDIntegrityClient::beginJob(), L1ScalersClient::beginJob(), ConverterTester::beginJob(), APVValidationPlots::beginJob(), StripValidationPlots::beginJob(), DQMDaqInfo::beginJob(), MuonAlignment::beginJob(), HLTScalersClient::beginJob(), RPCBxTest::beginRun(), DQMDcsInfoClient::beginRun(), CalibrationScanTask::book(), CalibrationTask::book(), FineDelayTask::book(), LatencyTask::book(), hcaldqm::ContainerSingleProf1D::book(), hcaldqm::ContainerSingleProf2D::book(), hcaldqm::ContainerSingle1D::book(), hcaldqm::ContainerProf1D::book(), hcaldqm::ContainerProf2D::book(), hcaldqm::ContainerSingle2D::book(), MEtoMEComparitor::book(), hcaldqm::Container2D::book(), hcaldqm::Container1D::book(), TrackerOfflineValidationSummary::bookHarvestingHists(), PixelVTXMonitor::bookHistograms(), DQMLumiMonitor::bookHistograms(), DQMStore::IBooker::bookProfile2D(), SiStripCertificationInfo::bookSiStripCertificationMEs(), SiStripQualityChecker::bookStatus(), SiStripDaqInfo::bookStatus(), SiStripDcsInfo::bookStatus(), cd(), dqmCopyRecursively(), HarvestingAnalyzer::endJob(), HLTScalersClient::endLuminosityBlock(), DQMDcsInfoClient::endRun(), 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;
  const std::string *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 552 of file DQMStore.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

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

{ return; }

void DQMStore::showDirStructure

(

)

const

Definition at line 3428 of file DQMStore.cc.

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

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

{
  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 3401 of file DQMStore.cc.

References MonitorElement::softReset().

Referenced by meBookerGetter(), and ecaldqm::MESet::softReset().

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

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

tag ME as <myTag> (myTag > 0)

Definition at line 1541 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	(	const std::string &	path,
		unsigned int	myTag
	)

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

Definition at line 1556 of file DQMStore.cc.

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

{
  std::string dir;
  std::string name;
  splitPath(dir, name, path);

  if (MonitorElement *me = findObject(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	(	const std::string &	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 1584 of file DQMStore.cc.

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

Referenced by meBookerGetter().

{
  std::string clean;
  const std::string *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	(	const std::string &	path,
		unsigned int	myTag
	)

tag all children of folder (does NOT include subfolders)

Definition at line 1572 of file DQMStore.cc.

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

Referenced by DQMStore::IBooker::bookProfile2D(), and meBookerGetter().

{
  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	(	const std::string &	dir,
		const std::string &	qtname
	)

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

Definition at line 3296 of file DQMStore.cc.

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

Referenced by mtEnabled().

{
  // Clean the path
  std::string clean;
  const std::string *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	(	const std::string &	pattern,
		const std::string &	qtname
	)

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

Definition at line 3314 of file DQMStore.cc.

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

Referenced by QTestHandle::attachTests(), mtEnabled(), 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.
  auto mi = data_.begin();
  auto me = data_.end();
  std::string path;
  int cases = 0;
  for ( ; mi != me; ++mi)
  {
    path.clear();
    mergePath(path, *mi->data_.dirname, mi->data_.objname);
    if (fm->match(path))
    {
      ++cases;
      const_cast<MonitorElement &>(*mi).addQReport(qts.second);
    }
  }

  //return the number of matched cases
  return cases;
}

Friends And Related Function Documentation

friend class DQMArchiver

friend

Definition at line 859 of file DQMStore.h.

friend class DQMFileSaver

friend

Definition at line 863 of file DQMStore.h.

friend class DQMNet

friend

Definition at line 858 of file DQMStore.h.

friend class DQMRootOutputModule

friend

Definition at line 861 of file DQMStore.h.

friend class DQMRootSource

friend

Definition at line 862 of file DQMStore.h.

friend class DQMService

friend

Definition at line 857 of file DQMStore.h.

friend class DQMStoreExample

friend

Definition at line 860 of file DQMStore.h.

friend class edm::DQMHttpSource

friend

Definition at line 856 of file DQMStore.h.

friend class MEtoEDMConverter

friend

Definition at line 864 of file DQMStore.h.

Member Data Documentation

std::mutex DQMStore::book_mutex_

private

Definition at line 852 of file DQMStore.h.

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

bool DQMStore::collateHistograms_

private

Definition at line 835 of file DQMStore.h.

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

MEMap DQMStore::data_

private

Definition at line 845 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 846 of file DQMStore.h.

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

bool DQMStore::enableMultiThread_

private

Definition at line 836 of file DQMStore.h.

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

bool DQMStore::forceResetOnBeginLumi_

private

Definition at line 838 of file DQMStore.h.

Referenced by DQMStore(), and forceReset().

IBooker* DQMStore::ibooker_

private

Definition at line 853 of file DQMStore.h.

Referenced by bookTransaction(), DQMStore(), and meBookerGetter().

IGetter* DQMStore::igetter_

private

Definition at line 854 of file DQMStore.h.

Referenced by DQMStore(), and meBookerGetter().

bool DQMStore::LSbasedMode_

private

Definition at line 837 of file DQMStore.h.

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

uint32_t DQMStore::moduleId_

private

Definition at line 841 of file DQMStore.h.

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

DQMStore::pwd_

private

Current directory.

Definition at line 844 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 849 of file DQMStore.h.

Referenced by createQTest(), and initializeFrom().

DQMStore::qtests_

private

All the quality tests.

Definition at line 848 of file DQMStore.h.

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

QTestSpecs DQMStore::qtestspecs_

private

Definition at line 850 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 839 of file DQMStore.h.

DQMStore::reset_

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 833 of file DQMStore.h.

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

uint32_t DQMStore::run_

private

Definition at line 840 of file DQMStore.h.

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

double DQMStore::scaleFlag_

private

Definition at line 834 of file DQMStore.h.

Referenced by initializeFrom(), and scaleElements().

std::ofstream* DQMStore::stream_

private

Definition at line 842 of file DQMStore.h.

Referenced by print_trace(), and ~DQMStore().

DQMStore::verbose_

private

Universal verbose flag for DQM.

Definition at line 831 of file DQMStore.h.

Referenced by book_(), cloneLumiHistograms(), cloneRunHistograms(), deleteUnusedLumiHistograms(), extract(), initializeFrom(), load(), print_trace(), readDirectory(), readFile(), readFilePB(), runQTests(), save(), saveMonitorElementRangeToPB(), saveMonitorElementRangeToROOT(), savePB(), and scaleElements().

DQMStore::verboseQT_

private

Verbose flag for xml-based QTests.

Definition at line 832 of file DQMStore.h.

Referenced by createQTest(), and initializeFrom().