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)
	~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 &)
std::string const &	getName () const
bool	onlineMode () const
void	setEventNumber (edm::EventNumber_t _e)
void	setLumiNumber (edm::LuminosityBlockNumber_t _l)
void	setRunNumber (edm::RunNumber_t _r)
void	setTime (time_t _t)
virtual	~DQWorker ()(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_

Detailed Description

Definition at line 14 of file DQWorkerClient.h.

Member Enumeration Documentation

enum ecaldqm::DQWorkerClient::ProcessType

Enumerator
kLumi
kJob
nProcessType

Definition at line 16 of file DQWorkerClient.h.

                     {
      kLumi,
      kJob,
      nProcessType
    };

enum ecaldqm::DQWorkerClient::Quality

Enumerator
kBad
kGood
kUnknown
kMBad
kMGood
kMUnknown

Definition at line 42 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 18 of file DQWorkerClient.cc.

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

ecaldqm::DQWorkerClient::~DQWorkerClient ( )

inlineoverride

Definition at line 23 of file DQWorkerClient.h.

References bookMEs(), endLuminosityBlock(), fillDescriptions(), releaseMEs(), releaseSource(), resetPerLumi(), and retrieveSource().

{}

Member Function Documentation

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

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 98 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock(), and ~DQWorkerClient().

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

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 85 of file DQWorkerClient.cc.

References sources_.

Referenced by ~DQWorkerClient().

  {
// 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 29 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::fillDescriptions(), and ~DQWorkerClient().

  {
    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::IntegrityClient, ecaldqm::TowerStatusTask, ecaldqm::SummaryClient, ecaldqm::CalibrationSummaryClient, ecaldqm::CertificationClient, ecaldqm::LaserClient, ecaldqm::LedClient, ecaldqm::OccupancyClient, ecaldqm::PedestalClient, ecaldqm::PNIntegrityClient, ecaldqm::PresampleClient, ecaldqm::RawDataClient, ecaldqm::SelectiveReadoutClient, ecaldqm::TestPulseClient, ecaldqm::TimingClient, and ecaldqm::TrigPrimClient.

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

void ecaldqm::DQWorkerClient::releaseMEs ( )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 105 of file DQWorkerClient.cc.

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

Referenced by ~DQWorkerClient().

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

void ecaldqm::DQWorkerClient::releaseSource

(

)

Definition at line 112 of file DQWorkerClient.cc.

References sources_.

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

  {
    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 135 of file DQWorkerClient.cc.

References MonitorElement::DQM_KIND_TH2F, ecaldqm::MESet::getBinType(), ecaldqm::MESet::getKind(), ecaldqm::MESetMulti::getMultiplicity(), ecaldqm::binning::kTrend, kUnknown, ecaldqm::DQWorker::MEs_, trackerHitRTTI::multi, qualitySummaries_, ecaldqm::MESet::reset(), ecaldqm::MESetMulti::reset(), ecaldqm::MESet::resetAll(), ecaldqm::MESetMulti::resetAll(), and ecaldqm::MESetMulti::use().

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

  {
    for(MESetCollection::iterator mItr(MEs_.begin()); mItr != MEs_.end(); ++mItr){
      MESet* meset(mItr->second);

      // 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::DQM_KIND_TH2F){
              multi->resetAll(-1.);
              multi->reset(kUnknown);
            }
            else
              multi->reset(-1.);
          }
        }
        else{
          if(meset->getKind() == MonitorElement::DQM_KIND_TH2F){
            meset->resetAll(-1.);
            meset->reset(kUnknown);
          }
          else
            meset->reset(-1.);
        }
      }
      else
        meset->reset();
    }
  }    

void ecaldqm::DQWorkerClient::resetPerLumi

(

)

Definition at line 173 of file DQWorkerClient.cc.

References gather_cfg::cout, mps_fire::i, and ecaldqm::DQWorker::MEs_.

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock(), and ~DQWorkerClient().

  {
    for (auto const& meset : MEs_) {
      int i = 0;
      while (auto me = meset.second->getME(i)) {
        if (me->getLumiFlag()) {
          std::cout << "+++ reset " << me->getFullname() << "\n";
          // 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 119 of file DQWorkerClient.cc.

References kLumi, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, sources_, AlCaHLTBitMon_QueryRunRegistry::string, and ecaldqm::DQWorker::verbosity_.

Referenced by EcalDQMonitorClient::runWorkers(), and ~DQWorkerClient().

  {
    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(_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 36 of file DQWorkerClient.h.

References hasLumiPlots_, kJob, producePlots(), and resetMEs().

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 43 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(MESetCollection::iterator mItr(MEs_.begin()); mItr != MEs_.end(); ++mItr){
      if(mItr->second->getLumiFlag()){
        hasLumiPlots_ = true;
        break;
      }
    }

  }

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

overrideprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 61 of file DQWorkerClient.cc.

References ecaldqm::createMESet(), edm::ParameterSet::getParameterNames(), edm::ParameterSet::getUntrackedParameterSet(), dataset::name, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, sources_, 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 40 of file DQWorkerClient.h.

References statusManager_.

Referenced by EcalDQMonitorClient::EcalDQMonitorClient().

{ statusManager_ = &_manager; }

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

protected

Definition at line 190 of file DQWorkerClient.cc.

References ecaldqm::MESet::beginChannel(), EcalTrigTowerConstituentsMap::constituentsOf(), ws_sso_content_reader::content, EcalTriggerTower, ecaldqm::MESet::end(), ecaldqm::MESet::getBinContent(), ecaldqm::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(), ecaldqm::LedClient::producePlots(), and using_().

  {
    bool isQuality(_threshold > 0.);

    MESet::iterator tEnd(_target.end());
    for(MESet::iterator tItr(_target.beginChannel()); tItr != tEnd; tItr.toNextChannel()){
      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(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 55 of file DQWorkerClient.h.

References kJob, sources_, and towerAverage_().

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 68 of file DQWorkerClient.h.

Referenced by runsOn(), and setME().

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

protected

Definition at line 66 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::CalibrationSummaryClient::setParams(), ecaldqm::TestPulseClient::setParams(), ecaldqm::PedestalClient::setParams(), ecaldqm::LaserClient::setParams(), ecaldqm::LedClient::setParams(), ecaldqm::SummaryClient::SummaryClient(), ecaldqm::TimingClient::TimingClient(), and ecaldqm::TrigPrimClient::TrigPrimClient().

MESetCollection ecaldqm::DQWorkerClient::sources_

protected

Definition at line 65 of file DQWorkerClient.h.

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

StatusManager const* ecaldqm::DQWorkerClient::statusManager_

protected

Definition at line 70 of file DQWorkerClient.h.

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