ESRawDataTask.cc

Go to the documentation of this file.

#include <iostream>
#include <fstream>
#include <vector>
 
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/Framework/interface/Frameworkfwd.h"
 
#include "DQMServices/Core/interface/DQMStore.h"
 
#include "DataFormats/FEDRawData/interface/FEDRawData.h"
#include "DataFormats/FEDRawData/interface/FEDHeader.h"
#include "DataFormats/FEDRawData/interface/FEDTrailer.h"
#include "DataFormats/FEDRawData/interface/FEDNumbering.h"
 
#include "DataFormats/DetId/interface/DetId.h"
#include "DataFormats/EcalDetId/interface/ESDetId.h"
#include "DataFormats/EcalDigi/interface/ESDataFrame.h"
#include "DataFormats/EcalRawData/interface/ESDCCHeaderBlock.h"
 
#include "DQM/EcalPreshowerMonitorModule/interface/ESRawDataTask.h"
 
using namespace cms;
using namespace edm;
using namespace std;
 
ESRawDataTask::ESRawDataTask(const ParameterSet& ps) {
  prefixME_ = ps.getUntrackedParameter<string>("prefixME", "");
 
  FEDRawDataCollection_ = consumes<FEDRawDataCollection>(ps.getParameter<InputTag>("FEDRawDataCollection"));
  dccCollections_ = consumes<ESRawDataCollection>(ps.getParameter<InputTag>("ESDCCCollections"));
 
  ievt_ = 0;
}
 
void ESRawDataTask::bookHistograms(DQMStore::IBooker& iBooker, Run const&, EventSetup const&) {
  char histo[200];
 
  iBooker.setCurrentFolder(prefixME_ + "/ESRawDataTask");
 
  //sprintf(histo, "ES run number errors");
  //meRunNumberErrors_ = iBooker.book1D(histo, histo, 56, 519.5, 575.5);
  //meRunNumberErrors_->setAxisTitle("ES FED", 1);
  //meRunNumberErrors_->setAxisTitle("Num of Events", 2);
 
  sprintf(histo, "ES L1A DCC errors");
  meL1ADCCErrors_ = iBooker.book1D(histo, histo, 56, 519.5, 575.5);
  meL1ADCCErrors_->setAxisTitle("ES FED", 1);
  meL1ADCCErrors_->setAxisTitle("Num of Events", 2);
 
  sprintf(histo, "ES BX DCC errors");
  meBXDCCErrors_ = iBooker.book1D(histo, histo, 56, 519.5, 575.5);
  meBXDCCErrors_->setAxisTitle("ES FED", 1);
  meBXDCCErrors_->setAxisTitle("Num of Events", 2);
 
  sprintf(histo, "ES Orbit Number DCC errors");
  meOrbitNumberDCCErrors_ = iBooker.book1D(histo, histo, 56, 519.5, 575.5);
  meOrbitNumberDCCErrors_->setAxisTitle("ES FED", 1);
  meOrbitNumberDCCErrors_->setAxisTitle("Num of Events", 2);
 
  sprintf(histo, "Difference between ES and GT L1A");
  meL1ADiff_ = iBooker.book1D(histo, histo, 201, -100.5, 100.5);
  meL1ADiff_->setAxisTitle("ES - GT L1A", 1);
  meL1ADiff_->setAxisTitle("Num of Events", 2);
 
  sprintf(histo, "Difference between ES and GT BX");
  meBXDiff_ = iBooker.book1D(histo, histo, 201, -100.5, 100.5);
  meBXDiff_->setAxisTitle("ES - GT BX", 1);
  meBXDiff_->setAxisTitle("Num of Events", 2);
 
  sprintf(histo, "Difference between ES and GT Orbit Number");
  meOrbitNumberDiff_ = iBooker.book1D(histo, histo, 201, -100.5, 100.5);
  meOrbitNumberDiff_->setAxisTitle("ES - GT orbit number", 1);
  meOrbitNumberDiff_->setAxisTitle("Num of Events", 2);
}
 
