ATLAS Offline Software
Loading...
Searching...
No Matches
TrackOverlayDecisionAlg::TrackOverlayDecisionAlg Class Reference

#include <TrackOverlayDecisionAlg.h>

Inheritance diagram for TrackOverlayDecisionAlg::TrackOverlayDecisionAlg:
Collaboration diagram for TrackOverlayDecisionAlg::TrackOverlayDecisionAlg:

Public Member Functions

 TrackOverlayDecisionAlg (const std::string &name, ISvcLocator *pSvcLocator)
 Constructor with parameters.
virtual ~TrackOverlayDecisionAlg ()=default
 Destructor.
virtual StatusCode initialize () override final
 Athena algorithm's interface method initialize().
virtual StatusCode execute (const EventContext &ctx) const override final
 Athena algorithm's interface method execute().
virtual StatusCode finalize () override final
 Athena algorithm's interface method finalize().
virtual StatusCode sysInitialize () override
 Override sysInitialize.
virtual bool isClonable () const override
 Specify if the algorithm is clonable.
virtual unsigned int cardinality () const override
 Cardinality (Maximum number of clones that can exist) special value 0 means that algorithm is reentrant.
virtual StatusCode sysExecute (const EventContext &ctx) override
 Execute an algorithm.
virtual const DataObjIDColl & extraOutputDeps () const override
 Return the list of extra output dependencies.
virtual bool filterPassed (const EventContext &ctx) const
virtual void setFilterPassed (bool state, const EventContext &ctx) const
ServiceHandle< StoreGateSvc > & evtStore ()
 The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.
const ServiceHandle< StoreGateSvc > & detStore () const
 The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.
virtual StatusCode sysStart () override
 Handle START transition.
virtual std::vector< Gaudi::DataHandle * > inputHandles () const override
 Return this algorithm's input handles.
virtual std::vector< Gaudi::DataHandle * > outputHandles () const override
 Return this algorithm's output handles.
Gaudi::Details::PropertyBase & declareProperty (Gaudi::Property< T, V, H > &t)
void updateVHKA (Gaudi::Details::PropertyBase &)
MsgStream & msg () const
bool msgLvl (const MSG::Level lvl) const

Protected Member Functions

void renounceArray (SG::VarHandleKeyArray &handlesArray)
 remove all handles from I/O resolution
std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void > renounce (T &h)
void extraDeps_update_handler (Gaudi::Details::PropertyBase &ExtraDeps)
 Add StoreName to extra input/output deps as needed.

Private Types

typedef ServiceHandle< StoreGateSvcStoreGateSvc_t

Private Member Functions

void markSelectedByPileupSwitch (const std::vector< const xAOD::TruthParticle * > &truthParticles) const
const std::vector< const xAOD::TruthParticle * > getTruthParticles () const
std::tuple< std::vector< int64_t >, std::vector< char * > > GetInputNodeInfo (const std::unique_ptr< Ort::Session > &session)
std::tuple< std::vector< int64_t >, std::vector< char * > > GetOutputNodeInfo (const std::unique_ptr< Ort::Session > &session)
Gaudi::Details::PropertyBase & declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
 specialization for handling Gaudi::Property<SG::VarHandleKey>

Private Attributes

ToolHandle< IAthSelectionToolm_truthSelectionTool {this, "TruthSelectionTool","AthTruthSelectionTool", "Truth selection tool (for efficiencies and resolutions)"}
SG::AuxElement::Decorator< bool > m_dec_selectedByPileupSwitch {"selectedByPileupSwitch"}
bool m_usingSpecialPileupSwitch {false}
BooleanProperty m_useTrackSelection {this, "useTrackSelection", false, "plot only tracks accepted by selection tool"}
StringProperty m_pileupSwitch {this, "PileupSwitch", "HardScatter", "Pileup truth strategy to use. May be \"All\", \"HardScatter\", or \"PileUp\""}
FloatProperty m_lowProb {this,"LowProb",0.5,"Truth match prob. cutoff for efficiency (lower bound) and fake (upper bound) classification."}
SG::ReadHandleKey< xAOD::EventInfom_eventInfoContainerName {this,"EventInfoContainerName", "EventInfo", ""}
SG::ReadHandleKey< xAOD::TruthPileupEventContainerm_truthPileUpEventName {this, "TruthPileupEvents", "TruthPileupEvents","Name of the truth pileup events container probably TruthPileupEvent(s)"}
SG::ReadHandleKey< xAOD::TruthParticleContainerm_truthParticleName {this, "TruthParticleContainerName", "TruthParticles", ""}
SG::ReadHandleKey< xAOD::TruthEventContainerm_truthEventName {this, "TruthEvents", "TruthEvents","Name of the truth events container probably either TruthEvent or TruthEvents"}
FilterReporterParams m_filterParams {this, "TrackOverlayDecisionAlg", "Decides whether events should be reconstructed in track-overlay workflow or MC-overlay."}
Gaudi::Property< bool > m_invertfilter {this, "InvertFilter", false, "Invert filter decision."}
 invert filter decision at the end
