ecaldqm::DQWorkerClient Class Reference

#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)
virtual void	setTokens (edm::ConsumesCollector &)
	~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 &)
EcalDQMSetupObjects const	getEcalDQMSetupObjects ()
EcalElectronicsMapping const *	GetElectronicsMap ()
CaloGeometry const *	GetGeometry ()
std::string const &	getName () const
CaloTopology const *	GetTopology ()
EcalTrigTowerConstituentsMap const *	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	setSetupObjectsEndLumi (edm::EventSetup const &)
void	setTime (time_t _t)
void	setTokens (edm::ConsumesCollector &)
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
Public Attributes inherited from ecaldqm::DQWorker
edm::ESGetToken < EcalElectronicsMapping, EcalMappingRcd >	elecMapHandle
edm::ESGetToken < EcalElectronicsMapping, EcalMappingRcd >	elecMapHandleEndLumi
edm::ESGetToken< CaloGeometry, CaloGeometryRecord >	geomHandle
edm::ESGetToken< CaloGeometry, CaloGeometryRecord >	geomHandleEndLumi
edm::ESGetToken< CaloTopology, CaloTopologyRecord >	topoHandle
edm::ESGetToken< CaloTopology, CaloTopologyRecord >	topoHandleEndLumi
edm::ESGetToken < EcalTrigTowerConstituentsMap, IdealGeometryRecord >	ttMapHandle
edm::ESGetToken < EcalTrigTowerConstituentsMap, IdealGeometryRecord >	ttMapHandleEndLumi
Protected Types inherited from ecaldqm::DQWorker
typedef dqm::legacy::DQMStore	DQMStore
typedef dqm::legacy::MonitorElement	MonitorElement

Detailed Description

Definition at line 17 of file DQWorkerClient.h.

Member Enumeration Documentation

enum ecaldqm::DQWorkerClient::ProcessType

Enumerator
kLumi
kJob
nProcessType

Definition at line 19 of file DQWorkerClient.h.

{ kLumi, kJob, nProcessType };

enum ecaldqm::DQWorkerClient::Quality

Enumerator
kBad
kGood
kUnknown
kMBad
kMGood
kMUnknown

Definition at line 44 of file DQWorkerClient.h.

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

Constructor & Destructor Documentation

ecaldqm::DQWorkerClient::DQWorkerClient

(

)

Definition at line 17 of file DQWorkerClient.cc.

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

ecaldqm::DQWorkerClient::~DQWorkerClient ( )

inlineoverride

Definition at line 22 of file DQWorkerClient.h.

{}

Member Function Documentation

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

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 81 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock().

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

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

overridevirtual

Reimplemented from ecaldqm::DQWorker.

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

Definition at line 70 of file DQWorkerClient.cc.

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

                                                                                         {
// 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
  }

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

static

Definition at line 21 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::fillDescriptions().

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

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

pure virtual

Implemented in ecaldqm::TowerStatusTask, ecaldqm::IntegrityClient, ecaldqm::MLClient, 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.

Referenced by EcalDQMonitorClient::runWorkers().

void ecaldqm::DQWorkerClient::releaseMEs ( )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 86 of file DQWorkerClient.cc.

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

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

void ecaldqm::DQWorkerClient::releaseSource

(

)

Definition at line 91 of file DQWorkerClient.cc.

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

Referenced by releaseMEs(), and EcalDQMonitorClient::runWorkers().

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

void ecaldqm::DQWorkerClient::resetMEs ( )

virtual

Reimplemented in ecaldqm::SummaryClient.

Definition at line 113 of file DQWorkerClient.cc.

References ecaldqm::DQWorker::GetElectronicsMap(), ecaldqm::MESet::getKind(), ecaldqm::MESetMulti::getMultiplicity(), ecaldqm::binning::kTrend, kUnknown, ecaldqm::DQWorker::MEs_, trackerHitRTTI::multi, qualitySummaries_, ecaldqm::MESetMulti::reset(), ecaldqm::MESetMulti::resetAll(), MonitorElementData::TH2F, and ecaldqm::MESetMulti::use().

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

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

void ecaldqm::DQWorkerClient::resetPerLumi

(

)

Definition at line 145 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock().

                                    {
    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++;
      }
    }
  }

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

Definition at line 96 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::runWorkers().

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

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

inline

Definition at line 35 of file DQWorkerClient.h.

References hasLumiPlots_, and kJob.

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock(), and EcalDQMonitorClient::runWorkers().

{ return _type == kJob || hasLumiPlots_; }

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

finalprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 33 of file DQWorkerClient.cc.

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

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

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

overrideprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 47 of file DQWorkerClient.cc.

References ecaldqm::MESetCollection::begin(), ecaldqm::createMESet(), ecaldqm::MESetCollection::end(), edm::ParameterSet::getParameterNames(), edm::ParameterSet::getUntrackedParameterSet(), ecaldqm::MESetCollection::insert(), mergeVDriftHistosByStation::name, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, submitPVValidationJobs::params, sources_, contentValuesCheck::ss, AlCaHLTBitMon_QueryRunRegistry::string, and ecaldqm::DQWorker::verbosity_.

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

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

inline

Definition at line 42 of file DQWorkerClient.h.

References statusManager_.

Referenced by EcalDQMonitorClient::EcalDQMonitorClient().

{ statusManager_ = &_manager; }

virtual void ecaldqm::DQWorkerClient::setTokens ( edm::ConsumesCollector &  )

inlinevirtual

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

Definition at line 40 of file DQWorkerClient.h.

Referenced by EcalDQMonitorClient::EcalDQMonitorClient().

{}

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

protected

Definition at line 159 of file DQWorkerClient.cc.

References ecaldqm::MESet::beginChannel(), EcalTrigTowerConstituentsMap::constituentsOf(), ws_sso_content_reader::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().

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

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

inlineprotected

Definition at line 50 of file DQWorkerClient.h.

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

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

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

Member Data Documentation

bool ecaldqm::DQWorkerClient::hasLumiPlots_

protected

Definition at line 65 of file DQWorkerClient.h.

Referenced by runsOn(), and setME().

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

protected

Definition at line 63 of file DQWorkerClient.h.

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

MESetCollection ecaldqm::DQWorkerClient::sources_

protected

Definition at line 62 of file DQWorkerClient.h.

Referenced by endLuminosityBlock(), ecaldqm::LaserClient::producePlots(), ecaldqm::PedestalClient::producePlots(), ecaldqm::PNIntegrityClient::producePlots(), ecaldqm::PresampleClient::producePlots(), ecaldqm::LedClient::producePlots(), ecaldqm::TestPulseClient::producePlots(), ecaldqm::TrigPrimClient::producePlots(), ecaldqm::OccupancyClient::producePlots(), ecaldqm::TimingClient::producePlots(), ecaldqm::CertificationClient::producePlots(), ecaldqm::RawDataClient::producePlots(), ecaldqm::SelectiveReadoutClient::producePlots(), ecaldqm::CalibrationSummaryClient::producePlots(), ecaldqm::SummaryClient::producePlots(), ecaldqm::IntegrityClient::producePlots(), ecaldqm::MLClient::producePlots(), releaseSource(), retrieveSource(), ecaldqm::LedClient::setParams(), ecaldqm::TrigPrimClient::setParams(), ecaldqm::LaserClient::setParams(), ecaldqm::TestPulseClient::setParams(), ecaldqm::PedestalClient::setParams(), ecaldqm::CalibrationSummaryClient::setParams(), ecaldqm::SummaryClient::setParams(), ecaldqm::MLClient::setParams(), setSource(), and using_().

StatusManager const* ecaldqm::DQWorkerClient::statusManager_

protected

Definition at line 67 of file DQWorkerClient.h.

Referenced by ecaldqm::LaserClient::producePlots(), ecaldqm::LedClient::producePlots(), ecaldqm::PNIntegrityClient::producePlots(), ecaldqm::PresampleClient::producePlots(), ecaldqm::PedestalClient::producePlots(), ecaldqm::TestPulseClient::producePlots(), ecaldqm::TrigPrimClient::producePlots(), ecaldqm::TimingClient::producePlots(), ecaldqm::OccupancyClient::producePlots(), ecaldqm::RawDataClient::producePlots(), ecaldqm::SummaryClient::producePlots(), ecaldqm::IntegrityClient::producePlots(), ecaldqm::MLClient::producePlots(), and setStatusManager().