ATLAS Offline Software
Loading...
Searching...
No Matches
TruthResetAlg Class Reference

#include <TruthResetAlg.h>

Inheritance diagram for TruthResetAlg:
Collaboration diagram for TruthResetAlg:

Public Member Functions

 TruthResetAlg (const std::string &name, ISvcLocator *pSvcLocator)
 ~TruthResetAlg ()=default
virtual StatusCode initialize () override final
virtual StatusCode execute () override final
virtual StatusCode sysInitialize () override
 Override sysInitialize.
virtual const DataObjIDColl & extraOutputDeps () const override
 Return the list of extra output dependencies.
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

Gaudi::Details::PropertyBase & declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
 specialization for handling Gaudi::Property<SG::VarHandleKey>

Private Attributes

SG::ReadHandleKey< McEventCollectionm_inputMcEventCollection
SG::WriteHandleKey< McEventCollectionm_outputMcEventCollection
DataObjIDColl m_extendedExtraObjects
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 16 of file TruthResetAlg.h.

Member Typedef Documentation

◆ StoreGateSvc_t

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

Definition at line 388 of file AthCommonDataStore.h.

Constructor & Destructor Documentation

◆ TruthResetAlg()

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

Definition at line 23 of file TruthResetAlg.cxx.

23 :
24 AthAlgorithm(name, pSvcLocator)
25{
26 declareProperty("InputMcEventCollection" , m_inputMcEventCollection = "TruthEvent");
27 declareProperty("OutputMcEventCollection" , m_outputMcEventCollection = "NewTruthEvent");
28}
AthAlgorithm()
Default constructor:
Gaudi::Details::PropertyBase & declareProperty(Gaudi::Property< T, V, H > &t)
SG::WriteHandleKey< McEventCollection > m_outputMcEventCollection
SG::ReadHandleKey< McEventCollection > m_inputMcEventCollection

◆ ~TruthResetAlg()

TruthResetAlg::~TruthResetAlg ( )
default

Member Function Documentation

◆ declareGaudiProperty()

Gaudi::Details::PropertyBase & AthCommonDataStore< AthCommonMsg< 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 }

◆ declareProperty()

Gaudi::Details::PropertyBase & AthCommonDataStore< AthCommonMsg< 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< 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< 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 TruthResetAlg::execute ( )
finaloverridevirtual

Definition at line 42 of file TruthResetAlg.cxx.