void ESRawDataTask::analyze(const Event& e, const EventSetup& c) {
  ievt_++;
  runNum_ = e.id().run();
 
  int gt_L1A = 0, gt_OrbitNumber = 0, gt_BX = 0;
  int esDCC_L1A_MostFreqCounts = 0;
  int esDCC_BX_MostFreqCounts = 0;
  int esDCC_OrbitNumber_MostFreqCounts = 0;
 
  Handle<ESRawDataCollection> dccs;
  Handle<FEDRawDataCollection> allFedRawData;
 
  int gtFedDataSize = 0;
 
  if (e.getByToken(FEDRawDataCollection_, allFedRawData)) {
    // GT FED data
    const FEDRawData& gtFedData = allFedRawData->FEDData(812);
 
    gtFedDataSize = gtFedData.size() / sizeof(uint64_t);
 
    if (gtFedDataSize > 0) {
      FEDHeader header(gtFedData.data());
 
      gt_L1A = header.lvl1ID();
      gt_OrbitNumber = e.orbitNumber();
      gt_BX = e.bunchCrossing();
    } else {
      map<int, int> esDCC_L1A_FreqMap;
      map<int, int> esDCC_BX_FreqMap;
      map<int, int> esDCC_OrbitNumber_FreqMap;
 
      if (e.getByToken(dccCollections_, dccs)) {
        for (ESRawDataCollection::const_iterator dccItr = dccs->begin(); dccItr != dccs->end(); ++dccItr) {
          ESDCCHeaderBlock esdcc = (*dccItr);
 
          esDCC_L1A_FreqMap[esdcc.getLV1()]++;
          esDCC_BX_FreqMap[esdcc.getBX()]++;
          esDCC_OrbitNumber_FreqMap[esdcc.getOrbitNumber()]++;
 
          if (esDCC_L1A_FreqMap[esdcc.getLV1()] > esDCC_L1A_MostFreqCounts) {
            esDCC_L1A_MostFreqCounts = esDCC_L1A_FreqMap[esdcc.getLV1()];
            gt_L1A = esdcc.getLV1();
          }
 
          if (esDCC_BX_FreqMap[esdcc.getBX()] > esDCC_BX_MostFreqCounts) {
            esDCC_BX_MostFreqCounts = esDCC_BX_FreqMap[esdcc.getBX()];
            gt_BX = esdcc.getBX();
          }
 
          if (esDCC_OrbitNumber_FreqMap[esdcc.getOrbitNumber()] > esDCC_OrbitNumber_MostFreqCounts) {
            esDCC_OrbitNumber_MostFreqCounts = esDCC_OrbitNumber_FreqMap[esdcc.getOrbitNumber()];
            gt_OrbitNumber = esdcc.getOrbitNumber();
          }
        }
      } else {
        LogWarning("ESRawDataTask") << "dccCollections not available";
      }
    }
  } else {
    LogWarning("ESRawDataTask") << "FEDRawDataCollection not available";
  }
 
  // DCC
  vector<int> fiberStatus;
  if (e.getByToken(dccCollections_, dccs)) {
    for (ESRawDataCollection::const_iterator dccItr = dccs->begin(); dccItr != dccs->end(); ++dccItr) {
      ESDCCHeaderBlock dcc = (*dccItr);
 
      //if (dcc.getRunNumber() != runNum_) {
      //meRunNumberErrors_->Fill(dcc.fedId());
      //cout<<"Run # err : "<<dcc.getRunNumber()<<" "<<runNum_<<endl;
      //}
 
      if (dcc.getLV1() != gt_L1A) {
        meL1ADCCErrors_->Fill(dcc.fedId());
        //cout<<"L1A err : "<<dcc.getLV1()<<" "<<gt_L1A<<endl;
        Float_t l1a_diff = dcc.getLV1() - gt_L1A;
        if (l1a_diff > 100)
          l1a_diff = 100;
        else if (l1a_diff < -100)
          l1a_diff = -100;
        meL1ADiff_->Fill(l1a_diff);
      }
 
      if (dcc.getBX() != gt_BX) {
        meBXDCCErrors_->Fill(dcc.fedId());
        //cout<<"BX err : "<<dcc.getBX()<<" "<<gt_BX<<endl;
        Float_t bx_diff = dcc.getBX() - gt_BX;
        if (bx_diff > 100)
          bx_diff = 100;
        else if (bx_diff < -100)
          bx_diff = -100;
        meBXDiff_->Fill(bx_diff);
      }
      if (dcc.getOrbitNumber() != gt_OrbitNumber) {
        meOrbitNumberDCCErrors_->Fill(dcc.fedId());
        //cout<<"Orbit err : "<<dcc.getOrbitNumber()<<" "<<gt_OrbitNumber<<endl;
        Float_t orbitnumber_diff = dcc.getOrbitNumber() - gt_OrbitNumber;
        if (orbitnumber_diff > 100)
          orbitnumber_diff = 100;
        else if (orbitnumber_diff < -100)
          orbitnumber_diff = -100;
        meOrbitNumberDiff_->Fill(orbitnumber_diff);
      }
    }
  }
}
 
DEFINE_FWK_MODULE(ESRawDataTask);