#include <DQMFileSaverBase.h>

Inheritance diagram for dqm::DQMFileSaverBase:

Classes
struct	FileParameters

Public Types
typedef dqm::legacy::DQMStore	DQMStore

typedef dqm::legacy::MonitorElement	MonitorElement

Public Types inherited from edm::global::EDAnalyzerBase
typedef EDAnalyzerBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Public Member Functions
	DQMFileSaverBase (const edm::ParameterSet &ps)

	~DQMFileSaverBase () override

Public Member Functions inherited from edm::global::EDAnalyzer< edm::RunCache< NoCache >, edm::LuminosityBlockCache< NoCache > >
	EDAnalyzer ()=default

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsStreamLuminosityBlocks () const final

bool	wantsStreamRuns () const final

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

	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

	~EDAnalyzerBase () override

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

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

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

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

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

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

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

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

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

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

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

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static void	fillDescription (edm::ParameterSetDescription &d)

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Protected Member Functions
void	analyze (edm::StreamID, const edm::Event &e, const edm::EventSetup &) const final

std::shared_ptr< NoCache >	globalBeginLuminosityBlock (const edm::LuminosityBlock &, const edm::EventSetup &) const final

std::shared_ptr< NoCache >	globalBeginRun (const edm::Run &, const edm::EventSetup &) const final

void	globalEndLuminosityBlock (const edm::LuminosityBlock &, const edm::EventSetup &) const final

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

virtual void	initRun () const

void	logFileAction (const std::string &msg, const std::string &fileName) const

void	saveJobReport (const std::string &filename) const

virtual void	saveLumi (const FileParameters &fp) const

virtual void	saveRun (const FileParameters &fp) const

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

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

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

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

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

void	consumesMany (const TypeToGet &id)

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

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

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

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

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

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

Static Protected Member Functions
static const std::string	filename (const FileParameters &fp, bool useLumi=false)

Protected Attributes
FileParameters	initial_fp_

std::mutex	initial_fp_lock_

Detailed Description

Definition at line 23 of file DQMFileSaverBase.h.

Member Typedef Documentation

typedef dqm::legacy::DQMStore dqm::DQMFileSaverBase::DQMStore

Definition at line 26 of file DQMFileSaverBase.h.

typedef dqm::legacy::MonitorElement dqm::DQMFileSaverBase::MonitorElement

Definition at line 25 of file DQMFileSaverBase.h.

Constructor & Destructor Documentation

DQMFileSaverBase::DQMFileSaverBase ( const edm::ParameterSet & ps )

Definition at line 27 of file DQMFileSaverBase.cc.

                                                             {
   FileParameters fp;
 
   fp.path_ = ps.getUntrackedParameter<std::string>("path");
   fp.producer_ = ps.getUntrackedParameter<std::string>("producer");
   fp.run_ = 0;
   fp.tag_ = ps.getUntrackedParameter<std::string>("tag");
   fp.lumi_ = 0;
   fp.version_ = 1;
   fp.child_ = "";
 
   fp.saveReference_ = DQMStore::SaveWithReference;
   // Check how we should save the references.
   std::string refsave = ps.getUntrackedParameter<std::string>("referenceHandling", "all");
   if (refsave == "skip") {
     fp.saveReference_ = DQMStore::SaveWithoutReference;
   } else if (refsave == "all") {
     fp.saveReference_ = DQMStore::SaveWithReference;
   } else if (refsave == "qtests") {
     fp.saveReference_ = DQMStore::SaveWithReferenceForQTest;
   } else {
     //edm::LogInfo("DQMFileSaverBase")
     std::cerr << "Invalid 'referenceHandling' parameter '" << refsave << "'.  Expected 'skip', 'all' or 'qtests'.";
   }
 
   // Check minimum required quality test result for which reference is saved.
   fp.saveReferenceQMin_ = ps.getUntrackedParameter<int>("referenceRequireStatus", dqm::qstatus::STATUS_OK);
 
   std::unique_lock<std::mutex> lck(initial_fp_lock_);
   initial_fp_ = fp;
 }

DQMFileSaverBase::~DQMFileSaverBase ( )

overridedefault

Referenced by DQMFileSaverBase().

Member Function Documentation

void DQMFileSaverBase::analyze	(	edm::StreamID	,
		const edm::Event &	e,
		const edm::EventSetup &
	)		const

finalprotected

Definition at line 72 of file DQMFileSaverBase.cc.

                                                                                           {
   // not supported
 }

const std::string DQMFileSaverBase::filename	(	const FileParameters &	fp,
		bool	useLumi = `false`
	)

staticprotected

Definition at line 104 of file DQMFileSaverBase.cc.

References dqm::DQMFileSaverBase::FileParameters::child_, FrontierConditions_GlobalTag_cff::file, dqm::DQMFileSaverBase::FileParameters::lumi_, castor_dqm_sourceclient_file_cfg::path, dqm::DQMFileSaverBase::FileParameters::path_, dqm::DQMFileSaverBase::FileParameters::producer_, dqm::DQMFileSaverBase::FileParameters::run_, dqm::DQMFileSaverBase::FileParameters::tag_, and dqm::DQMFileSaverBase::FileParameters::version_.

Referenced by dqm::DQMFileSaverOnline::makeSnapshot(), and Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::properties().

                                                                                  {
   char buf[256];
   if (useLumi) {
     snprintf(buf,
              256,
              "%s_V%04d_%s_R%09ld_L%09ld%s",
              fp.producer_.c_str(),
              fp.version_,
              fp.tag_.c_str(),
              fp.run_,
              fp.lumi_,
              fp.child_.c_str());
   } else {
     snprintf(buf,
              256,
              "%s_V%04d_%s_R%09ld%s",
              fp.producer_.c_str(),
              fp.version_,
              fp.tag_.c_str(),
              fp.run_,
              fp.child_.c_str());
   }
   buf[255] = 0;
 
   namespace fs = boost::filesystem;
   fs::path path(fp.path_);
   fs::path file(buf);
 
   return (path / file).string();
 }

void DQMFileSaverBase::fillDescription ( edm::ParameterSetDescription & d )

static

Definition at line 151 of file DQMFileSaverBase.cc.

References edm::ParameterSetDescription::addUntracked(), dqm::qstatus::STATUS_OK, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by dqm::DQMFileSaverPB::fillDescriptions(), and dqm::DQMFileSaverOnline::fillDescriptions().

                                                                        {
   desc.addUntracked<std::string>("tag", "UNKNOWN")->setComment("File tag, DQM_V000_<TAG>*, usually a subsytem name.");
 
   desc.addUntracked<std::string>("producer", "DQM")
       ->setComment("Base prefix for files, <BASE>_V000_**, either 'DQM' or 'Playback'.");
 
   desc.addUntracked<std::string>("referenceHandling", "all")->setComment("saveReference_, passed to the DQMStore");
 
   desc.addUntracked<int>("referenceRequireStatus", dqm::qstatus::STATUS_OK)
       ->setComment("saveReference_, passed to the DQMStore");
 
   desc.addUntracked<std::string>("path", "./")->setComment("Output path prefix.");
 }

std::shared_ptr< NoCache > DQMFileSaverBase::globalBeginLuminosityBlock	(	const edm::LuminosityBlock &	l,
		const edm::EventSetup &
	)		const

finalprotected

Definition at line 67 of file DQMFileSaverBase.cc.

                                                                                                    {
   return nullptr;
 }

std::shared_ptr< NoCache > DQMFileSaverBase::globalBeginRun	(	const edm::Run &	r,
		const edm::EventSetup &
	)		const

finalprotected

Definition at line 61 of file DQMFileSaverBase.cc.

References initRun().

                                                                                                     {
   this->initRun();
 
   return nullptr;
 }

void DQMFileSaverBase::globalEndLuminosityBlock	(	const edm::LuminosityBlock &	iLS,
		const edm::EventSetup &
	)		const

finalprotected

Definition at line 76 of file DQMFileSaverBase.cc.

References dqm::dqmstoreimpl::DQMStore::deleteUnusedLumiHistograms(), personalPlayback::fp, edm::LuminosityBlockBase::id(), initial_fp_, initial_fp_lock_, dqm::DQMFileSaverBase::FileParameters::lumi_, edm::LuminosityBlockID::luminosityBlock(), dqm::dqmstoreimpl::DQMStore::mtEnabled(), edm::LuminosityBlockID::run(), dqm::DQMFileSaverBase::FileParameters::run_, and saveLumi().

                                                                                                           {
   int ilumi = iLS.id().luminosityBlock();
   int irun = iLS.id().run();
 
   std::unique_lock<std::mutex> lck(initial_fp_lock_);
   FileParameters fp = initial_fp_;
   lck.unlock();
 
   fp.lumi_ = ilumi;
   fp.run_ = irun;
 
   this->saveLumi(fp);
 
   edm::Service<DQMStore> store;
   store->deleteUnusedLumiHistograms(store->mtEnabled() ? irun : 0, ilumi);
 }

void DQMFileSaverBase::globalEndRun	(	const edm::Run &	iRun,
		const edm::EventSetup &
	)		const

finalprotected

Definition at line 93 of file DQMFileSaverBase.cc.

References personalPlayback::fp, edm::RunBase::id(), initial_fp_, initial_fp_lock_, edm::RunID::run(), dqm::DQMFileSaverBase::FileParameters::run_, and saveRun().

                                                                                    {
   std::unique_lock<std::mutex> lck(initial_fp_lock_);
   FileParameters fp = initial_fp_;
   lck.unlock();
 
   fp.run_ = iRun.id().run();
 
   // empty
   this->saveRun(fp);
 }

virtual void dqm::DQMFileSaverBase::initRun ( ) const

inlineprotectedvirtual

Reimplemented in dqm::DQMFileSaverPB.

Definition at line 63 of file DQMFileSaverBase.h.

Referenced by globalBeginRun().

63 {};

void DQMFileSaverBase::logFileAction	(	const std::string &	msg,
		const std::string &	fileName
	)		const

protected

Definition at line 146 of file DQMFileSaverBase.cc.

References MillePedeFileConverter_cfg::fileName, and edm::FlushMessageLog().

Referenced by dqm::DQMFileSaverOnline::appendSnapshot(), dqm::DQMFileSaverOnline::checkError(), and dqm::DQMFileSaverOnline::makeSnapshot().

                                                                                           {
   edm::LogAbsolute("fileAction") << std::setprecision(0) << edm::TimeOfDay() << "  " << msg << fileName;
   edm::FlushMessageLog();
 }

void DQMFileSaverBase::saveJobReport ( const std::string & filename ) const

protected

Definition at line 135 of file DQMFileSaverBase.cc.

References info(), edm::Service< T >::isAvailable(), and edm::JobReport::reportAnalysisFile().

Referenced by dqm::DQMFileSaverOnline::makeSnapshot().

                                                                     {
   // Report the file to job report service.
   edm::Service<edm::JobReport> jr;
   if (jr.isAvailable()) {
     std::map<std::string, std::string> info;
     info["Source"] = "DQMStore";
     info["FileClass"] = "DQM";
     jr->reportAnalysisFile(filename, info);
   }
 }