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

Class for Tile raw channel time based monitoring. More...

#include <TileRawChannelTimeMonitorAlgorithm.h>

Inheritance diagram for TileRawChannelTimeMonitorAlgorithm:

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

virtual ~TileRawChannelTimeMonitorAlgorithm ()=default
virtual StatusCode initialize () override
 initialize
virtual StatusCode fillHistograms (const EventContext &ctx) const override
 adds event to the monitoring histograms
 AthMonitorAlgorithm (const std::string &name, ISvcLocator *pSvcLocator)
 Constructor.
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

 flags = initConfigFlags()
str inputDirectory = '/cvmfs/atlas-nightlies.cern.ch/repo/data/data-art/TileByteStream/TileByteStream-02-00-00'
str inputFile = 'data18_tilecomm.00363899.calibration_tile.daq.RAW._lb0000._TileREB-ROS._0005-200ev.data'
 Files
 AtlasVersion
 GlobalTag
 HISTFileName
 useTrigger
 enableLumiAccess
 RunType
 doFit
 correctTime
 doOverflowFit
 BestPhaseFromCOOL
 NoiseFilter
 MaxEvents
 cfg = MainServicesCfg(flags)
 withDetails
 True
 summariseProps
 sc = cfg.run()

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

enum  Signal { SIGNAL_NOT_EXPECTED = 0 , SIGNAL_EXPECTED , SIGNAL_PRESENT }
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< bool > m_checkDCS {this, "CheckDCS", false, "Check Tile DCS status"}
Gaudi::Property< std::vector< unsigned int > > m_triggerTypes
Gaudi::Property< std::vector< double > > m_energyThresholds
Gaudi::Property< std::vector< double > > m_partitionTimeCorrection
Gaudi::Property< std::vector< std::pair< int, int > > > m_partitionTimeDifferencePairs
Gaudi::Property< int > m_fakeTime
Gaudi::Property< bool > m_fillFakeTime
Gaudi::Property< std::vector< int > > m_amplitudeFragIDs
SG::ReadHandleKey< TileDQstatusm_DQstatusKey
SG::ReadHandleKey< TileRawChannelContainerm_rawChannelContainerKey
SG::ReadCondHandleKey< TileDCSStatem_DCSStateKey
 Name of TileDCSState object in condition store.
SG::ReadCondHandleKey< TileBadChannelsm_badChannelsKey
 Name of TileBadChannels in condition store.
SG::ReadCondHandleKey< TileEMScalem_emScaleKey
 Name of TileEMScale in condition store.
ServiceHandle< TileCablingSvcm_cablingSvc
 Name of Tile cabling service.
const TileHWIDm_tileHWID {nullptr}
const TileCablingServicem_cabling {nullptr}
std::vector< int > m_timeGroups
std::vector< int > m_uncorrTimeGroups
std::vector< int > m_timeLBGroups
std::vector< int > m_timeDiffLBGroups
std::vector< std::vector< std::vector< int > > > m_digiTimeLBGroups
std::vector< int > m_amplitudeGroups
std::map< std::string, int > m_amplitudeVsLBGroups
std::array< bool, TileCalibUtils::MAX_DRAWERIDXm_amplitudeMonitoredDrawerIdx {}
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 constexpr int s_nDigitizers = 8

Detailed Description

Class for Tile raw channel time based monitoring.

Definition at line 29 of file TileRawChannelTimeMonitorAlgorithm.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 };

◆ Signal

enum TileRawChannelTimeMonitorAlgorithm::Signal
private
Enumerator
SIGNAL_NOT_EXPECTED 
SIGNAL_EXPECTED 
SIGNAL_PRESENT 

Definition at line 108 of file TileRawChannelTimeMonitorAlgorithm.h.

108{SIGNAL_NOT_EXPECTED = 0, SIGNAL_EXPECTED, SIGNAL_PRESENT};

Constructor & Destructor Documentation

◆ ~TileRawChannelTimeMonitorAlgorithm()

virtual TileRawChannelTimeMonitorAlgorithm::~TileRawChannelTimeMonitorAlgorithm ( )
virtualdefault

Member Function Documentation

◆ AthMonitorAlgorithm()

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

Constructor.

Definition at line 45 of file AthMonitorAlgorithm.cxx.

9:AthReentrantAlgorithm(name,pSvcLocator)
10 // Put this here rather than in the header to allow forward-declaring
11 // TrigDecisionTool.
12,m_trigDecTool{this, "TrigDecisionTool",""}
13,m_environment(Environment_t::user)
14,m_dataType(DataType_t::userDefined)
15,m_vTrigChainNames({})
16{}
An algorithm that can be simultaneously executed in multiple threads.

◆ 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 TileRawChannelTimeMonitorAlgorithm::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 73 of file TileRawChannelTimeMonitorAlgorithm.cxx.

73 {
74
75 using Tile = TileCalibUtils;
76
77 // In case you want to measure the execution time
78 auto timer = Monitored::Timer("TIME_execute");
79
80 const xAOD::EventInfo* eventInfo = GetEventInfo(ctx).get();
81
82 unsigned int lvl1TriggerType = eventInfo->level1TriggerType();
83 if (!m_triggerTypes.empty()
84 && std::find( m_triggerTypes.begin(), m_triggerTypes.end(), lvl1TriggerType) == m_triggerTypes.end()) {
85 fill("TileRawChanTimeMonExecuteTime", timer);
86 return StatusCode::SUCCESS;
87 }
88
89 unsigned int lumiBlock = eventInfo->lumiBlock();
90 auto monLumiBlock = Monitored::Scalar<double>("lumiBlock", lumiBlock);
91
92 std::vector<int> drawers[Tile::MAX_ROS - 1];
93 std::vector<int> channels[Tile::MAX_ROS - 1];
94 std::vector<double> channelTimes[Tile::MAX_ROS - 1];
95 std::vector<double> channelUncorrectedTimes[Tile::MAX_ROS - 1];
96 std::vector<double> channelAmplitudes[Tile::MAX_ROS - 1];
97
98 const TileDQstatus* dqStatus = SG::makeHandle(m_DQstatusKey, ctx).get();
99 const TileDCSState* dcsState = m_checkDCS ? SG::ReadCondHandle(m_DCSStateKey, ctx).cptr() : nullptr;
100
101 SG::ReadCondHandle<TileEMScale> emScale(m_emScaleKey, ctx);
102 ATH_CHECK( emScale.isValid() );
103
104 SG::ReadCondHandle<TileBadChannels> badChannels(m_badChannelsKey, ctx);
105
106 SG::ReadHandle<TileRawChannelContainer> rawChannelContainer(m_rawChannelContainerKey, ctx);
107 ATH_CHECK( rawChannelContainer.isValid() );
108
109 TileRawChannelUnit::UNIT rawChannelUnit = rawChannelContainer->get_unit();
110
111 static const int channel2digitizer[48] = {7, 7, 7, 7, 7, 7,
112 6, 6, 6, 6, 6, 6,
113 5, 5, 5, 5, 5, 5,
114 4, 4, 4, 4, 4, 4,
115 3, 3, 3, 3, 3, 3,
116 2, 2, 2, 2, 2, 2,
117 1, 1, 1, 1, 1, 1,
118 0, 0, 0, 0, 0, 0};
119
120 int signalState[Tile::MAX_ROS - 1][Tile::MAX_DRAWER][s_nDigitizers] = {{{SIGNAL_NOT_EXPECTED}}};
121
122 for (const TileRawChannelCollection* rawChannelCollection : *rawChannelContainer) {
123 if (rawChannelCollection->empty() ) continue;
124
125 HWIdentifier adc_id = rawChannelCollection->front()->adc_HWID();
126 int ros = m_tileHWID->ros(adc_id);
127 int drawer = m_tileHWID->drawer(adc_id);
128 unsigned int drawerIdx = TileCalibUtils::getDrawerIdx(ros, drawer);
129 int partition = ros - 1;
130 std::string moduleName = TileCalibUtils::getDrawerString(ros, drawer);
131
132 for (const TileRawChannel* rawChannel : *rawChannelCollection) {
133
134 adc_id = rawChannel->adc_HWID();
135 int channel = m_tileHWID->channel(adc_id);
136 int adc = m_tileHWID->adc(adc_id);
137
138 if (m_cabling->isDisconnected(ros, drawer, channel)) {
139 ATH_MSG_VERBOSE(m_tileHWID->to_string(adc_id) << ": channlel is disconnected => skipping!");
140 continue;
141 }
142
143 if (!(dqStatus->isAdcDQgood(ros, drawer, channel, adc))) {
144 ATH_MSG_VERBOSE(m_tileHWID->to_string(adc_id) << ": DQ is BAD => skipping!");
145 continue;
146 }
147
148 if (m_checkDCS && dcsState->isStatusBad(ros, drawer, channel)) {
149 ATH_MSG_VERBOSE(m_tileHWID->to_string(adc_id) << ": DCS is Bad => skipping!");
150 continue;
151 }
152
153 TileBchStatus status = badChannels->getAdcStatus(adc_id);
154 if (status.isBad() || status.isBadTiming()) {
155 ATH_MSG_VERBOSE(m_tileHWID->to_string(adc_id) << ": Status or Timing is BAD => skipping!");
156 continue;
157 }
158
159 if (signalState[partition][drawer][channel2digitizer[channel]] != SIGNAL_PRESENT) {
160 signalState[partition][drawer][channel2digitizer[channel]] = SIGNAL_EXPECTED;
161 }
162
163 if (rawChannel->amplitude() < m_energyThresholds[adc]) {
164 ATH_MSG_VERBOSE(m_tileHWID->to_string(adc_id) << ": Energy is below threshold => skipping!");
165 continue;
166 }
167
168 signalState[partition][drawer][channel2digitizer[channel]] = SIGNAL_PRESENT;
169
170 drawers[partition].push_back(drawer);
171 channels[partition].push_back(channel);
172 channelTimes[partition].push_back(rawChannel->time());
173 channelUncorrectedTimes[partition].push_back(rawChannel->uncorrTime());
174
175 float amplitude = rawChannel->amplitude();
176 amplitude = emScale->calibrateChannel(drawerIdx, channel, adc, amplitude, rawChannelUnit, TileRawChannelUnit::PicoCoulombs);
177 channelAmplitudes[partition].push_back(amplitude);
178
179 if (m_amplitudeMonitoredDrawerIdx[drawerIdx]) {
180 auto monAmplitude = Monitored::Scalar<double>("amplitude_" + std::to_string(channel), amplitude);
181 fill(m_tools[m_amplitudeVsLBGroups.at(moduleName)], monLumiBlock, monAmplitude);
182 }
183 }
184 }
185
186 float partitionTime[4] = {0};
187
188 for (unsigned int partition = 0; partition < Tile::MAX_ROS - 1; ++partition) {
189 int nChannels = 0;
190 double averagePartitionTime = 0.0;
191 std::vector<double>& times = channelTimes[partition];
192
193 for (unsigned int channelIdx = 0; channelIdx < channels[partition].size(); ++ channelIdx) {
194 int channel = channels[partition][channelIdx];
195 if ( (partition > 1) // EB, exclude some channels (most likely single PMT) from calculating average time
196 && (channel < 6 || channel == 12 || channel == 13 || channel == 18 || channel == 19) ) continue;
197
198 averagePartitionTime += times[channelIdx];
199 ++nChannels;
200 }
201
202 if (nChannels > 0) {
203 averagePartitionTime /= nChannels;
204 partitionTime[partition] = averagePartitionTime - m_partitionTimeCorrection[partition];
205
206 std::transform(times.begin(), times.end(), times.begin(),
207 [averagePartitionTime] (double time) {return time - averagePartitionTime;});
208 }
209 }
210
211
212 for (unsigned int partition = 0; partition < Tile::MAX_ROS - 1; ++partition) {
213 if (!channelTimes[partition].empty()) {
214 auto monModule = Monitored::Collection("module", drawers[partition]);
215 auto monChannel = Monitored::Collection("channel", channels[partition]);
216 auto monTime = Monitored::Collection("time", channelTimes[partition]);
217 fill(m_tools[m_timeGroups[partition]], monModule, monChannel, monTime);
218
219 auto monUncorrTime = Monitored::Collection("time", channelUncorrectedTimes[partition]);
220 fill(m_tools[m_uncorrTimeGroups[partition]], monModule, monChannel, monUncorrTime);
221
222 auto monPartitionTime = Monitored::Scalar<float>("time", partitionTime[partition]);
223 fill(m_tools[m_timeLBGroups[partition]], monLumiBlock, monPartitionTime);
224
225 auto monAmplitude = Monitored::Collection("amplitude", channelAmplitudes[partition]);
226 fill(m_tools[m_amplitudeGroups[partition]], monModule, monChannel, monAmplitude);
227
228 for (unsigned int channelIdx = 0; channelIdx < channels[partition].size(); ++ channelIdx) {
229 int drawer = drawers[partition][channelIdx];
230 int digitizer = channel2digitizer[ channels[partition][channelIdx] ];
231 auto monTime = Monitored::Scalar<double>("time", channelTimes[partition][channelIdx]);
232 fill(m_tools[m_digiTimeLBGroups[partition][drawer][digitizer]], monLumiBlock, monTime);
233 }
234
235 if (m_fillFakeTime) {
236 for (unsigned int drawer = 0; drawer < Tile::MAX_DRAWER; ++drawer) {
237 for (unsigned int digitizer = 0; digitizer < s_nDigitizers; ++digitizer) {
238 if (signalState[partition][drawer][digitizer] == SIGNAL_EXPECTED) {
239 auto monTime = Monitored::Scalar<double>("time", m_fakeTime);
240 fill(m_tools[m_digiTimeLBGroups[partition][drawer][digitizer]], monLumiBlock, monTime);
241 }
242 }
243 }
244 }
245 }
246 }
247
248 for (unsigned int pairIdx = 0; pairIdx < m_partitionTimeDifferencePairs.size(); ++pairIdx) {
249 const std::pair<int, int>& partitionPair = m_partitionTimeDifferencePairs[pairIdx];
250 int partition1 = partitionPair.first;
251 int partition2 = partitionPair.second;
252 auto monTime = Monitored::Scalar<double>("time", partitionTime[partition1] - partitionTime[partition2]);
253 fill(m_tools[m_timeDiffLBGroups[pairIdx]], monLumiBlock, monTime);
254 }
255
256 fill("TileRawChanTimeMonExecuteTime", timer);
257
258 return StatusCode::SUCCESS;
259}
#define ATH_CHECK
Evaluate an expression and check for errors.
#define ATH_MSG_VERBOSE(x)
static const Attributes_t empty
Declare a monitored scalar variable.
A monitored timer.
const_pointer_type cptr()
bool isDisconnected(int ros, int drawer, int channel) const
Static class providing several utility functions and constants.
static std::string getDrawerString(unsigned int ros, unsigned int drawer)
Return the drawer name, e.g.
static unsigned int getDrawerIdx(unsigned int ros, unsigned int drawer)
Returns a drawer hash.
Condition object to keep Tile DCS status from DB.
bool isStatusBad(unsigned int ros, unsigned int drawer) const
Return true if given Tile drawer considered as bad by summary drawer states per LVPS otherwise return...
Class that holds Data Quality fragment information and provides functions to extract the data quality...
bool isAdcDQgood(int partition, int drawer, int ch, int gain) const
returns status of single ADC returns False if there are any errors
int channel(const HWIdentifier &id) const
extract channel field from HW identifier
Definition TileHWID.h:189
int adc(const HWIdentifier &id) const
extract adc field from HW identifier
Definition TileHWID.h:193
int drawer(const HWIdentifier &id) const
extract drawer field from HW identifier
Definition TileHWID.h:171
std::string to_string(const HWIdentifier &id, int level=0) const
extract all fields from HW identifier HWIdentifier get_all_fields ( const HWIdentifier & id,...
Definition TileHWID.cxx:50
int ros(const HWIdentifier &id) const
extract ros field from HW identifier
Definition TileHWID.h:167
Gaudi::Property< std::vector< std::pair< int, int > > > m_partitionTimeDifferencePairs
Gaudi::Property< std::vector< double > > m_partitionTimeCorrection
uint32_t lumiBlock() const
The current event's luminosity block number.
uint16_t level1TriggerType() const
The Level-1 trigger type.
ValuesCollection< T > Collection(std::string name, const T &collection)
Declare a monitored (double-convertible) collection.
unsigned int constexpr nChannels
Definition RPDUtils.h:23
SG::ReadCondHandle< T > makeHandle(const SG::ReadCondHandleKey< T > &key, const EventContext &ctx=Gaudi::Hive::currentContext())
status
Definition merge.py:16
EventInfo_v1 EventInfo
Definition of the latest event info version.
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

◆ 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 TileRawChannelTimeMonitorAlgorithm::initialize ( )
overridevirtual

initialize

Returns
StatusCode

Reimplemented from AthMonitorAlgorithm.

Definition at line 12 of file TileRawChannelTimeMonitorAlgorithm.cxx.

12 {
13
14 ATH_MSG_DEBUG("in initialize()");
15
16 // initialize superclass
18
19 ATH_CHECK( detStore()->retrieve(m_tileHWID) );
20
21 ATH_CHECK( m_cablingSvc.retrieve() );
22 m_cabling = m_cablingSvc->cablingService();
23
24 ATH_CHECK( m_rawChannelContainerKey.initialize() );
25 ATH_CHECK( m_DQstatusKey.initialize() );
26 ATH_CHECK( m_badChannelsKey.initialize() );
27 ATH_CHECK( m_DCSStateKey.initialize(m_checkDCS) );
28 ATH_CHECK( m_emScaleKey.initialize() );
29
30 using Tile = TileCalibUtils;
31 using namespace Monitored;
32
33 m_timeGroups = buildToolMap<int>(m_tools, "TileAverageTime", Tile::MAX_ROS - 1);
34 m_uncorrTimeGroups = buildToolMap<int>(m_tools, "TileAverageUncorrectedTime", Tile::MAX_ROS - 1);
35 m_timeLBGroups = buildToolMap<int>(m_tools, "TileAverageTimeLB", Tile::MAX_ROS - 1);
36 m_timeDiffLBGroups = buildToolMap<int>(m_tools, "TileAverageTimeDifferenceLB", m_partitionTimeDifferencePairs.size());
37 m_digiTimeLBGroups = buildToolMap<std::vector<std::vector<int>>>(m_tools, "TileDigitizerTimeLB",
38 Tile::MAX_ROS - 1, Tile::MAX_DRAWER, s_nDigitizers);
39
40 m_amplitudeGroups = buildToolMap<int>(m_tools, "TileAverageAmplitude", Tile::MAX_ROS - 1);
41
42 std::vector<std::string> modules;
43 for (int fragID : m_amplitudeFragIDs) {
44 unsigned int ros = fragID >> 8;
45 unsigned int drawer = fragID & 0x3F;
46 modules.push_back(TileCalibUtils::getDrawerString(ros, drawer));
47 m_amplitudeMonitoredDrawerIdx[TileCalibUtils::getDrawerIdx(ros, drawer)] = true;
48 }
49
50 std::ostringstream os;
51 if ( m_amplitudeFragIDs.size() != 0) {
52 std::sort(m_amplitudeFragIDs.begin(), m_amplitudeFragIDs.end());
53 for (int fragID : m_amplitudeFragIDs) {
54 unsigned int ros = fragID >> 8;
55 unsigned int drawer = fragID & 0x3F;
56 std::string module = TileCalibUtils::getDrawerString(ros, drawer);
57 os << " " << module << "/0x" << std::hex << fragID << std::dec;
58 }
59 } else {
60 os << "NONE";
61 }
62
63 ATH_MSG_INFO("Monitored amplitude vs LB for modules/frag ID:" << os.str());
64
65 if (!modules.empty()) {
66 m_amplitudeVsLBGroups = buildToolMap<int>(m_tools, "TileAmplitudeVsLB", modules);
67 }
68
69 return StatusCode::SUCCESS;
70}
#define ATH_MSG_INFO(x)
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.
Generic monitoring tool for athena components.
std::vector< V > buildToolMap(const ToolHandleArray< GenericMonitoringTool > &tools, const std::string &baseName, int nHist)
Builds an array of indices (base case)
void sort(typename DataModel_detail::iterator< DVL > beg, typename DataModel_detail::iterator< DVL > end)
Specialization of sort for DataVector/List.

◆ 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}
#define ATH_MSG_ERROR(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.