Gaudi::Property< float > m_MLthreshold {this, "MLThreshold", 0.74201, "ML threshold for bad/good tracks decision. ML scores larger than this threshold are considered as bad tracks."}
ServiceHandle< AthOnnx::IOnnxRuntimeSvcm_svc {this, "ONNXRuntimeSvc", "AthOnnx::OnnxRuntimeSvc", "CaloMuonScoreTool ONNXRuntimeSvc"}
std::tuple< std::vector< int64_t >, std::vector< char * > > m_inputInfo
std::tuple< std::vector< int64_t >, std::vector< char * > > m_outputInfo
std::unique_ptr< Ort::Session > m_session
DataObjIDColl m_extendedExtraObjects
 Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.
StoreGateSvc_t m_evtStore
 Pointer to StoreGate (event store by default).
StoreGateSvc_t m_detStore
 Pointer to StoreGate (detector store by default).
std::vector< SG::VarHandleKeyArray * > m_vhka
bool m_varHandleArraysDeclared

Detailed Description

Definition at line 55 of file TrackOverlayDecisionAlg.h.

Member Typedef Documentation

◆ StoreGateSvc_t

typedef ServiceHandle<StoreGateSvc> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::StoreGateSvc_t
privateinherited

Definition at line 388 of file AthCommonDataStore.h.

Constructor & Destructor Documentation

◆ TrackOverlayDecisionAlg()

TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::TrackOverlayDecisionAlg ( const std::string & name,
ISvcLocator * pSvcLocator )

Constructor with parameters.

Definition at line 19 of file TrackOverlayDecisionAlg.cxx.

19 :
20 ::AthReentrantAlgorithm( name, pSvcLocator )
21 {
22 }

◆ ~TrackOverlayDecisionAlg()

virtual TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::~TrackOverlayDecisionAlg ( )
virtualdefault

Destructor.

Member Function Documentation

◆ cardinality()

unsigned int AthCommonReentrantAlgorithm< Gaudi::Algorithm >::cardinality ( ) const
overridevirtualinherited

Cardinality (Maximum number of clones that can exist) special value 0 means that algorithm is reentrant.

Override this to return 0 for reentrant algorithms.

Definition at line 75 of file AthCommonReentrantAlgorithm.cxx.

62{
63 return 0;
64}

◆ declareGaudiProperty()

Gaudi::Details::PropertyBase & AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty ( Gaudi::Property< T, V, H > & hndl,
const SG::VarHandleKeyType &  )
inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKey>

Definition at line 156 of file AthCommonDataStore.h.

158 {
160 hndl.value(),
161 hndl.documentation());
162
163 }
Gaudi::Details::PropertyBase & declareProperty(Gaudi::Property< T, V, H > &t)

◆ declareProperty()

Gaudi::Details::PropertyBase & AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( Gaudi::Property< T, V, H > & t)
inlineinherited

Definition at line 145 of file AthCommonDataStore.h.

