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

read calibration constants from text file and publish them in ConditionsStore More...

#include <TRTCondWrite.h>

Inheritance diagram for TRTCondWrite:
Collaboration diagram for TRTCondWrite:

Public Types

typedef TRTCond::RtRelationMultChanContainer RtRelationContainer
typedef TRTCond::StrawT0MultChanContainer StrawT0Container

Public Member Functions

 TRTCondWrite (const std::string &name, ISvcLocator *pSvcLocator)
 constructor
virtual ~TRTCondWrite () override=default
 destructor
virtual StatusCode initialize (void) override
virtual StatusCode execute (const EventContext &ctx) const override
virtual StatusCode finalize (void) override
virtual TRTCond::ExpandedIdentifier trtcondid (const Identifier &id, int level=TRTCond::ExpandedIdentifier::STRAW) const
 create an TRTCond::ExpandedIdentifier from a TRTID identifier
virtual StatusCode checkTextFile (const std::string &file, int &format)
 read calibration from text file into TDS
virtual StatusCode readTextFile (const EventContext &ctx, const std::string &file, int &format) const
virtual StatusCode readTextFile_Format1 (const EventContext &, std::istream &) const
virtual EventIDRange IOVInfRange () const
virtual bool isReEntrant () const override
 Avoid scheduling algorithm multiple times.
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

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

Private Attributes

const TRT_IDm_trtid {}
 trt id helper
ServiceHandle< ICondSvc > m_condSvc {this, "CondSvc", "CondSvc"}
Gaudi::Property< std::string > m_par_caltextfile {this, "CalibInputFile", "dummy_TRTCondWrite.txt", ""}
SG::WriteCondHandleKey< RtRelationContainerm_rtWriteKey {this, "RtWriteKeyName", "/TRT/Calib/RT", "r-t relation out-key"}
SG::WriteCondHandleKey< StrawT0Containerm_t0WriteKey {this, "T0WriteKeyName", "/TRT/Calib/T0", "t0 out-key"}
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

read calibration constants from text file and publish them in ConditionsStore

Definition at line 33 of file TRTCondWrite.h.

Member Typedef Documentation

◆ RtRelationContainer

◆ StoreGateSvc_t

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

Definition at line 388 of file AthCommonDataStore.h.

◆ StrawT0Container

Constructor & Destructor Documentation

◆ TRTCondWrite()

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

constructor

Definition at line 22 of file TRTCondWrite.cxx.

23 : AthCondAlgorithm(name, pSvcLocator) {}

◆ ~TRTCondWrite()

virtual TRTCondWrite::~TRTCondWrite ( )
overridevirtualdefault

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.

64{
65 return 0;
66}

◆ checkTextFile()

StatusCode TRTCondWrite::checkTextFile ( const std::string & file,
int & format )
virtual

read calibration from text file into TDS

Definition at line 113 of file TRTCondWrite.cxx.

114{
115
116 StatusCode sc = StatusCode::SUCCESS;
117 std::ifstream infile(filename.c_str());
118 if (!infile)
119 {
120 sc = StatusCode::FAILURE;
121 }
122 else
123 {
124 // read the format tag. if none, default to 0
125 format = 0;
126 char line[512];
127 infile.getline(line, 512);
128 std::string linestring(line);
129 size_t pos = linestring.find("Fileformat");
130 if (pos != std::string::npos)
131 {
132 sscanf(line, "# Fileformat=%d", &format);
133 }
134 else
135 {
136 ATH_MSG_WARNING("Input file has no Fileformat identifier. Assuming format=0.");
137 // 'rewind' the file
138
139 infile.close();
140 infile.open(filename.c_str());
141 }
142 }
143 infile.close();
144 return sc;
145}
#define ATH_MSG_WARNING(x)
static Double_t sc
::StatusCode StatusCode
StatusCode definition for legacy code.
str infile
Definition run.py:13

◆ 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 TRTCondWrite::execute ( const EventContext & ctx) const
overridevirtual

Definition at line 74 of file TRTCondWrite.cxx.

