CSCDQM_Dispatcher.h

Go to the documentation of this file.

 
/*
 * =====================================================================================
 *
 *       Filename:  CSCDQM_Dispatcher.h
 *
 *    Description:  CSCDQM Framework frontend and Histogram Cache controller
 *
 *        Version:  1.0
 *        Created:  10/03/2008 10:26:04 AM
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  Valdas Rapsevicius, valdas.rapsevicius@cern.ch
 *        Company:  CERN, CH
 *
 * =====================================================================================
 */
 
#ifndef CSCDQM_Dispatcher_H
#define CSCDQM_Dispatcher_H
 
#include <typeinfo>
 
#ifdef DQMMT
#include <boost/thread.hpp>
#endif
 
#include "CSCDQM_Configuration.h"
#include "CSCDQM_EventProcessor.h"
#include "CSCDQM_Collection.h"
#include "CSCDQM_HistoDef.h"
#include "CSCDQM_Cache.h"
#include "CSCDQM_Logger.h"
#include "CSCDQM_Lock.h"
 
namespace cscdqm {
 
  class EventProcessorMutex : public Lock {
  private:
    EventProcessor processor;
 
    Configuration* config;
 
    bool fullStandbyProcessed;
 
    HWStandbyType lastStandby;
 
  public:
    EventProcessorMutex(Configuration* const p_config) : processor(p_config) {
      config = p_config;
      fullStandbyProcessed = false;
    }
 
    void updateFractionAndEfficiencyHistos() {
      LockType lock(mutex);
      config->updateFraTimer(true);
      processor.updateFractionHistos();
      config->updateFraTimer(false);
      if (config->getPROCESS_EFF_HISTOS()) {
        config->updateEffTimer(true);
        processor.updateEfficiencyHistos();
        config->updateEffTimer(false);
      }
    }
 
    unsigned int maskHWElements(std::vector<std::string>& tokens) { return processor.maskHWElements(tokens); }
 
    void processStandby(HWStandbyType& standby) {
      if (lastStandby != standby) {
        processor.standbyEfficiencyHistos(standby);
        if (config->getIN_FULL_STANDBY()) {
          // Lets mark CSCs as BAD - have not ever ever been in !STANDBY
          if (!fullStandbyProcessed) {
            processor.standbyEfficiencyHistos(standby);
            processor.writeShifterHistograms();
            fullStandbyProcessed = true;
          }
        }
        lastStandby = standby;
      }
    }
  };
 
  class Dispatcher {
  public:
    Dispatcher(Configuration* const p_config, MonitorObjectProvider* const p_provider);
 
#ifdef DQMGLOBAL
    Dispatcher(Configuration* const p_config,
               MonitorObjectProvider* const p_provider,
               const edm::InputTag& itag,
               edm::ConsumesCollector&& coco);
#endif
 
    ~Dispatcher() {
#ifdef DQMMT
      threads.join_all();
#endif
    }
 
    void init();
    void book();
    void updateFractionAndEfficiencyHistos();
    const bool getHisto(const HistoDef& histoD, MonitorObject*& me);
    unsigned int maskHWElements(std::vector<std::string>& tokens);
    void processStandby(HWStandbyType& standby);
 
  private:
    // Old content of ctor into separate function so it can be called by both ctors
    void commonConstruct(Configuration* const p_config, MonitorObjectProvider* const p_provider);
 
    void updateFractionAndEfficiencyHistosAuto();
 
    Configuration* config;
 
    MonitorObjectProvider* provider;
 
    Collection collection;
 
    EventProcessor processor;
 
    Cache cache;
 
    EventProcessorMutex processorFract;
 
#ifdef DQMMT
 
    boost::thread_group threads;
 
#endif
 
#ifdef DQMLOCAL
 
  public:
    void processEvent(const char* data, const int32_t dataSize, const uint32_t errorStat, const int32_t nodeNumber);
 
#endif
 
#ifdef DQMGLOBAL
 
  public:
    void processEvent(const edm::Event& e, const edm::InputTag& inputTag, HWStandbyType& standby);
 
#endif
  };
 
}  // namespace cscdqm
 
#endif