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

#include <DQTDetSynchMonAlg.h>

Inheritance diagram for DQTDetSynchMonAlg:
Collaboration diagram for DQTDetSynchMonAlg:

Public Types

enum class  Environment_t {
  user = 0 , online , tier0 , tier0Raw ,
  tier0ESD , AOD , altprod
}
 Specifies the processing environment. More...
enum class  DataType_t {
  userDefined = 0 , monteCarlo , collisions , cosmics ,
  heavyIonCollisions
}
 Specifies what type of input data is being monitored. More...

Public Member Functions

 DQTDetSynchMonAlg (const std::string &name, ISvcLocator *pSvcLocator)
virtual ~DQTDetSynchMonAlg ()
virtual StatusCode initialize () override
 initialize
virtual StatusCode fillHistograms (const EventContext &ctx) const override
 adds event to the monitoring histograms
uint32_t findid (const std::multiset< uint32_t > &mset) const
float findfrac (const std::multiset< uint32_t > &mset, uint16_t ctpid) const
virtual StatusCode execute (const EventContext &ctx) const override
 Applies filters and trigger requirements.
void fill (const ToolHandle< GenericMonitoringTool > &groupHandle, std::vector< std::reference_wrapper< Monitored::IMonitoredVariable > > &&variables) const
 Fills a vector of variables to a group by reference.
void fill (const ToolHandle< GenericMonitoringTool > &groupHandle, const std::vector< std::reference_wrapper< Monitored::IMonitoredVariable > > &variables) const
 Fills a vector of variables to a group by reference.
template<typename... T>
void fill (const ToolHandle< GenericMonitoringTool > &groupHandle, T &&... variables) const
 Fills a variadic list of variables to a group by reference.
void fill (const std::string &groupName, std::vector< std::reference_wrapper< Monitored::IMonitoredVariable > > &&variables) const
 Fills a vector of variables to a group by name.
void fill (const std::string &groupName, const std::vector< std::reference_wrapper< Monitored::IMonitoredVariable > > &variables) const
 Fills a vector of variables to a group by name.
template<typename... T>
void fill (const std::string &groupName, T &&... variables) const
 Fills a variadic list of variables to a group by name.
Environment_t environment () const
 Accessor functions for the environment.
Environment_t envStringToEnum (const std::string &str) const
 Convert the environment string from the python configuration to an enum object.
DataType_t dataType () const
 Accessor functions for the data type.
DataType_t dataTypeStringToEnum (const std::string &str) const
 Convert the data type string from the python configuration to an enum object.
const ToolHandle< GenericMonitoringTool > & getGroup (const std::string &name) const
 Get a specific monitoring tool from the tool handle array.
const ToolHandle< Trig::TrigDecisionTool > & getTrigDecisionTool () const
 Get the trigger decision tool member.
bool trigChainsArePassed (const std::vector< std::string > &vTrigNames) const
 Check whether triggers are passed.
SG::ReadHandle< xAOD::EventInfoGetEventInfo (const EventContext &) const
 Return a ReadHandle for an EventInfo object (get run/event numbers, etc.)