75{
76
77 // Read from text file?
78 if (!m_par_caltextfile.empty())
79 {
80 std::ifstream infile(m_par_caltextfile.value().c_str());
81 if (infile)
82 {
83 ATH_MSG_INFO(" Read calibration constants from text file " << m_par_caltextfile);
84 int format = 0;
85 if (StatusCode::SUCCESS != readTextFile(ctx, m_par_caltextfile, format))
86 {
87 ATH_MSG_FATAL("Could not read calibration objects from text file " << m_par_caltextfile);
88 return StatusCode::FAILURE;
89 }
90 }
91 else
92 {
93 ATH_MSG_ERROR("Input file does not exist " << m_par_caltextfile.value().c_str());
94 return StatusCode::FAILURE;
95 }
96 infile.close();
97 }
98 else
99 {
100 ATH_MSG_ERROR("No input filename supplied ");
101 return StatusCode::FAILURE;
102 }
103
104 return StatusCode::SUCCESS;
105 ;
106}
#define ATH_MSG_ERROR(x)
#define ATH_MSG_FATAL(x)
#define ATH_MSG_INFO(x)
Gaudi::Property< std::string > m_par_caltextfile
virtual StatusCode readTextFile(const EventContext &ctx, const std::string &file, int &format) const

◆ 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.

90{
91 // If we didn't find any symlinks to add, just return the collection
92 // from the base class. Otherwise, return the extended collection.
93 if (!m_extendedExtraObjects.empty()) {
95 }
97}
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 TRTCondWrite::finalize ( void )
overridevirtual

Definition at line 108 of file TRTCondWrite.cxx.

109{
110 return StatusCode::SUCCESS;
111}

◆ initialize()

StatusCode TRTCondWrite::initialize ( void )
overridevirtual

Definition at line 25 of file TRTCondWrite.cxx.

26{
27
28 ATH_MSG_DEBUG("TRTCondWrite::initialize() called");
29
30 // Get ID helper
31 ATH_CHECK(detStore()->retrieve(m_trtid, "TRT_ID"));
32
33 // Get condSvc
34 ATH_CHECK(m_condSvc.retrieve());
35
36 // Format of input text file
37 int format = 0;
38 if (m_par_caltextfile != "")
39 {
40 ATH_MSG_INFO(" input text file supplied " << m_par_caltextfile);
41 if (StatusCode::SUCCESS != checkTextFile(m_par_caltextfile, format))
42 {
43 ATH_MSG_INFO("Could not find or could not read text file" << m_par_caltextfile);
44 return StatusCode::SUCCESS;
45 }
46 ATH_MSG_INFO(" Found format " << format << " in text file " << m_par_caltextfile);
47 }
48 else
49 {
50 ATH_MSG_ERROR(" No input text file supplied. Initialization done. ");
51 return StatusCode::FAILURE;
52 }
53
54 // Write keys
55 // If an input text file is specified, initialize write keys. The corresponding folders must be blocked.
56
57 if (m_par_caltextfile != "" && format > 0)
58 {
59
60 ATH_CHECK(m_rtWriteKey.initialize());
61 if (m_condSvc->regHandle(this, m_rtWriteKey).isFailure())
62 ATH_MSG_ERROR("unable to register WriteCondHandle " << m_rtWriteKey.fullKey());
63 ATH_MSG_INFO("Registered WriteCondHandle " << m_rtWriteKey.fullKey());
64 ATH_CHECK(m_t0WriteKey.initialize());
65 if (m_condSvc->regHandle(this, m_t0WriteKey).isFailure())
66 ATH_MSG_ERROR("unable to register WriteCondHandle " << m_t0WriteKey.fullKey());
67 ATH_MSG_INFO("Registered WriteCondHandle " << m_t0WriteKey.fullKey());
68 }
69 ATH_MSG_INFO(" Initilization done with WriteKey Registraton ");
70
71 return StatusCode::SUCCESS;
72}
#define ATH_CHECK
Evaluate an expression and check for errors.
#define ATH_MSG_DEBUG(x)
const ServiceHandle< StoreGateSvc > & detStore() const
virtual StatusCode checkTextFile(const std::string &file, int &format)
read calibration from text file into TDS
SG::WriteCondHandleKey< StrawT0Container > m_t0WriteKey
const TRT_ID * m_trtid
trt id helper
ServiceHandle< ICondSvc > m_condSvc
SG::WriteCondHandleKey< RtRelationContainer > m_rtWriteKey
retrieve(aClass, aKey=None)
Definition PyKernel.py:110

◆ 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.

◆ IOVInfRange()

EventIDRange TRTCondWrite::IOVInfRange ( ) const
virtual

Definition at line 316 of file TRTCondWrite.cxx.

317{
318 const EventIDBase start{1, EventIDBase::UNDEFEVT, EventIDBase::UNDEFNUM, EventIDBase::UNDEFNUM, 0};
319 const EventIDBase stop{EventIDBase::UNDEFNUM - 1, EventIDBase::UNDEFEVT, EventIDBase::UNDEFNUM, EventIDBase::UNDEFNUM, EventIDBase::UNDEFNUM - 1};
320 return EventIDRange{start, stop};
321}

◆ isClonable()

◆ isReEntrant()

