ZDCDataAnalyzer.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef ZDCANALYSIS_ZDCDataAnalyzer_h
#define ZDCANALYSIS_ZDCDataAnalyzer_h
 
#include "ZDCJSONConfig.h"
#include "ZdcAnalysis/ZDCPulseAnalyzer.h"
#include "ZdcAnalysis/ZDCMsg.h"
#include "TSpline.h"
 
#include <array>
#include <string>
#include <memory>
#include <cmath> //for std::sqrt
#include <functional>
 
#include "CxxUtils/checker_macros.h"
 
 
class ATLAS_NOT_THREAD_SAFE ZDCDataAnalyzer
{
public:
  typedef std::array<std::array<float, 4>, 2> ZDCModuleFloatArray;
  typedef std::array<std::array<bool, 4>, 2> ZDCModuleBoolArray;
  typedef std::array<std::array<int, 4>, 2> ZDCModuleIntArray;
 
  using JSON = ZDCJSONConfig::JSON;
  static const ZDCJSONConfig::JSONParamList JSONConfigParams;
  
private:
  ZDCMsg::MessageFunctionPtr m_msgFunc_p;
  std::unique_ptr<ZDCJSONConfig> m_dataAnalyzerConfig{};
  std::unique_ptr<ZDCJSONConfig> m_pulseAnalyzerConfig{};
  
  bool m_repassEnabled{false};
 
  std::array<std::array<int, 4>, 2> m_delayedOrder{};
 
  ZDCModuleBoolArray m_moduleEnabled{};
  std::array<std::array<std::unique_ptr<ZDCPulseAnalyzer>, 4>, 2> m_moduleAnalyzers{};
 
  int m_eventCount{0};
 
  ZDCModuleFloatArray m_HGGains{};
  ZDCModuleFloatArray m_pedestals{};
 
  bool m_haveECalib{false};
  bool m_haveT0Calib{false};
  std::array<std::array<std::unique_ptr<TSpline>, 4>, 2> m_LBDepEcalibSplines{};
  std::array<std::array<std::unique_ptr<TSpline>, 4>, 2> m_T0HGOffsetSplines{};
  std::array<std::array<std::unique_ptr<TSpline>, 4>, 2> m_T0LGOffsetSplines{};
 
  // Transient data that is updated each LB or each event
  //
  int m_currentLB{-1};
  ZDCModuleFloatArray m_currentECalibCoeff{};
  ZDCModuleFloatArray m_currentT0OffsetsHG{};
  ZDCModuleFloatArray m_currentT0OffsetsLG{};
 
  std::array<std::array<bool, 4>, 2> m_dataLoaded{};
 
  unsigned int m_moduleMask{0};
 
  std::array<std::array<unsigned int, 4>, 2> m_moduleStatus{};
  std::array<std::array<float, 4>, 2> m_calibAmplitude{};
  std::array<std::array<float, 4>, 2> m_calibTime{};
 
  std::array<float, 2> m_moduleSum{};
  std::array<float, 2> m_moduleSumErrSq{};
  std::array<float, 2> m_moduleSumPreSample{};
  std::array<float, 2> m_moduleSumBkgdFrac{};
 
  std::array<float, 2> m_calibModuleSum{};
  std::array<float, 2> m_calibModuleSumErrSq{};
  std::array<float, 2> m_calibModSumBkgdFrac{};
 
  bool m_haveNLcalib{false};
  std::array< std::array< std::vector<float>, 3>, 2> m_NLcalibFactors{}; // 3 POL5s for each side
  
  std::array<float, 2> m_NLcalibModuleSum{};
  std::array<float, 2> m_NLcalibModuleSumErrSq{};
  std::array<float, 2> m_NLcalibModSumBkgdFrac{};
 
  std::array<float, 2> m_averageTime{};
  std::array<bool, 2> m_fail{};
 
  std::array<std::array<float, 4>, 2> m_moduleAmpFractionLG{};
 