42 {
43//-------------------------------------------------
44
45 ATH_MSG_DEBUG( " execute..... " );
46 SG::ReadHandle<McEventCollection> inputMcEventCollection(m_inputMcEventCollection);
47 if (!inputMcEventCollection.isValid()) {
48 ATH_MSG_ERROR("Could not find input McEventCollection called " << inputMcEventCollection.name() << " in store " << inputMcEventCollection.store() << ".");
49 return StatusCode::FAILURE;
50 }
51 const HepMC::GenEvent& inputEvent(**(inputMcEventCollection->begin()));
52
53 //Sanity check
54 bool inputProblem(false);
55 for (const auto& particle: inputEvent) {
56 if (MC::isStable(particle)) {
57 if (!particle->production_vertex()) {
58 ATH_MSG_ERROR("Stable particle without a production vertex!! " << particle);
59 inputProblem = true;
60 }
61 }
62 else if (MC::isDecayed(particle)) {
63 if (!particle->production_vertex()) {
64 ATH_MSG_ERROR("Decyed particle without a production vertex!! " << particle);
65 inputProblem = true;
66 }
67 if (!particle->end_vertex()) {
68 ATH_MSG_ERROR("Decyed particle without an end vertex!! " << particle);
69 inputProblem = true;
70 }
71 }
72 }
73 if (inputProblem) {
74 ATH_MSG_FATAL("Problems in input GenEvent - bailing out.");
75 return StatusCode::FAILURE;
76 }
77#ifdef HEPMC3
80 std::unique_ptr<HepMC::GenEvent> outputEvent = std::make_unique<HepMC::GenEvent>(inputEvent);
81 if (inputEvent.run_info()) outputEvent->set_run_info(std::make_shared<HepMC3::GenRunInfo>(*(inputEvent.run_info().get())));
82 for (;;) {
83 std::vector<HepMC::GenParticlePtr> p_to_remove;
84 std::vector<HepMC::GenVertexPtr> v_to_remove;
85 for (auto& particle: outputEvent->particles()) {
86 if (HepMC::is_simulation_particle(particle)) {
87 p_to_remove.push_back(particle);
88 }
89 }
90 for (auto& particle: p_to_remove) outputEvent->remove_particle(particle);
91 for (auto& vertex: outputEvent->vertices()) {
92 if (HepMC::is_simulation_vertex(vertex) || vertex->particles_out().empty() ) {
93 v_to_remove.push_back(vertex);
94 }
95 }
96 for (auto& vertex: v_to_remove) outputEvent->remove_vertex(vertex);
97 if (p_to_remove.empty() && v_to_remove.empty()) break;
98 }
99#else
100
101 std::unique_ptr<HepMC::GenEvent> outputEvent = std::make_unique<HepMC::GenEvent>(inputEvent.signal_process_id(),
102 inputEvent.event_number());
103
104 outputEvent->set_mpi ( inputEvent.mpi() );
105 outputEvent->set_event_scale ( inputEvent.event_scale() );
106 outputEvent->set_alphaQCD ( inputEvent.alphaQCD() );
107 outputEvent->set_alphaQED ( inputEvent.alphaQED() );
108 if ( inputEvent.cross_section() ) {
109 outputEvent->set_cross_section ( *inputEvent.cross_section());
110 }
111 if (inputEvent.heavy_ion()) {
112 outputEvent->set_heavy_ion(*(inputEvent.heavy_ion()));
113 }
114 if (inputEvent.pdf_info()) {
115 outputEvent->set_pdf_info(*(inputEvent.pdf_info()));
116 }
117 outputEvent->define_units( inputEvent.momentum_unit(), inputEvent.length_unit() );
118
119 // 1. create a NEW copy of all vertices from inputEvent
120 // taking care to map new vertices onto the vertices being copied
121 // and add these new vertices to this event.
122 // We do not use GenVertex::operator= because that would copy
123 // the attached particles as well.
124 std::map<const HepMC::GenVertex*,HepMC::GenVertex*> inputEvtVtxToOutputEvtVtx;
125 HepMC::GenEvent::vertex_const_iterator currentVertexIter(inputEvent.vertices_begin());
126 const HepMC::GenEvent::vertex_const_iterator endOfCurrentListOfVertices(inputEvent.vertices_end());
127 ATH_MSG_VERBOSE( "Starting a vertex loop ... " );
128 for (; currentVertexIter != endOfCurrentListOfVertices; ++currentVertexIter) {
129 const HepMC::GenVertex *pCurrentVertex(*currentVertexIter);
130 if (HepMC::is_simulation_vertex(pCurrentVertex)) {
131 continue; // skip vertices created by the simulation
132 }
133 std::unique_ptr<HepMC::GenVertex> copyOfGenVertex =std::make_unique<HepMC::GenVertex>(pCurrentVertex->position(), pCurrentVertex->id(), pCurrentVertex->weights() );
134 copyOfGenVertex->suggest_barcode( HepMC::barcode(pCurrentVertex) );
135 inputEvtVtxToOutputEvtVtx[pCurrentVertex] = copyOfGenVertex.get();
136 outputEvent->add_vertex( copyOfGenVertex.release() );
137 } //vertex loop
138
139 // 2. copy the signal process vertex info.
140 if ( inputEvent.signal_process_vertex() ) {
141 outputEvent->set_signal_process_vertex( inputEvtVtxToOutputEvtVtx[inputEvent.signal_process_vertex()] );
142 }
143 else {
144 outputEvent->set_signal_process_vertex( nullptr );
145 }
146 //
147 // 3. create a NEW copy of all particles from inputEvent
148 // taking care to attach them to the appropriate vertex
149 HepMC::GenParticle* beam1{};
150 HepMC::GenParticle* beam2{};
151 for ( HepMC::GenEvent::particle_const_iterator particleIter = inputEvent.particles_begin();
152 particleIter != inputEvent.particles_end(); ++particleIter ) {
153 const HepMC::GenParticle* currentParticle = *particleIter;
154 if (HepMC::is_simulation_particle(currentParticle)) {
155 continue; // skip particles created by simulation
156 }
157 std::unique_ptr<HepMC::GenParticle> copyOfGenParticle = std::make_unique<HepMC::GenParticle>(*currentParticle);
158 const bool isBeamParticle1(currentParticle == inputEvent.beam_particles().first);
159 const bool isBeamParticle2(currentParticle == inputEvent.beam_particles().second);
160 // There may (will) be particles which had end vertices added by
161 // the simulation (inputEvent). Those vertices will not be copied
162 // to the outputEvent, so we should not try to use them here.
163 const bool shouldAddProdVertex(currentParticle->production_vertex() && inputEvtVtxToOutputEvtVtx[ currentParticle->production_vertex() ]);
164 const bool shouldAddEndVertex(currentParticle->end_vertex() && inputEvtVtxToOutputEvtVtx[ currentParticle->end_vertex() ]);
165 if ( isBeamParticle1 || isBeamParticle2 || shouldAddProdVertex || shouldAddEndVertex ) {
166 HepMC::GenParticle* particleCopy = copyOfGenParticle.release();
167 if ( isBeamParticle1 ) {
168 beam1 = particleCopy;
169 }
170 if ( isBeamParticle2 ) {
171 beam2 = particleCopy;
172 }
173 if ( shouldAddProdVertex || shouldAddEndVertex ) {
174 if ( shouldAddEndVertex ) {
175 inputEvtVtxToOutputEvtVtx[ currentParticle->end_vertex() ]->
176 add_particle_in(particleCopy);
177 }
178 if ( shouldAddProdVertex ) {
179 inputEvtVtxToOutputEvtVtx[ currentParticle->production_vertex() ]->
180 add_particle_out(particleCopy);
181 }
182 }
183 else {
184 ATH_MSG_WARNING ( "Found GenParticle with no production or end vertex! \n" << *currentParticle);
185 }
186 }
187 }
188 outputEvent->set_beam_particles( beam1, beam2 );
189 //
190 // 4. now that vtx/particles are copied, copy weights and random states
191 outputEvent->set_random_states( inputEvent.random_states() );
192 outputEvent->weights() = inputEvent.weights();
193#endif
194
195 //Sanity check
196 bool outputProblem(false);
197 for (const auto& particle: *(outputEvent.get())) {
198 if (MC::isStable(particle)) {
199 if (!particle->production_vertex()) {
200 ATH_MSG_ERROR("Stable particle without a production vertex!! " << particle);
201 outputProblem = true;
202 }
203 if (particle->end_vertex()) {
204 ATH_MSG_ERROR("Stable particle with an end vertex!! " << particle);
205 outputProblem = true;
206 }
207 }
208 else if (MC::isDecayed(particle)) {
209 if (!particle->production_vertex()) {
210 ATH_MSG_ERROR("Decayed particle without a production vertex!! " << particle);
211 outputProblem = true;
212 }
213 if (!particle->end_vertex()) {
214 ATH_MSG_ERROR("Decayed particle without an end vertex!! " << particle);
215 outputProblem = true;
216 }
217 }
218 }
219 if (outputProblem) {
220 ATH_MSG_FATAL("Problems in output GenEvent - bailing out.");
221 return StatusCode::FAILURE;
222 }
223
224 SG::WriteHandle<McEventCollection> outputMcEventCollection(m_outputMcEventCollection);
225 ATH_CHECK(outputMcEventCollection.record(std::make_unique<McEventCollection>()));
226 outputMcEventCollection->push_back(outputEvent.release());
227 if (!outputMcEventCollection.isValid()) {
228 ATH_MSG_ERROR("Could not record output McEventCollection called " << outputMcEventCollection.name() << " in store " << outputMcEventCollection.store() << ".");
229 return StatusCode::FAILURE;
230 }
231
232 ATH_MSG_DEBUG( "succeded TruthResetAlg ..... " );
233
234 return StatusCode::SUCCESS;
235
236}
#define ATH_CHECK
Evaluate an expression and check for errors.
#define ATH_MSG_ERROR(x)
#define ATH_MSG_FATAL(x)
#define ATH_MSG_VERBOSE(x)
#define ATH_MSG_WARNING(x)
#define ATH_MSG_DEBUG(x)
bool is_simulation_vertex(const T &v)
Method to establish if the vertex was created during simulation (TODO migrate to be based on status).
int barcode(const T *p)
Definition Barcode.h:16
bool is_simulation_particle(const T &p)
Method to establish if a particle (or barcode) was created during the simulation (TODO update to be s...
bool isStable(const T &p)
Identify if the particle is stable, i.e. has not decayed.
bool isDecayed(const T &p)
Identify if the particle decayed.
constexpr ParticleHypothesis particle[PARTICLEHYPOTHESES]
the array of masses

◆ extraDeps_update_handler()

void AthCommonDataStore< AthCommonMsg< 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 & AthAlgorithm::extraOutputDeps ( ) const
overridevirtualinherited

Return the list of extra output dependencies.

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

Definition at line 50 of file AthAlgorithm.cxx.

51{
52 // If we didn't find any symlinks to add, just return the collection
53 // from the base class. Otherwise, return the extended collection.
54 if (!m_extendedExtraObjects.empty()) {
56 }
57 return Algorithm::extraOutputDeps();
58}
DataObjIDColl m_extendedExtraObjects

◆ initialize()

StatusCode TruthResetAlg::initialize ( )
finaloverridevirtual

Definition at line 32 of file TruthResetAlg.cxx.

32 {
33//----------------------------------------------------
34
37 return StatusCode::SUCCESS;
38
39}

◆ inputHandles()

virtual std::vector< Gaudi::DataHandle * > AthCommonDataStore< AthCommonMsg< 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.

◆ msg()

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

Definition at line 24 of file AthCommonMsg.h.

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

◆ msgLvl()

bool AthCommonMsg< 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< 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< 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< Algorithm > >::renounceArray ( SG::VarHandleKeyArray & handlesArray)
inlineprotectedinherited

remove all handles from I/O resolution

Definition at line 364 of file AthCommonDataStore.h.

364 {
366 }

◆ sysInitialize()

StatusCode AthAlgorithm::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< Algorithm > >.

Reimplemented in AthAnalysisAlgorithm, AthFilterAlgorithm, AthHistogramAlgorithm, and PyAthena::Alg.

Definition at line 66 of file AthAlgorithm.cxx.

66 {
68
69 if (sc.isFailure()) {
70 return sc;
71 }
72 ServiceHandle<ICondSvc> cs("CondSvc",name());
73 for (auto h : outputHandles()) {
74 if (h->isCondition() && h->mode() == Gaudi::DataHandle::Writer) {
75 // do this inside the loop so we don't create the CondSvc until needed
76 if ( cs.retrieve().isFailure() ) {
77 ATH_MSG_WARNING("no CondSvc found: won't autoreg WriteCondHandles");
78 return StatusCode::SUCCESS;
79 }
80 if (cs->regHandle(this,*h).isFailure()) {
81 sc = StatusCode::FAILURE;
82 ATH_MSG_ERROR("unable to register WriteCondHandle " << h->fullKey()
83 << " with CondSvc");
84 }
85 }
86 }
87 return sc;
88}
static Double_t sc
virtual StatusCode sysInitialize() override
Override sysInitialize.
AthCommonDataStore(const std::string &name, T... args)
virtual std::vector< Gaudi::DataHandle * > outputHandles() const override
::StatusCode StatusCode
StatusCode definition for legacy code.

◆ sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< 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< 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 }
std::vector< SG::VarHandleKeyArray * > m_vhka

Member Data Documentation

◆ m_detStore

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

Pointer to StoreGate (detector store by default)

Definition at line 393 of file AthCommonDataStore.h.

◆ m_evtStore

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

Pointer to StoreGate (event store by default)

Definition at line 390 of file AthCommonDataStore.h.

◆ m_extendedExtraObjects

DataObjIDColl AthAlgorithm::m_extendedExtraObjects
privateinherited

Definition at line 79 of file AthAlgorithm.h.

◆ m_inputMcEventCollection

SG::ReadHandleKey<McEventCollection> TruthResetAlg::m_inputMcEventCollection
private

Definition at line 26 of file TruthResetAlg.h.

◆ m_outputMcEventCollection

SG::WriteHandleKey<McEventCollection> TruthResetAlg::m_outputMcEventCollection
private

Definition at line 27 of file TruthResetAlg.h.

◆ m_varHandleArraysDeclared

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

Definition at line 399 of file AthCommonDataStore.h.

◆ m_vhka

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

Definition at line 398 of file AthCommonDataStore.h.


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