◆ 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

◆ AtlasVersion

TileRawChannelTimeMonitorAlgorithm.AtlasVersion

Definition at line 199 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ BestPhaseFromCOOL

TileRawChannelTimeMonitorAlgorithm.BestPhaseFromCOOL

Definition at line 209 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ cfg

TileRawChannelTimeMonitorAlgorithm.cfg = MainServicesCfg(flags)

Definition at line 218 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ correctTime

TileRawChannelTimeMonitorAlgorithm.correctTime

Definition at line 207 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ doFit

TileRawChannelTimeMonitorAlgorithm.doFit

Definition at line 206 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ doOverflowFit

TileRawChannelTimeMonitorAlgorithm.doOverflowFit

Definition at line 208 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ enableLumiAccess

TileRawChannelTimeMonitorAlgorithm.enableLumiAccess

Definition at line 203 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ Files

TileRawChannelTimeMonitorAlgorithm.Files

Definition at line 198 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ flags

TileRawChannelTimeMonitorAlgorithm.flags = initConfigFlags()

Definition at line 195 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ GlobalTag

TileRawChannelTimeMonitorAlgorithm.GlobalTag

Definition at line 200 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ HISTFileName

TileRawChannelTimeMonitorAlgorithm.HISTFileName

Definition at line 201 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ inputDirectory

