HcalBeamMonitor.cc

Go to the documentation of this file.

#include "DQM/HcalMonitorTasks/interface/HcalBeamMonitor.h"
#include "CondFormats/HcalObjects/interface/HcalChannelQuality.h"
#include "CondFormats/DataRecord/interface/HcalChannelQualityRcd.h"
#include "Geometry/HcalTowerAlgo/src/HcalHardcodeGeometryData.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/Framework/interface/LuminosityBlock.h"
#include "FWCore/Framework/interface/Run.h"

#include <iomanip>
#include <cmath>

// define sizes of ieta arrays for each subdetector

#define PI        3.1415926535897932
#define HBETASIZE 34  // one more bin than needed, I think
#define HEETASIZE 60  // ""
#define HOETASIZE 32  // ""
#define HFETASIZE 84  // ""

/*  Task calculates various moments of Hcal recHits 

    v1.0
    16 August 2008
    by Jeff Temple

*/

// constructor
HcalBeamMonitor::HcalBeamMonitor(const edm::ParameterSet& ps):
  ETA_OFFSET_HB(16),
  ETA_OFFSET_HE(29),
  ETA_BOUND_HE(17),
  ETA_OFFSET_HO(15),
  ETA_OFFSET_HF(41),
  ETA_BOUND_HF(29)
{
  Online_                = ps.getUntrackedParameter<bool>("online",false);
  mergeRuns_             = ps.getUntrackedParameter<bool>("mergeRuns",false);
  enableCleanup_         = ps.getUntrackedParameter<bool>("enableCleanup",false);
  debug_                 = ps.getUntrackedParameter<int>("debug",0);
  prefixME_              = ps.getUntrackedParameter<std::string>("subSystemFolder","Hcal/");
  if (prefixME_.substr(prefixME_.size()-1,prefixME_.size())!="/")
    prefixME_.append("/");
  subdir_                = ps.getUntrackedParameter<std::string>("TaskFolder","BeamMonitor_Hcal");
  if (subdir_.size()>0 && subdir_.substr(subdir_.size()-1,subdir_.size())!="/")
    subdir_.append("/");
  subdir_=prefixME_+subdir_;
  AllowedCalibTypes_     = ps.getUntrackedParameter<std::vector<int> > ("AllowedCalibTypes");
  skipOutOfOrderLS_      = ps.getUntrackedParameter<bool>("skipOutOfOrderLS",true);
  NLumiBlocks_           = ps.getUntrackedParameter<int>("NLumiBlocks",4000);
  makeDiagnostics_       = ps.getUntrackedParameter<bool>("makeDiagnostics",false);

  // Beam Monitor-specific stuff

  // Collection type info
  digiLabel_             =ps.getUntrackedParameter<edm::InputTag>("digiLabel");
  tok_hfdigi_ = consumes<HFDigiCollection>(digiLabel_);
  hbheRechitLabel_       = ps.getUntrackedParameter<edm::InputTag>("hbheRechitLabel");

  tok_hbhe_ = consumes<HBHERecHitCollection>(hbheRechitLabel_);

  hoRechitLabel_         = ps.getUntrackedParameter<edm::InputTag>("hoRechitLabel");
  tok_ho_ = consumes<HORecHitCollection>(hoRechitLabel_);

  hfRechitLabel_         = ps.getUntrackedParameter<edm::InputTag>("hfRechitLabel");
  tok_hf_ = consumes<HFRecHitCollection>(hfRechitLabel_);

  // minimum events required in lumi block for tests to be processed
  minEvents_       = ps.getUntrackedParameter<int>("minEvents",500); 
  lumiqualitydir_ = ps.getUntrackedParameter<std::string>("lumiqualitydir","");
  if (lumiqualitydir_.size()>0 && lumiqualitydir_.substr(lumiqualitydir_.size()-1,lumiqualitydir_.size())!="/")
    lumiqualitydir_.append("/");
  occThresh_ = ps.getUntrackedParameter<double>("occupancyThresh",0.0625);  // energy required to be counted by dead/hot checks
  hotrate_        = ps.getUntrackedParameter<double>("hotrate",0.25);
  minBadCells_    = ps.getUntrackedParameter<int>("minBadCells",10);
  Overwrite_      = ps.getUntrackedParameter<bool>("Overwrite",false);
  setupDone_      = false;
}



HcalBeamMonitor::~HcalBeamMonitor() {}

void HcalBeamMonitor::reset() 
{
  CenterOfEnergyRadius->Reset();
  CenterOfEnergy->Reset();
  COEradiusVSeta->Reset();

  HBCenterOfEnergyRadius->Reset();
  HBCenterOfEnergy->Reset();
  HECenterOfEnergyRadius->Reset();
  HECenterOfEnergy->Reset();
  HOCenterOfEnergyRadius->Reset();
  HOCenterOfEnergy->Reset();
  HFCenterOfEnergyRadius->Reset();
  HFCenterOfEnergy->Reset();

  Etsum_eta_L->Reset();
  Etsum_eta_S->Reset();
  Etsum_phi_L->Reset();
  Etsum_phi_S->Reset();
  Etsum_ratio_p->Reset();
  Etsum_ratio_m->Reset();
  Etsum_map_L->Reset();
  Etsum_map_S->Reset();
  Etsum_ratio_map->Reset();
  Etsum_rphi_L->Reset();
  Etsum_rphi_S->Reset();
  Energy_Occ->Reset();

  Occ_rphi_L->Reset();
  Occ_rphi_S->Reset();
  Occ_eta_L->Reset();
  Occ_eta_S->Reset();
  Occ_phi_L->Reset();
  Occ_phi_S->Reset();
  Occ_map_L->Reset();
  Occ_map_S->Reset();
  
  HFlumi_ETsum_perwedge->Reset();
  HFlumi_Occupancy_above_thr_r1->Reset();
  HFlumi_Occupancy_between_thrs_r1->Reset();
  HFlumi_Occupancy_below_thr_r1->Reset();
  HFlumi_Occupancy_above_thr_r2->Reset();
  HFlumi_Occupancy_between_thrs_r2->Reset();
  HFlumi_Occupancy_below_thr_r2->Reset();

  HFlumi_Occupancy_per_channel_vs_lumiblock_RING1->Reset();
  HFlumi_Occupancy_per_channel_vs_lumiblock_RING2->Reset();
  HFlumi_Occupancy_per_channel_vs_BX_RING1->Reset();
  HFlumi_Occupancy_per_channel_vs_BX_RING2->Reset();
  HFlumi_ETsum_vs_BX->Reset();
  HFlumi_Et_per_channel_vs_lumiblock->Reset();

  HFlumi_occ_LS->Reset();
  HFlumi_total_hotcells->Reset();
  HFlumi_total_deadcells->Reset();
  HFlumi_diag_hotcells->Reset();
  HFlumi_diag_deadcells->Reset();


  HFlumi_Ring1Status_vs_LS->Reset();
  HFlumi_Ring2Status_vs_LS->Reset();
}

void HcalBeamMonitor::cleanup()
{
  if (dbe_) 
    {
      dbe_->setCurrentFolder(subdir_);
      dbe_->removeContents();
      dbe_->setCurrentFolder(subdir_+"LSvalues");
      dbe_->removeContents();
    } // if (dbe_)
} // void HcalBeamMonitor::cleanup()


