#include <LaserClient.h>

Inheritance diagram for ecaldqm::LaserClient:

Public Member Functions
	LaserClient ()

void	producePlots (ProcessType) override

	~LaserClient ()

Public Member Functions inherited from ecaldqm::DQWorkerClient
void	bookMEs (DQMStore::IBooker &) override

	DQWorkerClient ()

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

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)

Private Member Functions
void	setParams (edm::ParameterSet const &) override

Private Attributes
std::vector< float >	expectedAmplitude_

std::vector< float >	expectedPNAmplitude_

std::vector< float >	expectedTiming_

float	forwardFactor_

int	minChannelEntries_

float	toleranceAmplitudeHi_

float	toleranceAmplitudeLo_

float	toleranceAmpRMSRatio_

float	tolerancePNAmp_

float	tolerancePNRMSRatio_

float	toleranceTiming_

float	toleranceTimRMS_

std::map< int, unsigned >	wlToME_

Additional Inherited Members
Public Types inherited from ecaldqm::DQWorkerClient
enum	ProcessType { kLumi, kJob, nProcessType }

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

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

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

Protected Member Functions inherited from ecaldqm::DQWorkerClient
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

void	setVerbosity (int _verbosity)

Protected Attributes inherited from ecaldqm::DQWorkerClient
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 8 of file LaserClient.h.

Constructor & Destructor Documentation

ecaldqm::LaserClient::LaserClient ( )

Definition at line 16 of file LaserClient.cc.

                            :
     DQWorkerClient(),
     wlToME_(),
     minChannelEntries_(0),
     expectedAmplitude_(0),
     toleranceAmplitudeLo_(0.),
     toleranceAmplitudeHi_(0.),
     toleranceAmpRMSRatio_(0.),
     expectedTiming_(0),
     toleranceTiming_(0.),
     toleranceTimRMS_(0.),
     expectedPNAmplitude_(0),
     tolerancePNAmp_(0.),
     tolerancePNRMSRatio_(0.),
     forwardFactor_(0.)
   {
   }

ecaldqm::LaserClient::~LaserClient ( )

inline

Definition at line 11 of file LaserClient.h.

References producePlots(), and setParams().

11 {}

Member Function Documentation

void ecaldqm::LaserClient::producePlots ( ProcessType )

overridevirtual

Implements ecaldqm::DQWorkerClient.

Definition at line 86 of file LaserClient.cc.

