xAODJetRetriever.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#include "xAODJiveXML/xAODJetRetriever.h"
 
#include "xAODJet/JetContainer.h"
#include "xAODCaloEvent/CaloCluster.h"
#include "xAODTracking/TrackParticle.h"
#include "xAODJet/JetAttributes.h"
#include "xAODPFlow/PFO.h"
#include "xAODPFlow/FlowElement.h"
 
#include "AthenaKernel/Units.h"
using Athena::Units::GeV;
 
namespace JiveXML {

  xAODJetRetriever::xAODJetRetriever(const std::string& type,const std::string& name,const IInterface* parent):
    AthAlgTool(type,name,parent){}
 
  StatusCode xAODJetRetriever::initialize() {
    ATH_CHECK(m_keys.initialize());
    if (m_bTaggerNames.size()!=m_CDIPaths.size()){
      ATH_MSG_WARNING("Number of btaggers and CDI files do not match. Will not retrieve b-tagging information.");
      return StatusCode::SUCCESS;
    } else {
      m_nTaggers = m_bTaggerNames.size();
    }
    const std::string taggerKey{"TaggerName"};
    const std::string authorKey{"JetAuthor"};
    const std::string authorVal{"AntiKt4EMPFlowJets"};
    const std::string opKey{"OperatingPoint"};
    const std::string opVal{"FixedCutBEff_70"};
    const std::string fnameKey{"FlvTagCutDefinitionsFileName"};
    const std::string minPtKey{"MinPt"};
    for (unsigned int i=0; i<m_nTaggers; i++){
      std::string taggerName = m_bTaggerNames[i];
      asg::AnaToolHandle<IBTaggingSelectionTool> btagSelTool;
      btagSelTool.setTypeAndName("BTaggingSelectionTool/btagSelTool_"+taggerName);
      ATH_CHECK(btagSelTool.setProperty(taggerKey, taggerName));
      ATH_CHECK(btagSelTool.setProperty(authorKey, authorVal)); // only AntiKt4EMPFlowJets is supported
      ATH_CHECK(btagSelTool.setProperty(opKey, opVal)); // the working point doesn't matter because we don't cut on the tagger discriminant, but it must exist in CDI.
      ATH_CHECK(btagSelTool.setProperty(fnameKey, m_CDIPaths[i]));
      ATH_CHECK(btagSelTool.setProperty( minPtKey, 0.0));
      ATH_CHECK(btagSelTool.initialize());
      m_btagSelTools.emplace(taggerName, btagSelTool);
    }
 
    return StatusCode::SUCCESS;
  }
 
  
  StatusCode xAODJetRetriever::retrieve(ToolHandle<IFormatTool> &FormatTool) {
 
    ATH_MSG_DEBUG( "in retrieve()" );
 
    // Loop through the keys and retrieve the corresponding data
    for (const auto& key : m_keys) {
      SG::ReadHandle<xAOD::JetContainer> cont(key);
      if (cont.isValid()) {
    DataMap data = getData(&(*cont), key.key());
    if (FormatTool->AddToEvent(dataTypeName(), key.key() + "_xAOD", &data).isFailure()) {
      ATH_MSG_WARNING("Failed to add collection " << key.key());
    } else {
      ATH_MSG_DEBUG(" (" << key.key() << ") retrieved");
    }
      } else {
    ATH_MSG_WARNING("Collection " << key.key() << " not found in SG");
      }
    }
 
    return StatusCode::SUCCESS;
  }
 

  const DataMap xAODJetRetriever::getData(const xAOD::JetContainer* jetCont, const std::string &jetkey) {
 
    ATH_MSG_DEBUG( "in getData()" );
 
    DataMap DataMap;
 
    DataVect et; et.reserve(jetCont->size());
    DataVect phi; phi.reserve(jetCont->size());
    DataVect eta; eta.reserve(jetCont->size());
    DataVect mass; mass.reserve(jetCont->size());
    DataVect energy; energy.reserve(jetCont->size());
    DataVect bTagName; bTagName.reserve(jetCont->size());
    DataVect bTagValue; bTagValue.reserve(jetCont->size());
    DataVect charge; energy.reserve(jetCont->size());
    DataVect idVec; idVec.reserve(jetCont->size());
    DataVect px; px.reserve(jetCont->size());
    DataVect py; py.reserve(jetCont->size());
    DataVect pz; pz.reserve(jetCont->size());
    DataVect jvf; jvf.reserve(jetCont->size());
    DataVect jvt; jvt.reserve(jetCont->size());
    DataVect emfrac; emfrac.reserve(jetCont->size());
 
    DataVect trackKey; trackKey.reserve(jetCont->size());
    DataVect trackContKey; trackContKey.reserve(jetCont->size());
    DataVect trackLinkCount; trackLinkCount.reserve(jetCont->size());
    DataVect clusterID; clusterID.reserve(jetCont->size());
 
    DataVect cellID; cellID.reserve(jetCont->size());
    DataVect numCells; numCells.reserve(jetCont->size());
 
    int id = 0;
 
    int counter = 0;
    for (const auto jet : *jetCont) {
      if(!jet)continue;
      ATH_MSG_DEBUG( "  Jet #" << counter++ << " : eta = "  << jet->eta() << ", phi = " << jet->phi() << ", pt = " << jet->pt() );
 
      /* retrieve associated tracks and calo clusters */
      size_t numConstit = jet->numConstituents();
      std::vector<std::string> tempCellID;
      size_t trackcounter = 0;
      //TODO FIXME jet->rawConstituent(0) fails for some keys, including (but not exclusively) HLT_AntiKt10EMPFlowCSSKJets_nojcalib_ftf, HLT_AntiKt10EMPFlowCSSKSoftDropBeta100Zcut10Jets_jes_ftf, HLT_AntiKt4EMPFlowJets_nojcalib_ftf, HLT_AntiKt4EMPFlowJets_subjesgscIS_ftf, HLT_AntiKt4EMPFlowJets_subresjesgscIS_ftf
      if (numConstit > 0){
    const xAOD::IParticle* constituent = jet->rawConstituent(0);
    if (constituent){
      xAOD::Type::ObjectType ctype=jet->rawConstituent(0)->type();
      // PFlow and Flow jets from athena/Reconstruction/Jet/JetMomentTools/Root/JetTrackMomentsTool.cxx
      if (ctype == xAOD::Type::ParticleFlow) {
        // This jet is either a PFlow jet (constituent type: xAOD::FlowElement::PFlow) or UFO jets
        for (size_t i = 0; i < numConstit; i++) {
          const xAOD::PFO *constit =
        static_cast<const xAOD::PFO *>(jet->rawConstituent(i));
          if (constit->isCharged()) {
        const xAOD::TrackParticle *thisTrack = constit->track(0); // by construction xAOD::PFO can only have one track, in eflowRec usage
        trackKey.emplace_back(DataType(thisTrack->index()));
        trackContKey.emplace_back(m_tracksName.value());
        trackcounter++;
          } // We have a charged PFO
        } // Loop on jet constituents
      } else if (ctype == xAOD::Type::FlowElement) {
        // This jet is made from xAOD::FlowElement, so we calculate the pflow moments if they're PFOs
        size_t numConstit = jet->numConstituents();
        for (size_t i = 0; i < numConstit; i++) {
          const xAOD::FlowElement *constit = dynamic_cast<const xAOD::FlowElement *>(jet->rawConstituent(i));
          // UFO jet constituents have signalType xAOD::FlowElement::Charged or xAOD::FlowElement::Neutral
          // PFlow jet constituents have signalType xAOD::FlowElement::ChargedPFlow or xAOD::FlowElement::NeutralPFlow
          if (constit != nullptr && ((constit->signalType() & xAOD::FlowElement::PFlow) || constit->signalType() == xAOD::FlowElement::Charged)) {
        if (constit->isCharged()) {
          const xAOD::TrackParticle *thisTrack = dynamic_cast<const xAOD::TrackParticle *>( constit->chargedObject( 0)); // PFO should have only 1 track
          if (thisTrack != nullptr) {
            trackKey.emplace_back(DataType(thisTrack->index()));
            trackContKey.emplace_back(m_tracksName.value());
            trackcounter++;
          }
          else
            ATH_MSG_WARNING( "Charged PFO had no associated TrackParticle");
        } // We have a charged PFO
          }   // The FlowElement is a PFO
        }     // Loop on jet constituents
      } else if (ctype == xAOD::Type::CaloCluster) {
        // get associated cluster
        for (size_t j = 0; j < numConstit; ++j) {
          const xAOD::CaloCluster *cluster = static_cast<const xAOD::CaloCluster *>(jet->rawConstituent(j));
          clusterID.emplace_back(DataType(cluster->index()));
          if(!cluster->getCellLinks())continue;
          for (const auto cc : *(cluster->getCellLinks())) {
        if (std::find(tempCellID.begin(), tempCellID.end(), std::to_string( cc->caloDDE()->identify().get_compact())) != tempCellID.end()) {
          continue;
        } else {
          cellID.emplace_back( DataType(cc->caloDDE()->identify().get_compact()));
          tempCellID.emplace_back( std::to_string(cc->caloDDE()->identify().get_compact()));
        }
          }
          ATH_MSG_VERBOSE("  Associated cluster: eta = " << cluster->eta() << ", phi = " << cluster->phi());
        }
        // get ghost associated tracks
        std::vector<const xAOD::TrackParticle*> ghosttracks;
        jet->getAssociatedObjects<xAOD::TrackParticle>(xAOD::JetAttribute::GhostTrack, ghosttracks);
        if (ghosttracks.empty()) {
          ATH_MSG_VERBOSE("  Associated track: ERROR");
        } else {
          for (size_t i = 0; i < ghosttracks.size(); i++) {
 
        // can access the base track class, should be able to get tracker hits ?
        // const Trk::Track* baseTrack = dynamic_cast< const Trk::Track* >( ghosttracks[i]->track());
 
        trackKey.emplace_back(DataType(ghosttracks[i]->index()));
        trackContKey.emplace_back(m_tracksName.value());
 
        ATH_MSG_VERBOSE("  Associated track: d0 = " << ghosttracks[i]->d0() << ", pt = " << ghosttracks[i]->pt());
          }
          trackcounter = ghosttracks.size();
        }
      } else if (ctype == xAOD::Type::TrackParticle) {
        for (size_t j = 0; j < numConstit; ++j) {
          const xAOD::TrackParticle *track =
        dynamic_cast<const xAOD::TrackParticle *>(jet->rawConstituent(j));
          if (!track) {
        ATH_MSG_VERBOSE("  Associated track: ERROR");
          } else {
        trackKey.emplace_back(DataType(track->index()));
        trackContKey.emplace_back(m_tracksName.value());
        trackcounter++;
        ATH_MSG_VERBOSE("  Associated track: d0 = " << track->d0() << ", pt = " << track->pt());
          }
        }
      }
    }
      }
      trackLinkCount.emplace_back(DataType(trackcounter));
      numCells.emplace_back(DataType(tempCellID.size()));
 
 
      phi.emplace_back(DataType(jet->phi()));
      eta.emplace_back(DataType(jet->eta()));
      et.emplace_back(DataType(jet->pt()/GeV)); // hack ! no et in xAOD_Jet_v1 currently
      idVec.emplace_back( DataType( ++id ));
 
      mass.emplace_back(DataType(jet->m()/GeV));
      energy.emplace_back( DataType(jet->e()/GeV ) );
 
      px.emplace_back(DataType(jet->px()/GeV));
      py.emplace_back(DataType(jet->py()/GeV));
      pz.emplace_back(DataType(jet->pz()/GeV));
 
      // bjet tagger values
      if (jetkey!="AntiKt4EMPFlowJets" || (m_nTaggers==0)){
    for (auto taggerName : m_bTaggerNames) {
      bTagName.emplace_back(DataType("None"));
      bTagValue.emplace_back(DataType(0.));
    }
      }else{
    double btagValue;
    for (auto taggerName : m_bTaggerNames) {
      CP::CorrectionCode code = m_btagSelTools[taggerName]->getTaggerWeight(*jet, btagValue);
      if (code != CP::CorrectionCode::Ok) {
        ATH_MSG_DEBUG("Failed to get btagging weight for tagger " << taggerName);
        btagValue = 0;
      }
      bTagName.emplace_back(DataType(taggerName));
      bTagValue.emplace_back(DataType(btagValue));
    }
      }
 
      float chargeread;
      if (!jet->getAttribute<float>(xAOD::JetAttribute::Charge, chargeread)) {
    ATH_MSG_DEBUG("Jet charge unavailable!");
    charge.emplace_back( DataType( 0. ));
      }else{
    charge.emplace_back( DataType( chargeread ));
      }
 
      // updated for data15
      // from: Reconstruction/MET/METReconstruction/Root/METJetFilterTool.cxx
      std::vector<float> jvfread;
      if(!jet->getAttribute<std::vector<float> >(xAOD::JetAttribute::JVF,jvfread)) {
    ATH_MSG_DEBUG("Jet JVF unavailable!");
    jvf.emplace_back( DataType( 1. ));
      }else{
    jvf.emplace_back( DataType(  jvfread[0] ));
      }
 
      float jvtread;
      if(!jet->getAttribute<float>(xAOD::JetAttribute::Jvt,jvtread)) {
    ATH_MSG_DEBUG("Jet JVT unavailable!");
    jvt.emplace_back(DataType(0.));
      } else {
    jvt.emplace_back(DataType(jvtread));
      }
 
      float emfracread = 0;
      if(!jet->getAttribute(xAOD::JetAttribute::EMFrac,emfracread)) {
    ATH_MSG_DEBUG("Jet EMFrac unavailable!");
    emfrac.emplace_back( DataType( 0. ));
      }else{
    emfrac.emplace_back( DataType( emfracread ));
      }
 
    } // end loop
 
    // four-vectors
    const std::size_t nphi = phi.size();
    DataMap["phi"] = std::move(phi);
    DataMap["eta"] = std::move(eta);
    DataMap["et"] = std::move(et);
    DataMap["energy"] = std::move(energy);
    DataMap["mass"] = std::move(mass);
    std::string str_nTaggers = m_nTaggers>0 ? std::to_string(m_nTaggers) : "1"; // default to 1 if no btaggers so that atlantis can process the jets properly
    DataMap["bTagName multiple=\""+str_nTaggers+"\""] = std::move(bTagName); // assigned by hand !
    DataMap["bTagValue multiple=\""+str_nTaggers+"\""] = std::move(bTagValue);
    DataMap["charge"] = std::move(charge);
    DataMap["id"] = std::move(idVec);
    DataMap["px"] = std::move(px);
    DataMap["py"] = std::move(py);
    DataMap["pz"] = std::move(pz);
    DataMap["jvf"] = std::move(jvf);
    DataMap["jvt"] = std::move(jvt);
    DataMap["emfrac"] = std::move(emfrac);
 
    if (!trackKey.empty()){
      double NTracksPerVertex = trackKey.size()*1./jetCont->size();
      std::string tag = "trackIndex multiple=\"" +DataType(NTracksPerVertex).toString()+"\"";
      DataMap[tag] = std::move(trackKey);
      tag = "trackKey multiple=\"" +DataType(NTracksPerVertex).toString()+"\"";
      DataMap[tag] = std::move(trackContKey);
    }
 
    if (!clusterID.empty()){
      std::string tag = "clusterIndex multiple=\"" + DataType(clusterID.size()).toString()+"\"";
      double NCellsPerJet = cellID.size()*1./jetCont->size();
      tag = "cells multiple=\"" +DataType(NCellsPerJet).toString()+"\"";
      DataMap[tag] = std::move(cellID);
    }
 
    DataMap["trackLinkCount"] = std::move(trackLinkCount);
    DataMap["numCells"] = std::move(numCells);
 
    ATH_MSG_DEBUG( dataTypeName() << " retrieved with " << nphi << " entries" );
 
    return DataMap;
  }
 
 
} // JiveXML namespace