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