  void init();
  
public:
 
  ZDCDataAnalyzer(ZDCMsg::MessageFunctionPtr messageFunc_p, int nSample, float deltaTSample,
                  size_t preSampleIdx, const std::string &fitFunction,
                  const ZDCModuleIntArray& peak2ndDerivMinSamples,
                  const ZDCModuleFloatArray& peak2ndDerivMinThresholdsHG,
                  const ZDCModuleFloatArray& peak2ndDerivMinThresholdsLG,
                  unsigned int LGMode = ZDCPulseAnalyzer::LGModeNormal);
 
  ZDCDataAnalyzer(ZDCMsg::MessageFunctionPtr messageFunc_p, const JSON& configJSON);
 
  ~ZDCDataAnalyzer(){};
 
  template<typename T> bool getPulseAnalyzerGlobalPar(const std::string& key, T& value) {
    if (m_pulseAnalyzerConfig.get()) return m_pulseAnalyzerConfig->getGlobalParam(key, value);
    else return false;
  }
 
  template<typename T> void invokeAll(T functor)
  {
    for (size_t side : {0, 1}) {
      for (size_t module : {0, 1, 2, 3}) {
    functor(m_moduleAnalyzers[side][module].get());
      }
    }
  }
  
  void enableDelayed(float deltaT, const ZDCModuleFloatArray& undelayedDelayedPedestalDiff);
  void enableDelayed(const ZDCModuleFloatArray& delayDeltaT, const ZDCModuleFloatArray& undelayedDelayedPedestalDiff);
 
  void enableRepass(const ZDCModuleFloatArray& peak2ndDerivMinRepassHG, const ZDCModuleFloatArray& peak2ndDerivMinRepassLG);
 
  void enablePreExclusion(unsigned int maxSamplesExcl, const ZDCModuleIntArray& HGADCThresh, const ZDCModuleIntArray& LGADCThresh);
  void enablePreExclusion(unsigned int maxSamplesExcl, unsigned int HGADCThresh, unsigned int LGADCThresh);
 
  void enablePostExclusion(unsigned int maxSamplesExcl, const ZDCModuleIntArray& HGADCThresh, const ZDCModuleIntArray& LGADCThresh);
  void enablePostExclusion(unsigned int maxSamplesExcl, unsigned int HGADCThresh, unsigned int LGADCThresh);
 
  bool ModuleDisabled(unsigned int side, unsigned int module) const {return !m_moduleEnabled[side][module];}
  bool moduleEnabled(unsigned int side, unsigned int module) const {return m_moduleEnabled[side][module];}
 
  unsigned int GetModuleMask() const {return m_moduleMask;}
 
  float GetModuleSum(size_t side) const {return m_moduleSum.at(side);}
  float GetModuleSumErr(size_t side) const {return std::sqrt(m_moduleSumErrSq.at(side));}
  float GetSideBkgdFrac(size_t side) const {return m_moduleSumBkgdFrac.at(side);}
  
  float GetCalibModuleSum(size_t side) const {return m_calibModuleSum.at(side);}
  float GetCalibModuleSumErr(size_t side) const {return std::sqrt(m_calibModuleSumErrSq.at(side));}
  float GetSideCalibBkgdFrac(size_t side) const {return m_calibModSumBkgdFrac.at(side);}
 
  void DoNLcalibModuleSum();
  float GetNLcalibModuleSum(size_t side) const {return m_NLcalibModuleSum.at(side);}
  float GetNLcalibModuleSumErr(size_t side) const {return std::sqrt(m_NLcalibModuleSumErrSq.at(side));}
 
  float GetModuleSumPreSample(size_t side) const {return m_moduleSumPreSample.at(side);}
 
  float GetAverageTime(size_t side) const {return m_averageTime.at(side);}
  bool SideFailed(size_t side) const {return m_fail.at(side);}
 