void HcalBeamMonitor::setup()
{
  if (setupDone_)
    return;
  setupDone_ = true;
   if (debug_>0) std::cout <<"<HcalBeamMonitor::setup> Setup in progress..."<<std::endl;
  HcalBaseDQMonitor::setup();
  if (!dbe_) return;

  //jason's
  dbe_->setCurrentFolder(subdir_);
  CenterOfEnergyRadius = dbe_->book1D("CenterOfEnergyRadius",
                       "Center Of Energy radius",
                       200,0,1);
      
  CenterOfEnergyRadius->setAxisTitle("(normalized) radius",1);
      
  CenterOfEnergy = dbe_->book2D("CenterOfEnergy",
                 "Center of Energy;normalized x coordinate;normalize y coordinate",
                 40,-1,1,
                 40,-1,1);

  COEradiusVSeta = dbe_->bookProfile("COEradiusVSeta",
                      "Center of Energy radius vs i#eta",
                      172,-43,43,
                      20,0,1);
  COEradiusVSeta->setAxisTitle("i#eta",1);
  COEradiusVSeta->setAxisTitle("(normalized) radius",2);
      
  std::stringstream histname;
  std::stringstream histtitle;
  dbe_->setCurrentFolder(subdir_+"HB");
  HBCenterOfEnergyRadius = dbe_->book1D("HBCenterOfEnergyRadius",
                     "HB Center Of Energy radius",
                     200,0,1);
  HBCenterOfEnergy = dbe_->book2D("HBCenterOfEnergy",
                   "HB Center of Energy",
                   40,-1,1,
                   40,-1,1);
  if (makeDiagnostics_)
    {
      for (int i=-16;i<=16;++i)
    {
      if (i==0) continue;
      histname.str("");
      histtitle.str("");
      histname<<"HB_CenterOfEnergyRadius_ieta"<<i;
      histtitle<<"HB Center Of Energy ieta = "<<i;
      HB_CenterOfEnergyRadius[i+ETA_OFFSET_HB]=dbe_->book1D(histname.str().c_str(),
                                 histtitle.str().c_str(),
                                 200,0,1);
    } // end of HB loop
    }
  dbe_->setCurrentFolder(subdir_+"HE");
  HECenterOfEnergyRadius = dbe_->book1D("HECenterOfEnergyRadius",
                     "HE Center Of Energy radius",
                     200,0,1);
  HECenterOfEnergy = dbe_->book2D("HECenterOfEnergy",
                   "HE Center of Energy",
                   40,-1,1,
                   40,-1,1);

  if (makeDiagnostics_)
    {
      for (int i=-29;i<=29;++i)
    {
      if (abs(i)<ETA_BOUND_HE) continue;
      histname.str("");
      histtitle.str("");
      histname<<"HE_CenterOfEnergyRadius_ieta"<<i;
      histtitle<<"HE Center Of Energy ieta = "<<i;
      HE_CenterOfEnergyRadius[i+ETA_OFFSET_HE]=dbe_->book1D(histname.str().c_str(),
                                 histtitle.str().c_str(),
                                 200,0,1);
    } // end of HE loop
    }
  dbe_->setCurrentFolder(subdir_+"HO");
  HOCenterOfEnergyRadius = dbe_->book1D("HOCenterOfEnergyRadius",
                     "HO Center Of Energy radius",
                     200,0,1);
  HOCenterOfEnergy = dbe_->book2D("HOCenterOfEnergy",
                   "HO Center of Energy",
                   40,-1,1,
                   40,-1,1);
  if (makeDiagnostics_)
    {
      for (int i=-15;i<=15;++i)
    {
      if (i==0) continue;
      histname.str("");
      histtitle.str("");
      histname<<"HO_CenterOfEnergyRadius_ieta"<<i;
      histtitle<<"HO Center Of Energy radius ieta = "<<i;
      HO_CenterOfEnergyRadius[i+ETA_OFFSET_HO]=dbe_->book1D(histname.str().c_str(),
                                 histtitle.str().c_str(),
                                 200,0,1);
    } // end of HO loop
    }
  dbe_->setCurrentFolder(subdir_+"HF");
  HFCenterOfEnergyRadius = dbe_->book1D("HFCenterOfEnergyRadius",
                     "HF Center Of Energy radius",
                     200,0,1);
  HFCenterOfEnergy = dbe_->book2D("HFCenterOfEnergy",
                   "HF Center of Energy",
                   40,-1,1,
                   40,-1,1);
  if (makeDiagnostics_)
    {
      for (int i=-41;i<=41;++i)
    {
      if (abs(i)<ETA_BOUND_HF) continue;
      histname.str("");
      histtitle.str("");
      histname<<"HF_CenterOfEnergyRadius_ieta"<<i;
      histtitle<<"HF Center Of Energy radius ieta = "<<i;
      HF_CenterOfEnergyRadius[i+ETA_OFFSET_HF]=dbe_->book1D(histname.str().c_str(),
                                 histtitle.str().c_str(),
                                 200,0,1);
    } // end of HF loop
    }
      
  dbe_->setCurrentFolder(subdir_+"Lumi");
  // Wenhan's 
  // reducing bins from ",200,0,2000" to ",40,0,800"
      
  float radiusbins[13]={169,201,240,286,340,406,483,576,686,818,975,1162,1300};
  float phibins[71]={-3.5,-3.4,-3.3,-3.2,-3.1,
             -3.0,-2.9,-2.8,-2.7,-2.6,-2.5,-2.4,-2.3,-2.2,-2.1,
             -2.0,-1.9,-1.8,-1.7,-1.6,-1.5,-1.4,-1.3,-1.2,-1.1,
             -1.0,-0.9,-0.8,-0.7,-0.6,-0.5,-0.4,-0.3,-0.2,-0.1,
             0.0, 0.1, 0.2, 0.3, 0.4, 0.5, 0.6, 0.7, 0.8, 0.9,
             1.0, 1.1, 1.2, 1.3, 1.4, 1.5, 1.6, 1.7, 1.8, 1.9,
             2.0, 2.1, 2.2, 2.3, 2.4, 2.5, 2.6, 2.7, 2.8, 2.9,
             3.0, 3.1, 3.2, 3.3, 3.4, 3.5};
  Etsum_eta_L=dbe_->bookProfile("Et Sum vs Eta Long Fiber","Et Sum per Area vs Eta Long Fiber",27,0,27,100,0,100);
  Etsum_eta_S=dbe_->bookProfile("Et Sum vs Eta Short Fiber","Et Sum per Area vs Eta Short Fiber",27,0,27,100,0,100);
  Etsum_phi_L=dbe_->bookProfile("Et Sum vs Phi Long Fiber","Et Sum per Area vs Phi Long Fiber",36,0.5,72.5,100,0,100);
  Etsum_phi_S=dbe_->bookProfile("Et Sum vs Phi Short Fiber","Et Sum per Area crossing vs Phi Short Fiber",36,0.5,72.5,100,0,100);

  Etsum_ratio_p=dbe_->book1D("Occ vs PMT events HF+","Energy difference of Long and Short Fiber HF+ in PMT events",105,0.,1.05);
  Energy_Occ=dbe_->book1D("Occ vs Energy","Occupancy vs Energy",200,0,2000);
  Etsum_ratio_m=dbe_->book1D("Occ vs PMT events HF-","Energy difference of Long and Short Fiber HF- in PMT events",105,0.,1.05);
  Etsum_map_L=dbe_->book2D("EtSum 2D phi and eta Long Fiber","Et Sum 2D phi and eta Long Fiber",27,0,27,36,0.5,72.5);
  Etsum_map_S=dbe_->book2D("EtSum 2D phi and eta Short Fiber","Et Sum 2D phi and eta Short Fiber",27,0,27,36,0.5,72.5);

  Etsum_rphi_S=dbe_->book2D("EtSum 2D phi and radius Short Fiber","Et Sum 2D phi and radius Short Fiber",12, radiusbins, 70, phibins);
  Etsum_rphi_L=dbe_->book2D("EtSum 2D phi and radius Long Fiber","Et Sum 2D phi and radius Long Fiber",12, radiusbins, 70, phibins);

  Etsum_ratio_map=dbe_->book2D("Abnormal PMT events","Abnormal PMT events",
                8,0,8,36, 0.5,72.5);
  SetEtaLabels(Etsum_ratio_map);

  HFlumi_occ_LS = dbe_->book2D("HFlumi_occ_LS","HFlumi occupancy for current LS",
                8,0,8,36, 0.5,72.5);
  SetEtaLabels(HFlumi_occ_LS);
      
  HFlumi_total_deadcells = dbe_->book2D("HFlumi_total_deadcells","Number of dead lumi channels for LS with at least 10 bad channels",
                     8,0,8,36,0.5,72.5);
  SetEtaLabels(HFlumi_total_deadcells);
  HFlumi_total_hotcells = dbe_->book2D("HFlumi_total_hotcells","Number of hot lumi channels for LS with at least 10 bad channels",
                    8,0,8,36,0.5,72.5);
  SetEtaLabels(HFlumi_total_hotcells);

  HFlumi_diag_deadcells = dbe_->book2D("HFlumi_diag_deadcells","Channels that had no hit for at least one LS",
                       8,0,8,36,0.5,72.5);
  SetEtaLabels(HFlumi_diag_deadcells);
  HFlumi_diag_hotcells = dbe_->book2D("HFlumi_diag_hotcells","Channels that appeared hot for at least one LS",
                      8,0,8,36,0.5,72.5);
  SetEtaLabels(HFlumi_diag_hotcells);



  Occ_rphi_S=dbe_->book2D("Occ 2D phi and radius Short Fiber","Occupancy 2D phi and radius Short Fiber",12, radiusbins, 70, phibins);
  Occ_rphi_L=dbe_->book2D("Occ 2D phi and radius Long Fiber","Occupancy 2D phi and radius Long Fiber",12, radiusbins, 70, phibins);
  Occ_eta_S=dbe_->bookProfile("Occ vs iEta Short Fiber","Occ per Bunch crossing vs iEta Short Fiber",27,0,27,40,0,800);
  Occ_eta_L=dbe_->bookProfile("Occ vs iEta Long Fiber","Occ per Bunch crossing vs iEta Long Fiber",27,0,27,40,0,800);
      
  Occ_phi_L=dbe_->bookProfile("Occ vs iPhi Long Fiber","Occ per Bunch crossing vs iPhi Long Fiber",36,0.5,72.5,40,0,800);
      
  Occ_phi_S=dbe_->bookProfile("Occ vs iPhi Short Fiber","Occ per Bunch crossing vs iPhi Short Fiber",36,0.5,72.5,40,0,800);
      
  Occ_map_L=dbe_->book2D("Occ_map Long Fiber","Occ Map long Fiber (above threshold)",27,0,27,36,0.5,72.5);
  Occ_map_S=dbe_->book2D("Occ_map Short Fiber","Occ Map Short Fiber (above threshold)",27,0,27,36,0.5,72.5);

  std::stringstream binlabel;
  for (int zz=0;zz<27;++zz)
    {
      if (zz<13)
    binlabel<<zz-41;
      else if (zz==13)
    binlabel<<"NULL";
      else
    binlabel<<zz+15;
      Occ_eta_S->setBinLabel(zz+1,binlabel.str().c_str());
      Occ_eta_L->setBinLabel(zz+1,binlabel.str().c_str());
      Occ_map_S->setBinLabel(zz+1,binlabel.str().c_str());
      Occ_map_L->setBinLabel(zz+1,binlabel.str().c_str());
      Etsum_eta_S->setBinLabel(zz+1,binlabel.str().c_str());
      Etsum_eta_L->setBinLabel(zz+1,binlabel.str().c_str());
      Etsum_map_S->setBinLabel(zz+1,binlabel.str().c_str());
      Etsum_map_L->setBinLabel(zz+1,binlabel.str().c_str());
      binlabel.str("");
    }

  //HFlumi plots
  HFlumi_ETsum_perwedge =  dbe_->book1D("HF lumi ET-sum per wedge","HF lumi ET-sum per wedge;wedge",36,1,37);
  HFlumi_ETsum_perwedge->getTH1F()->SetMinimum(0); 
      
  HFlumi_Occupancy_above_thr_r1 =  dbe_->book1D("HF lumi Occupancy above threshold ring1","HF lumi Occupancy above threshold ring1;wedge",36,1,37);
  HFlumi_Occupancy_between_thrs_r1 = dbe_->book1D("HF lumi Occupancy between thresholds ring1","HF lumi Occupancy between thresholds ring1;wedge",36,1,37);
  HFlumi_Occupancy_below_thr_r1 = dbe_->book1D("HF lumi Occupancy below threshold ring1","HF lumi Occupancy below threshold ring1;wedge",36,1,37);
  HFlumi_Occupancy_above_thr_r2 = dbe_->book1D("HF lumi Occupancy above threshold ring2","HF lumi Occupancy above threshold ring2;wedge",36,1,37);
  HFlumi_Occupancy_between_thrs_r2 = dbe_->book1D("HF lumi Occupancy between thresholds ring2","HF lumi Occupancy between thresholds ring2;wedge",36,1,37);
  HFlumi_Occupancy_below_thr_r2 = dbe_->book1D("HF lumi Occupancy below threshold ring2","HF lumi Occupancy below threshold ring2;wedge",36,1,37);

  HFlumi_Occupancy_above_thr_r1->getTH1F()->SetMinimum(0);
  HFlumi_Occupancy_between_thrs_r1->getTH1F()->SetMinimum(0);
  HFlumi_Occupancy_below_thr_r1->getTH1F()->SetMinimum(0);
  HFlumi_Occupancy_above_thr_r2->getTH1F()->SetMinimum(0);
  HFlumi_Occupancy_between_thrs_r2->getTH1F()->SetMinimum(0);
  HFlumi_Occupancy_below_thr_r2->getTH1F()->SetMinimum(0);
 
  HFlumi_Occupancy_per_channel_vs_lumiblock_RING1 = dbe_->bookProfile("HFlumiRing1OccupancyPerChannelVsLB",
                                      "HFlumi Occupancy per channel vs lumi-block (RING 1);LS; -ln(empty fraction)",
                                      NLumiBlocks_,0.5,NLumiBlocks_+0.5,100,0,10000);
  HFlumi_Occupancy_per_channel_vs_lumiblock_RING2 = dbe_->bookProfile("HFlumiRing2OccupancyPerChannelVsLB","HFlumi Occupancy per channel vs lumi-block (RING 2);LS; -ln(empty fraction)",NLumiBlocks_,0.5,NLumiBlocks_+0.5,100,0,10000);

  HFlumi_Occupancy_per_channel_vs_BX_RING1 = dbe_->bookProfile("HFlumi Occupancy per channel vs BX (RING 1)","HFlumi Occupancy per channel vs BX (RING 1);BX; -ln(empty fraction)",4000,0,4000,100,0,10000);
  HFlumi_Occupancy_per_channel_vs_BX_RING2 = dbe_->bookProfile("HFlumi Occupancy per channel vs BX (RING 2)","HFlumi Occupancy per channel vs BX (RING 2);BX; -ln(empty fraction)",4000,0,4000,100,0,10000);
  HFlumi_ETsum_vs_BX = dbe_->bookProfile("HFlumi_ETsum_vs_BX","HFlumi ETsum vs BX; BX; ETsum",4000,0,4000,100,0,10000);

  HFlumi_Et_per_channel_vs_lumiblock = dbe_->bookProfile("HFlumi Et per channel vs lumi-block","HFlumi Et per channel vs lumi-block;LS;ET",NLumiBlocks_,0.5,NLumiBlocks_+0.5,100,0,10000);

  HFlumi_Occupancy_per_channel_vs_lumiblock_RING1->getTProfile()->SetMarkerStyle(20);
  HFlumi_Occupancy_per_channel_vs_lumiblock_RING2->getTProfile()->SetMarkerStyle(20);
  HFlumi_Et_per_channel_vs_lumiblock->getTProfile()->SetMarkerStyle(20);

  HFlumi_Ring1Status_vs_LS = dbe_->bookProfile("HFlumi_Ring1Status_vs_LS","Fraction of good Ring 1 channels vs LS;LS; Fraction of Good Channels",NLumiBlocks_,0.5,NLumiBlocks_+0.5,100,0,10000);
  HFlumi_Ring2Status_vs_LS = dbe_->bookProfile("HFlumi_Ring2Status_vs_LS","Fraction of good Ring 2 channels vs LS;LS; Fraction of Good Channels",NLumiBlocks_,0.5,NLumiBlocks_+0.5,100,0,10000);
  HFlumi_Ring1Status_vs_LS->getTProfile()->SetMarkerStyle(20);
  HFlumi_Ring2Status_vs_LS->getTProfile()->SetMarkerStyle(20);

  return;
}

void HcalBeamMonitor::beginRun(const edm::Run& run, const edm::EventSetup& c)
{
  HcalBaseDQMonitor::beginRun(run,c);  

  if (debug_>1) std::cout <<"HcalBeamMonitor::beginRun"<<std::endl;
  HcalBaseDQMonitor::beginRun(run,c);

  lastProcessedLS_=0;
  runNumber_=run.id().run();
  if (lumiqualitydir_.size()>0 && Online_==true)
    {
      if (Overwrite_==false)
    outfile_ <<lumiqualitydir_<<"HcalHFLumistatus_"<<runNumber_<<".txt";
      else
    outfile_ <<lumiqualitydir_<<"HcalHFLumistatus.txt";
      std::ofstream outStream(outfile_.str().c_str()); // recreate the file, rather than appending to it
      outStream<<"## Run "<<runNumber_<<std::endl;
      outStream<<"## LumiBlock\tRing1Status\t\tRing2Status\t\tGlobalStatus\tNentries"<<std::endl;
      outStream.close();
    }

  // Get expected good channels in run according to channel quality database
  // Get channel quality status info for each run

  // Default number of expected good channels in the run
  ring1totalchannels_=144;
  ring2totalchannels_=144;
  BadCells_.clear(); // remove any old maps
  // Get Channel quality info for the run
  // Exclude bad channels from overall calculation
  edm::ESHandle<HcalChannelQuality> p;
  c.get<HcalChannelQualityRcd>().get(p);
  HcalChannelQuality* chanquality = new HcalChannelQuality(*p.product());
  std::vector<DetId> mydetids = chanquality->getAllChannels();
  
  for (unsigned int i=0;i<mydetids.size();++i)
    {
      if (mydetids[i].det()!=DetId::Hcal) continue;
      HcalDetId id=mydetids[i];
      
      if (id.subdet()!=HcalForward) continue;
      if ((id.depth()==1 && (abs(id.ieta())==33 || abs(id.ieta())==34)) ||
      (id.depth()==2 && (abs(id.ieta())==35 || abs(id.ieta())==36)))
    {
      const HcalChannelStatus* origstatus=chanquality->getValues(id);
      HcalChannelStatus* mystatus=new HcalChannelStatus(origstatus->rawId(),origstatus->getValue());
      if (mystatus->isBitSet(HcalChannelStatus::HcalCellHot)) 
        BadCells_[id]=HcalChannelStatus::HcalCellHot;
      
      else if (mystatus->isBitSet(HcalChannelStatus::HcalCellDead))
        BadCells_[id]=HcalChannelStatus::HcalCellDead;
      
      if (mystatus->isBitSet(HcalChannelStatus::HcalCellHot) || 
          mystatus->isBitSet(HcalChannelStatus::HcalCellDead))
        {
          if (id.depth()==1) --ring1totalchannels_;
          else if (id.depth()==2) --ring2totalchannels_;
        }
      delete mystatus;
    } // if ((id.depth()==1) ...
    } // for (unsigned int i=0;...)
    
  if (tevt_==0) this->setup(); // create all histograms; not necessary if merging runs together
  if (mergeRuns_==false) this->reset(); // call reset at start of all runs

  return;

} // void HcalBeamMonitor::beginRun(const edm::Run& run, const edm::EventSetup& c)