str TileRawChannelTimeMonitorAlgorithm.inputDirectory = '/cvmfs/atlas-nightlies.cern.ch/repo/data/data-art/TileByteStream/TileByteStream-02-00-00'

Definition at line 196 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ inputFile

str TileRawChannelTimeMonitorAlgorithm.inputFile = 'data18_tilecomm.00363899.calibration_tile.daq.RAW._lb0000._TileREB-ROS._0005-200ev.data'

Definition at line 197 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ m_amplitudeFragIDs

Gaudi::Property<std::vector<int> > TileRawChannelTimeMonitorAlgorithm::m_amplitudeFragIDs
private
Initial value:
{this,
"AmplitudeFragIDs", {}, "Tile Frag IDs of modules to fill histograms with amplitude vs LB."}

Definition at line 61 of file TileRawChannelTimeMonitorAlgorithm.h.

61 {this,
62 "AmplitudeFragIDs", {}, "Tile Frag IDs of modules to fill histograms with amplitude vs LB."};

◆ m_amplitudeGroups

std::vector<int> TileRawChannelTimeMonitorAlgorithm::m_amplitudeGroups
private

Definition at line 102 of file TileRawChannelTimeMonitorAlgorithm.h.

◆ m_amplitudeMonitoredDrawerIdx

std::array<bool, TileCalibUtils::MAX_DRAWERIDX> TileRawChannelTimeMonitorAlgorithm::m_amplitudeMonitoredDrawerIdx {}
private

Definition at line 105 of file TileRawChannelTimeMonitorAlgorithm.h.

105{};

◆ m_amplitudeVsLBGroups

std::map<std::string, int> TileRawChannelTimeMonitorAlgorithm::m_amplitudeVsLBGroups
private

Definition at line 103 of file TileRawChannelTimeMonitorAlgorithm.h.

◆ m_badChannelsKey

SG::ReadCondHandleKey<TileBadChannels> TileRawChannelTimeMonitorAlgorithm::m_badChannelsKey
private
Initial value:
{this,
"TileBadChannels", "TileBadChannels", "Input Tile bad channel status"}

Name of TileBadChannels in condition store.

Definition at line 79 of file TileRawChannelTimeMonitorAlgorithm.h.

79 {this,
80 "TileBadChannels", "TileBadChannels", "Input Tile bad channel status"};

◆ m_cabling

const TileCablingService* TileRawChannelTimeMonitorAlgorithm::m_cabling {nullptr}
private

Definition at line 95 of file TileRawChannelTimeMonitorAlgorithm.h.

95{nullptr};

◆ m_cablingSvc

ServiceHandle<TileCablingSvc> TileRawChannelTimeMonitorAlgorithm::m_cablingSvc
private
Initial value:
{ this,
"TileCablingSvc", "TileCablingSvc", "The Tile cabling service"}

Name of Tile cabling service.

Definition at line 91 of file TileRawChannelTimeMonitorAlgorithm.h.

91 { this,
92 "TileCablingSvc", "TileCablingSvc", "The Tile cabling service"};

◆ m_checkDCS

Gaudi::Property<bool> TileRawChannelTimeMonitorAlgorithm::m_checkDCS {this, "CheckDCS", false, "Check Tile DCS status"}
private

Definition at line 40 of file TileRawChannelTimeMonitorAlgorithm.h.

40{this, "CheckDCS", false, "Check Tile DCS status"};

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

SG::ReadCondHandleKey<TileDCSState> TileRawChannelTimeMonitorAlgorithm::m_DCSStateKey
private
Initial value:
{this,
"TileDCS", "TileDCS", "Input Tile DCS status"}

Name of TileDCSState object in condition store.

Definition at line 73 of file TileRawChannelTimeMonitorAlgorithm.h.

73 {this,
74 "TileDCS", "TileDCS", "Input Tile DCS status"};

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

std::vector<std::vector<std::vector<int> > > TileRawChannelTimeMonitorAlgorithm::m_digiTimeLBGroups
private

Definition at line 101 of file TileRawChannelTimeMonitorAlgorithm.h.

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

SG::ReadHandleKey<TileDQstatus> TileRawChannelTimeMonitorAlgorithm::m_DQstatusKey
private
Initial value:
{this,
"TileDQstatus", "TileDQstatus", "Tile DQ status name"}

Definition at line 64 of file TileRawChannelTimeMonitorAlgorithm.h.

64 {this,
65 "TileDQstatus", "TileDQstatus", "Tile DQ status name"};

◆ m_dummy

const ToolHandle<GenericMonitoringTool> AthMonitorAlgorithm::m_dummy
privateinherited

Definition at line 374 of file AthMonitorAlgorithm.h.

◆ m_emScaleKey

SG::ReadCondHandleKey<TileEMScale> TileRawChannelTimeMonitorAlgorithm::m_emScaleKey
private
Initial value:
{this,
"TileEMScale", "TileEMScale", "Input Tile EMS calibration constants"}

Name of TileEMScale in condition store.

Definition at line 85 of file TileRawChannelTimeMonitorAlgorithm.h.

85 {this,
86 "TileEMScale", "TileEMScale", "Input Tile EMS calibration constants"};

◆ m_energyThresholds

Gaudi::Property<std::vector<double> > TileRawChannelTimeMonitorAlgorithm::m_energyThresholds
private
Initial value:
{this,
"EnergyThresholds", {10, 40}, "Energy thresholds [LG, HG]"}

Definition at line 45 of file TileRawChannelTimeMonitorAlgorithm.h.

45 {this,
46 "EnergyThresholds", {10, 40}, "Energy thresholds [LG, HG]"};

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

Gaudi::Property<int> TileRawChannelTimeMonitorAlgorithm::m_fakeTime
private
Initial value:
{this,
"FakeTime", -100, "Fake time to fill if there is no signal, but it's expected"}

Definition at line 55 of file TileRawChannelTimeMonitorAlgorithm.h.

55 {this,
56 "FakeTime", -100, "Fake time to fill if there is no signal, but it's expected"};

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

Gaudi::Property<bool> TileRawChannelTimeMonitorAlgorithm::m_fillFakeTime
private
Initial value:
{this,
"FillFakeTime", true, "File fake time to fill if there is no signal, but it's expected"}

Definition at line 58 of file TileRawChannelTimeMonitorAlgorithm.h.

58 {this,
59 "FillFakeTime", true, "File fake time to fill if there is no signal, but it's expected"};

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

Gaudi::Property<std::vector<double> > TileRawChannelTimeMonitorAlgorithm::m_partitionTimeCorrection
private
Initial value:
{this,
"PartitionTimeCorrections", {-15.18, -15.37, 47.65, 47.42},
"Partition time corrections [LBA, LBC, EBA, EBC]"}

Definition at line 48 of file TileRawChannelTimeMonitorAlgorithm.h.

48 {this,
49 "PartitionTimeCorrections", {-15.18, -15.37, 47.65, 47.42},
50 "Partition time corrections [LBA, LBC, EBA, EBC]"};

◆ m_partitionTimeDifferencePairs

Gaudi::Property<std::vector<std::pair<int, int> > > TileRawChannelTimeMonitorAlgorithm::m_partitionTimeDifferencePairs
private
Initial value:
{this,
"PartitionTimeDiffferncePairs", {}, "Partition (ROS - 1) pairs to monitor time differnce"}

Definition at line 52 of file TileRawChannelTimeMonitorAlgorithm.h.

52 {this,
53 "PartitionTimeDiffferncePairs", {}, "Partition (ROS - 1) pairs to monitor time differnce"};

◆ m_rawChannelContainerKey

SG::ReadHandleKey<TileRawChannelContainer> TileRawChannelTimeMonitorAlgorithm::m_rawChannelContainerKey
private
Initial value:
{this,
"TileRawChannelContainer", "TileRawChannelFit", "Input Tile raw channel container key"}

Definition at line 67 of file TileRawChannelTimeMonitorAlgorithm.h.

67 {this,
68 "TileRawChannelContainer", "TileRawChannelFit", "Input Tile raw channel container key"};

◆ m_tileHWID

const TileHWID* TileRawChannelTimeMonitorAlgorithm::m_tileHWID {nullptr}
private

Definition at line 94 of file TileRawChannelTimeMonitorAlgorithm.h.

94{nullptr};

◆ m_timeDiffLBGroups

std::vector<int> TileRawChannelTimeMonitorAlgorithm::m_timeDiffLBGroups
private

Definition at line 100 of file TileRawChannelTimeMonitorAlgorithm.h.

◆ m_timeGroups

std::vector<int> TileRawChannelTimeMonitorAlgorithm::m_timeGroups
private

Definition at line 97 of file TileRawChannelTimeMonitorAlgorithm.h.

◆ m_timeLBGroups

std::vector<int> TileRawChannelTimeMonitorAlgorithm::m_timeLBGroups
private

Definition at line 99 of file TileRawChannelTimeMonitorAlgorithm.h.

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

Gaudi::Property<std::vector<unsigned int> > TileRawChannelTimeMonitorAlgorithm::m_triggerTypes
private
Initial value:
{this,
"TriggerTypes", {}, "Given trigger types only events with these TTs will be used, otherwise all"}

Definition at line 42 of file TileRawChannelTimeMonitorAlgorithm.h.

42 {this,
43 "TriggerTypes", {}, "Given trigger types only events with these TTs will be used, otherwise all"};

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

std::vector<int> TileRawChannelTimeMonitorAlgorithm::m_uncorrTimeGroups
private

Definition at line 98 of file TileRawChannelTimeMonitorAlgorithm.h.

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

◆ MaxEvents

TileRawChannelTimeMonitorAlgorithm.MaxEvents

Definition at line 211 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ NoiseFilter

TileRawChannelTimeMonitorAlgorithm.NoiseFilter

Definition at line 210 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ RunType

TileRawChannelTimeMonitorAlgorithm.RunType

Definition at line 205 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ s_nDigitizers

int TileRawChannelTimeMonitorAlgorithm::s_nDigitizers = 8
staticconstexprprivate

Definition at line 107 of file TileRawChannelTimeMonitorAlgorithm.h.

◆ sc

TileRawChannelTimeMonitorAlgorithm.sc = cfg.run()

Definition at line 233 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ summariseProps

TileRawChannelTimeMonitorAlgorithm.summariseProps

Definition at line 228 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ True

TileRawChannelTimeMonitorAlgorithm.True

Definition at line 228 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ useTrigger

TileRawChannelTimeMonitorAlgorithm.useTrigger

Definition at line 202 of file TileRawChannelTimeMonitorAlgorithm.py.

◆ withDetails

TileRawChannelTimeMonitorAlgorithm.withDetails

Definition at line 228 of file TileRawChannelTimeMonitorAlgorithm.py.


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