virtual float lbAverageInteractionsPerCrossing (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate the average mu, i.e.
virtual float lbInteractionsPerCrossing (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate instantaneous number of interactions, i.e.
virtual float lbAverageLuminosity (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate average luminosity (in ub-1 s-1 => 10^30 cm-2 s-1).
virtual float lbLuminosityPerBCID (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate the instantaneous luminosity per bunch crossing.
virtual double lbDuration (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate the duration of the luminosity block (in seconds)
virtual float lbAverageLivefraction (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate the average luminosity livefraction.
virtual float livefractionPerBCID (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate the live fraction per bunch crossing ID.
virtual double lbLumiWeight (const EventContext &ctx=Gaudi::Hive::currentContext()) const
 Calculate the average integrated luminosity multiplied by the live fraction.
virtual StatusCode parseList (const std::string &line, std::vector< std::string > &result) const
 Parse a string into a vector.
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

Public Attributes

str nightly = '/cvmfs/atlas-nightlies.cern.ch/repo/data/data-art/CommonInputs/'
str file = 'data16_13TeV.00311321.physics_Main.recon.AOD.r9264/AOD.11038520._000001.pool.root.1'
 flags = initConfigFlags()
 Files
 HISTFileName
 cfg = MainServicesCfg(flags)
 withDetails

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.

Protected Attributes

ToolHandleArray< GenericMonitoringToolm_tools {this,"GMTools",{}}
 Array of Generic Monitoring Tools.
PublicToolHandle< Trig::TrigDecisionToolm_trigDecTool
 Tool to tell whether a specific trigger is passed.
ToolHandleArray< IDQFilterToolm_DQFilterTools {this,"FilterTools",{}}
 Array of Data Quality filter tools.
SG::ReadCondHandleKey< LuminosityCondDatam_lumiDataKey {this,"LuminosityCondDataKey","LuminosityCondData","SG Key of LuminosityCondData object"}
SG::ReadCondHandleKey< LBDurationCondDatam_lbDurationDataKey {this,"LBDurationCondDataKey","LBDurationCondData","SG Key of LBDurationCondData object"}
SG::ReadCondHandleKey< TrigLiveFractionCondDatam_trigLiveFractionDataKey {this,"TrigLiveFractionCondDataKey","TrigLiveFractionCondData", "SG Key of TrigLiveFractionCondData object"}
AthMonitorAlgorithm::Environment_t m_environment
 Instance of the Environment_t enum.
AthMonitorAlgorithm::DataType_t m_dataType
 Instance of the DataType_t enum.
Gaudi::Property< std::string > m_environmentStr {this,"Environment","user"}
 Environment string pulled from the job option and converted to enum.
Gaudi::Property< std::string > m_dataTypeStr {this,"DataType","userDefined"}
 DataType string pulled from the job option and converted to enum.
Gaudi::Property< std::string > m_triggerChainString {this,"TriggerChain",""}
 Trigger chain string pulled from the job option and parsed into a vector.
std::vector< std::string > m_vTrigChainNames
 Vector of trigger chain names parsed from trigger chain string.
Gaudi::Property< std::string > m_fileKey {this,"FileKey",""}
 Internal Athena name for file.
Gaudi::Property< bool > m_useLumi {this,"EnableLumi",false}
 Allows use of various luminosity functions.
Gaudi::Property< float > m_defaultLBDuration {this,"DefaultLBDuration",60.}
 Default duration of one lumi block.
Gaudi::Property< int > m_detailLevel {this,"DetailLevel",0}
 Sets the level of detail used in the monitoring.
SG::ReadHandleKey< xAOD::EventInfom_EventInfoKey {this,"EventInfoKey","EventInfo"}
 Key for retrieving EventInfo from StoreGate.

Private Types

typedef std::vector< std::reference_wrapper< Monitored::IMonitoredVariable > > MonVarVec_t
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

Gaudi::Property< Int_t > m_solenoidPositionX { this, "SolenoidPositionX", 0 }
Gaudi::Property< Int_t > m_solenoidPositionY { this, "SolenoidPositionY", 10 }
Gaudi::Property< Int_t > m_solenoidPositionZ { this, "SolenoidPositionZ", 0 }
Gaudi::Property< Int_t > m_toroidPositionX { this, "ToroidPositionX", 0 }
Gaudi::Property< Int_t > m_toroidPositionY { this, "ToroidPositionY", 6000 }
Gaudi::Property< Int_t > m_toroidPositionZ { this, "ToroidPositionZ", 0 }
Gaudi::Property< bool > m_doRPC { this, "doRPC", true }
Gaudi::Property< bool > m_run2Compat { this, "run2Compat", false, "Make histograms with Run 2 naming" }
std::vector< std::string > m_diffnamevec
SG::ReadHandleKeyArray< InDetTimeCollectionm_InDetTimeCollectionKeys { this, "InDetTimeCollectionKeys", {"TRT_BCID", "SCT_BCID", "PixelBCID", "TRT_LVL1ID", "SCT_LVL1ID", "PixelLVL1ID"} }
SG::ReadHandleKey< LArFebHeaderContainerm_LArFebHeaderContainerKey { this, "LArFebHeaderKey", "LArFebHeader" }
SG::ReadHandleKey< TileDigitsContainerm_TileDigitsContainerKey { this, "TileDigitsContainerKey", "TileDigitsFlt" }
SG::ReadHandleKey< RpcPadContainerm_RpcPadContainerKey { this, "RpcPadContainerKey", "RPCPAD" }
SG::ReadCondHandleKey< AtlasFieldCacheCondObjm_fieldCacheCondObjInputKey
std::string m_name
std::unordered_map< std::string, size_t > m_toolLookupMap
const ToolHandle< GenericMonitoringToolm_dummy
Gaudi::Property< bool > m_enforceExpressTriggers
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

Static Private Attributes

static const int NDETS = 7

Detailed Description

Definition at line 39 of file DQTDetSynchMonAlg.h.

Member Typedef Documentation

◆ MonVarVec_t

typedef std::vector<std::reference_wrapper<Monitored::IMonitoredVariable> > AthMonitorAlgorithm::MonVarVec_t
privateinherited

Definition at line 370 of file AthMonitorAlgorithm.h.

◆ StoreGateSvc_t

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

Definition at line 388 of file AthCommonDataStore.h.

Member Enumeration Documentation

◆ DataType_t

enum class AthMonitorAlgorithm::DataType_t
stronginherited

Specifies what type of input data is being monitored.

An enumeration of the different types of data the monitoring application may be running over. This can be used to select which histograms to produce, e.g. to prevent the production of colliding-beam histograms when running on cosmic-ray data. Strings of the same names may be given as jobOptions.

Enumerator
userDefined 
monteCarlo 
collisions 
cosmics 
heavyIonCollisions 

Definition at line 194 of file AthMonitorAlgorithm.h.

194 {
195 userDefined = 0,
196 monteCarlo,
197 collisions,
198 cosmics,
199 heavyIonCollisions,
200 };
AthConfigFlags cosmics(AthConfigFlags flags, str instanceName, str recoMode)

◆ Environment_t

enum class AthMonitorAlgorithm::Environment_t
stronginherited

Specifies the processing environment.

The running environment may be used to select which histograms are produced, and where they are located in the output. For example, the output paths of the histograms are different for the "user", "online" and the various offline flags. Strings of the same names may be given as jobOptions.

Enumerator
user 
online 
tier0 
tier0Raw 
tier0ESD 
AOD 
altprod 

Definition at line 175 of file AthMonitorAlgorithm.h.

175 {
176 user = 0,
177 online,
178 tier0,
179 tier0Raw,
180 tier0ESD,
181 AOD,
182 altprod,
183 };

Constructor & Destructor Documentation

◆ DQTDetSynchMonAlg()

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

Definition at line 32 of file DQTDetSynchMonAlg.cxx.

34 : AthMonitorAlgorithm(name, pSvcLocator)
35{
36 for (size_t ix = 0; ix < NDETS; ++ix) {
37 for (size_t iy = ix+1; iy < NDETS; ++iy) {
38 if (m_run2Compat && iy == 6) {
39 m_diffnamevec.push_back("diff_" + std::to_string(iy) + "_" + std::to_string(ix));
40 } else {
41 m_diffnamevec.push_back("diff_" + std::to_string(ix) + "_" + std::to_string(iy));
42 }
43 }
44 }
45}
Base class for Athena Monitoring Algorithms.

◆ ~DQTDetSynchMonAlg()

DQTDetSynchMonAlg::~DQTDetSynchMonAlg ( )
virtual

Definition at line 48 of file DQTDetSynchMonAlg.cxx.

50{
51}

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}

◆ dataType()

DataType_t AthMonitorAlgorithm::dataType ( ) const
inlineinherited

Accessor functions for the data type.

Returns
the current value of the class's DataType_t instance.

Definition at line 224 of file AthMonitorAlgorithm.h.

224{ return m_dataType; }
AthMonitorAlgorithm::DataType_t m_dataType
Instance of the DataType_t enum.

◆ dataTypeStringToEnum()

AthMonitorAlgorithm::DataType_t AthMonitorAlgorithm::dataTypeStringToEnum ( const std::string & str) const
inherited

Convert the data type string from the python configuration to an enum object.

Returns
a value in the DataType_t enumeration which matches the input string.

Definition at line 144 of file AthMonitorAlgorithm.cxx.

144 {
145 // convert the string to all lowercase
146 std::string lowerCaseStr = str;
147 std::transform(lowerCaseStr.begin(), lowerCaseStr.end(), lowerCaseStr.begin(), ::tolower);
148
149 // check if it matches one of the enum choices
150 if( lowerCaseStr == "userdefined" ) {
152 } else if( lowerCaseStr == "montecarlo" ) {
154 } else if( lowerCaseStr == "collisions" ) {
156 } else if( lowerCaseStr == "cosmics" ) {
157 return DataType_t::cosmics;
158 } else if( lowerCaseStr == "heavyioncollisions" ) {
160 } else { // otherwise, warn the user and return "userDefined"
161 ATH_MSG_WARNING("AthMonitorAlgorithm::dataTypeStringToEnum(): Unknown data type "
162 <<str<<", returning userDefined.");
164 }
165}
#define ATH_MSG_WARNING(x)
void tolower(std::string &s)

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

◆ environment()

Environment_t AthMonitorAlgorithm::environment ( ) const
inlineinherited

Accessor functions for the environment.

Returns
the current value of the class's Environment_t instance.

Definition at line 208 of file AthMonitorAlgorithm.h.

208{ return m_environment; }
AthMonitorAlgorithm::Environment_t m_environment
Instance of the Environment_t enum.

◆ envStringToEnum()

AthMonitorAlgorithm::Environment_t AthMonitorAlgorithm::envStringToEnum ( const std::string & str) const
inherited

Convert the environment string from the python configuration to an enum object.

Returns
a value in the Environment_t enumeration which matches the input string.

Definition at line 116 of file AthMonitorAlgorithm.cxx.

116 {
117 // convert the string to all lowercase
118 std::string lowerCaseStr = str;
119 std::transform(lowerCaseStr.begin(), lowerCaseStr.end(), lowerCaseStr.begin(), ::tolower);
120
121 // check if it matches one of the enum choices
122 if( lowerCaseStr == "user" ) {
123 return Environment_t::user;
124 } else if( lowerCaseStr == "online" ) {
126 } else if( lowerCaseStr == "tier0" ) {
128 } else if( lowerCaseStr == "tier0raw" ) {
130 } else if( lowerCaseStr == "tier0esd" ) {
132 } else if( lowerCaseStr == "aod" ) {
133 return Environment_t::AOD;
134 } else if( lowerCaseStr == "altprod" ) {
136 } else { // otherwise, warn the user and return "user"
137 ATH_MSG_WARNING("AthMonitorAlgorithm::envStringToEnum(): Unknown environment "
138 <<str<<", returning user.");
139 return Environment_t::user;
140 }
141}

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

Applies filters and trigger requirements.

Then, calls fillHistograms().

Parameters
ctxevent context for reentrant Athena call
Returns
StatusCode

Definition at line 77 of file AthMonitorAlgorithm.cxx.

77 {
78
79 // Checks that all of the DQ filters are passed. If any one of the filters
80 // fails, return SUCCESS code and do not fill the histograms with the event.
81 for ( const auto& filterItr : m_DQFilterTools ) {
82 if (!filterItr->accept()) {
83 ATH_MSG_DEBUG("Event rejected due to filter tool.");
84 return StatusCode::SUCCESS;
85 }
86 }
87
88 // Trigger: If there is a decision tool and the chains fail, skip the event.
90 ATH_MSG_DEBUG("Event rejected due to trigger filter.");
91 return StatusCode::SUCCESS;
92 }
93
94 ATH_MSG_DEBUG("Event accepted!");
95 return fillHistograms(ctx);
96}
#define ATH_MSG_DEBUG(x)
virtual StatusCode fillHistograms(const EventContext &ctx) const =0
adds event to the monitoring histograms
bool trigChainsArePassed(const std::vector< std::string > &vTrigNames) const
Check whether triggers are passed.
std::vector< std::string > m_vTrigChainNames
Vector of trigger chain names parsed from trigger chain string.
PublicToolHandle< Trig::TrigDecisionTool > m_trigDecTool
Tool to tell whether a specific trigger is passed.
ToolHandleArray< IDQFilterTool > m_DQFilterTools
Array of Data Quality filter tools.

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

◆ fillHistograms()

StatusCode DQTDetSynchMonAlg::fillHistograms ( const EventContext & ctx) const
overridevirtual

adds event to the monitoring histograms

User will overwrite this function. Histogram booking is no longer done in C++. This function is called in execute once the filters are all passed.

Parameters
ctxforwarded from execute
Returns
StatusCode

Implements AthMonitorAlgorithm.

Definition at line 65 of file DQTDetSynchMonAlg.cxx.

67{
68 ATH_MSG_DEBUG("in DQTDetSynchMonAlg::fillHistograms()");
69
70 std::multiset<uint32_t> sctbcidset;
71 std::multiset<uint32_t> trtbcidset;
72 std::multiset<uint32_t> larbcidset;
73 std::multiset<uint32_t> tilebcidset;
74 std::multiset<uint32_t> rpcbcidset;
75 std::multiset<uint32_t> pixelbcidset;
76
77 std::multiset<uint32_t> sctl1idset;
78 std::multiset<uint32_t> trtl1idset;
79 std::multiset<uint32_t> larl1idset;
80 std::multiset<uint32_t> tilel1idset;
81 std::multiset<uint32_t> rpcl1idset;
82 std::multiset<uint32_t> pixell1idset;
83
84
85 Monitored::Scalar<uint16_t> sctbcid("sctbcid", 0), trtbcid("trtbcid", 0), larbcid("larbcid", 0), tilebcid("tilebcid", 0), rpcbcid("rpcbcid", 0), pixelbcid("pixelbcid", 0);
86 Monitored::Scalar<uint32_t> sctl1id("sctl1id", 0), trtl1id("trtl1id", 0), larl1id("larl1id", 0), rpcl1id("rpcl1id", 0), pixell1id("pixell1id", 0);
87 uint32_t tilel1id(0); // handled specially
88
89 Monitored::Scalar<float> sctfrac("sctfrac", 0.0), trtfrac("trtfrac", 0.0), larfrac("larfrac", 0.0), tilefrac("tilefrac", 0.0), rpcfrac("rpcfrac", 0.0), pixelfrac("pixelfrac", 0.0);
90
91 auto ctpbcid = Monitored::Scalar("ctpbcid", (uint16_t) 9999);
92 uint32_t ctpl1id(9999999); // handled specially
93
94 uint32_t lumi(0), evtNum(0);
95
96 //Retrieve CTP, other things from EventInfo
97 SG::ReadHandle<xAOD::EventInfo> thisEventInfo { GetEventInfo(ctx) } ;
98 if(! thisEventInfo.isValid())
99 {
100 ATH_MSG_WARNING( "Could not find EventInfo in evtStore" );
101 }
102 else
103 {
104 ctpbcid = thisEventInfo->bcid();
105 lumi = thisEventInfo->lumiBlock() ;
106 evtNum = thisEventInfo->eventNumber();
107 ctpl1id = thisEventInfo->extendedLevel1ID();
108 }
109
110 auto lb = Monitored::Scalar("LB", lumi);
111 auto inDetTimeCollections = m_InDetTimeCollectionKeys.makeHandles(ctx);
112
113 if (inDetTimeCollections[0].isValid()) {
114 auto& TRT_BCIDColl(inDetTimeCollections[0]);
115 for ( InDetTimeCollection::const_iterator itrt_bcid
116 = TRT_BCIDColl->begin();
117 itrt_bcid != TRT_BCIDColl->end(); ++itrt_bcid ) {
118 //Current bcid
119 trtbcidset.insert((uint16_t)(*itrt_bcid).second);
120 } // End for loop
121 }
122 else {
123 ATH_MSG_WARNING( "Could not get any TRT_BCID containers " );
124 }
125
126
127 if (inDetTimeCollections[1].isValid()) {
128 auto& SCT_BCIDColl(inDetTimeCollections[1]);
129 for ( InDetTimeCollection::const_iterator isct_bcid
130 = SCT_BCIDColl->begin();
131 isct_bcid != SCT_BCIDColl->end(); ++isct_bcid ) {
132 //Current bcid
133 sctbcidset.insert((uint16_t)(*isct_bcid).second);
134 } // End for loop
135 }
136 else {
137 ATH_MSG_WARNING( "Could not get any SCT_BCID containers " );
138 }
139
140
141 if (inDetTimeCollections[2].isValid()) {
142 auto& Pixel_BCIDColl(inDetTimeCollections[2]);
143 for ( InDetTimeCollection::const_iterator ipixel_bcid
144 = Pixel_BCIDColl->begin();
145 ipixel_bcid != Pixel_BCIDColl->end(); ++ipixel_bcid ) {
146 //Current bcid
147 pixelbcidset.insert((uint16_t)(*ipixel_bcid).second);
148 } // End for loop
149 }
150 else {
151 ATH_MSG_WARNING( "Could not get any Pixel_BCID containers " );
152 }
153
154
155 if (inDetTimeCollections[3].isValid()) {
156 auto& TRT_LVL1IDColl(inDetTimeCollections[3]);
157 for ( InDetTimeCollection::const_iterator itrt_lvl1id
158 = TRT_LVL1IDColl->begin();
159 itrt_lvl1id != TRT_LVL1IDColl->end(); ++itrt_lvl1id ) {
160 //Current lvl1id
161 trtl1idset.insert((uint16_t)(*itrt_lvl1id).second);
162 } // End for loop
163 }
164 else {
165 ATH_MSG_WARNING( "Could not get TRT_LVL1ID container " );
166 }
167
168
169 if (inDetTimeCollections[4].isValid()) {
170 auto& SCT_LVL1IDColl(inDetTimeCollections[4]);
171 for ( InDetTimeCollection::const_iterator isct_lvl1id
172 = SCT_LVL1IDColl->begin();
173 isct_lvl1id != SCT_LVL1IDColl->end(); ++isct_lvl1id ) {
174 //Current lvl1id
175 sctl1idset.insert((uint16_t)(*isct_lvl1id).second);
176 } // End for loop
177 }
178 else {
179 ATH_MSG_WARNING( "Could not get SCT_LVL1ID container " );
180 }
181
182
183 if (inDetTimeCollections[5].isValid()) {
184 auto& Pixel_LVL1IDColl(inDetTimeCollections[5]);
185 for ( InDetTimeCollection::const_iterator ipixel_lvl1id
186 = Pixel_LVL1IDColl->begin();
187 ipixel_lvl1id != Pixel_LVL1IDColl->end(); ++ipixel_lvl1id ) {
188 //Current lvl1id
189 pixell1idset.insert((uint16_t)(*ipixel_lvl1id).second);
190 } // End for loop
191 }
192 else {
193 ATH_MSG_WARNING( "Could not get Pixel_LVL1ID container " );
194 }
195
196
197 sctbcid=findid(sctbcidset);
198 sctfrac=findfrac(sctbcidset,ctpbcid);
199 trtbcid=findid(trtbcidset);
200 trtfrac=findfrac(trtbcidset,ctpbcid);
201 sctl1id=findid(sctl1idset);
202 trtl1id=findid(trtl1idset);
203 pixell1id=findid(pixell1idset);
204 pixelbcid=findid(pixelbcidset);
205 pixelfrac=findfrac(pixelbcidset,ctpbcid);
206
207 SG::ReadHandle<LArFebHeaderContainer> hdrCont(m_LArFebHeaderContainerKey, ctx);
208 if (! hdrCont.isValid()) {
209 ATH_MSG_WARNING( "No LArFEB container found in TDS" );
210 }
211 else {
212 //log << MSG::DEBUG << "LArFEB container found" <<endmsg;
213 LArFebHeaderContainer::const_iterator it = hdrCont->begin();
214 LArFebHeaderContainer::const_iterator itend = hdrCont->end();
215 for ( ; it!=itend;++it) {
216 //HWIdentifier febid=(*it)->FEBId();
217 unsigned int febid=((*it)->FEBId()).get_identifier32().get_compact();
218 if (febid >= 0x38000000 && febid <= 0x3bc60000) {
219 larbcidset.insert((uint16_t) (*it)->BCId() );
220 larl1idset.insert((uint32_t) (*it)->ELVL1Id() );
221 }
222 }
223 }
224 larbcid=findid(larbcidset);
225 larfrac=findfrac(larbcidset,larbcid);
226 larl1id=findid(larl1idset);
227
228 SG::ReadHandle<TileDigitsContainer> DigitsCnt(m_TileDigitsContainerKey, ctx);
229 if (! DigitsCnt.isValid()) {
230 ATH_MSG_WARNING( "No Tile Digits container found in TDS" );
231 }
232 else {
233 TileDigitsContainer::const_iterator collItr=DigitsCnt->begin();
234 TileDigitsContainer::const_iterator lastColl=DigitsCnt->end();
235 for (;collItr!=lastColl;++collItr){
236 tilebcidset.insert( (*collItr)->getRODBCID() );
237 tilel1idset.insert( (*collItr)->getLvl1Id() );
238 }
239 }
240 tilebcid=findid(tilebcidset);
241 tilefrac=findfrac(tilebcidset,tilebcid);
242 tilel1id=findid(tilel1idset);
243
244 if (m_doRPC) {
245 SG::ReadHandle<RpcPadContainer> rpcRDO(m_RpcPadContainerKey, ctx);
246 if (! rpcRDO.isValid()) {
247 ATH_MSG_WARNING( "No RPC Pad container found in TDS" );
248 } else {
249 RpcPadContainer::const_iterator pad = rpcRDO->begin();
250 RpcPadContainer::const_iterator endpad = rpcRDO->end();
251 for (; pad != endpad ; ++pad ) {
252 if ( (*pad) ) {
253 if ( (*pad)->size() > 0 ) {
254 rpcbcidset.insert( (*pad)->bcId() );
255 rpcl1idset.insert( (*pad)->lvl1Id() );
256 }
257 }
258 }
259 }
260 }
261
262
263 rpcbcid=findid(rpcbcidset);
264 rpcfrac=findfrac(rpcbcidset,rpcbcid);
265 rpcl1id=findid(rpcl1idset);
266
267 auto ctp_l1id16 = Monitored::Scalar<uint32_t>("ctpl1id", ctpl1id & 0xFFFF);
268 uint32_t ctp_l1id9 = ctpl1id & 0x1FF;
269 auto tile_l1id16 = Monitored::Scalar<uint32_t>("tilel1id", tilel1id & 0xFFFF);
270 uint32_t tile_l1id9 = tilel1id & 0x1FF;
271 uint32_t sct_l1id9 = sctl1id & 0x1FF;
272 uint32_t trt_l1id9 = trtl1id & 0x1FF;
273 uint32_t lar_l1id9 = larl1id & 0x1FF;
274 uint32_t pixel_l1id9 = pixell1id & 0x1FF;
275
276 std::vector<float> bcidrates_base { sctfrac, trtfrac, larfrac,
277 tilefrac, rpcfrac, pixelfrac };
278 auto bcidrates = Monitored::Collection( "bcidrates",
279 bcidrates_base );
280
281 std::vector<int> bcidrates_idx_base = { 1, 2, 3, 4, 5, 6 };
282
283 auto bcidrates_idx = Monitored::Collection( "bcidrates_idx",
284 bcidrates_idx_base );
285
286
287 std::vector<Int_t> bcidvals { ctpbcid, sctbcid, trtbcid, larbcid,
288 tilebcid, rpcbcid, pixelbcid };
289 std::vector<int> diffx_base, diffy_base;
290 // catch if we have a sync problem ...
291 assert( bcidvals.size() == NDETS );
292
293 std::vector<Monitored::Scalar<Int_t>> diffvec;
294 for (size_t ix = 0; ix < NDETS; ++ix) {
295 for (size_t iy = ix+1; iy < NDETS; ++iy) {
296 if (m_run2Compat && iy == 6) {
297 diffvec.push_back(Monitored::Scalar<Int_t>(m_diffnamevec[diffvec.size()]));
298 } else {
299 diffvec.push_back(Monitored::Scalar<Int_t>(m_diffnamevec[diffvec.size()]));
300 }
301 }
302 }
303
304 for (size_t ix = 0, ivec = 0; ix < NDETS; ++ix) {
305 for (size_t iy = ix+1; iy < NDETS; ++iy) {
306 Int_t comparison = bcidvals[ix] - bcidvals[iy];
307 if (comparison > 0) {
308 diffx_base.push_back(ix); diffy_base.push_back(iy);
309 } else if (comparison < 0) {
310 diffx_base.push_back(iy); diffy_base.push_back(ix);
311 } else {
312 diffx_base.push_back(ix); diffy_base.push_back(ix);
313 diffx_base.push_back(iy); diffy_base.push_back(iy);
314 }
315 if (m_run2Compat && iy == 6) {
316 diffvec[ivec] = -comparison;
317 } else {
318 diffvec[ivec] = comparison;
319 }
320 ++ivec;
321 }
322 }
323 for (auto&& var: diffvec) {
324 fill("bcid", var, lb);
325 }
326 if (m_run2Compat) {
327 auto diffjunk = Monitored::Scalar("diff_0_6", bcidvals[0]-bcidvals[6]);
328 fill("bcid", diffjunk, lb);
329 }
330
331 auto diffx = Monitored::Collection("diffx", diffx_base);
332 auto diffy = Monitored::Collection("diffy", diffy_base);
333 fill("bcid", ctpbcid, sctbcid, trtbcid, larbcid, tilebcid, rpcbcid,
334 pixelbcid, bcidrates, bcidrates_idx, diffx, diffy);
335
336
337// // Now l1id
338 std::vector<UInt_t> l1idvals { ctp_l1id16, sctl1id, trtl1id, larl1id,
339 tile_l1id16, rpcl1id, pixell1id };
340 // the following for comparison for RPC
341 std::vector<UInt_t> l1idvals_d9 { ctp_l1id9, sct_l1id9, trt_l1id9,
342 lar_l1id9, tile_l1id9, rpcl1id, pixel_l1id9 };
343 // catch if we have a sync problem ...
344 assert( l1idvals.size() == NDETS && l1idvals_d9.size() == NDETS );
345
346 diffx_base.clear(); diffy_base.clear();
347
348 for (size_t ix = 0, ivec = 0; ix < NDETS; ++ix) {
349 for (size_t iy = ix+1; iy < NDETS; ++iy) {
350 UInt_t xl1id, yl1id;
351 // RPC (index 5) is an exception
352 if (iy == 5) {
353 yl1id = rpcl1id; xl1id = l1idvals_d9[ix];
354 } else if (ix == 5) {
355 xl1id = rpcl1id; yl1id = l1idvals_d9[iy];
356 } else {
357 xl1id = l1idvals[ix]; yl1id = l1idvals[iy];
358 }
359 Int_t comparison = xl1id - yl1id;
360 if (comparison > 0) {
361 diffx_base.push_back(ix); diffy_base.push_back(iy);
362 } else if (comparison < 0) {
363 diffx_base.push_back(iy); diffy_base.push_back(ix);
364 } else {
365 diffx_base.push_back(ix); diffy_base.push_back(ix);
366 diffx_base.push_back(iy); diffy_base.push_back(iy);
367 }
368 if (m_run2Compat && iy == 6) {
369 diffvec[ivec] = -comparison;
370 } else {
371 diffvec[ivec] = comparison;
372 }
373 ++ivec;
374 }
375 }
376 for (auto&& var: diffvec) {
377 fill("l1id", var, lb);
378 }
379 if (m_run2Compat) {
380 auto diffjunk = Monitored::Scalar("diff_0_6", bcidvals[0]-bcidvals[6]);
381 fill("l1id", diffjunk, lb);
382 }
383 fill("l1id", ctp_l1id16, sctl1id, trtl1id, larl1id,
384 tile_l1id16, rpcl1id, pixell1id, diffx, diffy);
385
386 // B field
388 Amg::Vector3D gP1(m_solenoidPositionX, m_solenoidPositionY, m_solenoidPositionZ);
389 MagField::AtlasFieldCache fieldCache;
390 SG::ReadCondHandle<AtlasFieldCacheCondObj> readHandle{m_fieldCacheCondObjInputKey, ctx};
391 const AtlasFieldCacheCondObj* fieldCondObj{*readHandle};
392 if (fieldCondObj == nullptr) {
393 ATH_MSG_ERROR("DQTDetSynchMonAlg: Failed to retrieve AtlasFieldCacheCondObj with key " << m_fieldCacheCondObjInputKey.key());
394 return StatusCode::FAILURE;
395 }
396 fieldCondObj->getInitializedCache (fieldCache);
397 fieldCache.getField(gP1.data(),f.data());
398
399 // field is in kilotesla (!)
400 auto solenoid_bz = Monitored::Scalar("solenoid_bz", f[2]*1000.);
401
402 Amg::Vector3D gP2(m_toroidPositionX, m_toroidPositionY, m_toroidPositionZ);
403 fieldCache.getField(gP2.data(),f.data());
404
405 auto toroid_bx = Monitored::Scalar("toroid_bx", f[0]*1000.);
406
407 fill("bfield", solenoid_bz, toroid_bx, lb);
408
409
410 ATH_MSG_VERBOSE( "evt Num : " << evtNum << "\tLumi : " << lumi );
411 ATH_MSG_VERBOSE( "evt L1ID : " << ctpl1id << "\tevt BCID : " << ctpbcid );
412 ATH_MSG_VERBOSE( "CTP L1ID : " << ctpl1id << "\tCTP BCID : " << ctpbcid );
413 ATH_MSG_VERBOSE( "LAR L1ID : " << larl1id << "\tLAR BCID : " << larbcid );
414 ATH_MSG_VERBOSE( "TILE L1ID: " << tilel1id << "\tTILE BCID : " << tilebcid );
415 ATH_MSG_VERBOSE( "RPC L1ID : " << rpcl1id << "\tRPC BCID : " << rpcbcid );
416 ATH_MSG_VERBOSE( "Pixel L1ID : " << pixell1id << "\tPixel BCID : " << pixelbcid );
417 ATH_MSG_VERBOSE( "CTP-RPC L1ID : " << ctp_l1id9-rpcl1id << "\tCTP-LAR L1ID : " << ctp_l1id16-larl1id );
418 return StatusCode::SUCCESS;
419}
#define ATH_MSG_ERROR(x)
#define ATH_MSG_VERBOSE(x)
bool isValid(const T &p)
Av: we implement here an ATLAS-sepcific convention: all particles which are 99xxxxx are fine.
Definition AtlasPID.h:878
void getInitializedCache(MagField::AtlasFieldCache &cache) const
get B field cache for evaluation as a function of 2-d or 3-d position.
static const int NDETS
uint32_t findid(const std::multiset< uint32_t > &mset) const
float findfrac(const std::multiset< uint32_t > &mset, uint16_t ctpid) const
SG::ReadHandleKeyArray< InDetTimeCollection > m_InDetTimeCollectionKeys
SG::ReadCondHandleKey< AtlasFieldCacheCondObj > m_fieldCacheCondObjInputKey
DataModel_detail::const_iterator< DataVector > const_iterator
Definition DataVector.h:838
void getField(const double *ATH_RESTRICT xyz, double *ATH_RESTRICT bxyz, double *ATH_RESTRICT deriv=nullptr)
get B field value at given position xyz[3] is in mm, bxyz[3] is in kT if deriv[9] is given,...
Declare a monitored scalar variable.
virtual bool isValid() override final
Can the handle be successfully dereferenced?
const std::string & key() const
Return the StoreGate ID for the referenced object.
int lb
Definition globals.cxx:23
Eigen::Matrix< double, 3, 1 > Vector3D
vec_fb< typename boost::int_t< sizeof(T) *8 >::exact, N > ivec
Definition vec_fb.h:53
ValuesCollection< T > Collection(std::string name, const T &collection)
Declare a monitored (double-convertible) collection.
setEventNumber uint32_t
void fill(H5::Group &out_file, size_t iterations)

◆ 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

◆ findfrac()

float DQTDetSynchMonAlg::findfrac ( const std::multiset< uint32_t > & mset,
uint16_t ctpid ) const

Definition at line 450 of file DQTDetSynchMonAlg.cxx.

452{
453 MsgStream log(msgSvc(), name());
454 std::multiset<uint32_t>::iterator it = mset.begin();
455 std::multiset<uint32_t>::iterator itend = mset.end();
456
457 int totalCounter=0;
458 int nonctpIdCounter=0;
459 float frac = 0.0;
460
461 if (it!=itend && !mset.empty()){
462 for (;it!=itend;++it) {
463 totalCounter++;
464 if ( (*it) != ctpid ) nonctpIdCounter++;
465 }
466 }
467
468 if (totalCounter>0)
469 frac = ((float) nonctpIdCounter)/((float) totalCounter);
470 else
471 frac = 1.0;
472 return frac;
473}

◆ findid()

uint32_t DQTDetSynchMonAlg::findid ( const std::multiset< uint32_t > & mset) const

Definition at line 423 of file DQTDetSynchMonAlg.cxx.

425{
426 uint32_t id(9999999),refid(9999999);
427 int refcount(0),count(0);
428 std::multiset<uint32_t>::iterator it = mset.begin();
429 std::multiset<uint32_t>::iterator itend = mset.end();
430
431 if (it!=itend && !mset.empty()){
432 for (;it!=itend;++it) {
433 if ( (*it) != id ) { //skip check if the id value has been already evaluated
434
435 id=*it; count = mset.count(*it);
436 ATH_MSG_VERBOSE( "new id found: " << (*it) << " with counts: " << count );
437 if ( ( (*it) !=refid )&&(count>refcount) ){ // if count> previous maximum and double check the id value
438 refid = (*it);
439 refcount=count;
440 ATH_MSG_VERBOSE( "new REFERENCE id: " << refid << " with REFERENCE counts: " << refcount );
441 }
442 }
443 }
444 }
445 ATH_MSG_VERBOSE( "Returning REFERENCE id: " << refid << " with REFERENCE counts: " << refcount );
446 return refid;
447}
int count(std::string s, const std::string &regx)
count how many occurances of a regx are in a string
Definition hcg.cxx:146

◆ GetEventInfo()

SG::ReadHandle< xAOD::EventInfo > AthMonitorAlgorithm::GetEventInfo ( const EventContext & ctx) const
inherited

Return a ReadHandle for an EventInfo object (get run/event numbers, etc.)

Parameters
ctxEventContext for the event
Returns
a SG::ReadHandle<xAOD::EventInfo>

Definition at line 111 of file AthMonitorAlgorithm.cxx.

111 {
112 return SG::ReadHandle<xAOD::EventInfo>(m_EventInfoKey, ctx);
113}
SG::ReadHandleKey< xAOD::EventInfo > m_EventInfoKey
Key for retrieving EventInfo from StoreGate.

◆ getGroup()

const ToolHandle< GenericMonitoringTool > & AthMonitorAlgorithm::getGroup ( const std::string & name) const
inherited

Get a specific monitoring tool from the tool handle array.

Finds a specific GenericMonitoringTool instance from the list of monitoring tools (a ToolHandleArray). Throws a FATAL warning if the object found is empty.

Parameters
namestring name of the desired tool
Returns
reference to the desired monitoring tool

Definition at line 168 of file AthMonitorAlgorithm.cxx.

168 {
169 // get the pointer to the tool, and check that it exists
170 auto idx = m_toolLookupMap.find(name);
171 if (ATH_LIKELY(idx != m_toolLookupMap.end())) {
172 return m_tools[idx->second];
173 }
174 else {
175 // treat empty tool handle case as in Monitored::Group
176 if (m_toolLookupMap.empty()) {
177 return m_dummy;
178 }
179
180 if (!isInitialized()) {
182 "It seems that the AthMonitorAlgorithm::initialize was not called "
183 "in derived class initialize method");
184 } else {
185 std::string available = std::accumulate(
186 m_toolLookupMap.begin(), m_toolLookupMap.end(), std::string(""),
187 [](const std::string& s, auto h) { return s + "," + h.first; });
188 ATH_MSG_FATAL("The tool " << name << " could not be found in the tool array of the "
189 << "monitoring algorithm " << m_name << ". This probably reflects a discrepancy between "
190 << "your python configuration and c++ filling code. Note: your available groups are {"
191 << available << "}.");
192 }
193 }
194 return m_dummy;
195}
#define ATH_MSG_FATAL(x)
#define ATH_LIKELY(x)
std::unordered_map< std::string, size_t > m_toolLookupMap
const ToolHandle< GenericMonitoringTool > m_dummy
ToolHandleArray< GenericMonitoringTool > m_tools
Array of Generic Monitoring Tools.

◆ getTrigDecisionTool()

const ToolHandle< Trig::TrigDecisionTool > & AthMonitorAlgorithm::getTrigDecisionTool ( ) const
inherited

Get the trigger decision tool member.

The trigger decision tool is used to check whether a specific trigger is passed by an event.

Returns
m_trigDecTool

Definition at line 198 of file AthMonitorAlgorithm.cxx.

198 {
199 return m_trigDecTool;
200}

◆ initialize()

StatusCode DQTDetSynchMonAlg::initialize ( )
overridevirtual

initialize

Returns
StatusCode

Reimplemented from AthMonitorAlgorithm.

Definition at line 54 of file DQTDetSynchMonAlg.cxx.

54 {
55//----------------------------------------------------------------------------------
56 ATH_CHECK( m_InDetTimeCollectionKeys.initialize() );
57 ATH_CHECK( m_LArFebHeaderContainerKey.initialize() );
58 ATH_CHECK( m_TileDigitsContainerKey.initialize() );
59 ATH_CHECK( m_RpcPadContainerKey.initialize() );
60 ATH_CHECK( m_fieldCacheCondObjInputKey.initialize() );
62}
#define ATH_CHECK
Evaluate an expression and check for errors.
virtual StatusCode initialize() override
initialize
StatusCode initialize(bool used=true)
StatusCode initialize(bool used=true)
If this object is used as a property, then this should be called during the initialize phase.

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

◆ parseList()

StatusCode AthMonitorAlgorithm::parseList ( const std::string & line,
std::vector< std::string > & result ) const
virtualinherited

Parse a string into a vector.

The input string is a single long string of all of the trigger names. It parses this string and turns it into a vector, where each element is one trigger or trigger category.

Parameters
lineThe input string.
resultThe parsed output vector of strings.
Returns
StatusCode

Definition at line 345 of file AthMonitorAlgorithm.cxx.

345 {
346 std::string item;
347 std::stringstream ss(line);
348
349 ATH_MSG_DEBUG( "AthMonitorAlgorithm::parseList()" );
350
351 while ( std::getline(ss, item, ',') ) {
352 std::stringstream iss(item); // remove whitespace
353 iss >> item;
354 result.push_back(item);
355 }
356
357 return StatusCode::SUCCESS;
358}
static Double_t ss

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

◆ trigChainsArePassed()

bool AthMonitorAlgorithm::trigChainsArePassed ( const std::vector< std::string > & vTrigNames) const
inherited

Check whether triggers are passed.

For the event, use the trigger decision tool to check that at least one of the triggers listed in the supplied vector is passed.

Parameters
vTrigNamesList of trigger names.
Returns
If empty input, default to true. If at least one trigger is specified, returns whether at least one trigger was passed.

Definition at line 203 of file AthMonitorAlgorithm.cxx.

203 {
204
205
206 // If no triggers were given, return true.
207 if (vTrigNames.empty()) return true;
208
209
210 // Trigger: Check if this Algorithm is being run as an Express Stream job.
211 // Events are entering the express stream are chosen randomly, and by chain,
212 // Hence an additional check should be aplied to see if the chain(s)
213 // monitored here are responsible for the event being selected for
214 // the express stream.
215
216 const auto group = m_trigDecTool->getChainGroup(vTrigNames);
218 const auto passedBits = m_trigDecTool->isPassedBits(group);
219 bool expressPass = passedBits & TrigDefs::Express_passed; //bitwise AND
220 if(!expressPass) {
221 return false;
222 }
223 }
224
225 // monitor the event if any of the chains in the chain group passes the event.
226 return group->isPassed();
227
228}
Gaudi::Property< bool > m_enforceExpressTriggers

◆ 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

◆ cfg

DQTDetSynchMonAlg.cfg = MainServicesCfg(flags)

Definition at line 167 of file DQTDetSynchMonAlg.py.

◆ file

str DQTDetSynchMonAlg.file = 'data16_13TeV.00311321.physics_Main.recon.AOD.r9264/AOD.11038520._000001.pool.root.1'

Definition at line 155 of file DQTDetSynchMonAlg.py.

◆ Files

DQTDetSynchMonAlg.Files

Definition at line 157 of file DQTDetSynchMonAlg.py.

◆ flags

DQTDetSynchMonAlg.flags = initConfigFlags()

Definition at line 156 of file DQTDetSynchMonAlg.py.

◆ HISTFileName

DQTDetSynchMonAlg.HISTFileName

Definition at line 159 of file DQTDetSynchMonAlg.py.

◆ m_dataType

AthMonitorAlgorithm::DataType_t AthMonitorAlgorithm::m_dataType
protectedinherited

Instance of the DataType_t enum.

Definition at line 356 of file AthMonitorAlgorithm.h.

◆ m_dataTypeStr

Gaudi::Property<std::string> AthMonitorAlgorithm::m_dataTypeStr {this,"DataType","userDefined"}
protectedinherited

DataType string pulled from the job option and converted to enum.

Definition at line 358 of file AthMonitorAlgorithm.h.

358{this,"DataType","userDefined"};

◆ m_defaultLBDuration

Gaudi::Property<float> AthMonitorAlgorithm::m_defaultLBDuration {this,"DefaultLBDuration",60.}
protectedinherited

Default duration of one lumi block.

Definition at line 365 of file AthMonitorAlgorithm.h.

365{this,"DefaultLBDuration",60.};

◆ m_detailLevel

Gaudi::Property<int> AthMonitorAlgorithm::m_detailLevel {this,"DetailLevel",0}
protectedinherited

Sets the level of detail used in the monitoring.

Definition at line 366 of file AthMonitorAlgorithm.h.

366{this,"DetailLevel",0};

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

std::vector<std::string> DQTDetSynchMonAlg::m_diffnamevec
private

Definition at line 67 of file DQTDetSynchMonAlg.h.

◆ m_doRPC

Gaudi::Property<bool> DQTDetSynchMonAlg::m_doRPC { this, "doRPC", true }
private

Definition at line 62 of file DQTDetSynchMonAlg.h.

62{ this, "doRPC", true };

◆ m_DQFilterTools

ToolHandleArray<IDQFilterTool> AthMonitorAlgorithm::m_DQFilterTools {this,"FilterTools",{}}
protectedinherited

Array of Data Quality filter tools.

Definition at line 346 of file AthMonitorAlgorithm.h.

346{this,"FilterTools",{}};

◆ m_dummy

const ToolHandle<GenericMonitoringTool> AthMonitorAlgorithm::m_dummy
privateinherited

Definition at line 374 of file AthMonitorAlgorithm.h.

◆ m_enforceExpressTriggers

Gaudi::Property<bool> AthMonitorAlgorithm::m_enforceExpressTriggers
privateinherited
Initial value:
{this,
"EnforceExpressTriggers", false,
"Requires that matched triggers made the event enter the express stream"}

Definition at line 377 of file AthMonitorAlgorithm.h.

377 {this,
378 "EnforceExpressTriggers", false,
379 "Requires that matched triggers made the event enter the express stream"};

◆ m_environment

AthMonitorAlgorithm::Environment_t AthMonitorAlgorithm::m_environment
protectedinherited

Instance of the Environment_t enum.

Definition at line 355 of file AthMonitorAlgorithm.h.

◆ m_environmentStr

Gaudi::Property<std::string> AthMonitorAlgorithm::m_environmentStr {this,"Environment","user"}
protectedinherited

Environment string pulled from the job option and converted to enum.

Definition at line 357 of file AthMonitorAlgorithm.h.

357{this,"Environment","user"};

◆ m_EventInfoKey

SG::ReadHandleKey<xAOD::EventInfo> AthMonitorAlgorithm::m_EventInfoKey {this,"EventInfoKey","EventInfo"}
protectedinherited

Key for retrieving EventInfo from StoreGate.

Definition at line 367 of file AthMonitorAlgorithm.h.

367{this,"EventInfoKey","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_fieldCacheCondObjInputKey

SG::ReadCondHandleKey<AtlasFieldCacheCondObj> DQTDetSynchMonAlg::m_fieldCacheCondObjInputKey
private
Initial value:
{
this,
"AtlasFieldCacheCondObj",
"fieldCondObj",
"Name of the Magnetic Field conditions object key"
}

Definition at line 78 of file DQTDetSynchMonAlg.h.

78 {
79 this,
80 "AtlasFieldCacheCondObj",
81 "fieldCondObj",
82 "Name of the Magnetic Field conditions object key"
83 };

◆ m_fileKey

Gaudi::Property<std::string> AthMonitorAlgorithm::m_fileKey {this,"FileKey",""}
protectedinherited

Internal Athena name for file.

Definition at line 363 of file AthMonitorAlgorithm.h.

363{this,"FileKey",""};

◆ m_InDetTimeCollectionKeys

SG::ReadHandleKeyArray<InDetTimeCollection> DQTDetSynchMonAlg::m_InDetTimeCollectionKeys { this, "InDetTimeCollectionKeys", {"TRT_BCID", "SCT_BCID", "PixelBCID", "TRT_LVL1ID", "SCT_LVL1ID", "PixelLVL1ID"} }
private

Definition at line 70 of file DQTDetSynchMonAlg.h.

71{ this, "InDetTimeCollectionKeys", {"TRT_BCID", "SCT_BCID", "PixelBCID", "TRT_LVL1ID", "SCT_LVL1ID", "PixelLVL1ID"} } ;

◆ m_LArFebHeaderContainerKey

SG::ReadHandleKey<LArFebHeaderContainer> DQTDetSynchMonAlg::m_LArFebHeaderContainerKey { this, "LArFebHeaderKey", "LArFebHeader" }
private

Definition at line 72 of file DQTDetSynchMonAlg.h.

73{ this, "LArFebHeaderKey", "LArFebHeader" };

◆ m_lbDurationDataKey

SG::ReadCondHandleKey<LBDurationCondData> AthMonitorAlgorithm::m_lbDurationDataKey {this,"LBDurationCondDataKey","LBDurationCondData","SG Key of LBDurationCondData object"}
protectedinherited

Definition at line 350 of file AthMonitorAlgorithm.h.

351{this,"LBDurationCondDataKey","LBDurationCondData","SG Key of LBDurationCondData object"};

◆ m_lumiDataKey

SG::ReadCondHandleKey<LuminosityCondData> AthMonitorAlgorithm::m_lumiDataKey {this,"LuminosityCondDataKey","LuminosityCondData","SG Key of LuminosityCondData object"}
protectedinherited

Definition at line 348 of file AthMonitorAlgorithm.h.

349{this,"LuminosityCondDataKey","LuminosityCondData","SG Key of LuminosityCondData object"};

◆ m_name

std::string AthMonitorAlgorithm::m_name
privateinherited

Definition at line 371 of file AthMonitorAlgorithm.h.

◆ m_RpcPadContainerKey

SG::ReadHandleKey<RpcPadContainer> DQTDetSynchMonAlg::m_RpcPadContainerKey { this, "RpcPadContainerKey", "RPCPAD" }
private

Definition at line 76 of file DQTDetSynchMonAlg.h.

77{ this, "RpcPadContainerKey", "RPCPAD" };

◆ m_run2Compat

Gaudi::Property<bool> DQTDetSynchMonAlg::m_run2Compat { this, "run2Compat", false, "Make histograms with Run 2 naming" }
private

Definition at line 63 of file DQTDetSynchMonAlg.h.

63{ this, "run2Compat", false, "Make histograms with Run 2 naming" };

◆ m_solenoidPositionX

Gaudi::Property<Int_t> DQTDetSynchMonAlg::m_solenoidPositionX { this, "SolenoidPositionX", 0 }
private

Definition at line 56 of file DQTDetSynchMonAlg.h.

56{ this, "SolenoidPositionX", 0 };

◆ m_solenoidPositionY

Gaudi::Property<Int_t> DQTDetSynchMonAlg::m_solenoidPositionY { this, "SolenoidPositionY", 10 }
private

Definition at line 57 of file DQTDetSynchMonAlg.h.

57{ this, "SolenoidPositionY", 10 };

◆ m_solenoidPositionZ

Gaudi::Property<Int_t> DQTDetSynchMonAlg::m_solenoidPositionZ { this, "SolenoidPositionZ", 0 }
private

Definition at line 58 of file DQTDetSynchMonAlg.h.

58{ this, "SolenoidPositionZ", 0 };

◆ m_TileDigitsContainerKey

SG::ReadHandleKey<TileDigitsContainer> DQTDetSynchMonAlg::m_TileDigitsContainerKey { this, "TileDigitsContainerKey", "TileDigitsFlt" }
private

Definition at line 74 of file DQTDetSynchMonAlg.h.

75{ this, "TileDigitsContainerKey", "TileDigitsFlt" };

◆ m_toolLookupMap

std::unordered_map<std::string, size_t> AthMonitorAlgorithm::m_toolLookupMap
privateinherited

Definition at line 372 of file AthMonitorAlgorithm.h.

◆ m_tools

ToolHandleArray<GenericMonitoringTool> AthMonitorAlgorithm::m_tools {this,"GMTools",{}}
protectedinherited

Array of Generic Monitoring Tools.

Definition at line 341 of file AthMonitorAlgorithm.h.

341{this,"GMTools",{}};

◆ m_toroidPositionX

Gaudi::Property<Int_t> DQTDetSynchMonAlg::m_toroidPositionX { this, "ToroidPositionX", 0 }
private

Definition at line 59 of file DQTDetSynchMonAlg.h.

59{ this, "ToroidPositionX", 0 };

◆ m_toroidPositionY

Gaudi::Property<Int_t> DQTDetSynchMonAlg::m_toroidPositionY { this, "ToroidPositionY", 6000 }
private

Definition at line 60 of file DQTDetSynchMonAlg.h.

60{ this, "ToroidPositionY", 6000 };

◆ m_toroidPositionZ

Gaudi::Property<Int_t> DQTDetSynchMonAlg::m_toroidPositionZ { this, "ToroidPositionZ", 0 }
private

Definition at line 61 of file DQTDetSynchMonAlg.h.

61{ this, "ToroidPositionZ", 0 };

◆ m_trigDecTool

PublicToolHandle<Trig::TrigDecisionTool> AthMonitorAlgorithm::m_trigDecTool
protectedinherited

Tool to tell whether a specific trigger is passed.

Definition at line 345 of file AthMonitorAlgorithm.h.

◆ m_triggerChainString

Gaudi::Property<std::string> AthMonitorAlgorithm::m_triggerChainString {this,"TriggerChain",""}
protectedinherited

Trigger chain string pulled from the job option and parsed into a vector.

Definition at line 360 of file AthMonitorAlgorithm.h.

360{this,"TriggerChain",""};

◆ m_trigLiveFractionDataKey

SG::ReadCondHandleKey<TrigLiveFractionCondData> AthMonitorAlgorithm::m_trigLiveFractionDataKey {this,"TrigLiveFractionCondDataKey","TrigLiveFractionCondData", "SG Key of TrigLiveFractionCondData object"}
protectedinherited

Definition at line 352 of file AthMonitorAlgorithm.h.

353{this,"TrigLiveFractionCondDataKey","TrigLiveFractionCondData", "SG Key of TrigLiveFractionCondData object"};

◆ m_useLumi

Gaudi::Property<bool> AthMonitorAlgorithm::m_useLumi {this,"EnableLumi",false}
protectedinherited

Allows use of various luminosity functions.

Definition at line 364 of file AthMonitorAlgorithm.h.

364{this,"EnableLumi",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.

◆ m_vTrigChainNames

std::vector<std::string> AthMonitorAlgorithm::m_vTrigChainNames
protectedinherited

Vector of trigger chain names parsed from trigger chain string.

Definition at line 361 of file AthMonitorAlgorithm.h.

◆ NDETS

const int DQTDetSynchMonAlg::NDETS = 7
staticprivate

Definition at line 66 of file DQTDetSynchMonAlg.h.

◆ nightly

str DQTDetSynchMonAlg.nightly = '/cvmfs/atlas-nightlies.cern.ch/repo/data/data-art/CommonInputs/'

Definition at line 154 of file DQTDetSynchMonAlg.py.

◆ withDetails

DQTDetSynchMonAlg.withDetails

Definition at line 176 of file DQTDetSynchMonAlg.py.


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