Referenced by ~LaserClient().

   {
     uint32_t mask(1 << EcalDQMStatusHelper::LASER_MEAN_ERROR |
                   1 << EcalDQMStatusHelper::LASER_RMS_ERROR |
                   1 << EcalDQMStatusHelper::LASER_TIMING_MEAN_ERROR |
                   1 << EcalDQMStatusHelper::LASER_TIMING_RMS_ERROR);
 
     MESetMulti& meQuality(static_cast<MESetMulti&>(MEs_.at("Quality")));
     MESetMulti& meQualitySummary(static_cast<MESetMulti&>(MEs_.at("QualitySummary")));
     MESetMulti& meAmplitudeMean(static_cast<MESetMulti&>(MEs_.at("AmplitudeMean")));
     MESetMulti& meAmplitudeRMS(static_cast<MESetMulti&>(MEs_.at("AmplitudeRMS")));
     MESetMulti& meTimingMean(static_cast<MESetMulti&>(MEs_.at("TimingMean")));
     MESetMulti& meTimingRMSMap(static_cast<MESetMulti&>(MEs_.at("TimingRMSMap")));
     MESetMulti& meTimingRMS(static_cast<MESetMulti&>(MEs_.at("TimingRMS")));
     MESetMulti& mePNQualitySummary(static_cast<MESetMulti&>(MEs_.at("PNQualitySummary")));
 
     MESetMulti const& sAmplitude(static_cast<MESetMulti const&>(sources_.at("Amplitude")));
     MESetMulti const& sTiming(static_cast<MESetMulti const&>(sources_.at("Timing")));
     MESetMulti const& sPNAmplitude(static_cast<MESetMulti const&>(sources_.at("PNAmplitude")));
     MESet const& sCalibStatus(static_cast<MESet const&>(sources_.at("CalibStatus")));
 
     for(std::map<int, unsigned>::iterator wlItr(wlToME_.begin()); wlItr != wlToME_.end(); ++wlItr){
       meQuality.use(wlItr->second);
       meQualitySummary.use(wlItr->second);
       meAmplitudeMean.use(wlItr->second);
       meAmplitudeRMS.use(wlItr->second);
       meTimingMean.use(wlItr->second);
       meTimingRMSMap.use(wlItr->second);
       meTimingRMS.use(wlItr->second);
       mePNQualitySummary.use(wlItr->second);
 
       sAmplitude.use(wlItr->second);
       sTiming.use(wlItr->second);
       sPNAmplitude.use(wlItr->second);
 
       MESet::iterator qEnd(meQuality.end());
 
       MESet::const_iterator tItr(sTiming);
       MESet::const_iterator aItr(sAmplitude);
  
       int wl(wlItr->first-1);
       bool enabled(wl < 0? false: sCalibStatus.getBinContent(wl) > 0 ? true: false);
       for(MESet::iterator qItr(meQuality.beginChannel()); qItr != qEnd; qItr.toNextChannel()){
 
         DetId id(qItr->getId());
 
         bool doMask(meQuality.maskMatches(id, mask, statusManager_));
 
         aItr = qItr;
 
         float aEntries(aItr->getBinEntries());
 
         if(aEntries < minChannelEntries_){
           qItr->setBinContent(enabled ? (doMask ? kMUnknown : kUnknown) : kMUnknown);
           continue;
         }
 
         float aMean(aItr->getBinContent());
         float aRms(aItr->getBinError() * sqrt(aEntries));
 
         meAmplitudeMean.fill(id, aMean);
         meAmplitudeRMS.setBinContent(id, aRms);
 
         tItr = qItr;
 
         float tEntries(tItr->getBinEntries());
 
         if(tEntries < minChannelEntries_) continue;
 
         float tMean(tItr->getBinContent());
         float tRms(tItr->getBinError() * sqrt(tEntries));
 
         meTimingMean.fill(id, tMean);
         meTimingRMS.fill(id, tRms);
         meTimingRMSMap.setBinContent(id, tRms);
 
         float intensity(aMean / expectedAmplitude_[wlItr->second]);
         if(isForward(id)) intensity /= forwardFactor_;
 
         if(intensity < toleranceAmplitudeLo_
             || intensity > toleranceAmplitudeHi_
             || aRms > aMean * toleranceAmpRMSRatio_
             || std::abs(tMean - expectedTiming_[wlItr->second]) > toleranceTiming_ /*|| tRms > toleranceTimRMS_*/)
           qItr->setBinContent(doMask ? kMBad : kBad);
         else
           qItr->setBinContent(doMask ? kMGood : kGood);
       }
 
       towerAverage_(meQualitySummary, meQuality, 0.2);
 
       for(unsigned iDCC(0); iDCC < nDCC; ++iDCC){
 
         if(memDCCIndex(iDCC + 1) == unsigned(-1)) continue;
         int subdet(0);
         if(iDCC >= kEBmLow && iDCC <= kEBpHigh) subdet = EcalBarrel;
         else subdet = EcalEndcap;
 
         for(unsigned iPN(0); iPN < 10; ++iPN){
           EcalPnDiodeDetId id(subdet, iDCC + 1, iPN + 1);
 
           bool doMask(mePNQualitySummary.maskMatches(id, mask, statusManager_));
 
           float pEntries(sPNAmplitude.getBinEntries(id));
 
           if(pEntries < minChannelEntries_){
             mePNQualitySummary.setBinContent(id, doMask ? kMUnknown : kUnknown);
             continue;
           }
 
           float pMean(sPNAmplitude.getBinContent(id));
           float pRms(sPNAmplitude.getBinError(id) * sqrt(pEntries));
           float intensity(pMean / expectedPNAmplitude_[wlItr->second]);
 
           if(intensity < tolerancePNAmp_ || pRms > pMean * tolerancePNRMSRatio_)
             mePNQualitySummary.setBinContent(id, doMask ? kMBad : kBad);
           else
             mePNQualitySummary.setBinContent(id, doMask ? kMGood : kGood);
         }
       }
     }
   }