  float GetModuleAmplitude(size_t side, size_t module) const {return m_moduleAnalyzers.at(side).at(module)->GetAmplitude();}
  float GetModuleTime(size_t side, size_t module) const {return m_moduleAnalyzers.at(side).at(module)->GetT0Corr();}
  float GetModuleChisq(size_t side, size_t module) const {return m_moduleAnalyzers.at(side).at(module)->GetChisq();}
 
  float GetModuleCalibAmplitude(size_t side, size_t module) const {return m_calibAmplitude.at(side).at(module);}
  float GetModuleCalibTime(size_t side, size_t module) const {return m_calibTime.at(side).at(module);}
  float GetModuleStatus(size_t side, size_t module) const {return m_moduleStatus.at(side).at(module);}
 
  float GetdelayedBS(size_t side, size_t module) const {return m_moduleAnalyzers.at(side).at(module)->GetdelayBS();}
 
  const ZDCPulseAnalyzer* GetPulseAnalyzer(size_t side, size_t module) const {return m_moduleAnalyzers.at(side).at(module).get();}
  ZDCPulseAnalyzer* GetPulseAnalyzer(size_t side, size_t module) {return m_moduleAnalyzers.at(side).at(module).get();}
 
  bool disableModule(size_t side, size_t module);
 
  void set2ndDerivStep(size_t step);
 
  void setMinimumSignificance(float sigMinHG, float sigMinLG);
  
  void SetGainFactorsHGLG(float gainFactorHG, float gainFactorLG);
 
  void SetGainFactorsHGLG(const ZDCModuleFloatArray& gainFactorsHG, const ZDCModuleFloatArray& gainFactorsLG); 
 
  void SetPeak2ndDerivMinTolerances(size_t tolerance);
 
  void SetFitTimeMax(float tmax);
 
  void SetADCOverUnderflowValues(const ZDCModuleFloatArray& HGOverflowADC, const ZDCModuleFloatArray& HGUnderflowADC,
                                 const ZDCModuleFloatArray& LGOverflowADC);
 
  void SetNoiseSigmas(const ZDCModuleFloatArray& noiseSigmasHG, const ZDCModuleFloatArray& noiseSigmasLG);
 
  void setPerSampleNoiseSigmas(const std::array<std::array<std::vector<float>,4>,2>& sampleNoiseVecsHG,
                   const std::array<std::array<std::vector<float>,4>,2>& sampleNoiseVecsLG);
 
  void SetTauT0Values(const ZDCModuleBoolArray& fxiTau1, const ZDCModuleBoolArray& fxiTau2,
                      const ZDCModuleFloatArray& tau1, const ZDCModuleFloatArray& tau2,
                      const ZDCModuleFloatArray& t0HG, const ZDCModuleFloatArray& t0LG);
 
  void SetFitMinMaxAmpValues(const ZDCModuleFloatArray& minAmpHG, const ZDCModuleFloatArray& minAmpLG,
                             const ZDCModuleFloatArray& maxAmpHG, const ZDCModuleFloatArray& maxAmpLG);
 
  void SetFitMinMaxAmpValues(float minHG, float minLG, float maxHG, float maxLG);
 
  void SetCutValues(const ZDCModuleFloatArray& chisqDivAmpCutHG, const ZDCModuleFloatArray& chisqDivAmpCutLG,
                    const ZDCModuleFloatArray& deltaT0MinHG, const ZDCModuleFloatArray& deltaT0MaxHG,
                    const ZDCModuleFloatArray&  deltaT0MinLG, const ZDCModuleFloatArray& deltaT0MaxLG);
 
  void SetTimeCuts(const ZDCModuleFloatArray& deltaT0MinHG, const ZDCModuleFloatArray& deltaT0MaxHG,
           const ZDCModuleFloatArray&  deltaT0MinLG, const ZDCModuleFloatArray& deltaT0MaxLG);
 
  void SetChisqCuts(const ZDCModuleFloatArray& chisqDivAmpCutHG, const ZDCModuleFloatArray& chisqDivAmpScaleHG,
            const ZDCModuleFloatArray& chisqDivAmpOffsetHG, const ZDCModuleFloatArray& chisqDivAmpPowerHG, 
            const ZDCModuleFloatArray& chisqDivAmpCutLG, const ZDCModuleFloatArray& chisqDivAmpScaleLG,
            const ZDCModuleFloatArray& chisqDivAmpOffsetLG, const ZDCModuleFloatArray& chisqDivAmpPowerLG);
 
  void SetTimingCorrParams(ZDCPulseAnalyzer::TimingCorrMode mode, float refADC, float refScale,
               const std::array<std::array<std::vector<float>, 4>, 2>& HGParamArr,
               const std::array<std::array<std::vector<float>, 4>, 2>& LGParamArr);
 
  void SetNonlinCorrParams(float refADC, float refScale,
               const std::array<std::array<std::vector<float>, 4>, 2>& HGNonlinCorrParams,
               const std::array<std::array<std::vector<float>, 4>, 2>& LHGNonlinCorrParams);
 
  void SetNLcalibParams(std::array< std::array< std::vector<float>, 3>, 2>& nlcalibParams);
  
  void SetModuleAmpFractionLG(const ZDCDataAnalyzer::ZDCModuleFloatArray& moduleAmpFractionLG);
 
  void enablePostPulseCheck(unsigned int postPulseSampleDelta, float postPulseDerivMinSig, float postPulseAbsDer2ndMinSig, float minMainDer2ndRatio);
  
  void enableTimeSigCut(bool AND, float sigCut, const std::string& TF1String,
            const std::array<std::array<std::vector<double>, 4>, 2>& parsHGArr, 
            const std::array<std::array<std::vector<double>, 4>, 2>& parsLGArr);
 
  void enableFADCCorrections(bool correctPerSample,
                 std::array<std::array<std::unique_ptr<const TH1>, 4>, 2>& correHistHG,
                 std::array<std::array<std::unique_ptr<const TH1>, 4>, 2>& correHistLG);
 
  void disableFADCCorrections();
 
  void LoadEnergyCalibrations(std::array<std::array<std::unique_ptr<TSpline>, 4>, 2>&& calibSplines)
  {
    (*m_msgFunc_p)(ZDCMsg::Verbose, "Loading energy calibrations");
 
    m_LBDepEcalibSplines = std::move (calibSplines);
    m_haveECalib = true;
  }
 
  void LoadT0Calibrations(std::array<std::array<std::unique_ptr<TSpline>, 4>, 2>&& T0HGOffsetSplines,
                          std::array<std::array<std::unique_ptr<TSpline>, 4>, 2>&& T0LGOffsetSplines)
  {
    (*m_msgFunc_p)(ZDCMsg::Verbose, "Loading timing calibrations");
 
    m_T0HGOffsetSplines = std::move (T0HGOffsetSplines);
    m_T0LGOffsetSplines = std::move (T0LGOffsetSplines);
 
    m_haveT0Calib = true;
  }
 
  void StartEvent(int lumiBlock);
 
  void LoadAndAnalyzeData(size_t side, size_t module, const std::vector<float>& HGSamples, const std::vector<float>& LGSamples);
 
  void LoadAndAnalyzeData(size_t side, size_t module, const std::vector<float>& HGSamples, const std::vector<float>& LGSamples,
                          const std::vector<float>& HGSamplesDelayed, const std::vector<float>& LGSamplesDelayed);
 
  bool FinishEvent();
 
  void saveFitFunc(bool save);
 
  void setQuietFits(bool quiet) {
    if (quiet) invokeAll([](ZDCPulseAnalyzer* pa){pa->setQuietFits();});
    else invokeAll([](ZDCPulseAnalyzer* pa){pa->setUnquietFits();});
  }
 
};
#endif