virtual bool AthCondAlgorithm::isReEntrant ( ) const
inlineoverridevirtualinherited

Avoid scheduling algorithm multiple times.

With multiple concurrent events, conditions objects often expire simultaneously for all slots. To avoid that the scheduler runs the CondAlg in each slot, we declare it as "non-reentrant". This ensures that the conditions objects are only created once.

In case a particular CondAlg should behave differently, it can override this method again and return true.

See also
ATEAM-836

Definition at line 39 of file AthCondAlgorithm.h.

39{ return false; }

◆ 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.

◆ readTextFile()

StatusCode TRTCondWrite::readTextFile ( const EventContext & ctx,
const std::string & file,
int & format ) const
virtual

Definition at line 147 of file TRTCondWrite.cxx.

148{
149
150 StatusCode sc = StatusCode::SUCCESS;
151 std::ifstream infile(filename.c_str());
152 if (!infile)
153 {
154 ATH_MSG_ERROR("Cannot find input file " << filename);
155 sc = StatusCode::FAILURE;
156 }
157 else
158 {
159 // read the format tag. if none, default to 0
160 format = 0;
161 char line[512];
162 infile.getline(line, 512);
163 std::string linestring(line);
164 size_t pos = linestring.find("Fileformat");
165 if (pos != std::string::npos)
166 {
167 sscanf(line, "# Fileformat=%d", &format);
168 }
169 else
170 {
171 ATH_MSG_WARNING("Input file has no Fileformat identifier. Assuming format=1");
172 // 'rewind' the file
173
174 infile.close();
175 infile.open(filename.c_str());
176 }
177 ATH_MSG_INFO("Reading calibration data from text file " << filename << " format " << format);
178 // force format 1 here
179 sc = readTextFile_Format1(ctx, infile);
180 }
181 infile.close();
182 return sc;
183}
virtual StatusCode readTextFile_Format1(const EventContext &, std::istream &) const

◆ readTextFile_Format1()

StatusCode TRTCondWrite::readTextFile_Format1 ( const EventContext & ctx,
std::istream & infile ) const
virtual

Definition at line 185 of file TRTCondWrite.cxx.

186{
187
188 enum ReadMode
189 {
190 ReadingRtRelation,
191 ReadingStrawT0,
192 ReadingGarbage
193 };
194 ReadMode readmode = ReadingGarbage;
195
196 // Make containers for access via ReadCondHandle for the reconstruction.
197 std::unique_ptr<RtRelationContainer> rtCdo{std::make_unique<RtRelationContainer>()};
198 std::unique_ptr<StrawT0Container> t0Cdo{std::make_unique<StrawT0Container>()};
199
200 char line[512];
201 int nrtrelations(0), nstrawt0(0);
202 while (infile.getline(line, 512))
203 {
204 if (line[0] == '#')
205 {
206 // line with tag
207 std::string linestring(line);
208 if (linestring.find("RtRelation") != std::string::npos)
209 {
210 readmode = ReadingRtRelation;
211 ATH_MSG_INFO(" Found line with Rt tag ");
212 }
213 else if (linestring.find("StrawT0") != std::string::npos)
214 {
215 readmode = ReadingStrawT0;
216 ATH_MSG_INFO(" Found line with T0 tag ");
217 }
218 else
219 readmode = ReadingGarbage;
220 }
221 else if (readmode != ReadingGarbage)
222 {
223 std::istringstream is(line);
224 // read the id
225 TRTCond::ExpandedIdentifier id;
226 is >> id;
227 // read the semicolon that end the id
228 char dummy;
229 is >> dummy;
230
231 // read the object
232 if (readmode == ReadingRtRelation)
233 {
234
235 TRTCond::RtRelation *rt = TRTCond::RtRelationFactory::readFromFile(is);
236 //Values read in should have their values checked against sensible limits.
237 //We assume the input is trusted however.
238 //coverity[TAINTED_SCALAR]
239 rtCdo->set(id, rt);
240 delete rt;
241 ++nrtrelations;
242 }
243 else if (readmode == ReadingStrawT0)
244 {
245
246 float t0(0), t0err(0);
247 is >> t0 >> t0err;
248 if (t0 > 0)
249 {
250 //Values read in should have their values checked against sensible limits.
251 //We assume the input is trusted however.
252 //coverity[TAINTED_SCALAR]
253 t0Cdo->setT0(id, t0, t0err);
254 ++nstrawt0;
255 }
256 }
257 }
258 }
259
260 // Check that containers were filled
261
262 size_t t0footprint = t0Cdo->footprint();
263 size_t rtfootprint = rtCdo->footprint();
264
265 ATH_MSG_INFO("read " << nstrawt0 << " t0 and " << nrtrelations << " rt from file. "
266 << " t0/rt footprints " << t0footprint << " / " << rtfootprint << " t0 footprint after crunch " << t0Cdo->footprint());
267
268 // Record the containers for access via ReadCondHandle during reconstruction
269 const EventIDRange rangeW = IOVInfRange();
270 SG::WriteCondHandle<RtRelationContainer> rtWriteHandle{m_rtWriteKey, ctx};
271 if (rtWriteHandle.isValid())
272 {
273 ATH_MSG_DEBUG(" RtRelationContainer already available ");
274 return StatusCode::SUCCESS;
275 }
276
277 if (rtWriteHandle.record(rangeW, std::move(rtCdo)).isFailure())
278 {
279 ATH_MSG_ERROR("Could not record RT Container for key " << m_rtWriteKey.fullKey() << " with WriteHandle ");
280 return StatusCode::FAILURE;
281 }
282 else
283 {
284 ATH_MSG_INFO("Recorded RT Container for key " << m_rtWriteKey.fullKey() << " with range " << rtWriteHandle.getRange());
285 }
286
287 SG::WriteCondHandle<StrawT0Container> t0WriteHandle{m_t0WriteKey, ctx};
288 if (t0WriteHandle.isValid())
289 {
290 ATH_MSG_DEBUG(" StrawT0Container already available ");
291 return StatusCode::SUCCESS;
292 }
293
294 if (t0Cdo->initialize().isFailure())
295 ATH_MSG_WARNING("Could not initialize T0 Container for key " << m_t0WriteKey.fullKey());
296
297 if (t0WriteHandle.record(rangeW, std::move(t0Cdo)).isFailure())
298 {
299 ATH_MSG_ERROR("Could not record T0 Container for key " << m_t0WriteKey.fullKey() << " with WriteHandle ");
300 return StatusCode::FAILURE;
301 }
302 else
303 {
304 ATH_MSG_INFO("Recorded T0 Container for key " << m_t0WriteKey.fullKey() << " with range " << t0WriteHandle.getRange());
305 }
306
307 return StatusCode::SUCCESS;
308}
static Double_t t0
const EventIDRange & getRange() const
StatusCode record(const EventIDRange &range, T *t)
record handle, with explicit range DEPRECATED
virtual EventIDRange IOVInfRange() const
static RtRelation * readFromFile(std::istream &is)
read method

