#include <RPCDqmClient.h>

Inheritance diagram for RPCDqmClient:

Public Member Functions
	RPCDqmClient (const edm::ParameterSet &ps)
	Constructor. More...

virtual	~RPCDqmClient ()
	Destructor. More...

Public Member Functions inherited from DQMEDHarvester
virtual void	analyze (edm::Event const &, edm::EventSetup const &) final

virtual void	beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final

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

	DQMEDHarvester (void)

virtual void	endJob () final

virtual void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) final

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

Public Member Functions inherited from edm::one::EDAnalyzer< edm::one::WatchRuns, edm::one::WatchLuminosityBlocks, edm::one::SharedResources >
	EDAnalyzer ()=default

Public Member Functions inherited from edm::one::EDAnalyzerBase
	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

virtual	~EDAnalyzerBase ()

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

	EDConsumerBase ()

ProductHolderIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

Protected Member Functions
void	beginJob ()

void	dqmEndJob (DQMStore::IBooker &, DQMStore::IGetter &) override

void	dqmEndLuminosityBlock (DQMStore::IBooker &, DQMStore::IGetter &, edm::LuminosityBlock const &, edm::EventSetup const &)

void	getMonitorElements (DQMStore::IGetter &, const edm::EventSetup &)

void	makeClientMap (const edm::ParameterSet &parameters_)

Protected Member Functions inherited from edm::one::EDAnalyzerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

Private Attributes
std::vector< std::string >	clientHisto_

std::vector< std::string >	clientList_

std::vector< RPCClient * >	clientModules_

std::vector< std::string >	clientNames_

std::vector< int >	clientTag_

bool	enableDQMClients_

std::string	globalFolder_

bool	init_

int	lumiCounter_

int	minimumEvents_

int	numLumBlock_

bool	offlineDQM_

std::string	prefixDir_

int	prescaleGlobalFactor_

MonitorElement *	RPCEvents_

bool	useRollInfo_

Additional Inherited Members
Public Types inherited from edm::one::EDAnalyzerBase
typedef EDAnalyzerBase	ModuleType

Static Public Member Functions inherited from edm::one::EDAnalyzerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Detailed Description

Definition at line 13 of file RPCDqmClient.h.

Constructor & Destructor Documentation

RPCDqmClient::RPCDqmClient ( const edm::ParameterSet & ps )

Constructor.

Definition at line 22 of file RPCDqmClient.cc.

References clientList_, enableDQMClients_, edm::ParameterSet::getUntrackedParameter(), globalFolder_, init_, lumiCounter_, makeClientMap(), minimumEvents_, offlineDQM_, prefixDir_, prescaleGlobalFactor_, AlCaHLTBitMon_QueryRunRegistry::string, and useRollInfo_.

                                                             {
 
   edm::LogVerbatim ("rpcdqmclient") << "[RPCDqmClient]: Constructor";
 
   //  parameters_ = iConfig;
 
   offlineDQM_ = parameters_.getUntrackedParameter<bool> ("OfflineDQM",true); 
   useRollInfo_=  parameters_.getUntrackedParameter<bool>("UseRollInfo", false);
   //check enabling
   enableDQMClients_ = parameters_.getUntrackedParameter<bool> ("EnableRPCDqmClient",true); 
   minimumEvents_= parameters_.getUntrackedParameter<int>("MinimumRPCEvents", 10000);
 
   std::string subsystemFolder = parameters_.getUntrackedParameter<std::string>("RPCFolder", "RPC");
   std::string recHitTypeFolder= parameters_.getUntrackedParameter<std::string>("RecHitTypeFolder", "AllHits");
   std::string summaryFolder = parameters_.getUntrackedParameter<std::string>("SummaryFolder", "SummaryHistograms");
   
   prefixDir_ =   subsystemFolder+ "/"+ recHitTypeFolder;
   globalFolder_ = subsystemFolder + "/"+ recHitTypeFolder + "/"+ summaryFolder;
 
   //get prescale factor
   prescaleGlobalFactor_ = parameters_.getUntrackedParameter<int>("DiagnosticGlobalPrescale", 5);
 
 
   //make default client list  
   clientList_.push_back("RPCMultiplicityTest");
   clientList_.push_back("RPCDeadChannelTest");
   clientList_.push_back("RPCClusterSizeTest");
   clientList_= parameters_.getUntrackedParameter<std::vector<std::string> >("RPCDqmClientList",clientList_);
 
 
   //get all the possible RPC DQM clients 
   this->makeClientMap(parameters_);
 
   lumiCounter_ = prescaleGlobalFactor_;
   init_ = false;
 
 }