145 {
146 typedef typename SG::HandleClassifier<T>::type htype;
148 }
Gaudi::Details::PropertyBase & declareGaudiProperty(Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
specialization for handling Gaudi::Property<SG::VarHandleKey>

◆ detStore()

const ServiceHandle< StoreGateSvc > & AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::detStore ( ) const
inlineinherited

The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 95 of file AthCommonDataStore.h.

◆ evtStore()

ServiceHandle< StoreGateSvc > & AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::evtStore ( )
inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 85 of file AthCommonDataStore.h.

◆ execute()

StatusCode TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::execute ( const EventContext & ctx) const
finaloverridevirtual

Athena algorithm's interface method execute().

Definition at line 114 of file TrackOverlayDecisionAlg.cxx.

115{
116 ATH_MSG_DEBUG ("Executing ...");
117
118 std::vector<const xAOD::TruthParticle*> truthParticlesVec = TrackOverlayDecisionAlg::getTruthParticles();
119
120 //Access truth info for the NN input
121 float eventPxSum = 0.0;
122 float eventPySum = 0.0;
123 float eventPt = 0.0;
124 float puEvents = 0.0;
125
126 std::vector<float> pxValues, pyValues, pzValues, eValues, etaValues, phiValues, ptValues;
127 float truthMultiplicity = 0.0;
128 const int truthParticles = truthParticlesVec.size();
129 for (int itruth = 0; itruth < truthParticles; itruth++) {
130 const xAOD::TruthParticle* thisTruth = truthParticlesVec[itruth];
131 const IAthSelectionTool::CutResult accept = m_truthSelectionTool->accept(thisTruth);
132 if(accept){
133 pxValues.push_back((thisTruth->px()*0.001-1.46988000e+03)* px_diff); //as MinMaxScaler: 1.46988000e+03 is the lowest value of px from a J7 sample; *(0.001) is used to convert unit rather than *(1/1000) to speed up.
134 pyValues.push_back((thisTruth->py()*0.001-1.35142000e+03)* py_diff); //the lowest value of py: 1.35142000e+03
135 pzValues.push_back((thisTruth->pz()*0.001-1.50464000e+03)* pz_diff); //the lowest value of pz: 1.50464000e+03
136 ptValues.push_back((thisTruth->pt()*0.001-5.00006000e-01)* pt_diff); //the lowest value of pt: 5.00006000e-01
137
138 etaValues.push_back(thisTruth->eta());
139 phiValues.push_back(thisTruth->phi());
140 eValues.push_back((thisTruth->e()*0.001-5.08307000e-01)*e_diff); //the lowest value of energy: 5.08307000e-01
141
142 eventPxSum += thisTruth->px();
143 eventPySum += thisTruth->py();
144 truthMultiplicity++;
145 }//accept
146 }//for itruth
147 SG::ReadHandle<xAOD::TruthPileupEventContainer> truthPileupEventContainer;
148 SG::ReadHandle<xAOD::EventInfo> pie = SG::ReadHandle<xAOD::EventInfo>(m_eventInfoContainerName, ctx);
149 if (!m_truthPileUpEventName.key().empty()) {
150 truthPileupEventContainer = SG::ReadHandle<xAOD::TruthPileupEventContainer>(m_truthPileUpEventName, ctx);
151 }
152 puEvents = !m_truthPileUpEventName.key().empty() and truthPileupEventContainer.isValid() ? static_cast<int>( truthPileupEventContainer->size() ) : pie.isValid() ? pie->actualInteractionsPerCrossing() : 0;
153 eventPt = std::sqrt(eventPxSum*eventPxSum + eventPySum*eventPySum)*0.001;
154
155 std::vector<float> puEventsVec(pxValues.size(), (puEvents-1.55000000e+01)*pu_diff); //min of puEvents= 15.5, max of puEvents=84.5
156 std::vector<float> truthMultiplicityVec(pxValues.size(), (truthMultiplicity-1.80000000e+01)*multi_diff);
157 std::vector<float> eventPtVec(pxValues.size(), (eventPt-3.42359395e-01)*eventPt_diff);
158 std::vector<float> predictions;
159
160 //Compute the distances using Eigen for Eigen's optimized operations. Initialize matrices. Observed a significant improvement on computing calculation.
161 Eigen::VectorXf ptEigen = Eigen::VectorXf::Map(ptValues.data(), ptValues.size());
162 Eigen::VectorXf phiEigen = Eigen::VectorXf::Map(phiValues.data(), phiValues.size());
163 Eigen::VectorXf etaEigen = Eigen::VectorXf::Map(etaValues.data(), etaValues.size());
164 for (std::size_t i = 0; i < truthMultiplicity; ++i) {
165 float multiplicity_0p05 = 0.0, multiplicity_0p2 = 0.0;
166 float sum_0p05 = 0.0, sum_0p2 = 0.0;
167 float pt_0p05 = 0.0, pt_0p2 = 0.0;
168 float deltaEtaI = etaEigen[i];
169 float phiI = phiEigen[i];
170 for (std::size_t j = 0; j < truthMultiplicity; ++j) {
171 if (i == j) continue; // Skip the particle itself
172 float deltaEta = deltaEtaI - etaEigen[j];
173 float deltaPhi = phiI - phiEigen[j];
174 if (deltaPhi > M_PI) {
175 deltaPhi -= 2.0 * M_PI;
176 }
177 else if (deltaPhi < -M_PI) {
178 deltaPhi += 2.0 * M_PI;
179 }
180 float distances = std::sqrt(deltaEta * deltaEta + deltaPhi * deltaPhi);
181 if (distances < 0.05){
182 multiplicity_0p05++;
183 sum_0p05 += distances;
184 pt_0p05 += ptEigen[j];
185 }
186 if (distances < 0.2){
187 multiplicity_0p2++;
188 sum_0p2 += distances;
189 pt_0p2 += ptEigen[j];
190 }
191 }// for j
192
193 std::vector<float> featData;
194 featData.push_back(pxValues[i]);
195 featData.push_back(pyValues[i]);
196 featData.push_back(pzValues[i]);
197 featData.push_back(eValues[i]);
198 featData.push_back(ptValues[i]);
199 featData.push_back((multiplicity_0p2 * area0p2) * constant1);
200 featData.push_back((multiplicity_0p05 * area0p05) * constant2);
201 featData.push_back((sum_0p2 * area0p2) * constant3);
202 featData.push_back((sum_0p05 * area0p05) * constant4);
203 featData.push_back(pt_0p2 * constant5);
204 featData.push_back(pt_0p05 * constant6);
205
206 featData.push_back(puEventsVec[i]);
207 featData.push_back(truthMultiplicityVec[i]);
208 featData.push_back(eventPtVec[i]);
209
210 std::vector<int64_t> input_node_dims;
211 std::vector<char*> input_node_names;
212 input_node_dims = std::get<0>(m_inputInfo);
213 input_node_names = std::get<1>(m_inputInfo);
214
215 std::vector<int64_t> output_node_dims;
216 std::vector<char*> output_node_names;
217 output_node_dims = std::get<0>(m_outputInfo);
218 output_node_names = std::get<1>(m_outputInfo);
219
220 Ort::MemoryInfo memoryInfo = Ort::MemoryInfo::CreateCpu(OrtArenaAllocator, OrtMemTypeCPU);
221 input_node_dims[0]=1;
222 Ort::Value input_data = Ort::Value::CreateTensor(memoryInfo, featData.data(), featData.size(), input_node_dims.data(), input_node_dims.size());
223 Ort::RunOptions run_options(nullptr);
224 //Run the inference
225 Ort::Session& mysession ATLAS_THREAD_SAFE = *m_session;
226 auto output_values = mysession.Run(run_options, input_node_names.data(), &input_data, input_node_names.size(), output_node_names.data(), output_node_names.size());
227 float* predictionData = output_values[0].GetTensorMutableData<float>();
228 float prediction = predictionData[0];
229
230 predictions.push_back(prediction);
231 }//for i
232 float threshold = m_MLthreshold;
233 ATH_MSG_ALWAYS("ML threshold:" << threshold);
234 int badTracks = 0;
235 for (float prediction : predictions) {
236 if (prediction > threshold) {
237 badTracks++;
238 }
239 }
240 if (truthMultiplicity == 0){
241 ATH_MSG_ERROR("truthMultiplicity is zero!");
242 return StatusCode::FAILURE;
243 }
244 float rouletteScore = static_cast<float>(badTracks) / static_cast<float>(truthMultiplicity);
245
246 FilterReporter filter(m_filterParams, false, ctx);
247 bool pass = false;
248 int decision = rouletteScore == 0;
249 if (decision==0){ //if ML decision is False, it goes to the MC-overlay workflow
250 pass = true;
251 }
252 else{
253 pass = false;
254 }
255
256 if (m_invertfilter) {
257 pass =! pass;
258 }
259 filter.setPassed(pass);
260 ATH_MSG_ALWAYS("End TrackOverlayDecisionAlg, difference in filters: "<<(pass ? "found" : "not found")<<"="<<pass<<", invert="<<m_invertfilter);
261 return StatusCode::SUCCESS;
262}
#define M_PI
Scalar deltaPhi(const MatrixBase< Derived > &vec) const
#define ATH_MSG_ERROR(x)
#define ATH_MSG_ALWAYS(x)
#define ATH_MSG_DEBUG(x)
#define ATLAS_THREAD_SAFE
virtual bool isValid() override final
Can the handle be successfully dereferenced?
SG::ReadHandleKey< xAOD::EventInfo > m_eventInfoContainerName
Gaudi::Property< bool > m_invertfilter
invert filter decision at the end
std::tuple< std::vector< int64_t >, std::vector< char * > > m_outputInfo
std::tuple< std::vector< int64_t >, std::vector< char * > > m_inputInfo
const std::vector< const xAOD::TruthParticle * > getTruthParticles() const
SG::ReadHandleKey< xAOD::TruthPileupEventContainer > m_truthPileUpEventName
float px() const
The x component of the particle's momentum.
virtual double e() const override final
The total energy of the particle.
virtual double pt() const override final
The transverse momentum ( ) of the particle.
float py() const
The y component of the particle's momentum.
virtual double eta() const override final
The pseudorapidity ( ) of the particle.
virtual double phi() const override final
The azimuthal angle ( ) of the particle.
float pz() const
The z component of the particle's momentum.
StatusCode accept(const xAOD::Muon *mu)
double deltaEta(const I4Momentum &p1, const I4Momentum &p2)
Computes efficiently .
Definition P4Helpers.h:66
float j(const xAOD::IParticle &, const xAOD::TrackMeasurementValidation &hit, const Eigen::Matrix3d &jab_inv)
TruthParticle_v1 TruthParticle
Typedef to implementation.

◆ extraDeps_update_handler()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::extraDeps_update_handler ( Gaudi::Details::PropertyBase & ExtraDeps)
protectedinherited

Add StoreName to extra input/output deps as needed.

use the logic of the VarHandleKey to parse the DataObjID keys supplied via the ExtraInputs and ExtraOuputs Properties to add the StoreName if it's not explicitly given

◆ extraOutputDeps()

const DataObjIDColl & AthCommonReentrantAlgorithm< Gaudi::Algorithm >::extraOutputDeps ( ) const
overridevirtualinherited

Return the list of extra output dependencies.

This list is extended to include symlinks implied by inheritance relations.

Definition at line 94 of file AthCommonReentrantAlgorithm.cxx.

88{
89 // If we didn't find any symlinks to add, just return the collection
90 // from the base class. Otherwise, return the extended collection.
91 if (!m_extendedExtraObjects.empty()) {
93 }
95}
An algorithm that can be simultaneously executed in multiple threads.

◆ filterPassed()

virtual bool AthCommonReentrantAlgorithm< Gaudi::Algorithm >::filterPassed ( const EventContext & ctx) const
inlinevirtualinherited

Definition at line 96 of file AthCommonReentrantAlgorithm.h.

96 {
97 return execState( ctx ).filterPassed();
98 }
virtual bool filterPassed(const EventContext &ctx) const

◆ finalize()

StatusCode TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::finalize ( )
finaloverridevirtual

Athena algorithm's interface method finalize().

Definition at line 43 of file TrackOverlayDecisionAlg.cxx.

44{
45 ATH_MSG_VERBOSE ( "Finalizing ..." );
46 ATH_MSG_VERBOSE("-----------------------------------------------------------------");
47 ATH_MSG_VERBOSE("m_filterParams.summary()" << m_filterParams.summary());
48 ATH_MSG_VERBOSE("-----------------------------------------------------------------");
50 ATH_MSG_VERBOSE(" =====================================================================");
51
52 return StatusCode::SUCCESS;
53}
#define ATH_MSG_INFO(x)
#define ATH_MSG_VERBOSE(x)

◆ GetInputNodeInfo()

std::tuple< std::vector< int64_t >, std::vector< char * > > TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::GetInputNodeInfo ( const std::unique_ptr< Ort::Session > & session)
inlineprivate

Definition at line 91 of file TrackOverlayDecisionAlg.h.

91 {
92 std::vector<int64_t> input_node_dims;
93 size_t num_input_nodes = session->GetInputCount();
94 std::vector<char*> input_node_names(num_input_nodes);
95 Ort::AllocatorWithDefaultOptions allocator;
96 for( std::size_t i = 0; i < num_input_nodes; i++ ) {
97 char* input_name = session->GetInputNameAllocated(i, allocator).release();
98 input_node_names[i] = input_name;
99 Ort::TypeInfo type_info = session->GetInputTypeInfo(i);
100 auto tensor_info = type_info.GetTensorTypeAndShapeInfo();
101 input_node_dims = tensor_info.GetShape();
102 }
103 return std::make_tuple(input_node_dims, input_node_names);
104 }

◆ GetOutputNodeInfo()

std::tuple< std::vector< int64_t >, std::vector< char * > > TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::GetOutputNodeInfo ( const std::unique_ptr< Ort::Session > & session)
inlineprivate

Definition at line 106 of file TrackOverlayDecisionAlg.h.

106 {
107 std::vector<int64_t> output_node_dims;
108 size_t num_output_nodes = session->GetOutputCount();
109 std::vector<char*> output_node_names(num_output_nodes);
110 Ort::AllocatorWithDefaultOptions allocator;
111 for( std::size_t i = 0; i < num_output_nodes; i++ ) {
112 char* output_name = session->GetOutputNameAllocated(i, allocator).release();
113 output_node_names[i] = output_name;
114 Ort::TypeInfo type_info = session->GetOutputTypeInfo(i);
115 auto tensor_info = type_info.GetTensorTypeAndShapeInfo();
116 output_node_dims = tensor_info.GetShape();
117 }
118 return std::make_tuple(output_node_dims, output_node_names);
119 }

◆ getTruthParticles()

const std::vector< const xAOD::TruthParticle * > TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::getTruthParticles ( ) const
private

Definition at line 55 of file TrackOverlayDecisionAlg.cxx.

55 {
56 std::vector<const xAOD::TruthParticle*> tempVec {};
57 if (m_pileupSwitch == "All") {
58 if (m_truthParticleName.key().empty()) {
59 return tempVec;
60 }
61 SG::ReadHandle<xAOD::TruthParticleContainer> truthParticleContainer( m_truthParticleName);
62 if (not truthParticleContainer.isValid()) {
63 return tempVec;
64 }
65 tempVec.insert(tempVec.begin(), truthParticleContainer->begin(), truthParticleContainer->end());
66 } else {
67 if (m_pileupSwitch == "HardScatter") {
68 if (not m_truthEventName.key().empty()) {
69 ATH_MSG_VERBOSE("Getting TruthEvents container.");
70 SG::ReadHandle<xAOD::TruthEventContainer> truthEventContainer( m_truthEventName);
71 const xAOD::TruthEvent* event = (truthEventContainer.isValid()) ? truthEventContainer->at(0) : nullptr;
72 if (not event) {
73 return tempVec;
74 }
75 const auto& links = event->truthParticleLinks();
76 tempVec.reserve(event->nTruthParticles());
77 for (const auto& link : links) {
78 if (link.isValid()){
79 tempVec.push_back(*link);
80 }
81 }
82 }
83 }else if (m_pileupSwitch == "PileUp") {
84 if (not m_truthPileUpEventName.key().empty()) {
85 ATH_MSG_VERBOSE("getting TruthPileupEvents container");
86 // get truth particles from all pileup events
87 SG::ReadHandle<xAOD::TruthPileupEventContainer> truthPileupEventContainer(m_truthPileUpEventName);
88 if (truthPileupEventContainer.isValid()) {
89 const unsigned int nPileup = truthPileupEventContainer->size();
90 tempVec.reserve(nPileup * 200); // quick initial guess, will still save some time
91 for (unsigned int i(0); i != nPileup; ++i) {
92 const auto *eventPileup = truthPileupEventContainer->at(i);
93 // get truth particles from each pileup event
94 int ntruth = eventPileup->nTruthParticles();
95 ATH_MSG_VERBOSE("Adding " << ntruth << " truth particles from TruthPileupEvents container");
96 const auto& links = eventPileup->truthParticleLinks();
97 for (const auto& link : links) {
98 if (link.isValid()){
99 tempVec.push_back(*link);
100 }
101 }
102 }
103 } else {
104 ATH_MSG_ERROR("no entries in TruthPileupEvents container!");
105 }
106 }
107 } else {
108 ATH_MSG_ERROR("bad value for PileUpSwitch");
109 }
110 }
111 return tempVec;
112}
SG::ReadHandleKey< xAOD::TruthEventContainer > m_truthEventName
SG::ReadHandleKey< xAOD::TruthParticleContainer > m_truthParticleName
pointer & link(pointer p) const
Return a reference to the link for an element.
TruthEvent_v1 TruthEvent
Typedef to implementation.
Definition TruthEvent.h:17

◆ initialize()

StatusCode TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::initialize ( )
finaloverridevirtual

Athena algorithm's interface method initialize().

Definition at line 24 of file TrackOverlayDecisionAlg.cxx.

25{
26 ATH_CHECK(m_filterParams.initialize(false));
27 ATH_CHECK( m_eventInfoContainerName.initialize() );
28 ATH_CHECK( m_truthParticleName.initialize( (m_pileupSwitch == "HardScatter" or m_pileupSwitch == "All") and not m_truthParticleName.key().empty() ) );
29 ATH_CHECK(m_truthSelectionTool.retrieve(EnableTool {not m_truthParticleName.key().empty()} ));
30 ATH_CHECK( m_truthEventName.initialize( (m_pileupSwitch == "HardScatter" or m_pileupSwitch == "All") and not m_truthEventName.key().empty() ) );
31 ATH_CHECK( m_truthPileUpEventName.initialize( (m_pileupSwitch == "PileUp" or m_pileupSwitch == "All") and not m_truthPileUpEventName.key().empty() ) );
32 ATH_CHECK(m_svc.retrieve());
33 std::string this_file = __FILE__;
34 const std::string model_path = PathResolverFindCalibFile("TrackOverlay/TrackOverlay_J7_model.onnx");
35 Ort::SessionOptions session_options;
36
37 m_session = std::make_unique<Ort::Session>(m_svc->env(), model_path.c_str(), session_options);
40 return StatusCode::SUCCESS;
41}
#define ATH_CHECK
Evaluate an expression and check for errors.
std::string PathResolverFindCalibFile(const std::string &logical_file_name)
std::tuple< std::vector< int64_t >, std::vector< char * > > GetInputNodeInfo(const std::unique_ptr< Ort::Session > &session)
std::tuple< std::vector< int64_t >, std::vector< char * > > GetOutputNodeInfo(const std::unique_ptr< Ort::Session > &session)
ServiceHandle< AthOnnx::IOnnxRuntimeSvc > m_svc

◆ inputHandles()

virtual std::vector< Gaudi::DataHandle * > AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::inputHandles ( ) const
overridevirtualinherited

Return this algorithm's input handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

◆ isClonable()

◆ markSelectedByPileupSwitch()

void TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::markSelectedByPileupSwitch ( const std::vector< const xAOD::TruthParticle * > & truthParticles) const
private

◆ msg()

MsgStream & AthCommonMsg< Gaudi::Algorithm >::msg ( ) const
inlineinherited

Definition at line 24 of file AthCommonMsg.h.

24 {
25 return this->msgStream();
26 }

◆ msgLvl()

bool AthCommonMsg< Gaudi::Algorithm >::msgLvl ( const MSG::Level lvl) const
inlineinherited

Definition at line 30 of file AthCommonMsg.h.

30 {
31 return this->msgLevel(lvl);
32 }

◆ outputHandles()

virtual std::vector< Gaudi::DataHandle * > AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::outputHandles ( ) const
overridevirtualinherited

Return this algorithm's output handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

◆ renounce()

std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void > AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::renounce ( T & h)
inlineprotectedinherited

Definition at line 380 of file AthCommonDataStore.h.

381 {
382 h.renounce();
384 }
std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void > renounce(T &h)

◆ renounceArray()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::renounceArray ( SG::VarHandleKeyArray & handlesArray)
inlineprotectedinherited

remove all handles from I/O resolution

Definition at line 364 of file AthCommonDataStore.h.

364 {
366 }

◆ setFilterPassed()

virtual void AthCommonReentrantAlgorithm< Gaudi::Algorithm >::setFilterPassed ( bool state,
const EventContext & ctx ) const
inlinevirtualinherited

Definition at line 100 of file AthCommonReentrantAlgorithm.h.

100 {
102 }
virtual void setFilterPassed(bool state, const EventContext &ctx) const

◆ sysExecute()

StatusCode AthCommonReentrantAlgorithm< Gaudi::Algorithm >::sysExecute ( const EventContext & ctx)
overridevirtualinherited

Execute an algorithm.

We override this in order to work around an issue with the Algorithm base class storing the event context in a member variable that can cause crashes in MT jobs.

Definition at line 85 of file AthCommonReentrantAlgorithm.cxx.

75{
76 return BaseAlg::sysExecute (ctx);
77}

◆ sysInitialize()

StatusCode AthCommonReentrantAlgorithm< Gaudi::Algorithm >::sysInitialize ( )
overridevirtualinherited

Override sysInitialize.

Override sysInitialize from the base class.

Loop through all output handles, and if they're WriteCondHandles, automatically register them and this Algorithm with the CondSvc

Scan through all outputHandles, and if they're WriteCondHandles, register them with the CondSvc

Reimplemented from AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >.

Reimplemented in HypoBase, and InputMakerBase.

Definition at line 61 of file AthCommonReentrantAlgorithm.cxx.

105 {
107
108 if (sc.isFailure()) {
109 return sc;
110 }
111
112 ServiceHandle<ICondSvc> cs("CondSvc",name());
113 for (auto h : outputHandles()) {
114 if (h->isCondition() && h->mode() == Gaudi::DataHandle::Writer) {
115 // do this inside the loop so we don't create the CondSvc until needed
116 if ( cs.retrieve().isFailure() ) {
117 ATH_MSG_WARNING("no CondSvc found: won't autoreg WriteCondHandles");
118 return StatusCode::SUCCESS;
119 }
120 if (cs->regHandle(this,*h).isFailure()) {
122 ATH_MSG_ERROR("unable to register WriteCondHandle " << h->fullKey()
123 << " with CondSvc");
124 }
125 }
126 }
127 return sc;
128}
#define ATH_MSG_WARNING(x)
virtual std::vector< Gaudi::DataHandle * > outputHandles() const override

◆ sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::sysStart ( )
overridevirtualinherited

Handle START transition.

We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.

◆ updateVHKA()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::updateVHKA ( Gaudi::Details::PropertyBase & )
inlineinherited

Definition at line 308 of file AthCommonDataStore.h.

308 {
309 // debug() << "updateVHKA for property " << p.name() << " " << p.toString()
310 // << " size: " << m_vhka.size() << endmsg;
311 for (auto &a : m_vhka) {
313 for (auto k : keys) {
314 k->setOwner(this);
315 }
316 }
317 }

Member Data Documentation

◆ m_dec_selectedByPileupSwitch

SG::AuxElement::Decorator<bool> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_dec_selectedByPileupSwitch {"selectedByPileupSwitch"}
private

Definition at line 68 of file TrackOverlayDecisionAlg.h.

68{"selectedByPileupSwitch"};

◆ m_detStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_detStore
privateinherited

Pointer to StoreGate (detector store by default).

Definition at line 393 of file AthCommonDataStore.h.

◆ m_eventInfoContainerName

SG::ReadHandleKey<xAOD::EventInfo> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_eventInfoContainerName {this,"EventInfoContainerName", "EventInfo", ""}
private

Definition at line 76 of file TrackOverlayDecisionAlg.h.

76{this,"EventInfoContainerName", "EventInfo", ""};

◆ m_evtStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_evtStore
privateinherited

Pointer to StoreGate (event store by default).

Definition at line 390 of file AthCommonDataStore.h.

◆ m_extendedExtraObjects

DataObjIDColl AthCommonReentrantAlgorithm< Gaudi::Algorithm >::m_extendedExtraObjects
privateinherited

Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.

Empty if no symlinks were found.

Definition at line 114 of file AthCommonReentrantAlgorithm.h.

◆ m_filterParams

FilterReporterParams TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_filterParams {this, "TrackOverlayDecisionAlg", "Decides whether events should be reconstructed in track-overlay workflow or MC-overlay."}
private

Definition at line 83 of file TrackOverlayDecisionAlg.h.

83{this, "TrackOverlayDecisionAlg", "Decides whether events should be reconstructed in track-overlay workflow or MC-overlay."};

◆ m_inputInfo

std::tuple<std::vector<int64_t>, std::vector<char*> > TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_inputInfo
private

Definition at line 88 of file TrackOverlayDecisionAlg.h.

◆ m_invertfilter

Gaudi::Property<bool> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_invertfilter {this, "InvertFilter", false, "Invert filter decision."}
private

invert filter decision at the end

Definition at line 84 of file TrackOverlayDecisionAlg.h.

84{this, "InvertFilter", false, "Invert filter decision."};

◆ m_lowProb

FloatProperty TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_lowProb {this,"LowProb",0.5,"Truth match prob. cutoff for efficiency (lower bound) and fake (upper bound) classification."}
private

Definition at line 74 of file TrackOverlayDecisionAlg.h.

74{this,"LowProb",0.5,"Truth match prob. cutoff for efficiency (lower bound) and fake (upper bound) classification."};

◆ m_MLthreshold

Gaudi::Property<float> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_MLthreshold {this, "MLThreshold", 0.74201, "ML threshold for bad/good tracks decision. ML scores larger than this threshold are considered as bad tracks."}
private

Definition at line 85 of file TrackOverlayDecisionAlg.h.

85{this, "MLThreshold", 0.74201, "ML threshold for bad/good tracks decision. ML scores larger than this threshold are considered as bad tracks."};

◆ m_outputInfo

std::tuple<std::vector<int64_t>, std::vector<char*> > TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_outputInfo
private

Definition at line 89 of file TrackOverlayDecisionAlg.h.

◆ m_pileupSwitch

StringProperty TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_pileupSwitch {this, "PileupSwitch", "HardScatter", "Pileup truth strategy to use. May be \"All\", \"HardScatter\", or \"PileUp\""}
private

Definition at line 73 of file TrackOverlayDecisionAlg.h.

73{this, "PileupSwitch", "HardScatter", "Pileup truth strategy to use. May be \"All\", \"HardScatter\", or \"PileUp\""};

◆ m_session

std::unique_ptr<Ort::Session> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_session
private

Definition at line 90 of file TrackOverlayDecisionAlg.h.

◆ m_svc

ServiceHandle<AthOnnx::IOnnxRuntimeSvc> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_svc {this, "ONNXRuntimeSvc", "AthOnnx::OnnxRuntimeSvc", "CaloMuonScoreTool ONNXRuntimeSvc"}
private

Definition at line 87 of file TrackOverlayDecisionAlg.h.

87{this, "ONNXRuntimeSvc", "AthOnnx::OnnxRuntimeSvc", "CaloMuonScoreTool ONNXRuntimeSvc"};

◆ m_truthEventName

SG::ReadHandleKey<xAOD::TruthEventContainer> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_truthEventName {this, "TruthEvents", "TruthEvents","Name of the truth events container probably either TruthEvent or TruthEvents"}
private

Definition at line 80 of file TrackOverlayDecisionAlg.h.

80{this, "TruthEvents", "TruthEvents","Name of the truth events container probably either TruthEvent or TruthEvents"};

◆ m_truthParticleName

SG::ReadHandleKey<xAOD::TruthParticleContainer> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_truthParticleName {this, "TruthParticleContainerName", "TruthParticles", ""}
private

Definition at line 79 of file TrackOverlayDecisionAlg.h.

79{this, "TruthParticleContainerName", "TruthParticles", ""};

◆ m_truthPileUpEventName

SG::ReadHandleKey<xAOD::TruthPileupEventContainer> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_truthPileUpEventName {this, "TruthPileupEvents", "TruthPileupEvents","Name of the truth pileup events container probably TruthPileupEvent(s)"}
private

Definition at line 78 of file TrackOverlayDecisionAlg.h.

78{this, "TruthPileupEvents", "TruthPileupEvents","Name of the truth pileup events container probably TruthPileupEvent(s)"};

◆ m_truthSelectionTool

ToolHandle<IAthSelectionTool> TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_truthSelectionTool {this, "TruthSelectionTool","AthTruthSelectionTool", "Truth selection tool (for efficiencies and resolutions)"}
private

Definition at line 67 of file TrackOverlayDecisionAlg.h.

67{this, "TruthSelectionTool","AthTruthSelectionTool", "Truth selection tool (for efficiencies and resolutions)"};

◆ m_useTrackSelection

BooleanProperty TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_useTrackSelection {this, "useTrackSelection", false, "plot only tracks accepted by selection tool"}
private

Definition at line 72 of file TrackOverlayDecisionAlg.h.

72{this, "useTrackSelection", false, "plot only tracks accepted by selection tool"};

◆ m_usingSpecialPileupSwitch

bool TrackOverlayDecisionAlg::TrackOverlayDecisionAlg::m_usingSpecialPileupSwitch {false}
private

Definition at line 69 of file TrackOverlayDecisionAlg.h.

69{false};

◆ m_varHandleArraysDeclared

bool AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_varHandleArraysDeclared
privateinherited

Definition at line 399 of file AthCommonDataStore.h.

◆ m_vhka

std::vector<SG::VarHandleKeyArray*> AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_vhka
privateinherited

Definition at line 398 of file AthCommonDataStore.h.


The documentation for this class was generated from the following files: