CSCDQM_EventProcessor.h

Go to the documentation of this file.

/*
 * =====================================================================================
 *
 *       Filename:  EventProcessor.h
 *
 *    Description:  Object which processes Event and provides Hits to
 *    HitHandler object.
 *
 *        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_EventProcessor_H
#define CSCDQM_EventProcessor_H

#include <set>
#include <string>
#include <cmath>

#include <TString.h>

#ifdef DQMGLOBAL

#include "FWCore/Framework/interface/ConsumesCollector.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Utilities/interface/InputTag.h"
#include "DataFormats/FEDRawData/interface/FEDNumbering.h"
#include "DataFormats/FEDRawData/interface/FEDRawDataCollection.h"
#include "EventFilter/CSCRawToDigi/interface/CSCDCCEventData.h"

#endif

#include "CSCDQM_Logger.h"
#include "CSCDQM_Summary.h"
#include "CSCDQM_StripClusterFinder.h"
#include "CSCDQM_Configuration.h"
#include "CSCDQM_Configuration.h"

#include "EventFilter/CSCRawToDigi/interface/CSCDCCExaminer.h"
#include "EventFilter/CSCRawToDigi/interface/CSCDDUEventData.h"
#include "EventFilter/CSCRawToDigi/interface/CSCCFEBTimeSlice.h"
#include "EventFilter/CSCRawToDigi/interface/CSCCFEBData.h"

#include "DataFormats/CSCDigi/interface/CSCDCCFormatStatusDigi.h"
#include "DataFormats/CSCDigi/interface/CSCDCCFormatStatusDigiCollection.h"

namespace cscdqm {

  struct HWStandbyType {
    // if standby flag should be considered at all?
    // at the start it will be false, thus good for last value ;)
    bool process;

    // ME+
    bool MeP;

    // ME-
    bool MeM;

    HWStandbyType() { process = MeP = MeM = false; }

    void applyMeP(bool ready) { MeP = MeP || !ready; }

    void applyMeM(bool ready) { MeM = MeM || !ready; }

    bool fullStandby() const { return (MeM && MeP); }

    bool operator==(const HWStandbyType& t) const { return (t.MeP == MeP && t.MeM == MeM && t.process == process); }

    bool operator!=(const HWStandbyType& t) const { return !(*this == t); }

    const HWStandbyType& operator=(const HWStandbyType& t) {
      MeP = t.MeP;
      MeM = t.MeM;
      process = t.process;
      return *this;
    }
  };

  typedef std::map<CSCIdType, ExaminerStatusType> CSCExaminerMapType;
  typedef std::vector<DDUIdType> DDUExaminerVectorType;
  // typedef std::map<int, long> CSCExaminerMapType;
  // typedef std::vector<int>    DDUExaminerVectorType;

  class EventProcessor {
    // ===================================================================================================
    // General stuff
    // ===================================================================================================

  public:
    EventProcessor(Configuration* const p_config);

#ifdef DQMGLOBAL

    EventProcessor(Configuration* const p_config, const edm::InputTag& itag, edm::ConsumesCollector& coco);

#endif

    ~EventProcessor() {}

    void init();

    void updateFractionHistos();
    void updateEfficiencyHistos();
    void standbyEfficiencyHistos(HWStandbyType& standby);
    void writeShifterHistograms();

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

  private:
    bool processExaminer(const CSCDCCExaminer& binChecker);
    bool processExaminer(const CSCDCCExaminer& binChecker, const CSCDCCFormatStatusDigi& digi);
    void processDDU(const CSCDDUEventData& data, const CSCDCCExaminer& binChecker);
    void processCSC(const CSCEventData& data, const int dduID, const CSCDCCExaminer& binChecker);

    void calcEMUFractionHisto(const HistoId& result, const HistoId& set, const HistoId& subset);

    const bool getEMUHisto(const HistoId& histo, MonitorObject*& me);
    const bool getFEDHisto(const HistoId& histo, const HwId& fedID, MonitorObject*& me);
    const bool getDDUHisto(const HistoId& histo, const HwId& dduID, MonitorObject*& me);
    const bool getCSCHisto(const HistoId& histo, const HwId& crateID, const HwId& dmbSlot, MonitorObject*& me);
    const bool getCSCHisto(
        const HistoId& histo, const HwId& crateID, const HwId& dmbSlot, const HwId& adId, MonitorObject*& me);
    const bool getParHisto(const HistoId& histo, MonitorObject*& me);
    void preProcessEvent();

    const bool getCSCFromMap(const unsigned int& crateId,
                             const unsigned int& dmbId,
                             unsigned int& cscType,
                             unsigned int& cscPosition) const;
    void setEmuEventDisplayBit(MonitorObject*& mo, const unsigned int x, const unsigned int y, const unsigned int bit);
    void resetEmuEventDisplays();

    Configuration* config;

    Summary summary;

    std::map<uint32_t, uint32_t> L1ANumbers;
    std::map<uint32_t, bool> fNotFirstEvent;
    uint32_t L1ANumber;
    uint32_t BXN;
    uint32_t cntDMBs;   
    uint32_t cntCFEBs;  
    uint32_t cntALCTs;  
    uint32_t cntTMBs;   

    uint16_t theFormatVersion;  

    // bool fFirstEvent;
    bool fCloseL1As;  // Close L1A bit from DDU Trailer
    bool EmuEventDisplayWasReset;

    // token for input
    edm::EDGetTokenT<FEDRawDataCollection> frdtoken;

    // ===================================================================================================
    // Local ONLY stuff
    // ===================================================================================================

#ifdef DQMLOCAL

  public:
    void processEvent(const char* data, const int32_t dataSize, const uint32_t errorStat, const int32_t nodeNumber);

#endif

    // ===================================================================================================
    // Global ONLY stuff
    // ===================================================================================================

#ifdef DQMGLOBAL

  private:
    bool bCSCEventCounted;

  public:
    void processEvent(const edm::Event& e, const edm::InputTag& inputTag);

#endif
  };

}  // namespace cscdqm

#endif