◆ 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.

77{
78 return BaseAlg::sysExecute (ctx);
79}

◆ 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.

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

◆ trtcondid()

TRTCond::ExpandedIdentifier TRTCondWrite::trtcondid ( const Identifier & id,
int level = TRTCond::ExpandedIdentifier::STRAW ) const
virtual

create an TRTCond::ExpandedIdentifier from a TRTID identifier

Definition at line 310 of file TRTCondWrite.cxx.

311{
312 return TRTCond::ExpandedIdentifier(m_trtid->barrel_ec(id), m_trtid->layer_or_wheel(id),
313 m_trtid->phi_module(id), m_trtid->straw_layer(id),
314 m_trtid->straw(id), level);
315}

◆ 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_condSvc

ServiceHandle<ICondSvc> TRTCondWrite::m_condSvc {this, "CondSvc", "CondSvc"}
private

Definition at line 60 of file TRTCondWrite.h.

60{this, "CondSvc", "CondSvc"};

◆ 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_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_par_caltextfile

Gaudi::Property<std::string> TRTCondWrite::m_par_caltextfile {this, "CalibInputFile", "dummy_TRTCondWrite.txt", ""}
private

Definition at line 61 of file TRTCondWrite.h.

61{this, "CalibInputFile", "dummy_TRTCondWrite.txt", ""};

◆ m_rtWriteKey

SG::WriteCondHandleKey<RtRelationContainer> TRTCondWrite::m_rtWriteKey {this, "RtWriteKeyName", "/TRT/Calib/RT", "r-t relation out-key"}
private

Definition at line 64 of file TRTCondWrite.h.

64{this, "RtWriteKeyName", "/TRT/Calib/RT", "r-t relation out-key"};

◆ m_t0WriteKey

SG::WriteCondHandleKey<StrawT0Container> TRTCondWrite::m_t0WriteKey {this, "T0WriteKeyName", "/TRT/Calib/T0", "t0 out-key"}
private

Definition at line 65 of file TRTCondWrite.h.

65{this, "T0WriteKeyName", "/TRT/Calib/T0", "t0 out-key"};

◆ m_trtid

const TRT_ID* TRTCondWrite::m_trtid {}
private

trt id helper

Definition at line 59 of file TRTCondWrite.h.

59{};

◆ 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: