CSCDQM Framework frontend and Histogram Cache controller. More...

#include <CSCDQM_Dispatcher.h>

Public Member Functions
	Dispatcher (Configuration const p_config, MonitorObjectProvider const p_provider)
	Constructor. More...

const bool	getHisto (const HistoDef &histoD, MonitorObject *&me)
	Global get MO function. If request has reached this function it means that histo is not in cache! More...

void	init ()
	Initialize Dispatcher: book histograms, init processor, etc. More...

unsigned int	maskHWElements (std::vector< std::string > &tokens)
	Mask HW elements from the efficiency calculations. Can be applied on runtime! More...

void	processStandby (HWStandbyType &standby)
	Set HW Standby modes. More...

void	updateFractionAndEfficiencyHistos ()
	On demand update fraction and efficiency MOs. More...

	~Dispatcher ()
	Destructor. Joins and waits to complete all threads. More...

Private Member Functions
void	commonConstruct (Configuration const p_config, MonitorObjectProvider const p_provider)

void	updateFractionAndEfficiencyHistosAuto ()
	Automatically called fraction and efficiency MOs update function. More...

Private Attributes
Cache	cache

Collection	collection

Configuration *	config

EventProcessor	processor

EventProcessorMutex	processorFract

MonitorObjectProvider *	provider

Detailed Description

CSCDQM Framework frontend and Histogram Cache controller.

Definition at line 121 of file CSCDQM_Dispatcher.h.

Constructor & Destructor Documentation

cscdqm::Dispatcher::Dispatcher	(	Configuration *const	p_config,
		MonitorObjectProvider *const	p_provider
	)

Constructor.

Parameters

p_config	Pointer to Global Configuration
p_provider	Pointer to MonitorObjectProvider

Returns

Definition at line 29 of file CSCDQM_Dispatcher.cc.

References commonConstruct().

                                                                                          : 
   collection(p_config), processor(p_config), processorFract(p_config) {
     commonConstruct( p_config, p_provider );
   }

cscdqm::Dispatcher::~Dispatcher ( )

inline

Destructor. Joins and waits to complete all threads.

Definition at line 135 of file CSCDQM_Dispatcher.h.

                     { 
 #ifdef DQMMT      
         threads.join_all(); 
 #endif      
       }

Member Function Documentation

void cscdqm::Dispatcher::commonConstruct	(	Configuration *const	p_config,
		MonitorObjectProvider *const	p_provider
	)

private

Save pointers to class properties

Link/share Cache methods to function pointers in configuration

Link/share local functions

Link/share getCSCDetId function

Link/share booking function

Definition at line 52 of file CSCDQM_Dispatcher.cc.

Referenced by Dispatcher().

                                                                                                      {
 
     config = p_config;
     provider = p_provider;
 
     config->fnGetCacheEMUHisto = boost::bind(&Cache::getEMU, &cache, _1, _2);
     config->fnGetCacheFEDHisto = boost::bind(&Cache::getFED, &cache, _1, _2, _3);
     config->fnGetCacheDDUHisto = boost::bind(&Cache::getDDU, &cache, _1, _2, _3);
     config->fnGetCacheCSCHisto = boost::bind(&Cache::getCSC, &cache, _1, _2, _3, _4, _5);
     config->fnGetCacheParHisto = boost::bind(&Cache::getPar, &cache, _1, _2);
     config->fnPutHisto = boost::bind(&Cache::put, &cache, _1, _2);
     config->fnNextBookedCSC = boost::bind(&Cache::nextBookedCSC, &cache, _1, _2, _3);
     config->fnIsBookedCSC = boost::bind(&Cache::isBookedCSC, &cache, _1, _2);
     config->fnIsBookedDDU = boost::bind(&Cache::isBookedDDU, &cache, _1);
     config->fnIsBookedFED = boost::bind(&Cache::isBookedFED, &cache, _1);
 
     config->fnGetHisto = boost::bind(&Dispatcher::getHisto, this, _1, _2);
 
     config->fnGetCSCDetId = boost::bind(&MonitorObjectProvider::getCSCDetId, provider, _1, _2, _3);
 
     config->fnBook = boost::bind(&MonitorObjectProvider::bookMonitorObject, provider, _1);
 
   }

const bool cscdqm::Dispatcher::getHisto	(	const HistoDef &	histoD,
		MonitorObject *&	me
	)

Global get MO function. If request has reached this function it means that histo is not in cache!

Parameters

histoD	Histogram Definition to get
me	MO to return

Returns: true if me found and filled, false - otherwise

For the first FED - book general

For the first DDU - book general

For the first and specific CSCs - book general and specific

cache.printContent();

For the Parameters - book parameter histogram

If not found after booking - mark it as not existent

Definition at line 106 of file CSCDQM_Dispatcher.cc.

References cscdqm::Collection::bookCSCHistos(), cscdqm::Collection::bookDDUHistos(), cscdqm::Collection::bookFEDHistos(), cscdqm::MonitorObjectProvider::bookMonitorObject(), cache, collection, config, cscdqm::CSCHistoDefT, cscdqm::DDUHistoDefT, cscdqm::FEDHistoDefT, cscdqm::Cache::get(), cscdqm::HistoDef::getAddId(), cscdqm::HistoDef::getCrateId(), cscdqm::HistoDef::getDDUId(), cscdqm::HistoDef::getDMBId(), cscdqm::HistoDef::getFEDId(), cscdqm::HistoDef::getHistoName(), cscdqm::HistoDef::getId(), cscdqm::Cache::isBookedCSC(), cscdqm::Cache::isBookedDDU(), cscdqm::Cache::isBookedFED(), cscdqm::Collection::isOnDemand(), NULL, cscdqm::ParHistoDefT, provider, and cscdqm::Cache::put().

