LaserTask.cc

Go to the documentation of this file.

#include "DQM/HcalTasks/interface/LaserTask.h"

using namespace hcaldqm;
using namespace hcaldqm::constants;
using namespace hcaldqm::filter;
LaserTask::LaserTask(edm::ParameterSet const& ps):
    DQTask(ps)
{
    _nevents = ps.getUntrackedParameter<int>("nevents", 2000);

    //  tags
    _tagHBHE = ps.getUntrackedParameter<edm::InputTag>("tagHBHE",
        edm::InputTag("hcalDigis"));
    _tagHE = ps.getUntrackedParameter<edm::InputTag>("tagHE",
        edm::InputTag("hcalDigis"));
    _tagHO = ps.getUntrackedParameter<edm::InputTag>("tagHO",
        edm::InputTag("hcalDigis"));
    _tagHF = ps.getUntrackedParameter<edm::InputTag>("tagHF",
        edm::InputTag("hcalDigis"));
    _taguMN = ps.getUntrackedParameter<edm::InputTag>("taguMN",
        edm::InputTag("hcalDigis"));
    _tokHBHE = consumes<HBHEDigiCollection>(_tagHBHE);
    _tokHEP17 = consumes<QIE11DigiCollection>(_tagHE);
    _tokHO = consumes<HODigiCollection>(_tagHO);
    _tokHF = consumes<QIE10DigiCollection>(_tagHF);
    _tokuMN = consumes<HcalUMNioDigi>(_taguMN);

    //  constants
    _lowHBHE = ps.getUntrackedParameter<double>("lowHBHE",
        20);
    _lowHEP17 = ps.getUntrackedParameter<double>("lowHEP17",
        20);
    _lowHO = ps.getUntrackedParameter<double>("lowHO",
        20);
    _lowHF = ps.getUntrackedParameter<double>("lowHF",
        20);
    _laserType = (uint32_t)ps.getUntrackedParameter<uint32_t>("laserType");
}
    
