HLXMonitor.h

Go to the documentation of this file.

// -*- C++ -*-
//
// Package:    HLXMonitor
// Class:      HLXMonitor
// 
//
// Original Author:  Adam Hunt - Princeton University
//           email:  ahunt@princeton.edu
//         Created:  Thu Jul 19 02:29:59 EDT 2007
// $Id: HLXMonitor.h,v 1.21 2010/07/21 04:23:20 wmtan Exp $
//
//

#ifndef _HLXMONITOR_H_
#define _HLXMONITOR_H_

// system include fileshlx_dqm_sourceclient-live.cfg
#include <iostream>
#include <string>
#include <memory>
#include <iomanip>
#include <cstdlib>
#include <sys/time.h>

// user include files
#include "FWCore/Framework/interface/Frameworkfwd.h" // Not included in example

#include "FWCore/Framework/interface/Event.h" // Not included in example
#include "FWCore/Framework/interface/MakerMacros.h" // Not included in example

#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"

#include "DQMServices/Core/interface/DQMStore.h"
#include "DQMServices/Core/interface/MonitorElement.h"

#include "FWCore/ServiceRegistry/interface/Service.h"

#include "RecoLuminosity/TCPReceiver/interface/TCPReceiver.h"
#include "RecoLuminosity/TCPReceiver/interface/LumiStructures.hh"

//
// class decleration
//


class HLXMonitor : public edm::EDAnalyzer 
{

   public:
      typedef HCAL_HLX::LUMI_SECTION LUMI_SECTION;
      typedef HCAL_HLX::TCPReceiver TCPReceiver;
      explicit HLXMonitor(const edm::ParameterSet&);
      ~HLXMonitor();
      
   private:
      virtual void beginJob() ;
      virtual void analyze(const edm::Event&, const edm::EventSetup&);
      virtual void endJob();
      //virtual void endRun(const edm::Run&, const edm::EventSetup&);

      void SaveDQMFile();

      void SetupHists();
      void SetupEventInfo();

      void FillHistograms(const LUMI_SECTION&);
      void FillHistoHFCompare(const LUMI_SECTION&);
      void FillReportSummary();
      void FillEventInfo(const LUMI_SECTION&, const edm::Event& e);

      void ResetAll();

      void EndRun( bool saveFile = true );

      double getUTCtime(timeval* a, timeval* b = NULL);

      //  void FillHistoHistory(const LUMI_SECTION&);

      // ----------member data ---------------------------
      TCPReceiver HLXTCP;      

      MonitorElement * Set1Below[36];
      MonitorElement * Set1Between[36];
      MonitorElement * Set1Above[36];
      MonitorElement * Set2Below[36];
      MonitorElement * Set2Between[36];
      MonitorElement * Set2Above[36];
      MonitorElement * ETSum[36];

      MonitorElement * HFCompareEtSum;
      MonitorElement * HFCompareOccBelowSet1;
      MonitorElement * HFCompareOccBetweenSet1;
      MonitorElement * HFCompareOccAboveSet1;
      MonitorElement * HFCompareOccBelowSet2;
      MonitorElement * HFCompareOccBetweenSet2;
      MonitorElement * HFCompareOccAboveSet2;

      MonitorElement * AvgEtSum;
      MonitorElement * AvgOccBelowSet1;
      MonitorElement * AvgOccBetweenSet1;
      MonitorElement * AvgOccAboveSet1;
      MonitorElement * AvgOccBelowSet2;
      MonitorElement * AvgOccBetweenSet2;
      MonitorElement * AvgOccAboveSet2;

      // Luminosity Monitoring
      MonitorElement * LumiAvgEtSum;
      MonitorElement * LumiAvgOccSet1;
      MonitorElement * LumiAvgOccSet2;
      MonitorElement * LumiInstantEtSum;
      MonitorElement * LumiInstantOccSet1;
      MonitorElement * LumiInstantOccSet2;
      MonitorElement * LumiIntegratedEtSum;
      MonitorElement * LumiIntegratedOccSet1;
      MonitorElement * LumiIntegratedOccSet2;

      // Sanity Check for Occupancy
      MonitorElement * SumAllOccSet1;
      MonitorElement * SumAllOccSet2;
      MonitorElement * MissingDQMDataCheck;

      // Signal and Background Levels
      MonitorElement * MaxInstLumiBX1;
      MonitorElement * MaxInstLumiBX2;
      MonitorElement * MaxInstLumiBX3;
      MonitorElement * MaxInstLumiBX4;

      MonitorElement * MaxInstLumiBXNum1;
      MonitorElement * MaxInstLumiBXNum2;
      MonitorElement * MaxInstLumiBXNum3;
      MonitorElement * MaxInstLumiBXNum4;

