#include <DQWorkerClient.h>

Inheritance diagram for ecaldqm::DQWorkerClient:

Public Types
enum	ProcessType { kLumi, kJob, nProcessType }

enum	Quality { kBad = 0, kGood = 1, kUnknown = 2, kMBad = 3, kMGood = 4, kMUnknown = 5 }

Public Member Functions
void	bookMEs (DQMStore::IBooker &) override

	DQWorkerClient ()

void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

virtual void	producePlots (ProcessType)=0

void	releaseMEs () override

void	releaseSource ()

virtual void	resetMEs ()

void	resetPerLumi ()

bool	retrieveSource (DQMStore::IGetter &, ProcessType)

bool	runsOn (ProcessType _type) const

void	setStatusManager (StatusManager const &_manager)

	~DQWorkerClient () override

Public Member Functions inherited from ecaldqm::DQWorker
virtual void	beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &)

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

	DQWorker ()

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

const EcalDQMSetupObjects	getEcalDQMSetupObjects ()

const EcalElectronicsMapping *	GetElectronicsMap ()

const CaloGeometry *	GetGeometry ()

const std::string &	getName () const

const CaloTopology *	GetTopology ()

const EcalTrigTowerConstituentsMap *	GetTrigTowerMap ()

bool	onlineMode () const

void	setEventNumber (edm::EventNumber_t _e)

void	setLumiNumber (edm::LuminosityBlockNumber_t _l)

void	setRunNumber (edm::RunNumber_t _r)

void	setSetupObjects (edm::EventSetup const &)

void	setTime (time_t _t)

virtual	~DQWorker () noexcept(false)

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

Static Public Member Functions inherited from ecaldqm::DQWorker
static void	fillDescriptions (edm::ParameterSetDescription &_desc)

Protected Member Functions
void	setME (edm::ParameterSet const &_ps) final

void	setSource (edm::ParameterSet const &) override

void	towerAverage_ (MESet &, MESet const &, float)

bool	using_ (std::string const &_name, ProcessType _type=kJob) const

Protected Member Functions inherited from ecaldqm::DQWorker
void	initialize (std::string const &_name, edm::ParameterSet const &)

void	print_ (std::string const &, int=0) const

virtual void	setParams (edm::ParameterSet const &)

void	setVerbosity (int _verbosity)

Protected Attributes
bool	hasLumiPlots_

std::set< std::string >	qualitySummaries_

MESetCollection	sources_

StatusManager const *	statusManager_

Protected Attributes inherited from ecaldqm::DQWorker
bool	booked_

MESetCollection	MEs_

std::string	name_

bool	onlineMode_

Timestamp	timestamp_

int	verbosity_

bool	willConvertToEDM_

Additional Inherited Members
Protected Types inherited from ecaldqm::DQWorker
typedef dqm::legacy::DQMStore	DQMStore

typedef dqm::legacy::MonitorElement	MonitorElement

Detailed Description

Definition at line 13 of file DQWorkerClient.h.

Member Enumeration Documentation

◆ ProcessType

enum ecaldqm::DQWorkerClient::ProcessType

Enumerator
kLumi
kJob
nProcessType

Definition at line 15 of file DQWorkerClient.h.

15 { kLumi, kJob, nProcessType };

◆ Quality

enum ecaldqm::DQWorkerClient::Quality

Enumerator
kBad
kGood
kUnknown
kMBad
kMGood
kMUnknown

Definition at line 37 of file DQWorkerClient.h.

37 { kBad = 0, kGood = 1, kUnknown = 2, kMBad = 3, kMGood = 4, kMUnknown = 5 };

Constructor & Destructor Documentation

◆ DQWorkerClient()

ecaldqm::DQWorkerClient::DQWorkerClient ( )

Definition at line 17 of file DQWorkerClient.cc.

18 : DQWorker(), sources_(), qualitySummaries_(), hasLumiPlots_(false), statusManager_(nullptr) {}

