#include <DQWorkerClient.h>

Inheritance diagram for ecaldqm::DQWorkerClient:

Public Types
enum	ProcessType { kLumi, kRun, nProcessType }

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

Public Member Functions
void	bookMEs (DQMStore &) override

	DQWorkerClient ()

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

virtual void	producePlots (ProcessType)=0

void	releaseMEs () override

void	releaseSource ()

void	resetMEs ()

bool	retrieveSource (DQMStore const &, ProcessType)

void	setStatusManager (StatusManager const &_manager)

virtual	~DQWorkerClient ()

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 &)

virtual void	bookMEs (DQMStore::IBooker &)

	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 ()

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=kRun) 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
std::set< std::string >	qualitySummaries_

MESetCollection	sources_

StatusManager const *	statusManager_

Protected Attributes inherited from ecaldqm::DQWorker
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
kRun
nProcessType

Definition at line 16 of file DQWorkerClient.h.

                      {
       kLumi,
       kRun,
       nProcessType
     };

enum ecaldqm::DQWorkerClient::Quality

Enumerator
kBad
kGood
kUnknown
kMBad
kMGood
kMUnknown

Definition at line 40 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_(),
     statusManager_(0)
   {
   }

virtual ecaldqm::DQWorkerClient::~DQWorkerClient ( )

inlinevirtual

Definition at line 23 of file DQWorkerClient.h.

23 {}

Member Function Documentation

void ecaldqm::DQWorkerClient::bookMEs ( DQMStore & _store )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 78 of file DQWorkerClient.cc.

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

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

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

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 65 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::runWorkers().

void ecaldqm::DQWorkerClient::releaseMEs ( )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 85 of file DQWorkerClient.cc.

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

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

void ecaldqm::DQWorkerClient::releaseSource ( )

Definition at line 92 of file DQWorkerClient.cc.

References sources_.

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

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

void ecaldqm::DQWorkerClient::resetMEs ( )

Definition at line 119 of file DQWorkerClient.cc.

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

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

   {
     for(MESetCollection::iterator mItr(MEs_.begin()); mItr != MEs_.end(); ++mItr){
       MESet* meset(mItr->second);
 
       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();
     }
   }    

bool ecaldqm::DQWorkerClient::retrieveSource	(	DQMStore const &	_store,
		ProcessType	_type
	)

Definition at line 99 of file DQWorkerClient.cc.

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

Referenced by EcalDQMonitorClient::runWorkers().

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

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

inlinefinalprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 50 of file DQWorkerClient.h.

References ecaldqm::DQWorker::setME().

50 { DQWorker::setME(_ps); }

ecaldqm::DQWorker::setME

virtual void setME(edm::ParameterSet const &)

Definition: DQWorker.cc:55

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

overrideprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 41 of file DQWorkerClient.cc.

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

References statusManager_.

Referenced by EcalDQMonitorClient::EcalDQMonitorClient().

38 { statusManager_ = &_manager; }

ecaldqm::DQWorkerClient::statusManager_

StatusManager const * statusManager_

Definition: DQWorkerClient.h:66

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

protected

Definition at line 152 of file DQWorkerClient.cc.

References ecaldqm::MESet::beginChannel(), EcalTrigTowerConstituentsMap::constituentsOf(), ws_sso_content_reader::content, EcalTriggerTower, ecaldqm::MESet::end(), ecaldqm::MESet::getBinContent(), ecaldqm::getTrigTowerMap(), timingPdfMaker::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());
     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.size() == 0) 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 = `kRun`
	)		const

inlineprotected

Definition at line 53 of file DQWorkerClient.h.

References kRun, 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 == kRun) return true;
       else return itr->second->getLumiFlag();
     }

Member Data Documentation

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

protected

Definition at line 64 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 63 of file DQWorkerClient.h.

StatusManager const* ecaldqm::DQWorkerClient::statusManager_

protected

Definition at line 66 of file DQWorkerClient.h.

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

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation