CMS 3D CMS Logo
List of all members | Public Member Functions | Private Member Functions | Private Attributes
cscdqm::Dispatcher Class Reference

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

#include <CSCDQM_Dispatcher.h>

Public Member Functions

void book ()
 
 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 122 of file CSCDQM_Dispatcher.h.

Constructor & Destructor Documentation

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

Constructor.

Parameters
p_configPointer to Global Configuration
p_providerPointer to MonitorObjectProvider
Returns

Definition at line 29 of file CSCDQM_Dispatcher.cc.

References collection, commonConstruct(), processor, and processorFract.

29  :
30  collection(p_config), processor(p_config), processorFract(p_config) {
31  commonConstruct( p_config, p_provider );
32 }
cscdqm::Dispatcher::processorFract
EventProcessorMutex processorFract
Definition: CSCDQM_Dispatcher.h:172
cscdqm::Dispatcher::processor
EventProcessor processor
Definition: CSCDQM_Dispatcher.h:166
cscdqm::Dispatcher::commonConstruct
void commonConstruct(Configuration *const p_config, MonitorObjectProvider *const p_provider)
Definition: CSCDQM_Dispatcher.cc:52
cscdqm::Dispatcher::~Dispatcher ( )
inline

Destructor. Joins and waits to complete all threads.

Definition at line 136 of file CSCDQM_Dispatcher.h.

References init, cscdqm::EventProcessorMutex::maskHWElements(), cscdqm::EventProcessorMutex::processStandby(), and cscdqm::EventProcessorMutex::updateFractionAndEfficiencyHistos().

136  {
137 #ifdef DQMMT
138  threads.join_all();
139 #endif
140  }

Member Function Documentation

void cscdqm::Dispatcher::book ( )

For the first FED - book general

For the first DDU - book general

For the first and specific CSCs - book general and specific

No DMB in slot 6

For the Parameters - book parameter histograms

Definition at line 91 of file CSCDQM_Dispatcher.cc.

References cscdqm::Collection::bookCSCHistos(), cscdqm::Collection::bookDDUHistos(), cscdqm::Collection::bookEMUHistos(), cscdqm::Collection::bookFEDHistos(), cscdqm::MonitorObjectProvider::bookMonitorObject(), cache, collection, mps_fire::i, cscdqm::EventProcessor::init(), cscdqm::Cache::isBookedCSC(), cscdqm::Cache::isBookedDDU(), cscdqm::Cache::isBookedFED(), cscdqm::h::PAR_CSC_SIDEMINUS, cscdqm::h::PAR_CSC_SIDEMINUS_STATION01, cscdqm::h::PAR_CSC_SIDEMINUS_STATION01_RING01, cscdqm::h::PAR_CSC_SIDEMINUS_STATION01_RING02, cscdqm::h::PAR_CSC_SIDEMINUS_STATION01_RING03, cscdqm::h::PAR_CSC_SIDEMINUS_STATION02, cscdqm::h::PAR_CSC_SIDEMINUS_STATION02_RING01, cscdqm::h::PAR_CSC_SIDEMINUS_STATION02_RING02, cscdqm::h::PAR_CSC_SIDEMINUS_STATION03, cscdqm::h::PAR_CSC_SIDEMINUS_STATION03_RING01, cscdqm::h::PAR_CSC_SIDEMINUS_STATION03_RING02, cscdqm::h::PAR_CSC_SIDEMINUS_STATION04, cscdqm::h::PAR_CSC_SIDEMINUS_STATION04_RING01, cscdqm::h::PAR_CSC_SIDEMINUS_STATION04_RING02, cscdqm::h::PAR_CSC_SIDEPLUS, cscdqm::h::PAR_CSC_SIDEPLUS_STATION01, cscdqm::h::PAR_CSC_SIDEPLUS_STATION01_RING01, cscdqm::h::PAR_CSC_SIDEPLUS_STATION01_RING02, cscdqm::h::PAR_CSC_SIDEPLUS_STATION01_RING03, cscdqm::h::PAR_CSC_SIDEPLUS_STATION02, cscdqm::h::PAR_CSC_SIDEPLUS_STATION02_RING01, cscdqm::h::PAR_CSC_SIDEPLUS_STATION02_RING02, cscdqm::h::PAR_CSC_SIDEPLUS_STATION03, cscdqm::h::PAR_CSC_SIDEPLUS_STATION03_RING01, cscdqm::h::PAR_CSC_SIDEPLUS_STATION03_RING02, cscdqm::h::PAR_CSC_SIDEPLUS_STATION04, cscdqm::h::PAR_CSC_SIDEPLUS_STATION04_RING01, cscdqm::h::PAR_CSC_SIDEPLUS_STATION04_RING02, cscdqm::h::PAR_REPORT_SUMMARY, processor, provider, and cscdqm::Cache::put().

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

91  {
92 
93  collection.bookEMUHistos();
94 
95  /*** FOr multi-threading pre-book all FED, DDU, CSC histograms ***/
96  if ( config->getPREBOOK_ALL_HISTOS()) {
97 
99  for (HwId FEDId = 750; FEDId < 758; FEDId++) {
100  if (!cache.isBookedFED(FEDId)) {
101  collection.bookFEDHistos(FEDId);
102  }
103  }
104 
105  if (config->getPROCESS_DDU()) {
107  for (HwId DDUId = 1; DDUId <= 36; DDUId++) {
108  if (!cache.isBookedDDU(DDUId)) {
109  collection.bookDDUHistos(DDUId);
110  }
111  }
112  }
113 
114  if (config->getPROCESS_CSC()) {
116  for (HwId CrateId = 1; CrateId <= 60; CrateId++) {
117  for (HwId DMBId = 1; DMBId <=10; DMBId++) {
118  if (DMBId == 6) continue;
119  if (!cache.isBookedCSC(CrateId, DMBId)) {
120  collection.bookCSCHistos(CrateId, DMBId);
121  }
122  }
123  }
124  }
125 
126  if (config->getPROCESS_EFF_PARAMETERS()) {
129  std::vector<HistoId> parameters;
130  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION01_RING01);
131  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION01_RING02);
132  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION01_RING03);
133  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION01);
134  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION02_RING01);
135  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION02_RING02);
136  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION02);
137  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION03_RING01);
138  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION03_RING02);
139  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION03);
140  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION04_RING01);
141  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION04_RING02);
142  parameters.push_back(h::PAR_CSC_SIDEPLUS_STATION04);
143  parameters.push_back(h::PAR_CSC_SIDEPLUS);
144  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION01_RING01);
145  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION01_RING02);
146  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION01_RING03);
147  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION01);
148  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION02_RING01);
149  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION02_RING02);
150  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION02);
151  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION03_RING01);
152  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION03_RING02);
153  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION03);
154  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION04_RING01);
155  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION04_RING02);
156  parameters.push_back(h::PAR_CSC_SIDEMINUS_STATION04);
157  parameters.push_back(h::PAR_CSC_SIDEMINUS);
158  parameters.push_back(h::PAR_REPORT_SUMMARY);
159 
160 
161  for (size_t i = 0; i < parameters.size(); i++) {
162  ParHistoDef histoD(parameters[i]);
163  auto histodef = HistoDef(parameters[i]);
164  HistoBookRequest req(histodef, config->getFOLDER_PAR(), -1.0f);
165  MonitorObject* me = provider->bookMonitorObject(req);
166  cache.put(histoD, me);
167  }
168  }
169 
170  }
171 
172  processor.init();
173 
174 }
cscdqm::HwId
unsigned int HwId
Definition: CSCDQM_HistoDef.h:38
cscdqm::Cache::isBookedDDU
const bool isBookedDDU(const HwId &dduId) const
Check if DDU was booked on given identifier.
Definition: CSCDQM_Cache.cc:334
mps_fire.i
i
Definition: mps_fire.py:269
cscdqm::Collection::bookEMUHistos
void bookEMUHistos() const
Book EMU histograms.
Definition: CSCDQM_Collection.cc:303
config
Definition: config.py:1
cscdqm::EventProcessor::init
void init()
Initialize EventProcessor: reading out config information.
Definition: CSCDQM_EventProcessor.cc:61
cscdqm::MonitorObjectProvider::bookMonitorObject
virtual MonitorObject * bookMonitorObject(const HistoBookRequest &p_req)=0
cscdqm::Dispatcher::processor
EventProcessor processor
Definition: CSCDQM_Dispatcher.h:166
cscdqm::Collection::bookFEDHistos
void bookFEDHistos(const HwId fedId) const
Book FED histograms.
Definition: CSCDQM_Collection.cc:325
cscdqm::Collection::bookDDUHistos
void bookDDUHistos(const HwId dduId) const
Book DDU histograms.
Definition: CSCDQM_Collection.cc:347
cscdqm::Cache::put
void put(const HistoDef &histo, MonitorObject *mo)
Put Monitoring Object into cache.
Definition: CSCDQM_Cache.cc:167
cscdqm::Cache::isBookedCSC
const bool isBookedCSC(const HwId &crateId, const HwId &dmbId) const
Check if CSC was booked on given identifiers.
Definition: CSCDQM_Cache.cc:311
cscdqm::Collection::bookCSCHistos
void bookCSCHistos(const HwId crateId, const HwId dmbId) const
Book Chamber Histograms.
Definition: CSCDQM_Collection.cc:370
parameters
parameters
Definition: BeamSpot_PayloadInspector.cc:14
cscdqm::Dispatcher::provider
MonitorObjectProvider * provider
Definition: CSCDQM_Dispatcher.h:160
cscdqm::Cache::isBookedFED
const bool isBookedFED(const HwId &fedId) const
Check if FED was booked on given identifier.
Definition: CSCDQM_Cache.cc:324
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.

References cscdqm::MonitorObjectProvider::bookMonitorObject(), cache, cscdqm::Cache::getCSC(), cscdqm::MonitorObjectProvider::getCSCDetId(), cscdqm::Cache::getDDU(), cscdqm::Cache::getEMU(), cscdqm::Cache::getFED(), getHisto(), cscdqm::Cache::getPar(), cscdqm::Cache::isBookedCSC(), cscdqm::Cache::isBookedDDU(), cscdqm::Cache::isBookedFED(), cscdqm::Cache::nextBookedCSC(), provider, and cscdqm::Cache::put().

Referenced by Dispatcher().

52  {
53 
55  config = p_config;
56  provider = p_provider;
57 
59  config->fnGetCacheEMUHisto = boost::bind(&Cache::getEMU, &cache, _1, _2);
60  config->fnGetCacheFEDHisto = boost::bind(&Cache::getFED, &cache, _1, _2, _3);
61  config->fnGetCacheDDUHisto = boost::bind(&Cache::getDDU, &cache, _1, _2, _3);
62  config->fnGetCacheCSCHisto = boost::bind(&Cache::getCSC, &cache, _1, _2, _3, _4, _5);
63  config->fnGetCacheParHisto = boost::bind(&Cache::getPar, &cache, _1, _2);
64  config->fnPutHisto = boost::bind(&Cache::put, &cache, _1, _2);
65  config->fnNextBookedCSC = boost::bind(&Cache::nextBookedCSC, &cache, _1, _2, _3);
66  config->fnIsBookedCSC = boost::bind(&Cache::isBookedCSC, &cache, _1, _2);
67  config->fnIsBookedDDU = boost::bind(&Cache::isBookedDDU, &cache, _1);
68  config->fnIsBookedFED = boost::bind(&Cache::isBookedFED, &cache, _1);
69 
71  config->fnGetHisto = boost::bind(&Dispatcher::getHisto, this, _1, _2);
72 
74  config->fnGetCSCDetId = boost::bind(&MonitorObjectProvider::getCSCDetId, provider, _1, _2, _3);
75 
77  config->fnBook = boost::bind(&MonitorObjectProvider::bookMonitorObject, provider, _1);
78 
79 }
cscdqm::Cache::getFED
const bool getFED(const HistoId &id, const HwId &fedId, MonitorObject *&mo)
Get FED MO on Histogram Id and FED Id.
Definition: CSCDQM_Cache.cc:71
cscdqm::Cache::isBookedDDU
const bool isBookedDDU(const HwId &dduId) const
Check if DDU was booked on given identifier.
Definition: CSCDQM_Cache.cc:334
cscdqm::Cache::getEMU
const bool getEMU(const HistoId &id, MonitorObject *&mo)
Get EMU MO on Histogram Id.
Definition: CSCDQM_Cache.cc:56
cscdqm::Cache::nextBookedCSC
const bool nextBookedCSC(unsigned int &n, unsigned int &crateId, unsigned int &dmbId) const
Iterator to get booked CSC identifiers on enumerator.
Definition: CSCDQM_Cache.cc:258
config
Definition: config.py:1
cscdqm::MonitorObjectProvider::bookMonitorObject
virtual MonitorObject * bookMonitorObject(const HistoBookRequest &p_req)=0
cscdqm::MonitorObjectProvider::getCSCDetId
virtual bool getCSCDetId(const unsigned int crateId, const unsigned int dmbId, CSCDetId &detId) const =0
cscdqm::Cache::getPar
const bool getPar(const HistoId &id, MonitorObject *&mo)
Get Parameter MO on Histogram Id.
Definition: CSCDQM_Cache.cc:153
cscdqm::Dispatcher::getHisto
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! ...
Definition: CSCDQM_Dispatcher.cc:191
cscdqm::Cache::getDDU
const bool getDDU(const HistoId &id, const HwId &dduId, MonitorObject *&mo)
Get DDU MO on Histogram Id and DDU Id.
Definition: CSCDQM_Cache.cc:100
cscdqm::Cache::put
void put(const HistoDef &histo, MonitorObject *mo)
Put Monitoring Object into cache.
Definition: CSCDQM_Cache.cc:167
cscdqm::Cache::isBookedCSC
const bool isBookedCSC(const HwId &crateId, const HwId &dmbId) const
Check if CSC was booked on given identifiers.
Definition: CSCDQM_Cache.cc:311
cscdqm::Dispatcher::provider
MonitorObjectProvider * provider
Definition: CSCDQM_Dispatcher.h:160
cscdqm::Cache::getCSC
const bool getCSC(const HistoId &id, const HwId &crateId, const HwId &dmbId, const HwId &addId, MonitorObject *&mo)
Get CSC MO on Histogram Id and CSC Crate and DMB Ids.
Definition: CSCDQM_Cache.cc:129
cscdqm::Cache::isBookedFED
const bool isBookedFED(const HwId &fedId) const
Check if FED was booked on given identifier.
Definition: CSCDQM_Cache.cc:324
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
histoDHistogram Definition to get
meMO 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 191 of file CSCDQM_Dispatcher.cc.

References cscdqm::Collection::bookCSCHistos(), cscdqm::Collection::bookDDUHistos(), cscdqm::Collection::bookFEDHistos(), cscdqm::MonitorObjectProvider::bookMonitorObject(), cache, collection, 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(), cscdqm::ParHistoDefT, provider, and cscdqm::Cache::put().

Referenced by commonConstruct().

191  {
192 
194  if (typeid(histoD) == FEDHistoDefT && !cache.isBookedFED(histoD.getFEDId())) {
195  collection.bookFEDHistos(histoD.getFEDId());
196  if (cache.get(histoD, me)) return true;
197  }
198 
200  if (typeid(histoD) == DDUHistoDefT && !cache.isBookedDDU(histoD.getDDUId())) {
201  collection.bookDDUHistos(histoD.getDDUId());
202  if (cache.get(histoD, me)) return true;
203  }
204 
206  if (typeid(histoD) == CSCHistoDefT) {
207  if (!cache.isBookedCSC(histoD.getCrateId(), histoD.getDMBId())) {
208  collection.bookCSCHistos(histoD.getCrateId(), histoD.getDMBId());
210  }
211  if (collection.isOnDemand(histoD.getHistoName())) {
212  collection.bookCSCHistos(histoD.getId(), histoD.getCrateId(), histoD.getDMBId(), histoD.getAddId());
213  }
214  if (cache.get(histoD, me)) return true;
215  }
216 
218  if (typeid(histoD) == ParHistoDefT) {
219  HistoBookRequest req(histoD, config->getFOLDER_PAR(), -1.0f);
220  me = provider->bookMonitorObject(req);
221  cache.put(histoD, me);
222  return true;
223  }
224 
226  cache.put(histoD, nullptr);
227 
228  return false;
229 }
cscdqm::FEDHistoDefT
static const std::type_info & FEDHistoDefT
Definition: CSCDQM_HistoDef.h:475
cscdqm::Cache::isBookedDDU
const bool isBookedDDU(const HwId &dduId) const
Check if DDU was booked on given identifier.
Definition: CSCDQM_Cache.cc:334
cscdqm::Collection::isOnDemand
const bool isOnDemand(const HistoName &name) const
Check if the histogram is on demand (by histogram name)
Definition: CSCDQM_Collection.cc:604
config
Definition: config.py:1
cscdqm::MonitorObjectProvider::bookMonitorObject
virtual MonitorObject * bookMonitorObject(const HistoBookRequest &p_req)=0
cscdqm::CSCHistoDefT
static const std::type_info & CSCHistoDefT
Definition: CSCDQM_HistoDef.h:477
cscdqm::ParHistoDefT
static const std::type_info & ParHistoDefT
Definition: CSCDQM_HistoDef.h:478
cscdqm::Collection::bookFEDHistos
void bookFEDHistos(const HwId fedId) const
Book FED histograms.
Definition: CSCDQM_Collection.cc:325
cscdqm::DDUHistoDefT
static const std::type_info & DDUHistoDefT
Definition: CSCDQM_HistoDef.h:476
cscdqm::Collection::bookDDUHistos
void bookDDUHistos(const HwId dduId) const
Book DDU histograms.
Definition: CSCDQM_Collection.cc:347
cscdqm::Cache::put
void put(const HistoDef &histo, MonitorObject *mo)
Put Monitoring Object into cache.
Definition: CSCDQM_Cache.cc:167
cscdqm::Cache::isBookedCSC
const bool isBookedCSC(const HwId &crateId, const HwId &dmbId) const
Check if CSC was booked on given identifiers.
Definition: CSCDQM_Cache.cc:311
cscdqm::Collection::bookCSCHistos
void bookCSCHistos(const HwId crateId, const HwId dmbId) const
Book Chamber Histograms.
Definition: CSCDQM_Collection.cc:370
cscdqm::Cache::get
const bool get(const HistoDef &histo, MonitorObject *&mo)
Get Monitoring Object on Histogram Definition.
Definition: CSCDQM_Cache.cc:29
cscdqm::Dispatcher::provider
MonitorObjectProvider * provider
Definition: CSCDQM_Dispatcher.h:160
cscdqm::Cache::isBookedFED
const bool isBookedFED(const HwId &fedId) const
Check if FED was booked on given identifier.
Definition: CSCDQM_Cache.cc:324
void cscdqm::Dispatcher::init ( void  )

Initialize Dispatcher: book histograms, init processor, etc.

Returns

Definition at line 85 of file CSCDQM_Dispatcher.cc.

References collection, and cscdqm::Collection::load().

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

85  {
86  collection.load();
87  // collection.bookEMUHistos();
88  // processor.init();
89 }
cscdqm::Collection::load
void load()
Load XML file and fill definition map(s)
Definition: CSCDQM_Collection.cc:40
unsigned int cscdqm::Dispatcher::maskHWElements ( std::vector< std::string > &  tokens)

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

Parameters
tokensString tokens of the HW elements
Returns
elements masked

Definition at line 181 of file CSCDQM_Dispatcher.cc.

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

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

181  {
182  return processorFract.maskHWElements(tokens);
183 }
cscdqm::Dispatcher::processorFract
EventProcessorMutex processorFract
Definition: CSCDQM_Dispatcher.h:172
cscdqm::EventProcessorMutex::maskHWElements
unsigned int maskHWElements(std::vector< std::string > &tokens)
Mask HW elements from the efficiency calculations. Can be applied on runtime!
Definition: CSCDQM_Dispatcher.h:92
void cscdqm::Dispatcher::processStandby ( HWStandbyType &  standby)

Set HW Standby modes.

Returns

Definition at line 265 of file CSCDQM_Dispatcher.cc.

References data, MillePedeFileConverter_cfg::e, cscdqm::HWStandbyType::fullStandby(), HiClusterCompatibility_cfi::inputTag, CommonMethods::lock(), cscdqm::Lock::mutex, cscdqm::HWStandbyType::process, processEvent(), processor, processorFract, cscdqm::EventProcessorMutex::processStandby(), and updateFractionAndEfficiencyHistosAuto().

265  {
266  LockType lock(processorFract.mutex);
267  if (config->getFRAEFF_SEPARATE_THREAD()) {
268  boost::function<void (HWStandbyType&)> fnUpdate = boost::bind(&EventProcessorMutex::processStandby, &processorFract, _1);
269 #ifdef DQMMT
270  threads.create_thread(boost::ref(fnUpdate));
271 #else
272  fnUpdate(standby);
273 #endif
274  } else {
275  processorFract.processStandby(standby);
276  }
277 }
cscdqm::Dispatcher::processorFract
EventProcessorMutex processorFract
Definition: CSCDQM_Dispatcher.h:172
config
Definition: config.py:1
cscdqm::EventProcessorMutex::processStandby
void processStandby(HWStandbyType &standby)
Process standby information.
Definition: CSCDQM_Dispatcher.h:101
void cscdqm::Dispatcher::updateFractionAndEfficiencyHistos ( )

On demand update fraction and efficiency MOs.

Returns

Definition at line 247 of file CSCDQM_Dispatcher.cc.

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

Referenced by CSCMonitorModule::bookHistograms(), CSCOfflineClient::dqmEndJob(), and updateFractionAndEfficiencyHistosAuto().

247  {
248  LockType lock(processorFract.mutex);
249  if (config->getFRAEFF_SEPARATE_THREAD()) {
250  boost::function<void ()> fnUpdate = boost::bind(&EventProcessorMutex::updateFractionAndEfficiencyHistos, &processorFract);
251 #ifdef DQMMT
252  threads.create_thread(boost::ref(fnUpdate));
253 #else
254  fnUpdate();
255 #endif
256  } else {
257  processorFract.updateFractionAndEfficiencyHistos();
258  }
259 }
cscdqm::Dispatcher::processorFract
EventProcessorMutex processorFract
Definition: CSCDQM_Dispatcher.h:172
config
Definition: config.py:1
cscdqm::EventProcessorMutex::updateFractionAndEfficiencyHistos
void updateFractionAndEfficiencyHistos()
Update Fraction and Efficiency histograms.
Definition: CSCDQM_Dispatcher.h:75
void cscdqm::Dispatcher::updateFractionAndEfficiencyHistosAuto ( )
private

Automatically called fraction and efficiency MOs update function.

Returns

Definition at line 235 of file CSCDQM_Dispatcher.cc.

References updateFractionAndEfficiencyHistos().

Referenced by processStandby().

235  {
236  if ( config->getFRAEFF_AUTO_UPDATE() &&
237  (config->getNEventsCSC() >= config->getFRAEFF_AUTO_UPDATE_START()) &&
238  (config->getNEventsCSC() % config->getFRAEFF_AUTO_UPDATE_FREQ()) == 0) {
239  updateFractionAndEfficiencyHistos();
240  }
241 }
cscdqm::Dispatcher::updateFractionAndEfficiencyHistos
void updateFractionAndEfficiencyHistos()
On demand update fraction and efficiency MOs.
Definition: CSCDQM_Dispatcher.cc:247
config
Definition: config.py:1

Member Data Documentation

Cache cscdqm::Dispatcher::cache
private

MO Cache object

Definition at line 169 of file CSCDQM_Dispatcher.h.

Referenced by book(), commonConstruct(), and getHisto().

Collection cscdqm::Dispatcher::collection
private

MO Collection object

Definition at line 163 of file CSCDQM_Dispatcher.h.

Referenced by book(), Dispatcher(), getHisto(), and init().

Configuration* cscdqm::Dispatcher::config
private

Pointer to Global Configuration

Definition at line 157 of file CSCDQM_Dispatcher.h.

EventProcessor cscdqm::Dispatcher::processor
private

Event Processor object

Definition at line 166 of file CSCDQM_Dispatcher.h.

Referenced by book(), Dispatcher(), and processStandby().

EventProcessorMutex cscdqm::Dispatcher::processorFract
private

Lockable Fractional and Efficiency MO update object

Definition at line 172 of file CSCDQM_Dispatcher.h.

Referenced by Dispatcher(), maskHWElements(), processStandby(), and updateFractionAndEfficiencyHistos().

MonitorObjectProvider* cscdqm::Dispatcher::provider
private

Pointer to MO provider

Definition at line 160 of file CSCDQM_Dispatcher.h.

Referenced by book(), commonConstruct(), and getHisto().

Generated for CMSSW Reference Manual by doxygen 1.8.11