◆ ~DQWorkerClient()

ecaldqm::DQWorkerClient::~DQWorkerClient ( )

inlineoverride

Definition at line 18 of file DQWorkerClient.h.

18 {}

Member Function Documentation

◆ bookMEs()

void ecaldqm::DQWorkerClient::bookMEs ( DQMStore::IBooker & _ibooker )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 81 of file DQWorkerClient.cc.

                                                         {
     DQWorker::bookMEs(_ibooker);
     resetMEs();
   }

References ecaldqm::DQWorker::bookMEs(), and resetMEs().

◆ endLuminosityBlock()

void ecaldqm::DQWorkerClient::endLuminosityBlock	(	edm::LuminosityBlock const &	,
		edm::EventSetup const &
	)

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Reimplemented in ecaldqm::IntegrityClient, and ecaldqm::TowerStatusTask.

Definition at line 70 of file DQWorkerClient.cc.

                                                                                          {
 // MESetChannel class removed until concurrency issue is finalized
 #if 0
     for(MESetCollection::iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr){
       if(!sItr->second->getLumiFlag()) continue;
       MESetChannel const* channel(dynamic_cast<MESetChannel const*>(sItr->second));
       if(channel) channel->checkDirectory();
     }
 #endif
   }

References ecaldqm::MESetCollection::begin(), ecaldqm::MESetCollection::end(), and sources_.

◆ fillDescriptions()

void ecaldqm::DQWorkerClient::fillDescriptions ( edm::ParameterSetDescription & _desc )

static

Definition at line 21 of file DQWorkerClient.cc.

                                                                          {
     DQWorker::fillDescriptions(_desc);
     _desc.addWildcardUntracked<std::vector<std::string> >("*");
  
     edm::ParameterSetDescription sourceParameters;
     edm::ParameterSetDescription sourceNodeParameters;
     fillMESetDescriptions(sourceNodeParameters);
     sourceParameters.addNode(
         edm::ParameterWildcard<edm::ParameterSetDescription>("*", edm::RequireZeroOrMore, false, sourceNodeParameters));
     _desc.addUntracked("sources", sourceParameters);
   }

References edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addWildcardUntracked(), ecaldqm::DQWorker::fillDescriptions(), ecaldqm::fillMESetDescriptions(), and edm::RequireZeroOrMore.

Referenced by EcalDQMonitorClient::fillDescriptions().

◆ producePlots()

virtual void ecaldqm::DQWorkerClient::producePlots ( ProcessType )

pure virtual

Implemented in ecaldqm::TowerStatusTask, ecaldqm::IntegrityClient, ecaldqm::SummaryClient, ecaldqm::CalibrationSummaryClient, ecaldqm::CertificationClient, ecaldqm::OccupancyClient, ecaldqm::RawDataClient, ecaldqm::SelectiveReadoutClient, ecaldqm::TimingClient, ecaldqm::LaserClient, ecaldqm::LedClient, ecaldqm::PedestalClient, ecaldqm::PNIntegrityClient, ecaldqm::PresampleClient, ecaldqm::TestPulseClient, and ecaldqm::TrigPrimClient.

◆ releaseMEs()

void ecaldqm::DQWorkerClient::releaseMEs ( )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 86 of file DQWorkerClient.cc.

                                   {
     DQWorker::releaseMEs();
     releaseSource();
   }

References ecaldqm::DQWorker::releaseMEs(), and releaseSource().

◆ releaseSource()

void ecaldqm::DQWorkerClient::releaseSource ( )

Definition at line 91 of file DQWorkerClient.cc.

                                      {
     for (MESetCollection::iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr)
       sItr->second->clear();
   }

References ecaldqm::MESetCollection::begin(), ecaldqm::MESetCollection::end(), and sources_.

Referenced by releaseMEs().

◆ resetMEs()

void ecaldqm::DQWorkerClient::resetMEs ( )

virtual