/* virtual */ void LaserTask::bookHistograms(DQMStore::IBooker &ib,
    edm::Run const& r, edm::EventSetup const& es)
{
    if (_ptype==fLocal)
        if (r.runAuxiliary().run()==1)
            return;

    DQTask::bookHistograms(ib, r, es);
    
    edm::ESHandle<HcalDbService> dbService;
    es.get<HcalDbRecord>().get(dbService);
    _emap = dbService->getHcalMapping();

    std::vector<uint32_t> vhashVME;
    std::vector<uint32_t> vhashuTCA;
    std::vector<uint32_t> vhashC36;
    vhashVME.push_back(HcalElectronicsId(constants::FIBERCH_MIN,
        constants::FIBER_VME_MIN, SPIGOT_MIN, CRATE_VME_MIN).rawId());
    vhashuTCA.push_back(HcalElectronicsId(CRATE_uTCA_MIN, SLOT_uTCA_MIN,
        FIBER_uTCA_MIN1, FIBERCH_MIN, false).rawId());
    _filter_VME.initialize(filter::fFilter, hcaldqm::hashfunctions::fElectronics,
        vhashVME);
    _filter_uTCA.initialize(filter::fFilter, hcaldqm::hashfunctions::fElectronics,
        vhashuTCA);

    //  INITIALIZE
    _cSignalMean_Subdet.initialize(_name, "SignalMean",
        hcaldqm::hashfunctions::fSubdet, 
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fQIE10fC_100000Coarse),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN, true),0);
    _cSignalRMS_Subdet.initialize(_name, "SignalRMS",
        hcaldqm::hashfunctions::fSubdet, 
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_1000),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN, true),0);
    _cTimingMean_Subdet.initialize(_name, "TimingMean",
        hcaldqm::hashfunctions::fSubdet, 
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN, true),0);
    _cTimingRMS_Subdet.initialize(_name, "TimingRMS",
        hcaldqm::hashfunctions::fSubdet, 
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200), 
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN, true),0);

    _cADC_SubdetPM.initialize(_name, "ADC",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fADC_128),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN, true),0);

    if (_ptype != fOffline) { // hidefed2crate
        _cSignalMean_FEDVME.initialize(_name, "SignalMean",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberVMEFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fQIE10fC_100000Coarse),0);
        _cSignalMean_FEDuTCA.initialize(_name, "SignalMean",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberuTCAFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fQIE10fC_100000Coarse),0);
        _cSignalRMS_FEDVME.initialize(_name, "SignalRMS",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberVMEFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_3000),0);
        _cSignalRMS_FEDuTCA.initialize(_name, "SignalRMS",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberuTCAFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_3000),0);
        _cTimingMean_FEDVME.initialize(_name, "TimingMean",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberVMEFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
        _cTimingMean_FEDuTCA.initialize(_name, "TimingMean",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberuTCAFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
        _cTimingRMS_FEDVME.initialize(_name, "TimingRMS",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberVMEFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
        _cTimingRMS_FEDuTCA.initialize(_name, "TimingRMS",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberuTCAFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);

        _cShapeCut_FEDSlot.initialize(_name, "Shape", 
            hcaldqm::hashfunctions::fFEDSlot,
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_3000),0);
    }
    _cTimingvsEvent_SubdetPM.initialize(_name, "TimingvsEvent",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::EventNumber(_nevents),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
    _cSignalvsEvent_SubdetPM.initialize(_name, "SignalvsEvent",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::EventNumber(_nevents),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_3000),0);
    _cTimingvsLS_SubdetPM.initialize(_name, "TimingvsLS",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::LumiSection(_maxLS),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
    _cSignalvsLS_SubdetPM.initialize(_name, "SignalvsLS",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::LumiSection(_maxLS),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_3000),0);
    _cTimingvsBX_SubdetPM.initialize(_name, "TimingvsBX",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fBX),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
    _cSignalvsBX_SubdetPM.initialize(_name, "SignalvsBX",
        hcaldqm::hashfunctions::fSubdetPM,
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fBX),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_3000),0);

    _cSignalMean_depth.initialize(_name, "SignalMean",
        hcaldqm::hashfunctions::fdepth, 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fieta), 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fiphi),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fQIE10fC_100000Coarse),0);
    _cSignalRMS_depth.initialize(_name, "SignalRMS",
        hcaldqm::hashfunctions::fdepth, 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fieta), 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fiphi),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::ffC_1000),0);
    _cTimingMean_depth.initialize(_name, "TimingMean",
        hcaldqm::hashfunctions::fdepth, 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fieta), 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fiphi),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);
    _cTimingRMS_depth.initialize(_name, "TimingRMS",
        hcaldqm::hashfunctions::fdepth,
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fieta), 
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fiphi),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fTiming_TS200),0);

    _cMissing_depth.initialize(_name, "Missing",
        hcaldqm::hashfunctions::fdepth,
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fieta),
        new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fiphi),
        new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
    if (_ptype != fOffline) { // hidefed2crate
        _cMissing_FEDVME.initialize(_name, "Missing",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberVMEFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
        _cMissing_FEDuTCA.initialize(_name, "Missing",
            hcaldqm::hashfunctions::fFED,
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
            new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberuTCAFiberCh),
            new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
    }

    
    //  initialize compact containers
    _xSignalSum.initialize(hcaldqm::hashfunctions::fDChannel);
    _xSignalSum2.initialize(hcaldqm::hashfunctions::fDChannel);
    _xTimingSum.initialize(hcaldqm::hashfunctions::fDChannel);
    _xTimingSum2.initialize(hcaldqm::hashfunctions::fDChannel);
    _xEntries.initialize(hcaldqm::hashfunctions::fDChannel);

    //  BOOK
    _cSignalMean_Subdet.book(ib, _emap, _subsystem);
    _cSignalRMS_Subdet.book(ib, _emap, _subsystem);
    _cTimingMean_Subdet.book(ib, _emap, _subsystem);
    _cTimingRMS_Subdet.book(ib, _emap, _subsystem);

    _cSignalMean_depth.book(ib, _emap, _subsystem);
    _cSignalRMS_depth.book(ib, _emap, _subsystem);
    _cTimingMean_depth.book(ib, _emap, _subsystem);
    _cTimingRMS_depth.book(ib, _emap, _subsystem);

    if (_ptype==fLocal)
    {
        _cTimingvsEvent_SubdetPM.book(ib, _emap, _subsystem);
        _cSignalvsEvent_SubdetPM.book(ib, _emap, _subsystem);
    }
    else
    {   
        _cTimingvsLS_SubdetPM.book(ib, _emap, _subsystem);
        _cSignalvsLS_SubdetPM.book(ib, _emap, _subsystem);
        _cTimingvsBX_SubdetPM.book(ib, _emap, _subsystem);
        _cSignalvsBX_SubdetPM.book(ib, _emap, _subsystem);
    }

    if (_ptype != fOffline) { // hidefed2crate
        _cSignalMean_FEDVME.book(ib, _emap, _filter_uTCA, _subsystem);
        _cSignalMean_FEDuTCA.book(ib, _emap, _filter_VME, _subsystem);
        _cSignalRMS_FEDVME.book(ib, _emap, _filter_uTCA, _subsystem);
        _cSignalRMS_FEDuTCA.book(ib, _emap, _filter_VME, _subsystem);
        _cTimingMean_FEDVME.book(ib, _emap, _filter_uTCA, _subsystem);
        _cTimingMean_FEDuTCA.book(ib, _emap, _filter_VME, _subsystem);
        _cTimingRMS_FEDVME.book(ib, _emap, _filter_uTCA, _subsystem);
        _cTimingRMS_FEDuTCA.book(ib, _emap, _filter_VME, _subsystem);
    }
    _cADC_SubdetPM.book(ib, _emap, _subsystem);

    _cMissing_depth.book(ib, _emap,_subsystem);
    if (_ptype != fOffline) { // hidefed2crate
        _cShapeCut_FEDSlot.book(ib, _emap, _subsystem);
        _cMissing_FEDVME.book(ib, _emap, _filter_uTCA,_subsystem);
        _cMissing_FEDuTCA.book(ib, _emap, _filter_VME,_subsystem);
    }

    _xSignalSum.book(_emap);
    _xSignalSum2.book(_emap);
    _xEntries.book(_emap);
    _xTimingSum.book(_emap);
    _xTimingSum2.book(_emap);

    _ehashmap.initialize(_emap, electronicsmap::fD2EHashMap);
}

