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      

  };

}

#endif