RPCDqmClient::~RPCDqmClient ( )

virtual

Destructor.

Definition at line 60 of file RPCDqmClient.cc.

60 {}

Member Function Documentation

void RPCDqmClient::beginJob ( void )

protectedvirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 62 of file RPCDqmClient.cc.

References clientModules_, enableDQMClients_, and globalFolder_.

                            {
 
   if (!enableDQMClients_) {return;}                 ;
   edm::LogVerbatim ("rpcdqmclient") << "[RPCDqmClient]: Begin Job";
 
     //Do whatever the begin jobs of all client modules do
   for(std::vector<RPCClient*>::iterator it = clientModules_.begin(); it!=clientModules_.end(); it++ ){
     (*it)->beginJob( globalFolder_ );
   }
 }

void RPCDqmClient::dqmEndJob	(	DQMStore::IBooker &	ibooker,
		DQMStore::IGetter &	igetter
	)

overrideprotectedvirtual

Implements DQMEDHarvester.

Definition at line 114 of file RPCDqmClient.cc.

References clientModules_, enableDQMClients_, MonitorElement::getBinContent(), init_, minimumEvents_, and RPCEvents_.

                                                                                  {
 
   if (!enableDQMClients_ || !init_) {return;}
 
   edm::LogVerbatim ("rpcdqmclient") << "[RPCDqmClient]: End DQM Job";
   
   float   rpcevents = minimumEvents_;
   if(RPCEvents_) {rpcevents = RPCEvents_ ->getBinContent(1);}
   if(rpcevents < minimumEvents_) {return;}
 
   edm::LogVerbatim ("rpcdqmclient") <<"[RPCDqmClient]: Client operations";
   for (std::vector<RPCClient*>::iterator it = clientModules_.begin(); it!=clientModules_.end(); it++ ){
     (*it)->clientOperation();
   }
   
 }

void RPCDqmClient::dqmEndLuminosityBlock	(	DQMStore::IBooker &	ibooker,
		DQMStore::IGetter &	igetter,
		edm::LuminosityBlock const &	lumiSeg,
		edm::EventSetup const &	c
	)

protectedvirtual

Reimplemented from DQMEDHarvester.

Definition at line 75 of file RPCDqmClient.cc.

References clientModules_, enableDQMClients_, MonitorElement::getBinContent(), getMonitorElements(), init_, lumiCounter_, minimumEvents_, offlineDQM_, prescaleGlobalFactor_, and RPCEvents_.

                                                                                                                                                          {
  
   if (!enableDQMClients_ ) {return;}
   edm::LogVerbatim ("rpcdqmclient") << "[RPCDqmClient]: End DQM LB";
   
   
   if(!init_) {  //At the end of the first LumiBlock...
     // ...get chamber based histograms 
     this->getMonitorElements(igetter, c);
 
     //...book summary histograms
     for (std::vector<RPCClient*>::iterator it = clientModules_.begin(); it!=clientModules_.end(); it++ ){
       (*it)->myBooker( ibooker);
     }
 
     lumiCounter_ = prescaleGlobalFactor_  - 1;
     init_= true;
   }
 
   lumiCounter_++;
   
   if (offlineDQM_) {return;} // If in offlineDQM mode, do nothing. Client operation will be done only at endJob
   
   //Check if there's enough statistics
   float   rpcevents = minimumEvents_;
   if(RPCEvents_) {rpcevents = RPCEvents_->getBinContent(1);}
   if( rpcevents < minimumEvents_) {return;}
   //Do not perform client oparations every lumi block  
   if (lumiCounter_%prescaleGlobalFactor_ != 0) {return;}
 
   edm::LogVerbatim ("rpcdqmclient") <<"[RPCDqmClient]: Client operations";
   for (std::vector<RPCClient*>::iterator it = clientModules_.begin(); it!=clientModules_.end(); it++ ){
     (*it)->clientOperation();
   }
 
 }

void RPCDqmClient::getMonitorElements	(	DQMStore::IGetter &	igetter,
		const edm::EventSetup &	c
	)

protected

Definition at line 133 of file RPCDqmClient.cc.

References RPCGeomServ::chambername(), GetRecoTauVFromDQM_MC_cff::cl, clientHisto_, clientModules_, RPCBookFolderStructure::folderStructure(), edm::EventSetup::get(), DQMStore::IGetter::get(), RPCGeomServ::name(), NULL, prefixDir_, alignCSCRings::r, RPCChamber::rolls(), RPCEvents_, AlCaHLTBitMon_QueryRunRegistry::string, and useRollInfo_.

Referenced by dqmEndLuminosityBlock().

                                                                                        {
  
   std::vector<MonitorElement *>  myMeVect;
   std::vector<RPCDetId>   myDetIds;
    
   edm::ESHandle<RPCGeometry> rpcGeo;
   c.get<MuonGeometryRecord>().get(rpcGeo);
   
   //dbe_->setCurrentFolder(prefixDir_);
   RPCBookFolderStructure *  folderStr = new RPCBookFolderStructure();
   MonitorElement * myMe = NULL;
   std::string rollName= "";
 
   //loop on all geometry and get all histos
   for (TrackingGeometry::DetContainer::const_iterator it=rpcGeo->dets().begin();it<rpcGeo->dets().end();it++){
     if( dynamic_cast< const RPCChamber* >( *it ) != 0 ){
        
        const RPCChamber* ch = dynamic_cast< const RPCChamber* >( *it ); 
        std::vector< const RPCRoll*> roles = (ch->rolls());
        
        //Loop on rolls in given chamber
        for(std::vector<const RPCRoll*>::const_iterator r = roles.begin();r != roles.end(); ++r){
      
      RPCDetId detId = (*r)->id();
      
      //Get name
      RPCGeomServ RPCname(detId);       
      rollName= "";
      if(useRollInfo_) {
        rollName =  RPCname.name();
      }else{
        rollName =   RPCname.chambername();
      }
 
      //loop on clients
      for( unsigned int cl = 0; cl<clientModules_.size(); cl++ ){
        
        myMe = NULL;
        myMe = igetter.get(prefixDir_ +"/"+ folderStr->folderStructure(detId)+"/"+clientHisto_[cl]+ "_"+rollName); 
        
        if (!myMe)continue;
        //      dbe_->tag(myMe, clientTag_[cl]);
        myMeVect.push_back(myMe);
        myDetIds.push_back(detId);
        
      }//end loop on clients
        }//end loop on roll in given chamber
     }
   }//end loop on all geometry and get all histos  
   
   
   RPCEvents_ = igetter.get(prefixDir_ +"/RPCEvents");  
   unsigned int cl = 0;
   for (std::vector<RPCClient*>::iterator it = clientModules_.begin(); it!=clientModules_.end(); it++ ){
     (*it)->getMonitorElements(myMeVect, myDetIds, clientHisto_[cl]);
     cl++;
   }
 
   delete folderStr;
 }

void RPCDqmClient::makeClientMap ( const edm::ParameterSet & parameters_ )

protected

Definition at line 198 of file RPCDqmClient.cc.

References clientHisto_, clientList_, clientModules_, and i.

Referenced by RPCDqmClient().

                                                                    {
 
   for(unsigned int i = 0; i<clientList_.size(); i++){
     
     if( clientList_[i] == "RPCMultiplicityTest" ) {
       clientHisto_.push_back("Multiplicity");
       // clientTag_.push_back(rpcdqm::MULTIPLICITY);
       clientModules_.push_back( new RPCMultiplicityTest(parameters_));
     } else if ( clientList_[i] == "RPCDeadChannelTest" ){
       clientHisto_.push_back("Occupancy");
       clientModules_.push_back( new RPCDeadChannelTest(parameters_));
       // clientTag_.push_back(rpcdqm::OCCUPANCY);
     } else if ( clientList_[i] == "RPCClusterSizeTest" ){
       clientHisto_.push_back("ClusterSize");
       clientModules_.push_back( new RPCClusterSizeTest(parameters_));
       // clientTag_.push_back(rpcdqm::CLUSTERSIZE);
     } else if ( clientList_[i] == "RPCOccupancyTest" ){
       clientHisto_.push_back("Occupancy");
       clientModules_.push_back( new RPCOccupancyTest(parameters_));
       // clientTag_.push_back(rpcdqm::OCCUPANCY);
     } else if ( clientList_[i] == "RPCNoisyStripTest" ){
       clientHisto_.push_back("Occupancy");
       clientModules_.push_back( new RPCNoisyStripTest(parameters_));
       //clientTag_.push_back(rpcdqm::OCCUPANCY);
     }
   }
 
   return;
 
 }