/* virtual */ void LaserTask::_resetMonitors(hcaldqm::UpdateFreq uf)
{
    DQTask::_resetMonitors(uf);
}

/* virtual */ void LaserTask::_dump()
{
    _cSignalMean_Subdet.reset();
    _cSignalRMS_Subdet.reset();
    _cTimingMean_Subdet.reset();
    _cTimingRMS_Subdet.reset();
    _cSignalMean_depth.reset();
    _cSignalRMS_depth.reset();
    _cTimingMean_depth.reset();
    _cTimingRMS_depth.reset();

    if (_ptype != fOffline) { // hidefed2crate
        _cSignalMean_FEDVME.reset();
        _cSignalMean_FEDuTCA.reset();
        _cSignalRMS_FEDVME.reset();
        _cSignalRMS_FEDuTCA.reset();
        _cTimingMean_FEDVME.reset();
        _cTimingMean_FEDuTCA.reset();
        _cTimingRMS_FEDVME.reset();
        _cTimingRMS_FEDuTCA.reset();
    }

    std::vector<HcalGenericDetId> dids = _emap->allPrecisionId();
    for (std::vector<HcalGenericDetId>::const_iterator it=dids.begin();
        it!=dids.end(); ++it)
    {
        if (!it->isHcalDetId())
            continue;
        HcalDetId did = HcalDetId(it->rawId());
        HcalElectronicsId eid(_ehashmap.lookup(*it));
        int n = _xEntries.get(did);
        //  channels missing or low signal
        if (n==0)
        {
            _cMissing_depth.fill(did);
            if (_ptype != fOffline) { // hidefed2crate
                if (eid.isVMEid())
                    _cMissing_FEDVME.fill(eid);
                else
                    _cMissing_FEDuTCA.fill(eid);
            }
            continue;
        }

        double msig = _xSignalSum.get(did)/n; 
        double mtim = _xTimingSum.get(did)/n;
        double rsig = sqrt(_xSignalSum2.get(did)/n-msig*msig);
        double rtim = sqrt(_xTimingSum2.get(did)/n-mtim*mtim);

        _cSignalMean_Subdet.fill(did, msig);
        _cSignalMean_depth.fill(did, msig);
        _cSignalRMS_Subdet.fill(did, rsig);
        _cSignalRMS_depth.fill(did, rsig);
        _cTimingMean_Subdet.fill(did, mtim);
        _cTimingMean_depth.fill(did, mtim);
        _cTimingRMS_Subdet.fill(did, rtim);
        _cTimingRMS_depth.fill(did, rtim);
        if (_ptype != fOffline) { // hidefed2crate
            if (eid.isVMEid())
            {
                _cSignalMean_FEDVME.fill(eid, msig);
                _cSignalRMS_FEDVME.fill(eid, rsig);
                _cTimingMean_FEDVME.fill(eid, mtim);
                _cTimingRMS_FEDVME.fill(eid, rtim);
            }
            else
            {
                _cSignalMean_FEDuTCA.fill(eid, msig);
                _cSignalRMS_FEDuTCA.fill(eid, rsig);
                _cTimingMean_FEDuTCA.fill(eid, mtim);
                _cTimingRMS_FEDuTCA.fill(eid, rtim);
            }
        }
    }
}

