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

#include <MuonCalibStreamTestAlg.h>

Inheritance diagram for MuonCalibStreamTestAlg:
Collaboration diagram for MuonCalibStreamTestAlg:

Public Member Functions

 MuonCalibStreamTestAlg (const std::string &name, ISvcLocator *pSvcLocator)
 Constructor.
virtual StatusCode initialize () override
 Initialize.
virtual StatusCode execute (const EventContext &ctx) const override
 Execute.
virtual StatusCode finalize () override
 ~MuonCalibStreamTestAlg ()=default
 Destructur.
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

SG::ReadHandleKey< xAOD::EventInfom_eventInfoKey {this, "MuonCalibStreamEventInfo", "EventInfo"}
SG::ReadHandleKey< Muon::MdtPrepDataContainerm_MdtPrepDataKey {this, "MdtPrepData", "MDT_DriftCircles"}
SG::ReadHandleKey< Muon::RpcPrepDataContainerm_RpcPrepDataKey {this, "RpcPrepData", "RPC_Measurements"}
SG::ReadHandleKey< Muon::TgcPrepDataContainerm_TgcPrepDataKey {this, "TgcPrepData", "TGC_Measurements"}
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 18 of file MuonCalibStreamTestAlg.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

◆ MuonCalibStreamTestAlg()

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

Constructor.

Definition at line 12 of file MuonCalibStreamTestAlg.cxx.

12 :
13 AthReentrantAlgorithm(name, pSvcLocator) {}

◆ ~MuonCalibStreamTestAlg()

MuonCalibStreamTestAlg::~MuonCalibStreamTestAlg ( )
default

Destructur.

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}

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

Execute.

Definition at line 28 of file MuonCalibStreamTestAlg.cxx.

28 {
29 ATH_MSG_DEBUG("execute");
30 // verify EventInfo class
31 SG::ReadHandle<xAOD::EventInfo> evtInfo(m_eventInfoKey, ctx);
32
33 const xAOD::EventInfo* ei = evtInfo.cptr();
34 // Basic info:
35 ATH_MSG_DEBUG( "runNumber = " << ei->runNumber());
36 ATH_MSG_DEBUG( "eventNumber = " << ei->eventNumber() );
37 ATH_MSG_DEBUG( "lumiBlock = " << ei->lumiBlock() );
38 ATH_MSG_DEBUG( "timeStamp = " << ei->timeStamp());
39 ATH_MSG_DEBUG( "pt = " << ei->timeStampNSOffset() ); // special bit for Muon calibration eventInfo
40 ATH_MSG_DEBUG( "bcid = " << ei->bcid() );
41 ATH_MSG_DEBUG( "detectorMask = " << ei->eventTypeBitmask());
42
43 // verify MdtPrepDataContainer
44 SG::ReadHandle<Muon::MdtPrepDataContainer> mdtPrds(m_MdtPrepDataKey, ctx);
45 ATH_MSG_DEBUG("****** MDT Container size: " << mdtPrds->size());
46 if (mdtPrds->size()) {
47 Muon::MdtPrepDataContainer::const_iterator it = mdtPrds->begin();
48 Muon::MdtPrepDataContainer::const_iterator it_end = mdtPrds->end();
49
50 for (; it != it_end; ++it) {
51 ATH_MSG_DEBUG("MDT ********** Collections size: " << (*it)->size());
52 Muon::MdtPrepDataCollection::const_iterator cit_begin = (*it)->begin();
55 for (; cit != cit_end; ++cit) {
56 const Muon::MdtPrepData *mdt = (*cit);
57 mdt->dump(msg());
58 }
59 }
60 } // end of MDTPrepDataCollections loop
61
62 // verify RpcPrepDataContainer
63 SG::ReadHandle<Muon::RpcPrepDataContainer> rpcPrds(m_RpcPrepDataKey, ctx);
64 ATH_MSG_DEBUG("****** RPC Container size: " << rpcPrds->size());
65 // If dumping by container
66 if (rpcPrds->size()) {
67 Muon::RpcPrepDataContainer::const_iterator it = rpcPrds->begin();
68 Muon::RpcPrepDataContainer::const_iterator it_end = rpcPrds->end();
69
70 for (; it != it_end; ++it) {
71 ATH_MSG_DEBUG("********** RPC Collections size: " << (*it)->size());
72 Muon::RpcPrepDataCollection::const_iterator cit_begin = (*it)->begin();
75 for (; cit != cit_end; ++cit) {
76 const Muon::RpcPrepData *rpc = (*cit);
77 rpc->dump(msg());
78 }
79 }
80 }
81
82 // verify TGC_Measurements
83 SG::ReadHandle<Muon::TgcPrepDataContainer> tgcPrds(m_TgcPrepDataKey, ctx);
84 ATH_MSG_DEBUG("****** TGC Container size: " << tgcPrds->size());
85 if (tgcPrds->size()) {
86 Muon::TgcPrepDataContainer::const_iterator it = tgcPrds->begin();
87 Muon::TgcPrepDataContainer::const_iterator it_end = tgcPrds->end();
88
89 for (; it != it_end; ++it) {
90 ATH_MSG_DEBUG("********** TGC Collections size: " << (*it)->size());
91 Muon::TgcPrepDataCollection::const_iterator cit_begin = (*it)->begin();
94 for (; cit != cit_end; ++cit) {
95 const Muon::TgcPrepData *tgc = (*cit);
96 tgc->dump(msg());
97 }
98 }
99 }
100
101 return StatusCode::SUCCESS;
102} // MuonCalibStreamTestAlg::execute()
#define ATH_MSG_DEBUG(x)
DataModel_detail::const_iterator< DataVector > const_iterator
Definition DataVector.h:838
SG::ReadHandleKey< Muon::TgcPrepDataContainer > m_TgcPrepDataKey
SG::ReadHandleKey< Muon::MdtPrepDataContainer > m_MdtPrepDataKey
SG::ReadHandleKey< Muon::RpcPrepDataContainer > m_RpcPrepDataKey
SG::ReadHandleKey< xAOD::EventInfo > m_eventInfoKey
virtual MsgStream & dump(MsgStream &stream) const override
Dumps information about the PRD.
virtual MsgStream & dump(MsgStream &stream) const override
Dumps information about the PRD.
virtual MsgStream & dump(MsgStream &stream) const override final
Dumps information about the PRD.
uint32_t lumiBlock() const
The current event's luminosity block number.
uint32_t eventTypeBitmask() const
The event type bitmask.
uint32_t bcid() const
The bunch crossing ID of the event.
uint32_t timeStamp() const
POSIX time in seconds from 1970. January 1st.
uint32_t runNumber() const
The current event's run number.
uint32_t timeStampNSOffset() const
Nanosecond time offset wrt. the time stamp.
uint64_t eventNumber() const
The current event's event number.
EventInfo_v1 EventInfo
Definition of the latest event info version.

◆ 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 MuonCalibStreamTestAlg::finalize ( )
overridevirtual

Definition at line 104 of file MuonCalibStreamTestAlg.cxx.

104{ return StatusCode::SUCCESS; }

◆ initialize()

StatusCode MuonCalibStreamTestAlg::initialize ( )
overridevirtual

Initialize.

Definition at line 15 of file MuonCalibStreamTestAlg.cxx.

15 {
16
17 ATH_MSG_INFO("initialize");
18
19 ATH_CHECK(m_eventInfoKey.initialize());
20 ATH_CHECK(m_MdtPrepDataKey.initialize());
21 ATH_CHECK(m_RpcPrepDataKey.initialize());
22 ATH_CHECK(m_TgcPrepDataKey.initialize());
23
24 return StatusCode::SUCCESS;
25}
#define ATH_CHECK
Evaluate an expression and check for errors.
#define ATH_MSG_INFO(x)

◆ 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()

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

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}
#define ATH_MSG_ERROR(x)
#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_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_eventInfoKey

SG::ReadHandleKey<xAOD::EventInfo> MuonCalibStreamTestAlg::m_eventInfoKey {this, "MuonCalibStreamEventInfo", "EventInfo"}
private

Definition at line 37 of file MuonCalibStreamTestAlg.h.

37{this, "MuonCalibStreamEventInfo", "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_MdtPrepDataKey

SG::ReadHandleKey<Muon::MdtPrepDataContainer> MuonCalibStreamTestAlg::m_MdtPrepDataKey {this, "MdtPrepData", "MDT_DriftCircles"}
private

Definition at line 38 of file MuonCalibStreamTestAlg.h.

38{this, "MdtPrepData", "MDT_DriftCircles"};

◆ m_RpcPrepDataKey

SG::ReadHandleKey<Muon::RpcPrepDataContainer> MuonCalibStreamTestAlg::m_RpcPrepDataKey {this, "RpcPrepData", "RPC_Measurements"}
private

Definition at line 39 of file MuonCalibStreamTestAlg.h.

39{this, "RpcPrepData", "RPC_Measurements"};

◆ m_TgcPrepDataKey

SG::ReadHandleKey<Muon::TgcPrepDataContainer> MuonCalibStreamTestAlg::m_TgcPrepDataKey {this, "TgcPrepData", "TGC_Measurements"}
private

Definition at line 40 of file MuonCalibStreamTestAlg.h.

40{this, "TgcPrepData", "TGC_Measurements"};

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