makeHIResponse.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#include "TChain.h"
#include "TChainElement.h"
#include "TFile.h"
#include "TH1I.h"
#include "TH2F.h"
#include "TH3F.h"
#include "TObjArray.h"
 
#include <algorithm>
#include <cmath>
#include <cstdio>
#include <iostream>
#include <memory>
#include <unordered_map>
#include <vector>
#include <string>

std::unordered_map<int, std::vector<std::pair<int, int>>> getGRLMap(char *grl) {
  // get rid of everything except the run numbers and LB ranges
  // also removes the line with all the runs, so each run number is mentioned only once
  FILE *runList = popen(Form("grep \"Run\\|LBRange\" %s | grep -v Metadata | grep -v GoodRunsListWriter"
                             " | sed -e's/[<>A-Za-z=\"/]//g' -e 's/^ //g' -e 's/ $//g' -e 's/  */ /g' ",
                             grl),
                        "r");
 
  std::unordered_map<int, std::vector<std::pair<int, int>>> grlMap{};
  int a, LB1 = 0;
  int currentRun = -1;
  while (fscanf(runList, "%d", &a) != EOF) {
    if (a > 100000) {
      // new run
      if(LB1 != 0) {
        std::cout << "Start of a new run " << a << ", but the previous LB range is not closed, LB1 = " 
        << LB1 << "; check the GRL file " << grl << std::endl;
      }
      currentRun = a;
      continue;
    } else {
      // LB
      if (LB1 == 0) {
        LB1 = a; // starting LB
      }
      else {
        // ending LB
        grlMap[currentRun].push_back(std::make_pair(LB1, a));
        LB1 = 0;
        continue;
      }
    }
  }
  int status = pclose(runList);
  if (status == -1) {
    std::cout << "Error in pclose" << std::endl;
  }
  return grlMap;
}

std::string getFileNamePattern(std::string name, int runNr) {
    std::string runStr = Form("%d", runNr);
    size_t position = 0;
    while ((position = name.find("%d", position)) != std::string::npos) {
        name.replace(position, 2, runStr);
        position += runStr.length();
    }
    return name;
}
 

int main(int argc, char **argv) {
  if (argc <= 2) {
    std::cout << "Syntax: " << argv[0] << " GoodRunList.xml /path/to/input/files/first.part. [.second.part [...]]" << std::endl;
    return -1;
  }
 
  auto grlMap = getGRLMap(argv[1]);
  // for(auto& run : grlMap)
  // {
  //   std::cout<<"Run "<<run.first<<", size: "<<run.second.size()<<std::endl;
  //   for(auto& lb : run.second)
  //   {
  //     std::cout<<"  LB "<<lb.first<<" "<<lb.second<<std::endl;
  //   }
  // }
  if (grlMap.size() == 0) {
    std::cout << "No runs found, is the GRL file (" << argv[1] << ") correct?" << std::endl;
    return -1;
  }
 
  std::vector<int> runs;
  for (auto &run : grlMap) {
    runs.push_back(run.first);
  }
  std::sort(runs.begin(), runs.end());
 
  // create run index, since we have all the runs now
  auto runIndex=std::make_unique<TH1I>("h1_run_index", "h1_run_index", runs.size(), 0, runs.size());
  for (unsigned int r = 0; r < runs.size(); r++) {
    runIndex->SetBinContent(r + 1, runs.at(r));
  }
 
  // connect all the parts of the file name with a placeholder for a run number
  std::string fileNameTemplate="";
  for(int a = 2; a < argc; ++a) {
    fileNameTemplate += std::string(argv[a]);
    if (a != argc-1) {
      // this will be replaced by a run number
      fileNameTemplate += std::string("%d");
    }
  }
 
  std::unique_ptr<TH3F> response;
  std::unique_ptr<TH3F> offset;
  std::unique_ptr<TH3F> entries;
  std::unique_ptr<TH2F> etaPhiMap;
 
  // loop over runs
  for (unsigned int r = 0; r < runs.size(); r++) {
    int run = runs.at(r);
    // replace placeholders with the actual run number;
    std::string fileNamePattern = getFileNamePattern(fileNameTemplate, run);
 
    std::unique_ptr<TChain> filesChain = std::make_unique<TChain>("");
    // "Add" also resolves wildcards, if present
    filesChain->Add(fileNamePattern.c_str());
    TObjArray * files = filesChain->GetListOfFiles();
 
    if (files->IsEmpty()) {
      std::cout << "Could not open any file with pattern " << fileNamePattern << ", skipping the run " << run << std::endl;
      continue;
    }
 
    int filesNum = files->GetEntries();
    std::cout << "Opened " << filesNum << " file" << (filesNum > 1 ? "s" : "") << " with pattern " << fileNamePattern 
    << ", processing the run " << run << std::endl;
 
    std::unique_ptr<TH2F> sums;
 
    // for each file matching the pattern
    TIter next(files);
    TChainElement * fileEl = 0;
    while (( fileEl = (TChainElement*)next() )) {
      std::unique_ptr<TFile> file = std::make_unique<TFile>(fileEl->GetTitle());
      std::cout << "Processing file " << file->GetName() << std::endl;
 
      if (!etaPhiMap) {
        // when the first file in opened, get the eta-phi mapping
        etaPhiMap = std::make_unique<TH2F>(*(TH2F*)file->Get<TH2F>("h_etaPhiMapping"));
        etaPhiMap->SetDirectory(nullptr);
 
        // book response and offset once eta-phi mapping is known
        response =
            std::make_unique<TH3F>("h3_eta_phi_response", "h3_eta_phi_response", 
                    etaPhiMap->GetNbinsX(), etaPhiMap->GetXaxis()->GetXmin(), etaPhiMap->GetXaxis()->GetXmax(),
                    etaPhiMap->GetNbinsY(), etaPhiMap->GetYaxis()->GetXmin(), etaPhiMap->GetYaxis()->GetXmax(),
                    runs.size(), 0, runs.size());
        response->SetDirectory(nullptr);
        offset = std::make_unique<TH3F>(*(TH3F*)response->Clone("h3_eta_phi_offset"));
        offset->SetTitle("h3_eta_phi_offset");
        offset->SetDirectory(nullptr);
        entries = std::make_unique<TH3F>(*(TH3F*)response->Clone("h3_eta_phi_entries"));
        entries->SetTitle("h3_eta_phi_entries");
        entries->SetDirectory(nullptr);
      }
 
      // for each range of LBs
      for (auto &lbs : grlMap[run]) {
        // for each LB in that range
        for (int lb = lbs.first; lb <= lbs.second; lb++) {
          std::unique_ptr<TH2F> tmp(file->Get<TH2F>(Form("h_clusterET_fcalET_%d_%d", run, lb)));
          if (!tmp) {
            std::cout << "Could not get h_clusterET_fcalET_" << run << "_" << lb << ", skipping this LB, r = "<<r << std::endl;
            continue;
          }
 
          // merge into a single histogram
          if (!sums) {
            sums = std::make_unique<TH2F>(*(TH2F*)tmp->Clone("h_clusterET_fcalET_sum"));
            sums->SetDirectory(nullptr);
          }
          else {
            sums->Add(tmp.get());
          }
        }
      }
    }
 
    if(!sums)
    {
      std::cout << "Could not get any LB, skipping the run " << run <<std::endl;
      continue;
    }
 
    // for each bin number
    for (int binID = 1; binID <= sums->GetNbinsX(); binID++) {
      float numEntries = sums->GetBinContent(binID, 6);
      if (numEntries == 0) {
        // skip empty bins - these are most likely under- and overflow bins
        continue;
      }
 
      int eta, phi, dummy;
      etaPhiMap->GetBinXYZ(binID - 1, eta, phi, dummy);
 
      float sumFCalET = sums->GetBinContent(binID, 1);
      float sumClusterET = sums->GetBinContent(binID, 2);
      float sumFCalET2 = sums->GetBinContent(binID, 3);
      // sumClusterET2 is not needed
      float sumFCalET_clusterET = sums->GetBinContent(binID, 5);
 
      float avgFCalET = sumFCalET / numEntries;
      float avgClusterET = sumClusterET / numEntries;
      float delta = sumFCalET2 - 2 * sumFCalET * avgFCalET + numEntries * avgFCalET * avgFCalET;
      if (delta == 0) {
        continue;
      }
 
      // response and offset; response is not normalized yet
      float resp = (sumFCalET_clusterET - sumClusterET * avgFCalET) / delta;
      float offs = avgClusterET - avgFCalET * resp;
 
      if (resp < 0) {
        resp = 0;
      }
 
      entries->SetBinContent(eta, phi, r + 1, numEntries);
      response->SetBinContent(eta, phi, r + 1, resp);
      offset->SetBinContent(eta, phi, r + 1, offs);
    }
  }
 
  if (!response || !offset) {
    std::cout << "Could not create response or offset" << std::endl;
    return -1;
  }
 
  entries->GetXaxis()->SetRangeUser(-1.99,1.99);
  std::unique_ptr<TH1F> avgEntries((TH1F *)entries->Project3D("z"));
  avgEntries->Scale(1.0 / ((entries->GetXaxis()->GetLast() - entries->GetXaxis()->GetFirst()+1) * entries->GetNbinsY()));
  entries->GetXaxis()->SetRange(0,0);
 
  // normalize response in phi
  for (int r = 1; r <= response->GetNbinsZ(); r++) {
 
    // use bins with at least 10% of average entries
    float limitEntries = 0.1 * avgEntries->GetBinContent(r);
 
    for (int eta = 1; eta <= response->GetNbinsX(); eta++) {
      int entr = 0;
      float sum = 0;
 
      for (int phi = 1; phi <= response->GetNbinsY(); phi++) {
        if (entries->GetBinContent(eta, phi, r) < limitEntries) {
          // skip this eta-phi bin
          continue;
        }
        sum += response->GetBinContent(eta, phi, r);
        ++entr;
      }
 
      if(entr > 0) {
        sum /= entr;
      }
      else {
        sum = 1.0;
      }
 
      for (int phi = 1; phi <= response->GetNbinsY(); phi++) {
        if (entries->GetBinContent(eta, phi, r) < limitEntries) {
          response->SetBinContent(eta, phi, r, 1.0);
          offset->SetBinContent(eta, phi, r, 0.0);
        } else {
          float resp = response->GetBinContent(eta, phi, r) / sum;
          if(std::isnan(resp) || resp<=0.) {
            resp = 1.0;
          }
 
          response->SetBinContent(eta, phi, r, resp);
        }
      }
    }
  }
 
 
  // save everything
  std::unique_ptr<TFile> outFile(TFile::Open("cluster.geo.RESPONSE_OFFSET_RUNINDEX.root", "RECREATE"));
  runIndex->Write();
  response->Write();
  offset->Write();
 
  std::cout << "Created output file cluster.geo.RESPONSE_OFFSET_RUNINDEX.root" << std::endl;
  return 0;
}