Referenced by commonConstruct().

                                                                             {
 
     if (typeid(histoD) == FEDHistoDefT && !cache.isBookedFED(histoD.getFEDId())) {
       collection.bookFEDHistos(histoD.getFEDId());
       if (cache.get(histoD, me)) return true;
     }
 
     if (typeid(histoD) == DDUHistoDefT && !cache.isBookedDDU(histoD.getDDUId())) {
       collection.bookDDUHistos(histoD.getDDUId());
       if (cache.get(histoD, me)) return true;
     }
 
     if (typeid(histoD) == CSCHistoDefT) {
       if (!cache.isBookedCSC(histoD.getCrateId(), histoD.getDMBId())) {
         collection.bookCSCHistos(histoD.getCrateId(), histoD.getDMBId());
       }
       if (collection.isOnDemand(histoD.getHistoName())) {
         collection.bookCSCHistos(histoD.getId(), histoD.getCrateId(), histoD.getDMBId(), histoD.getAddId());
       }
       if (cache.get(histoD, me)) return true;
     }
 
     if (typeid(histoD) == ParHistoDefT) {
       HistoBookRequest req(histoD, config->getFOLDER_PAR(), -1.0f);
       me = provider->bookMonitorObject(req);
       cache.put(histoD, me);
       return true;
     }
 
     cache.put(histoD, NULL);
 
     return false;
   }

void cscdqm::Dispatcher::init ( void )

Initialize Dispatcher: book histograms, init processor, etc.

Returns

Definition at line 85 of file CSCDQM_Dispatcher.cc.

References cscdqm::Collection::bookEMUHistos(), collection, cscdqm::EventProcessor::init(), cscdqm::Collection::load(), and processor.

Referenced by CSCMonitorModule::CSCMonitorModule(), and CSCOfflineClient::CSCOfflineClient().

                         {
     collection.load();
     collection.bookEMUHistos();
     processor.init();
   }

unsigned int cscdqm::Dispatcher::maskHWElements ( std::vector< std::string > & tokens )

Mask HW elements from the efficiency calculations. Can be applied on runtime!

Parameters

tokens String tokens of the HW elements

Returns: elements masked

Definition at line 96 of file CSCDQM_Dispatcher.cc.

References cscdqm::EventProcessorMutex::maskHWElements(), and processorFract.

Referenced by CSCMonitorModule::CSCMonitorModule(), and CSCOfflineClient::CSCOfflineClient().

                                                                       {
     return processorFract.maskHWElements(tokens);
   }

void cscdqm::Dispatcher::processStandby ( HWStandbyType & standby )

Set HW Standby modes.

Returns

Definition at line 180 of file CSCDQM_Dispatcher.cc.

References config, CommonMethods::lock(), cscdqm::Lock::mutex, processorFract, and cscdqm::EventProcessorMutex::processStandby().

                                                         {
     LockType lock(processorFract.mutex);
     if (config->getFRAEFF_SEPARATE_THREAD()) { 
       boost::function<void (HWStandbyType&)> fnUpdate = boost::bind(&EventProcessorMutex::processStandby, &processorFract, _1);
 #ifdef DQMMT
       threads.create_thread(boost::ref(fnUpdate));
 #else
       fnUpdate(standby);
 #endif 
     } else {
       processorFract.processStandby(standby);
     }
   }

void cscdqm::Dispatcher::updateFractionAndEfficiencyHistos ( )

On demand update fraction and efficiency MOs.

Returns

Definition at line 162 of file CSCDQM_Dispatcher.cc.

References config, CommonMethods::lock(), cscdqm::Lock::mutex, processorFract, and cscdqm::EventProcessorMutex::updateFractionAndEfficiencyHistos().

Referenced by CSCMonitorModule::beginRun(), CSCOfflineClient::endRun(), and updateFractionAndEfficiencyHistosAuto().

                                                      {
     LockType lock(processorFract.mutex);
     if (config->getFRAEFF_SEPARATE_THREAD()) { 
       boost::function<void ()> fnUpdate = boost::bind(&EventProcessorMutex::updateFractionAndEfficiencyHistos, &processorFract);
 #ifdef DQMMT
       threads.create_thread(boost::ref(fnUpdate));
 #else
       fnUpdate();
 #endif 
     } else {
       processorFract.updateFractionAndEfficiencyHistos();
     }
   }

void cscdqm::Dispatcher::updateFractionAndEfficiencyHistosAuto ( )

private

Automatically called fraction and efficiency MOs update function.

Returns

Definition at line 150 of file CSCDQM_Dispatcher.cc.

References config, cscdqm::Configuration::getNEventsCSC(), and updateFractionAndEfficiencyHistos().

                                                          {
     if ( config->getFRAEFF_AUTO_UPDATE() &&
         (config->getNEventsCSC() >= config->getFRAEFF_AUTO_UPDATE_START()) &&
         (config->getNEventsCSC() % config->getFRAEFF_AUTO_UPDATE_FREQ()) == 0) {
       updateFractionAndEfficiencyHistos();
     }
   }