Reimplemented in ecaldqm::SummaryClient.

Definition at line 113 of file DQWorkerClient.cc.

                                 {
     for (auto& mItr : MEs_) {
       MESet* meset(mItr.second.get());
  
       // Protects Trend-type Client MEs from being reset at the end of the LS
       // See: EcalDQMonitorClient::runWorkers
       if (meset->getBinType() == ecaldqm::binning::kTrend)
         continue;
  
       if (qualitySummaries_.find(mItr.first) != qualitySummaries_.end()) {
         MESetMulti* multi(dynamic_cast<MESetMulti*>(meset));
         if (multi) {
           for (unsigned iS(0); iS < multi->getMultiplicity(); ++iS) {
             multi->use(iS);
             if (multi->getKind() == MonitorElement::Kind::TH2F) {
               multi->resetAll(-1.);
               multi->reset(GetElectronicsMap(), kUnknown);
             } else
               multi->reset(GetElectronicsMap(), -1.);
           }
         } else {
           if (meset->getKind() == MonitorElement::Kind::TH2F) {
             meset->resetAll(-1.);
             meset->reset(GetElectronicsMap(), kUnknown);
           } else
             meset->reset(GetElectronicsMap(), -1.);
         }
       } else
         meset->reset(GetElectronicsMap());
     }
   }

References ecaldqm::DQWorker::GetElectronicsMap(), ecaldqm::binning::kTrend, kUnknown, ecaldqm::DQWorker::MEs_, trackerHitRTTI::multi, qualitySummaries_, and MonitorElementData::TH2F.

Referenced by bookMEs(), and ecaldqm::SummaryClient::resetMEs().

◆ resetPerLumi()

void ecaldqm::DQWorkerClient::resetPerLumi ( )

Definition at line 145 of file DQWorkerClient.cc.

                                     {
     for (auto const& meset : MEs_) {
       int i = 0;
       while (auto me = meset.second->getME(i)) {
         if (me->getLumiFlag()) {
           // reset per-lumi histograms in offline harvesting so that they only show
           // data of the current lumisection.
           me->Reset();
         }
         i++;
       }
     }
   }

References mps_fire::i, hlt_dqm_clientPB-live_cfg::me, and ecaldqm::DQWorker::MEs_.

◆ retrieveSource()

bool ecaldqm::DQWorkerClient::retrieveSource	(	DQMStore::IGetter &	_igetter,
		ProcessType	_type
	)

Definition at line 96 of file DQWorkerClient.cc.

                                                                                   {
     std::string failedPath;
     for (MESetCollection::iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr) {
       if (!onlineMode_ && _type == kLumi && !sItr->second->getLumiFlag())
         continue;
       if (verbosity_ > 1)
         edm::LogInfo("EcalDQM") << name_ << ": Retrieving source " << sItr->first;
       if (!sItr->second->retrieve(GetElectronicsMap(), _igetter, &failedPath)) {
         if (verbosity_ > 1)
           edm::LogWarning("EcalDQM") << name_ << ": Could not find source " << sItr->first << "@" << failedPath;
         return false;
       }
     }
  
     return true;
   }

References ecaldqm::MESetCollection::begin(), ecaldqm::MESetCollection::end(), ecaldqm::DQWorker::GetElectronicsMap(), kLumi, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, sources_, AlCaHLTBitMon_QueryRunRegistry::string, and ecaldqm::DQWorker::verbosity_.

◆ runsOn()

bool ecaldqm::DQWorkerClient::runsOn ( ProcessType _type ) const

inline

Definition at line 31 of file DQWorkerClient.h.

31 { return _type == kJob || hasLumiPlots_; }

References hasLumiPlots_, and kJob.

◆ setME()

void ecaldqm::DQWorkerClient::setME ( edm::ParameterSet const & _ps )

finalprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 33 of file DQWorkerClient.cc.

                                                        {
     DQWorker::setME(_ps);
  
     // Flags the Client ME to run as lumibased:
     // In offline mode will save the ME client at the end of the LS
     // See: EcalDQMonitorClient::dqmEndLuminosityBlock
     for (auto& mItr : MEs_) {
       if (mItr.second->getLumiFlag()) {
         hasLumiPlots_ = true;
         break;
       }
     }
   }

References hasLumiPlots_, ecaldqm::DQWorker::MEs_, and ecaldqm::DQWorker::setME().

◆ setSource()

void ecaldqm::DQWorkerClient::setSource ( edm::ParameterSet const & _params )

overrideprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 47 of file DQWorkerClient.cc.

                                                                {
     std::vector<std::string> const& sourceNames(_params.getParameterNames());
  
     for (unsigned iS(0); iS < sourceNames.size(); iS++) {
       std::string name(sourceNames[iS]);
       edm::ParameterSet const& params(_params.getUntrackedParameterSet(name));
  
       if (onlineMode_ && params.getUntrackedParameter<bool>("online"))
         continue;
  
       sources_.insert(name, createMESet(params));
     }
  
     if (verbosity_ > 1) {
       std::stringstream ss;
       ss << name_ << ": Using ";
       for (MESetCollection::const_iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr)
         ss << sItr->first << " ";
       ss << "as sources";
       edm::LogInfo("EcalDQM") << ss.str();
     }
   }

References l1extraParticles_cfi::_params, ecaldqm::MESetCollection::begin(), ecaldqm::createMESet(), ecaldqm::MESetCollection::end(), ecaldqm::MESetCollection::insert(), Skims_PA_cff::name, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, CalibrationSummaryClient_cfi::params, sources_, contentValuesCheck::ss, AlCaHLTBitMon_QueryRunRegistry::string, and ecaldqm::DQWorker::verbosity_.

◆ setStatusManager()

void ecaldqm::DQWorkerClient::setStatusManager ( StatusManager const & _manager )

inline

Definition at line 35 of file DQWorkerClient.h.

35 { statusManager_ = &_manager; }

References statusManager_.

◆ towerAverage_()

void ecaldqm::DQWorkerClient::towerAverage_	(	MESet &	_target,
		MESet const &	_source,
		float	_threshold
	)

protected

Definition at line 159 of file DQWorkerClient.cc.

                                                                                            {
     bool isQuality(_threshold > 0.);
  
     MESet::iterator tEnd(_target.end(GetElectronicsMap()));
     for (MESet::iterator tItr(_target.beginChannel(GetElectronicsMap())); tItr != tEnd;
          tItr.toNextChannel(GetElectronicsMap())) {
       DetId towerId(tItr->getId());
  
       std::vector<DetId> cryIds;
       if (towerId.subdetId() == EcalTriggerTower)
         cryIds = GetTrigTowerMap()->constituentsOf(EcalTrigTowerDetId(towerId));
       else {
         cryIds = scConstituents(EcalScDetId(towerId));
       }
  
       if (cryIds.empty())
         return;
  
       float mean(0.);
       float nValid(0.);
       bool masked(false);
       for (unsigned iId(0); iId < cryIds.size(); ++iId) {
         float content(_source.getBinContent(getEcalDQMSetupObjects(), cryIds[iId]));
         if (isQuality) {
           if (content < 0. || content == 2.)
             continue;
           if (content == 5.)
             masked = true;
           else {
             nValid += 1;
             if (content > 2.) {
               masked = true;
               mean += content - 3.;
             } else
               mean += content;
           }
         } else {
           mean += content;
           nValid += 1.;
         }
       }
  
       if (isQuality) {
         if (nValid < 1.)
           tItr->setBinContent(masked ? 5. : 2.);
         else {
           mean /= nValid;
           if (mean < _threshold)
             tItr->setBinContent(masked ? 3. : 0.);
           else
             tItr->setBinContent(masked ? 4. : 1.);
         }
       } else
         tItr->setBinContent(nValid < 1. ? 0. : mean / nValid);
     }
   }

References ecaldqm::MESet::beginChannel(), EcalTrigTowerConstituentsMap::constituentsOf(), Skims_PA_cff::content, EcalTriggerTower, ecaldqm::MESet::end(), ecaldqm::MESet::getBinContent(), ecaldqm::DQWorker::getEcalDQMSetupObjects(), ecaldqm::DQWorker::GetElectronicsMap(), ecaldqm::DQWorker::GetTrigTowerMap(), SiStripPI::mean, ecaldqm::scConstituents(), ecaldqm::MESet::iterator::toNextChannel(), and ecaldqm::towerId().

Referenced by ecaldqm::LaserClient::producePlots(), ecaldqm::TestPulseClient::producePlots(), ecaldqm::PresampleClient::producePlots(), ecaldqm::PedestalClient::producePlots(), and ecaldqm::LedClient::producePlots().

◆ using_()

bool ecaldqm::DQWorkerClient::using_	(	std::string const &	_name,
		ProcessType	_type = `kJob`
	)		const

inlineprotected

Definition at line 43 of file DQWorkerClient.h.

                                                                         {
       MESetCollection::const_iterator itr(sources_.find(_name));
       if (itr == sources_.end())
         return false;
       if (_type == kJob)
         return true;
       else
         return itr->second->getLumiFlag();
     }

References ecaldqm::MESetCollection::end(), ecaldqm::MESetCollection::find(), kJob, and sources_.

Referenced by ecaldqm::CalibrationSummaryClient::producePlots(), ecaldqm::SummaryClient::producePlots(), and ecaldqm::CalibrationSummaryClient::setParams().

Member Data Documentation

◆ hasLumiPlots_

bool ecaldqm::DQWorkerClient::hasLumiPlots_

protected

Definition at line 58 of file DQWorkerClient.h.

Referenced by runsOn(), and setME().

◆ qualitySummaries_

std::set<std::string> ecaldqm::DQWorkerClient::qualitySummaries_

protected

Definition at line 56 of file DQWorkerClient.h.

Referenced by ecaldqm::CertificationClient::CertificationClient(), ecaldqm::IntegrityClient::IntegrityClient(), ecaldqm::OccupancyClient::OccupancyClient(), ecaldqm::PNIntegrityClient::PNIntegrityClient(), ecaldqm::PresampleClient::PresampleClient(), ecaldqm::RawDataClient::RawDataClient(), resetMEs(), ecaldqm::TestPulseClient::setParams(), ecaldqm::PedestalClient::setParams(), ecaldqm::LaserClient::setParams(), ecaldqm::LedClient::setParams(), ecaldqm::CalibrationSummaryClient::setParams(), ecaldqm::SummaryClient::SummaryClient(), ecaldqm::TimingClient::TimingClient(), and ecaldqm::TrigPrimClient::TrigPrimClient().

◆ sources_

MESetCollection ecaldqm::DQWorkerClient::sources_

protected

Definition at line 55 of file DQWorkerClient.h.

◆ statusManager_

StatusManager const* ecaldqm::DQWorkerClient::statusManager_

protected

Definition at line 60 of file DQWorkerClient.h.

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ ProcessType

◆ Quality

Constructor & Destructor Documentation

◆ DQWorkerClient()

◆ ~DQWorkerClient()

Member Function Documentation

◆ bookMEs()

◆ endLuminosityBlock()

◆ fillDescriptions()

◆ producePlots()

◆ releaseMEs()

◆ releaseSource()

◆ resetMEs()

◆ resetPerLumi()

◆ retrieveSource()

◆ runsOn()

◆ setME()

◆ setSource()

◆ setStatusManager()

◆ towerAverage_()

◆ using_()

Member Data Documentation

◆ hasLumiPlots_

◆ qualitySummaries_

◆ sources_

◆ statusManager_