      // History plots - fill once per LS
      MonitorElement * HistAvgEtSumHFP;
      MonitorElement * HistAvgEtSumHFM;
      MonitorElement * HistAvgOccBelowSet1HFP;
      MonitorElement * HistAvgOccBelowSet1HFM;
      MonitorElement * HistAvgOccBetweenSet1HFP;
      MonitorElement * HistAvgOccBetweenSet1HFM;
      MonitorElement * HistAvgOccAboveSet1HFP;
      MonitorElement * HistAvgOccAboveSet1HFM;
      MonitorElement * HistAvgOccBelowSet2HFP;
      MonitorElement * HistAvgOccBelowSet2HFM;
      MonitorElement * HistAvgOccBetweenSet2HFP;
      MonitorElement * HistAvgOccBetweenSet2HFM;
      MonitorElement * HistAvgOccAboveSet2HFP;
      MonitorElement * HistAvgOccAboveSet2HFM;
      MonitorElement * BXvsTimeAvgEtSumHFP;
      MonitorElement * BXvsTimeAvgEtSumHFM;

      MonitorElement * HistAvgLumiEtSum;
      MonitorElement * HistAvgLumiOccSet1;
      MonitorElement * HistAvgLumiOccSet2;
      MonitorElement * HistInstantLumiEtSum;
      MonitorElement * HistInstantLumiOccSet1;
      MonitorElement * HistInstantLumiOccSet2;
      MonitorElement * HistInstantLumiEtSumError;
      MonitorElement * HistInstantLumiOccSet1Error;
      MonitorElement * HistInstantLumiOccSet2Error;
      MonitorElement * HistIntegratedLumiEtSum;
      MonitorElement * HistIntegratedLumiOccSet1;
      MonitorElement * HistIntegratedLumiOccSet2;

      MonitorElement * RecentInstantLumiEtSum;
      MonitorElement * RecentInstantLumiOccSet1;
      MonitorElement * RecentInstantLumiOccSet2;
      MonitorElement * RecentIntegratedLumiEtSum;
      MonitorElement * RecentIntegratedLumiOccSet1;
      MonitorElement * RecentIntegratedLumiOccSet2;


      //EventInfo Clone
      MonitorElement * runId_;
      MonitorElement * runStartTimeStamp_;  
      MonitorElement * eventId_;
      MonitorElement * lumisecId_;
      MonitorElement * eventTimeStamp_;
   
      MonitorElement * nUpdates_;          
      MonitorElement * processId_;         
      MonitorElement * processStartTimeStamp_; 
      MonitorElement * processTimeStamp_;  
      MonitorElement * processLatency_;    
      MonitorElement * processEventRate_;  
      MonitorElement * processEvents_;     
      MonitorElement * hostName_;          
      MonitorElement * processName_;       
      MonitorElement * workingDir_;        
      MonitorElement * cmsswVer_;          
      MonitorElement * dqmPatch_;          
      MonitorElement * errSummary_;        
      MonitorElement * errSummaryEtaPhi_;     
      MonitorElement * errSummarySegment_[10];

      // Report Summary
      MonitorElement * reportSummary_;
      MonitorElement * reportSummaryMap_;

      // DQM Store ...
      DQMStore* dbe_;

      unsigned int numActiveTowersSet1;
      unsigned int numActiveTowersSet2;

      unsigned int counter;
      unsigned char *rData;
      short int SectionComplete;
  
      // Parameters
      int listenPort;
      double XMIN,  XMAX;
      unsigned int NBINS;
      bool Accumulate;  
      std::string OutputFilePrefix;
      std::string OutputDir;
      std::string Style;   // BX, History, Distribution
      int SavePeriod;
      unsigned int NUM_HLX;
      unsigned int NUM_BUNCHES;
      unsigned int MAX_LS;
      unsigned int AquireMode;
      unsigned int TriggerBX;
      unsigned int MinLSBeforeSave;

      std::string monitorName_;
      int prescaleEvt_;

      unsigned int reconnTime;
      std::string DistribIP1;
      std::string DistribIP2;

      unsigned int set1BelowIndex;
      unsigned int set1BetweenIndex;
      unsigned int set1AboveIndex;
      unsigned int set2BelowIndex;
      unsigned int set2BetweenIndex;
      unsigned int set2AboveIndex;

      bool ResetAtNewRun;
      bool SaveAtEndJob;

      std::string eventInfoFolderHLX_;
      std::string eventInfoFolder_;
      std::string subSystemName_;

      unsigned int runNumLength;
      unsigned int secNumLength;

      std::string OccXAxisTitle;
      std::string OccYAxisTitle;
      std::string EtXAxisTitle;
      std::string EtYAxisTitle;

      HCAL_HLX::LUMI_SECTION lumiSection;

      bool         currentRunEnded_;
      unsigned int runNumber_;
      unsigned int expectedNibbles_;
      unsigned int totalNibbles_[36];

      unsigned int HLXHFMap[36];

      unsigned int previousSection;
      unsigned int lumiSectionCount;
      int lsBinOld;
      double sectionInstantSumEt;
      double sectionInstantErrSumEt;
      double sectionInstantSumOcc1;
      double sectionInstantErrSumOcc1;
      double sectionInstantSumOcc2;
      double sectionInstantErrSumOcc2;
      double sectionInstantNorm;

      // EventInfo Parameters
      timeval currentTime_, lastUpdateTime_, lastAvgTime_;
      timeval runStartTime_;
      float evtRateWindow_;
      int evtRateCount_;
      int pEvent_;

      // Lumi section info
      double num4NibblePerLS_;

};

#endif