void ecaldqm::LaserClient::setParams ( edm::ParameterSet const & _params )

overrideprivatevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 35 of file LaserClient.cc.

References CustomPhysics_cfi::amplitude, Exception, expectedAmplitude_, expectedPNAmplitude_, expectedTiming_, forwardFactor_, ecaldqm::MESetMulti::getIndex(), edm::ParameterSet::getUntrackedParameter(), minChannelEntries_, ecaldqm::DQWorkerClient::qualitySummaries_, ecaldqm::DQWorkerClient::sources_, toleranceAmplitudeHi_, toleranceAmplitudeLo_, toleranceAmpRMSRatio_, tolerancePNAmp_, tolerancePNRMSRatio_, toleranceTiming_, toleranceTimRMS_, and wlToME_.

Referenced by ~LaserClient().

   {
     minChannelEntries_ = _params.getUntrackedParameter<int>("minChannelEntries");
     toleranceAmplitudeLo_ = _params.getUntrackedParameter<double>("toleranceAmplitudeLo");
     toleranceAmplitudeHi_ = _params.getUntrackedParameter<double>("toleranceAmplitudeHi");
     toleranceAmpRMSRatio_ = _params.getUntrackedParameter<double>("toleranceAmpRMSRatio");
     toleranceTiming_ = _params.getUntrackedParameter<double>("toleranceTiming");
     toleranceTimRMS_ = _params.getUntrackedParameter<double>("toleranceTimRMS");
     tolerancePNAmp_ = _params.getUntrackedParameter<double>("tolerancePNAmp");
     tolerancePNRMSRatio_ = _params.getUntrackedParameter<double>("tolerancePNRMSRatio");
     forwardFactor_ = _params.getUntrackedParameter<double>("forwardFactor");
 
     std::vector<int> laserWavelengths(_params.getUntrackedParameter<std::vector<int> >("laserWavelengths"));
 
     // wavelengths are not necessarily ordered
     // create a map wl -> MESet index
     // using Amplitude here but any multi-wavelength plot is fine
 
     MESet::PathReplacements repl;
 
     MESetMulti const& amplitude(static_cast<MESetMulti const&>(sources_.at("Amplitude")));
     unsigned nWL(laserWavelengths.size());
     for(unsigned iWL(0); iWL != nWL; ++iWL){
       int wl(laserWavelengths[iWL]);
       if(wl <= 0 || wl >= 5) throw cms::Exception("InvalidConfiguration") << "Laser Wavelength";
       repl["wl"] = std::to_string(wl);
       wlToME_[wl] = amplitude.getIndex(repl);
     }
 
     expectedAmplitude_.resize(nWL);
     expectedTiming_.resize(nWL);
     expectedPNAmplitude_.resize(nWL);
 
     std::vector<double> inExpectedAmplitude(_params.getUntrackedParameter<std::vector<double> >("expectedAmplitude"));
     std::vector<double> inExpectedTiming(_params.getUntrackedParameter<std::vector<double> >("expectedTiming"));
     std::vector<double> inExpectedPNAmplitude(_params.getUntrackedParameter<std::vector<double> >("expectedPNAmplitude"));
 
     for(std::map<int, unsigned>::iterator wlItr(wlToME_.begin()); wlItr != wlToME_.end(); ++wlItr){
       unsigned iME(wlItr->second);
       int iWL(wlItr->first - 1);
       expectedAmplitude_[iME] = inExpectedAmplitude[iWL];
       expectedTiming_[iME] = inExpectedTiming[iWL];
       expectedPNAmplitude_[iME] = inExpectedPNAmplitude[iWL];
     }
 
     qualitySummaries_.insert("Quality");
     qualitySummaries_.insert("QualitySummary");
     qualitySummaries_.insert("PNQualitySummary");
   }