void HcalBeamMonitor::analyze(const edm::Event& e, const edm::EventSetup& c)
{
  if (!IsAllowedCalibType()) return;
  if (LumiInOrder(e.luminosityBlock())==false) return;

  // try to get rechits and digis
  edm::Handle<HFDigiCollection> hf_digi;

  edm::Handle<HBHERecHitCollection> hbhe_rechit;
  edm::Handle<HORecHitCollection> ho_rechit;
  edm::Handle<HFRecHitCollection> hf_rechit;
  
  if (!(e.getByToken(tok_hfdigi_,hf_digi)))
    {
      edm::LogWarning("HcalBeamMonitor")<< digiLabel_<<" hf_digi not available";
      return;
    }

  if (!(e.getByToken(tok_hbhe_,hbhe_rechit)))
    {
      edm::LogWarning("HcalBeamMonitor")<< hbheRechitLabel_<<" hbhe_rechit not available";
      return;
    }

  if (!(e.getByToken(tok_hf_,hf_rechit)))
    {
      edm::LogWarning("HcalBeamMonitor")<< hfRechitLabel_<<" hf_rechit not available";
      return;
    }
  if (!(e.getByToken(tok_ho_,ho_rechit)))
    {
      edm::LogWarning("HcalBeamMonitor")<< hoRechitLabel_<<" ho_rechit not available";
      return;
    }

  //good event; increment counters and process
  HcalBaseDQMonitor::analyze(e,c);
  processEvent(*hbhe_rechit, *ho_rechit, *hf_rechit, *hf_digi, e.bunchCrossing());

} //void HcalBeamMonitor::analyze(const edm::Event& e, const edm::EventSetup& c)


void HcalBeamMonitor::processEvent(const HBHERecHitCollection& hbheHits,
                   const HORecHitCollection& hoHits,
                   const HFRecHitCollection& hfHits,
                                   const HFDigiCollection& hf,
                   int   bunchCrossing
                   )
  
{ 
  //processEvent loop
  if (!dbe_)
    {
      if (debug_>0) std::cout <<"HcalBeamMonitor::processEvent   DQMStore not instantiated!!!"<<std::endl;
      return;
    }

  HBHERecHitCollection::const_iterator HBHEiter;
  HORecHitCollection::const_iterator HOiter;
  HFRecHitCollection::const_iterator HFiter;

  double totalX=0;
  double totalY=0;
  double totalE=0;

  double HBtotalX=0;
  double HBtotalY=0;
  double HBtotalE=0;
  double HEtotalX=0;
  double HEtotalY=0;
  double HEtotalE=0;
  double HOtotalX=0;
  double HOtotalY=0;
  double HOtotalE=0;
  double HFtotalX=0;
  double HFtotalY=0;
  double HFtotalE=0;
     
  float hitsp[13][36][2];
  float hitsm[13][36][2];
  float hitsp_Et[13][36][2];
  float hitsm_Et[13][36][2];
  
  for(int m=0;m<13;m++){
    for(int n=0;n<36;n++){
      hitsp[m][n][0]=0;
      hitsp[m][n][1]=0; 
      hitsm[m][n][0]=0;
      hitsm[m][n][1]=0;

      hitsp_Et[m][n][0]=0;
      hitsp_Et[m][n][1]=0; 
      hitsm_Et[m][n][0]=0;
      hitsm_Et[m][n][1]=0;
    }
  }

  if(hbheHits.size()>0)
    {
      double HB_weightedX[HBETASIZE]={0.};
      double HB_weightedY[HBETASIZE]={0.};
      double HB_energy[HBETASIZE]={0.};
      
      double HE_weightedX[HEETASIZE]={0.};
      double HE_weightedY[HEETASIZE]={0.};
      double HE_energy[HEETASIZE]={0.};
      
      int ieta, iphi;
      
      for (HBHEiter=hbheHits.begin(); 
       HBHEiter!=hbheHits.end(); 
       ++HBHEiter) 
    { 
      
      // loop over all hits
      if (HBHEiter->energy()<0) continue; // don't consider negative-energy cells
      HcalDetId id(HBHEiter->detid().rawId());
      ieta=id.ieta();
      iphi=id.iphi();
      
      int index=-1;
      if ((HcalSubdetector)(id.subdet())==HcalBarrel)
        {
          HBtotalX+=HBHEiter->energy()*cos(PI*iphi/36.);
          HBtotalY+=HBHEiter->energy()*sin(PI*iphi/36.);
          HBtotalE+=HBHEiter->energy();
          
          index=ieta+ETA_OFFSET_HB;
          if (index<0 || index>= HBETASIZE) continue;
          HB_weightedX[index]+=HBHEiter->energy()*cos(PI*iphi/36.);
          HB_weightedY[index]+=HBHEiter->energy()*sin(PI*iphi/36.);
          HB_energy[index]+=HBHEiter->energy();
        } // if id.subdet()==HcalBarrel
      
      else
        {
          HEtotalX+=HBHEiter->energy()*cos(PI*iphi/36.);
          HEtotalY+=HBHEiter->energy()*sin(PI*iphi/36.);
          HEtotalE+=HBHEiter->energy();
          
          index=ieta+ETA_OFFSET_HE;
          if (index<0 || index>= HEETASIZE) continue;
          HE_weightedX[index]+=HBHEiter->energy()*cos(PI*iphi/36.);
          HE_weightedY[index]+=HBHEiter->energy()*sin(PI*iphi/36.);
          HE_energy[index]+=HBHEiter->energy();
        }
    } // for (HBHEiter=hbheHits.begin()...
      // Fill each histogram
      
      int hbeta=ETA_OFFSET_HB;
      for (int i=-1*hbeta;i<=hbeta;++i)
    {
      if (i==0) continue;
      int index = i+ETA_OFFSET_HB;
      if (index<0 || index>= HBETASIZE) continue;
      if (HB_energy[index]==0) continue;
      double moment=pow(HB_weightedX[index],2)+pow(HB_weightedY[index],2);
      moment=pow(moment,0.5);
      moment/=HB_energy[index];
      if (moment!=0)
        {
          if (makeDiagnostics_) HB_CenterOfEnergyRadius[index]->Fill(moment);
          COEradiusVSeta->Fill(i,moment);
        }
    } // for (int i=-1*hbeta;i<=hbeta;++i)

      int heeta=ETA_OFFSET_HE;
      for (int i=-1*heeta;i<=heeta;++i)
    {
      if (i==0) continue;
      if (i>-1*ETA_BOUND_HE && i <ETA_BOUND_HE) continue;
      int index = i + ETA_OFFSET_HE;
      if (index<0 || index>= HEETASIZE) continue;
      if (HE_energy[index]==0) continue;
      double moment=pow(HE_weightedX[index],2)+pow(HE_weightedY[index],2);
      moment=pow(moment,0.5);
      moment/=HE_energy[index];
      if (moment!=0)
        {
          if (makeDiagnostics_) HE_CenterOfEnergyRadius[index]->Fill(moment);
          COEradiusVSeta->Fill(i,moment);
        }
    } // for (int i=-1*heeta;i<=heeta;++i)

    } // if (hbheHits.size()>0)

  
  // HO loop
  if(hoHits.size()>0)
    {
      double HO_weightedX[HOETASIZE]={0.};
      double HO_weightedY[HOETASIZE]={0.};
      double HO_energy[HOETASIZE]={0.};
      double offset;

      int ieta, iphi;
      for (HOiter=hoHits.begin(); 
       HOiter!=hoHits.end(); 
       ++HOiter) 
    { 
      // loop over all cells
      if (HOiter->energy()<0) continue;  // don't include negative-energy cells?
      HcalDetId id(HOiter->detid().rawId());
      ieta=id.ieta();
      iphi=id.iphi();

      HOtotalX+=HOiter->energy()*cos(PI*iphi/36.);
      HOtotalY+=HOiter->energy()*sin(PI*iphi/36.);
      HOtotalE+=HOiter->energy();

      int index=ieta+ETA_OFFSET_HO;
      if (index<0 || index>= HOETASIZE) continue;
      HO_weightedX[index]+=HOiter->energy()*cos(PI*iphi/36.);
      HO_weightedY[index]+=HOiter->energy()*sin(PI*iphi/36.);
      HO_energy[index]+=HOiter->energy();
    } // for (HOiter=hoHits.begin();...)
      
      for (int i=-1*ETA_OFFSET_HO;i<=ETA_OFFSET_HO;++i)
    {
      if (i==0) continue;
      int index = i + ETA_OFFSET_HO;
      if (index < 0 || index>= HOETASIZE) continue;
      if (HO_energy[index]==0) continue;
      double moment=pow(HO_weightedX[index],2)+pow(HO_weightedY[index],2);
      moment=pow(moment,0.5);
      moment/=HO_energy[index];
      // Shift HO values by 0.5 units in eta relative to HB
      offset = (i>0 ? 0.5: -0.5);
      if (moment!=0)
        {
          if (makeDiagnostics_) HO_CenterOfEnergyRadius[index]->Fill(moment);
          COEradiusVSeta->Fill(i+offset,moment);
        }
    } // for (int i=-1*hoeta;i<=hoeta;++i)
    } // if (hoHits.size()>0)
    
  // HF loop

  Etsum_ratio_map->Fill(-1,-1,1); // fill underflow bin with number of events
  {
    if(hfHits.size()>0)
      {
    double HF_weightedX[HFETASIZE]={0.};
    double HF_weightedY[HFETASIZE]={0.};
    double HF_energy[HFETASIZE]={0.};
    double offset;
    
    // Assume ZS until shown otherwise
    double emptytowersRing1 = ring1totalchannels_;
    double emptytowersRing2 = ring2totalchannels_;
    double ZStowersRing1 = ring1totalchannels_;
    double ZStowersRing2 = ring2totalchannels_;
    
    int ieta, iphi;
    float et,eta,phi,r;

    HFlumi_occ_LS->Fill(-1,-1,1 ); // event counter in occupancy histogram underflow bin
    // set maximum to HFlumi_occ_LS->getBinContent(0,0)?  
    // that won't work -- offline will add multiple histograms, and maximum will get screwed up?
    // No, we can add it here, but we also need a call to setMaximum in the client as well.
    HFlumi_occ_LS->getTH2F()->SetMaximum(HFlumi_occ_LS->getBinContent(0,0));

    double etx=0, ety=0;

    for (HFiter=hfHits.begin(); 
         HFiter!=hfHits.end(); 
         ++HFiter) 
      {  // loop on hfHits
        // If hit present, don't count it as ZS any more
        ieta = HFiter->id().ieta();
        iphi = HFiter->id().iphi();

        int binieta=ieta;
        if (ieta<0) binieta+=41;
        else if (ieta>0) binieta-=15;

        // Count that hit was found in one of the rings used for luminosity calculation.
        // If so, decrease the number of empty channels per ring by 1
        if (abs(ieta)>=33 && abs(ieta)<=36) // luminosity ring check
          {
        // don't subtract away cells that have already been removed as bad
        if (BadCells_.find(HFiter->id())==BadCells_.end()) // bad cell not found
          {
            if ((abs(ieta)<35) && HFiter->id().depth()==1) --ZStowersRing1;
            else if ((abs(ieta)>34) && HFiter->id().depth()==2) -- ZStowersRing2;
          }
          }

        if (HFiter->energy()<0) continue;  // don't include negative-energy cells?

        eta=theHFEtaBounds[abs(ieta)-29];
        et=HFiter->energy()/cosh(eta)/area[abs(ieta)-29];
        if (abs(ieta)>=33 && abs(ieta)<=36) // Luminosity ring check
          {
        // don't count cells that are below threshold, or that have been marked bad in Chan Stat DB
        if (et>=occThresh_ && BadCells_.find(HFiter->id())==BadCells_.end() ) // minimum ET threshold
          {
            if ((abs(ieta)<35) && HFiter->id().depth()==1) --emptytowersRing1;
            else if ((abs(ieta)>34) && HFiter->id().depth()==2) -- emptytowersRing2;
          }
          }
        r=radius[abs(ieta)-29];
        if(HFiter->id().iphi()<37)
          phi=HFiter->id().iphi()*0.087266;
        else phi=(HFiter->id().iphi()-72)*0.087266;
           
        
        if (HFiter->id().depth()==1)
          {
        Etsum_eta_L->Fill(binieta,et);
        Etsum_phi_L->Fill(iphi,et);
        Etsum_map_L->Fill(binieta,iphi,et);
        Etsum_rphi_L->Fill(r,phi,et);
          
        if(ieta>0) {
          hitsp[ieta-29][(HFiter->id().iphi()-1)/2][0]=HFiter->energy();
          hitsp_Et[ieta-29][(HFiter->id().iphi()-1)/2][0]=et;
        }
        else if(ieta<0) {
          hitsm[-ieta-29][(HFiter->id().iphi()-1)/2][0]=HFiter->energy(); 
          hitsm_Et[-ieta-29][(HFiter->id().iphi()-1)/2][0]=et; 
        }
          } // if (HFiter->id().depth()==1)
         
        //Fill 3 histos for Short Fibers :
        if (HFiter->id().depth()==2)
          {
        Etsum_eta_S->Fill(binieta,et);
        Etsum_phi_S->Fill(iphi,et);
        Etsum_rphi_S->Fill(r,phi,et); 
        Etsum_map_S->Fill(binieta,iphi,et);
        if(ieta>0)  
          {
            hitsp[ieta-29][(HFiter->id().iphi()-1)/2][1]=HFiter->energy();
            hitsp_Et[ieta-29][(HFiter->id().iphi()-1)/2][1]=et;
          }
        else if(ieta<0)  { 
          hitsm[-ieta-29][(HFiter->id().iphi()-1)/2][1]=HFiter->energy();
          hitsm_Et[-ieta-29][(HFiter->id().iphi()-1)/2][1]=et;
        }
          
          } // depth()==2
        Energy_Occ->Fill(HFiter->energy()); 
            
        //HF: no non-threshold occupancy map is filled?

        if ((abs(ieta) == 33 || abs(ieta) == 34) && HFiter->id().depth() == 1)
          { 
        etx+=et*cos(PI*iphi/36.);
        ety+=et*sin(PI*iphi/36.);

        HFlumi_Et_per_channel_vs_lumiblock->Fill(currentLS,et);
        if (et>occThresh_)
          {
            int etabin=0;
            if (ieta<0)
              etabin=36+ieta; // bins 0-3 correspond to ieta = -36, -35, -34, -33
            else
              etabin=ieta-29; // bins 4-7 correspond to ieta = 33, 34, 35, 36
            HFlumi_occ_LS->Fill(etabin,HFiter->id().iphi());
          }
          }

        else if ((abs(ieta) == 35 || abs(ieta) == 36) && HFiter->id().depth() == 2)
          { 
        etx+=et*cos(PI*iphi/36.);
        ety+=et*sin(PI*iphi/36.);

        HFlumi_Et_per_channel_vs_lumiblock->Fill(currentLS,et);
        if (et>occThresh_)
          {
            int etabin=0;
            if (ieta<0)
              etabin=36+ieta; // bins 0-3 correspond to ieta = -36, -35, -34, -33
            else
              etabin=ieta-29; // bins 4-7 correspond to ieta = 33, 34, 35, 36
            HFlumi_occ_LS->Fill(etabin,HFiter->id().iphi());
          }
          }

        // Fill occupancy plots.
        
        int value=0;
        if(et>occThresh_) value=1;

        if (HFiter->id().depth()==1)
          {
        Occ_eta_L->Fill(binieta,value);
        Occ_phi_L->Fill(iphi,value);
        Occ_map_L->Fill(binieta,iphi,value);
        Occ_rphi_L->Fill(r,phi,value);
          }
          
        else if (HFiter->id().depth()==2)
          {
        Occ_eta_S->Fill(binieta,value);
        Occ_phi_S->Fill(iphi,value);
        Occ_map_S->Fill(binieta,iphi,value);
        Occ_rphi_S->Fill(r,phi,value);
          }  
        HcalDetId id(HFiter->detid().rawId());

        HFtotalX+=HFiter->energy()*cos(PI*iphi/36.);
        HFtotalY+=HFiter->energy()*sin(PI*iphi/36.);
        HFtotalE+=HFiter->energy();

        int index=ieta+ETA_OFFSET_HF;
        if (index<0 || index>= HFETASIZE) continue;
        HF_weightedX[index]+=HFiter->energy()*cos(PI*iphi/36.);
        HF_weightedY[index]+=HFiter->energy()*sin(PI*iphi/36.);
        HF_energy[index]+=HFiter->energy();
        
      } // for (HFiter=hfHits.begin();...)
    
    // looped on all HF hits; calculate empty fraction
    //  empty towers  = # of cells with ET < 0.0625 GeV, or cells missing because of ZS
    //  Calculated as :  144 - (# of cells with ET >= 0.0625 GeV)
    //  At some point, allow for calculations when channels are masked (and less than 144 channels expected)

    // Check Ring 1
    double logvalue=-1;
    if (ring1totalchannels_>0)
      {
        if (emptytowersRing1>0)
          logvalue=-1.*log(emptytowersRing1/ring1totalchannels_);
        HFlumi_Occupancy_per_channel_vs_lumiblock_RING1->Fill(currentLS,logvalue);
        HFlumi_Occupancy_per_channel_vs_BX_RING1->Fill(bunchCrossing,logvalue);
      }
    // Check Ring 2
    logvalue=-1;
    if (ring2totalchannels_>0)
      {
        if (emptytowersRing2>0)
          logvalue=-1.*log(emptytowersRing2/ring2totalchannels_);
        HFlumi_Occupancy_per_channel_vs_lumiblock_RING2->Fill(currentLS,logvalue);
        HFlumi_Occupancy_per_channel_vs_BX_RING2->Fill(bunchCrossing,logvalue);
      }

    HFlumi_ETsum_vs_BX->Fill(bunchCrossing,pow(etx*etx+ety*ety,0.5));
    int hfeta=ETA_OFFSET_HF;
    for (int i=-1*hfeta;i<=hfeta;++i)
      {
        if (i==0) continue;
        if (i>-1*ETA_BOUND_HF && i <ETA_BOUND_HF) continue;
        int index = i + ETA_OFFSET_HF;
        if (index<0 || index>= HFETASIZE) continue;
        if (HF_energy[index]==0) continue;
        double moment=pow(HF_weightedX[index],2)+pow(HF_weightedY[index],2);
        moment=pow(moment,0.5);
        moment/=HF_energy[index];
        offset = (i>0 ? 0.5: -0.5);
        if (moment!=0)
          {
        if (makeDiagnostics_) HF_CenterOfEnergyRadius[index]->Fill(moment);
        COEradiusVSeta->Fill(i+offset,moment);
          }
      } // for (int i=-1*hfeta;i<=hfeta;++i)
    float ratiom,ratiop;
      
    for(int i=0;i<13;i++){
      for(int j=0;j<36;j++){
          
        if(hitsp[i][j][0]==hitsp[i][j][1]) continue;
          
        if (hitsp[i][j][0] < 1.2 && hitsp[i][j][1] < 1.8) continue;
        //use only lumi rings
        if (((i+29) < 33) || ((i+29) > 36)) continue;
        ratiop=fabs((fabs(hitsp[i][j][0])-fabs(hitsp[i][j][1]))/(fabs(hitsp[i][j][0])+fabs(hitsp[i][j][1])));
        //cout<<ratiop<<std::endl;
        if ((hitsp_Et[i][j][0] > 5. && hitsp[i][j][1] < 1.8) || (hitsp_Et[i][j][1] > 5. &&  hitsp[i][j][0] < 1.2)){
          Etsum_ratio_p->Fill(ratiop);
          if(abs(ratiop>0.95)) Etsum_ratio_map->Fill(i,2*j+1); // i=4,5,6,7 for HFlumi rings 
        }
      }
    }
      
    for(int p=0;p<13;p++){
      for(int q=0;q<36;q++){
          
        if(hitsm[p][q][0]==hitsm[p][q][1]) continue;

        if (hitsm[p][q][0] < 1.2 && hitsm[p][q][1] < 1.8) continue;
        //use only lumi rings
        if (((p+29) < 33) || ((p+29) > 36)) continue;
        ratiom=fabs((fabs(hitsm[p][q][0])-fabs(hitsm[p][q][1]))/(fabs(hitsm[p][q][0])+fabs(hitsm[p][q][1])));         
        if ((hitsm_Et[p][q][0] > 5. && hitsm[p][q][1] < 1.8) || (hitsm_Et[p][q][1] > 5. && hitsm[p][q][0] < 1.2)){
          Etsum_ratio_m->Fill(ratiom);
          if(abs(ratiom>0.95)) Etsum_ratio_map->Fill(7-p,2*q+1); // p=4,5,6,7 for HFlumi rings
          //p=7:  ieta=-36; p=4:  ieta=-33
        }
      }
    } 
      } // if (hfHits.size()>0)
  
    totalX=HBtotalX+HEtotalX+HOtotalX+HFtotalX;
    totalY=HBtotalY+HEtotalY+HOtotalY+HFtotalY;
    totalE=HBtotalE+HEtotalE+HOtotalE+HFtotalE;

    double moment;
    if (HBtotalE>0)
      {
    moment=pow(HBtotalX*HBtotalX+HBtotalY*HBtotalY,0.5)/HBtotalE;
    HBCenterOfEnergyRadius->Fill(moment);
    HBCenterOfEnergy->Fill(HBtotalX/HBtotalE, HBtotalY/HBtotalE);
      }
    if (HEtotalE>0)
      {
    moment=pow(HEtotalX*HEtotalX+HEtotalY*HEtotalY,0.5)/HEtotalE;
    HECenterOfEnergyRadius->Fill(moment);
    HECenterOfEnergy->Fill(HEtotalX/HEtotalE, HEtotalY/HEtotalE);
      }
    if (HOtotalE>0)
      {
    moment=pow(HOtotalX*HOtotalX+HOtotalY*HOtotalY,0.5)/HOtotalE;
    HOCenterOfEnergyRadius->Fill(moment);
    HOCenterOfEnergy->Fill(HOtotalX/HOtotalE, HOtotalY/HOtotalE);
      }
    if (HFtotalE>0)
      {
    moment=pow(HFtotalX*HFtotalX+HFtotalY*HFtotalY,0.5)/HFtotalE;
    HFCenterOfEnergyRadius->Fill(moment);
    HFCenterOfEnergy->Fill(HFtotalX/HFtotalE, HFtotalY/HFtotalE);
      }
    if (totalE>0)
      {
    moment = pow(totalX*totalX+totalY*totalY,0.5)/totalE;
    CenterOfEnergyRadius->Fill(moment);
    CenterOfEnergy->Fill(totalX/totalE, totalY/totalE);
      }


    
    for (HFDigiCollection::const_iterator j=hf.begin(); j!=hf.end(); j++){
      const HFDataFrame digi = (const HFDataFrame)(*j);
      //  calibs_= cond.getHcalCalibrations(digi.id());  // Old method was made private. 
      //       float en=0;
      //       float ts =0; float bs=0;
      //       int maxi=0; float maxa=0;
      //       for(int i=sigS0_; i<=sigS1_; i++){
      //    if(digi.sample(i).adc()>maxa){maxa=digi.sample(i).adc(); maxi=i;}
      //       }
      //       for(int i=sigS0_; i<=sigS1_; i++){     
      //    float tmp1 =0;   
      //         int j1=digi.sample(i).adc();
      //         tmp1 = (LedMonAdc2fc[j1]+0.5);       
      //    en += tmp1-calibs_.pedestal(digi.sample(i).capid());
      //    if(i>=(maxi-1) && i<=maxi+1){
      //      ts += i*(tmp1-calibs_.pedestal(digi.sample(i).capid()));
      //      bs += tmp1-calibs_.pedestal(digi.sample(i).capid());
      //    }
      //       }

      //---HFlumiplots
      int theTStobeused = 6;
      // will have masking later:
      int mask=1; 
      if(mask!=1) continue;
      //if we want to sum the 10 TS instead of just taking one:
      for (int i=0; i<digi.size(); i++) {
    if (i==theTStobeused) {
      float tmpET =0;
      int jadc=digi.sample(i).adc();
      //NOW LUT used in HLX are only identy LUTs, so Et filled
      //with unlinearised adc, ie tmpET = jadc
      //      tmpET = (adc2fc[jadc]+0.5);
      tmpET = jadc;

      //-find which wedge we are in
      //  ETsum and Occupancy will be summed for both L and S
      if(digi.id().ieta()>28){
        if((digi.id().iphi()==1)||(digi.id().iphi()==71)){
          HFlumi_ETsum_perwedge->Fill(1,tmpET);
              if((digi.id().ieta()==33)||(digi.id().ieta()==34)) {
        if(jadc>100) HFlumi_Occupancy_above_thr_r1->Fill(1,1);
        if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r1->Fill(1,1);
        if(jadc<10) HFlumi_Occupancy_below_thr_r1->Fill(1,1);
          }
          else if((digi.id().ieta()==35)||(digi.id().ieta()==36)) {
        if(jadc>100) HFlumi_Occupancy_above_thr_r2->Fill(1,1);
        if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r2->Fill(1,1);
        if(jadc<10) HFlumi_Occupancy_below_thr_r2->Fill(1,1);
          }
        }
        else {
          for (int iwedge=2; iwedge<19; iwedge++) {
        int itmp=4*(iwedge-1);
        if( (digi.id().iphi()==(itmp+1)) || (digi.id().iphi()==(itmp-1))) {
                  HFlumi_ETsum_perwedge->Fill(iwedge,tmpET);
          if((digi.id().ieta()==33)||(digi.id().ieta()==34)) {
            if(jadc>100) HFlumi_Occupancy_above_thr_r1->Fill(iwedge,1);
            if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r1->Fill(iwedge,1);
            if(jadc<10) HFlumi_Occupancy_below_thr_r1->Fill(iwedge,1);
          }
          else if((digi.id().ieta()==35)||(digi.id().ieta()==36)) {
            if(jadc>100) HFlumi_Occupancy_above_thr_r2->Fill(iwedge,1);
            if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r2->Fill(iwedge,1);
            if(jadc<10) HFlumi_Occupancy_below_thr_r2->Fill(iwedge,1);
          }
                  iwedge=99;
        }
          }
        }
      }  //--endif ieta in HF+
      else if(digi.id().ieta()<-28){
        if((digi.id().iphi()==1)||(digi.id().iphi()==71)){
          HFlumi_ETsum_perwedge->Fill(19,tmpET);
              if((digi.id().ieta()==-33)||(digi.id().ieta()==-34)) {
        if(jadc>100) HFlumi_Occupancy_above_thr_r1->Fill(19,1);
        if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r1->Fill(19,1);
        if(jadc<10) HFlumi_Occupancy_below_thr_r1->Fill(19,1);
          }
          else if((digi.id().ieta()==-35)||(digi.id().ieta()==-36)) {
        if(jadc>100) HFlumi_Occupancy_above_thr_r2->Fill(19,1);
        if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r2->Fill(19,1);
        if(jadc<10) HFlumi_Occupancy_below_thr_r2->Fill(19,1);
          }
        }
        else {
          for (int iw=2; iw<19; iw++) {
        int itemp=4*(iw-1);
        if( (digi.id().iphi()==(itemp+1)) || (digi.id().iphi()==(itemp-1))) {
                  HFlumi_ETsum_perwedge->Fill(iw+18,tmpET);
          if((digi.id().ieta()==-33)||(digi.id().ieta()==-34)) {
            if(jadc>100) HFlumi_Occupancy_above_thr_r1->Fill(iw+18,1);
            if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r1->Fill(iw+18,1);
            if(jadc<10) HFlumi_Occupancy_below_thr_r1->Fill(iw+18,1);
          }
          else if((digi.id().ieta()==-35)||(digi.id().ieta()==-36)) {
            if(jadc>100) HFlumi_Occupancy_above_thr_r2->Fill(iw+18,1);
            if((jadc>=10)&&(jadc<=100)) HFlumi_Occupancy_between_thrs_r2->Fill(iw+18,1);
            if(jadc<10) HFlumi_Occupancy_below_thr_r2->Fill(iw+18,1);
          }
                  iw=99;
        }
          }
        }
      }//---endif ieta inHF-
    }//---endif TS=nr6
      } 
    }//------end loop over TS for lumi
    return;
  }
}
 // void HcalBeamMonitor::processEvent(const HBHERecHit Collection&hbheHits; ...)


void HcalBeamMonitor::beginLuminosityBlock(const edm::LuminosityBlock& lumiSeg,
                       const edm::EventSetup& c)
  
{
  // reset histograms that get updated each luminosity section

  if (LumiInOrder(lumiSeg.luminosityBlock())==false) return;
  HcalBaseDQMonitor::beginLuminosityBlock(lumiSeg,c);

  if (lumiSeg.luminosityBlock()==lastProcessedLS_) return; // we're seeing more events from current lumi section (after some break) -- should not reset histogram
  ProblemsCurrentLB->Reset();
  HFlumi_occ_LS->Reset();
  std::stringstream title;
  title <<"HFlumi occupancy for LS # " <<currentLS;
  HFlumi_occ_LS->getTH2F()->SetTitle(title.str().c_str());
  return;
} // void HcalBeamMonitor::beginLuminosityBlock()

void HcalBeamMonitor::endLuminosityBlock(const edm::LuminosityBlock& lumiSeg,
                     const edm::EventSetup& c)
{
  if (debug_>1) std::cout <<"<HcalBeamMonitor::endLuminosityBlock>"<<std::endl;
  if (LumiInOrder(lumiSeg.luminosityBlock())==false)
    {
      if (debug_>1)  
    std::cout <<"<HcalBeamMonitor::endLuminosityBlock>  Failed LumiInOrder test!"<<std::endl;
      return;
    }
  lastProcessedLS_=lumiSeg.luminosityBlock();
  float Nentries=HFlumi_occ_LS->getBinContent(-1,-1);
  if (debug_>3) 
    std::cout <<"Number of entries in this LB = "<<Nentries<<std::endl;

  if (Nentries<minEvents_) 
    {
      // not enough entries to determine status; fill everything with -1 and return
      HFlumi_Ring1Status_vs_LS->Fill(currentLS,-1);
      HFlumi_Ring2Status_vs_LS->Fill(currentLS,-1);
      if (Online_==false)
    return;
      // write to output file if required (Online running)
      if (lumiqualitydir_.size()==0)
    return;
      // dump out lumi quality file
      std::ofstream outStream(outfile_.str().c_str(),std::ios::app);
      outStream<<currentLS<<"\t\t-1\t\t\t-1\t\t\t-1\t\t"<<Nentries<<std::endl;
      outStream.close();
      return;
    }
  if (Nentries==0) return;


  HFlumi_total_deadcells->Fill(-1,-1,1); // counts good lumi sections in underflow bin
  HFlumi_total_hotcells->Fill(-1,-1,1);
  HFlumi_diag_deadcells->Fill(-1,-1,1); // counts good lumi sections in underflow bin
  HFlumi_diag_hotcells->Fill(-1,-1,1);

  // ADD IETA MAP
  int ietamap[8]={-36,-35,-34,-33,33,34,35,36};
  int ieta=-1, iphi = -1, depth=-1;
  int badring1=0;
  int badring2=0;
  int ndeadcells=0;
  int nhotcells=0;
  
  // Loop over cells once to count hot & dead chanels
  for (int x=1;x<=HFlumi_occ_LS->getTH2F()->GetNbinsX();++x)
    {
      for (int y=1;y<=HFlumi_occ_LS->getTH2F()->GetNbinsY();++y)
    {

      // Skip over channels that are flagged as bad
      if (x<=8)
        ieta=ietamap[x-1];
      else
        ieta=-1;
      iphi=2*y-1;
      if (abs(ieta)==33 || abs(ieta)==34)  depth=1;
      else if (abs(ieta)==35 || abs(ieta)==36) depth =2;
      else depth = -1;
      if (depth !=-1 && ieta!=1)
        {
          HcalDetId thisID(HcalForward, ieta, iphi, depth);
          if (BadCells_.find(thisID)!=BadCells_.end())
        continue;
        }
      double Ncellhits=HFlumi_occ_LS->getBinContent(x,y);
      if (Ncellhits==0)
        {
          ++ndeadcells;
          HFlumi_diag_deadcells->Fill(x-1,2*y-1,1);
        }
      // hot if present in more than 25% of events in the LS
      if (Ncellhits>hotrate_*Nentries) 
        {
          ++nhotcells;
          HFlumi_diag_hotcells->Fill(x-1,2*y-1,1);
        }
      if (Ncellhits==0 || Ncellhits>hotrate_*Nentries) // cell was either hot or dead
        {
          if (depth==1)  badring1++;
          else if (depth==2)  badring2++;
        }
    } // loop over y
    } // loop over x

  // Fill problem histogram underflow bind with number of events
  ProblemsCurrentLB->Fill(-1,-1,levt_);
  if (ndeadcells+nhotcells>=minBadCells_)
    {
      // Fill with number of error channels * events (assume bad for all events in LS)
      ProblemsCurrentLB->Fill(6,0,(ndeadcells+nhotcells)*levt_);
      for (int x=1;x<=HFlumi_occ_LS->getTH2F()->GetNbinsX();++x)
    {
      for (int y=1;y<=HFlumi_occ_LS->getTH2F()->GetNbinsY();++y)
        {
          if (x<=8)
        ieta=ietamap[x-1];
          else
        ieta=-1;
          iphi=2*y-1;
          if (abs(ieta)==33 || abs(ieta)==34)  depth=1;
          else if (abs(ieta)==35 || abs(ieta)==36) depth =2;
          else depth = -1;
          if (depth !=-1 && ieta!=1)
        {
          // skip over channels that are flagged as bad
          HcalDetId thisID(HcalForward, ieta, iphi, depth);
          if (BadCells_.find(thisID)!=BadCells_.end())
            continue;
        }
          double Ncellhits=HFlumi_occ_LS->getBinContent(x,y);
          if (Ncellhits==0)
        {
          // One new luminosity section found with no entries for the cell in question
          HFlumi_total_deadcells->Fill(x-1,2*y-1,1);
        } // dead cell check
          
          // hot if present in more than 25% of events in the LS
          if (Ncellhits>hotrate_*Nentries)
        {
          HFlumi_total_hotcells->Fill(x-1,2*y-1,1);
        } // hot cell check
        } // loop over y
    } // loop over x
    } // if (ndeadcells+nhotcells>=minBadCells_)

  // Fill fraction of bad channels found in this LS
  double ring1status=0;
  double ring2status=0;
  if (ring1totalchannels_==0)
    ring1status=0;
  else
    ring1status=1-1.*badring1/ring1totalchannels_;
  HFlumi_Ring1Status_vs_LS->Fill(currentLS,ring1status);
  if (ring2totalchannels_==0)
    ring2status=0;
  else
    ring2status=1-1.*badring2/ring2totalchannels_;
  HFlumi_Ring2Status_vs_LS->Fill(currentLS,ring2status);  
  
  // Good status:  ring1 and ring2 status both > 90%
  int totalstatus=0;
  if (ring1status>0.9 && ring2status>0.9)
    totalstatus=1;
  else 
    {
      if (ring1status<=0.9)
    totalstatus-=2;
      if (ring2status<=0.9)
    totalstatus-=4;
    }

  if (lumiqualitydir_.size()==0)
    return;
  // dump out lumi quality file
  std::ofstream outStream(outfile_.str().c_str(),std::ios::app);
  outStream.precision(6);
  outStream<<currentLS<<"\t\t"<<ring1status<<"\t\t"<<ring2status<<"\t\t"<<totalstatus<<"\t\t"<<Nentries<<std::endl;
  outStream.close();
  return;
}

const float HcalBeamMonitor::area[]={0.111,0.175,0.175,0.175,0.175,0.175,0.174,0.178,0.172,0.175,0.178,0.346,0.604};
const float HcalBeamMonitor::radius[]={1300,1162,975,818,686,576,483,406,340,286,240,201,169};

void HcalBeamMonitor::SetEtaLabels(MonitorElement * h)
{
  h->getTH2F()->GetXaxis()->SetBinLabel(1,"-36S");
  h->getTH2F()->GetXaxis()->SetBinLabel(2,"-35S");
  h->getTH2F()->GetXaxis()->SetBinLabel(3,"-34L");
  h->getTH2F()->GetXaxis()->SetBinLabel(4,"-33L");
  h->getTH2F()->GetXaxis()->SetBinLabel(5,"33L");
  h->getTH2F()->GetXaxis()->SetBinLabel(6,"34L");
  h->getTH2F()->GetXaxis()->SetBinLabel(7,"35S");
  h->getTH2F()->GetXaxis()->SetBinLabel(8,"36S");
  return;
}

DEFINE_FWK_MODULE(HcalBeamMonitor);