/* virtual */ void LaserTask::_process(edm::Event const& e,
    edm::EventSetup const& es)
{
    edm::Handle<HBHEDigiCollection>     chbhe;
    edm::Handle<QIE11DigiCollection>        chep17;
    edm::Handle<HODigiCollection>       cho;
    edm::Handle<QIE10DigiCollection>        chf;

    if (!e.getByToken(_tokHBHE, chbhe))
        _logger.dqmthrow("Collection HBHEDigiCollection isn't available "
            + _tagHBHE.label() + " " + _tagHBHE.instance());
    if (!e.getByToken(_tokHEP17, chep17))
        _logger.dqmthrow("Collection QIE11DigiCollection isn't available "
            + _tagHE.label() + " " + _tagHE.instance());
    if (!e.getByToken(_tokHO, cho))
        _logger.dqmthrow("Collection HODigiCollection isn't available "
            + _tagHO.label() + " " + _tagHO.instance());
    if (!e.getByToken(_tokHF, chf))
        _logger.dqmthrow("Collection QIE10DigiCollection isn't available "
            + _tagHF.label() + " " + _tagHF.instance());

//  int currentEvent = e.eventAuxiliary().id().event();
    int bx = e.bunchCrossing();
    
    for (HBHEDigiCollection::const_iterator it=chbhe->begin();
        it!=chbhe->end(); ++it)
    {
        const HBHEDataFrame digi = (const HBHEDataFrame)(*it);
        double sumQ = hcaldqm::utilities::sumQ<HBHEDataFrame>(digi, 2.5, 0, 
            digi.size()-1);
        if (sumQ<_lowHBHE)
            continue;
        HcalDetId did = digi.id();
        HcalElectronicsId eid = digi.elecId();

        double aveTS = hcaldqm::utilities::aveTS<HBHEDataFrame>(digi, 2.5, 0,
            digi.size()-1);
        _xSignalSum.get(did)+=sumQ;
        _xSignalSum2.get(did)+=sumQ*sumQ;
        _xTimingSum.get(did)+=aveTS;
        _xTimingSum2.get(did)+=aveTS*aveTS;
        _xEntries.get(did)++;

        for (int i=0; i<digi.size(); i++)
        {
            if (_ptype != fOffline) { // hidefed2crate
                _cShapeCut_FEDSlot.fill(eid, i, 
                    digi.sample(i).nominal_fC()-2.5);
            }
            _cADC_SubdetPM.fill(did, digi.sample(i).adc());
        }

        //  select based on local global
        if (_ptype==fLocal)
        {
            int currentEvent = e.eventAuxiliary().id().event();
            _cTimingvsEvent_SubdetPM.fill(did, currentEvent, aveTS);
            _cSignalvsEvent_SubdetPM.fill(did, currentEvent, sumQ);
        }
        else
        {
            _cTimingvsLS_SubdetPM.fill(did, _currentLS, aveTS);
            _cSignalvsLS_SubdetPM.fill(did, _currentLS, sumQ);
            _cTimingvsBX_SubdetPM.fill(did, bx, aveTS);
            _cSignalvsBX_SubdetPM.fill(did, bx, sumQ);
        }
    }
    for (QIE11DigiCollection::const_iterator it=chep17->begin(); it!=chep17->end();
        ++it)
    {
        const QIE11DataFrame digi = static_cast<const QIE11DataFrame>(*it);
        HcalDetId const& did = digi.detid();
        if (did.subdet() != HcalEndcap) {
            continue;
        }
        uint32_t rawid = _ehashmap.lookup(did);
        HcalElectronicsId const& eid(rawid);

        CaloSamples digi_fC = hcaldqm::utilities::loadADC2fCDB<QIE11DataFrame>(_dbService, did, digi);
        //double sumQ = hcaldqm::utilities::sumQ_v10<QIE11DataFrame>(digi, 2.5, 0, digi.samples()-1);
        double sumQ = hcaldqm::utilities::sumQDB<QIE11DataFrame>(_dbService, digi_fC, did, digi, 0, digi.samples()-1);
        if (sumQ<_lowHEP17)
            continue;


        //double aveTS = hcaldqm::utilities::aveTS_v10<QIE11DataFrame>(digi, 2.5, 0,digi.samples()-1);
        double aveTS = hcaldqm::utilities::aveTSDB<QIE11DataFrame>(_dbService, digi_fC, did, digi, 0, digi.size()-1);
        _xSignalSum.get(did)+=sumQ;
        _xSignalSum2.get(did)+=sumQ*sumQ;
        _xTimingSum.get(did)+=aveTS;
        _xTimingSum2.get(did)+=aveTS*aveTS;
        _xEntries.get(did)++;

        for (int i=0; i<digi.samples(); i++)
        {
            _cShapeCut_FEDSlot.fill(eid, i, hcaldqm::utilities::adc2fCDBMinusPedestal<QIE11DataFrame>(_dbService, digi_fC, did, digi, i));
            _cADC_SubdetPM.fill(did, digi[i].adc());
        }

        //  select based on local global
        if (_ptype==fLocal)
        {
            int currentEvent = e.eventAuxiliary().id().event();
            _cTimingvsEvent_SubdetPM.fill(did, currentEvent, aveTS);
            _cSignalvsEvent_SubdetPM.fill(did, currentEvent, sumQ);
        }
        else
        {
            _cTimingvsLS_SubdetPM.fill(did, _currentLS, aveTS);
            _cSignalvsLS_SubdetPM.fill(did, _currentLS, sumQ);
            _cTimingvsBX_SubdetPM.fill(did, bx, aveTS);
            _cSignalvsBX_SubdetPM.fill(did, bx, sumQ);
        }
    }
    for (HODigiCollection::const_iterator it=cho->begin();
        it!=cho->end(); ++it)
    {
        const HODataFrame digi = (const HODataFrame)(*it);
        double sumQ = hcaldqm::utilities::sumQ<HODataFrame>(digi, 8.5, 0, 
            digi.size()-1);
        if (sumQ<_lowHO)
            continue;
        HcalDetId did = digi.id();
        HcalElectronicsId eid = digi.elecId();

        double aveTS = hcaldqm::utilities::aveTS<HODataFrame>(digi, 8.5, 0,
            digi.size()-1);
        _xSignalSum.get(did)+=sumQ;
        _xSignalSum2.get(did)+=sumQ*sumQ;
        _xTimingSum.get(did)+=aveTS;
        _xTimingSum2.get(did)+=aveTS*aveTS;
        _xEntries.get(did)++;

        for (int i=0; i<digi.size(); i++)
        {
            if (_ptype != fOffline) { // hidefed2crate
                _cShapeCut_FEDSlot.fill(eid, i, 
                    digi.sample(i).nominal_fC()-8.5);
            }
            _cADC_SubdetPM.fill(did, digi.sample(i).adc());
        }

        //  select based on local global
        if (_ptype==fLocal)
        {
            int currentEvent = e.eventAuxiliary().id().event();
            _cTimingvsEvent_SubdetPM.fill(did, currentEvent, aveTS);
            _cSignalvsEvent_SubdetPM.fill(did, currentEvent, sumQ);
        }
        else
        {
            _cTimingvsLS_SubdetPM.fill(did, _currentLS, aveTS);
            _cSignalvsLS_SubdetPM.fill(did, _currentLS, sumQ);
            _cTimingvsBX_SubdetPM.fill(did, bx, aveTS);
            _cSignalvsBX_SubdetPM.fill(did, bx, sumQ);
        }
    }
    for (QIE10DigiCollection::const_iterator it=chf->begin();
        it!=chf->end(); ++it)
    {
        const QIE10DataFrame digi = (const QIE10DataFrame)(*it);
        HcalDetId did = digi.detid();
        if (did.subdet() != HcalForward) {
            continue;
        }
        HcalElectronicsId eid = HcalElectronicsId(_ehashmap.lookup(did));

        CaloSamples digi_fC = hcaldqm::utilities::loadADC2fCDB<QIE10DataFrame>(_dbService, did, digi);
        double sumQ = hcaldqm::utilities::sumQDB<QIE10DataFrame>(_dbService, digi_fC, did, digi, 0, digi.samples()-1);
        //double sumQ = hcaldqm::utilities::sumQ_v10<QIE10DataFrame>(digi, 2.5, 0, digi.samples()-1);
        if (sumQ<_lowHF)
            continue;

        //double aveTS = hcaldqm::utilities::aveTS_v10<QIE10DataFrame>(digi, 2.5, 0, digi.samples()-1);
        double aveTS = hcaldqm::utilities::aveTSDB<QIE10DataFrame>(_dbService, digi_fC, did, digi, 0, digi.size()-1);
        
        _xSignalSum.get(did)+=sumQ;
        _xSignalSum2.get(did)+=sumQ*sumQ;
        _xTimingSum.get(did)+=aveTS;
        _xTimingSum2.get(did)+=aveTS*aveTS;
        _xEntries.get(did)++;

        for (int i=0; i<digi.samples(); i++)
        {
            if (_ptype != fOffline) { // hidefed2crate
                _cShapeCut_FEDSlot.fill(eid, (int)i, hcaldqm::utilities::adc2fCDBMinusPedestal<QIE10DataFrame>(_dbService, digi_fC, did, digi, i));
            }
            _cADC_SubdetPM.fill(did, digi[i].adc());
        }

        //  select based on local global
        if (_ptype==fLocal)
        {
            int currentEvent = e.eventAuxiliary().id().event();
            _cTimingvsEvent_SubdetPM.fill(did, currentEvent, aveTS);
            _cSignalvsEvent_SubdetPM.fill(did, currentEvent, sumQ);
        }
        else
        {
            _cTimingvsLS_SubdetPM.fill(did, _currentLS, aveTS);
            _cSignalvsLS_SubdetPM.fill(did, _currentLS, sumQ);
            _cTimingvsBX_SubdetPM.fill(did, bx, aveTS);
            _cSignalvsBX_SubdetPM.fill(did, bx, sumQ);
        }
    }
}

/* virtual */ void LaserTask::endLuminosityBlock(edm::LuminosityBlock const& lb,
    edm::EventSetup const& es)
{
    if (_ptype==fLocal)
        return;
    this->_dump();

    DQTask::endLuminosityBlock(lb, es);
}

/* virtual */ bool LaserTask::_isApplicable(edm::Event const& e)
{
    if (_ptype!=fOnline)
        return true;
    else 
    {
        //  fOnline mode
        edm::Handle<HcalUMNioDigi> cumn;
        if (!e.getByToken(_tokuMN, cumn))
            return false;
        
        //  event type check first
        uint8_t eventType = cumn->eventType();
        if (eventType!=constants::EVENTTYPE_LASER)
            return false;

        //  check if this analysis task is of the right laser type
        uint32_t laserType = cumn->valueUserWord(0);
        if (laserType==_laserType) return true;
    }

    return false;
}

DEFINE_FWK_MODULE(LaserTask);