![Logo](../../ATLAS-Logo-Square-Blue-RGB.png) |
ATLAS Offline Software
|
#include <NswDcsDbAlg.h>
|
virtual | ~NswDcsDbAlg ()=default |
|
virtual StatusCode | initialize () override |
|
virtual StatusCode | execute (const EventContext &) const override |
|
virtual bool | isReEntrant () const override |
|
| AthReentrantAlgorithm (const std::string &name, ISvcLocator *pSvcLocator) |
| Constructor with parameters: More...
|
|
virtual StatusCode | sysInitialize () override |
| Override sysInitialize. More...
|
|
virtual bool | isClonable () const override |
| Specify if the algorithm is clonable. More...
|
|
virtual unsigned int | cardinality () const override |
| Cardinality (Maximum number of clones that can exist) special value 0 means that algorithm is reentrant. More...
|
|
virtual StatusCode | sysExecute (const EventContext &ctx) override |
| Execute an algorithm. More...
|
|
virtual const DataObjIDColl & | extraOutputDeps () const override |
| Return the list of extra output dependencies. More...
|
|
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 . More...
|
|
const ServiceHandle< StoreGateSvc > & | evtStore () const |
| The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc . More...
|
|
const ServiceHandle< StoreGateSvc > & | detStore () const |
| The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc . More...
|
|
virtual StatusCode | sysStart () override |
| Handle START transition. More...
|
|
virtual std::vector< Gaudi::DataHandle * > | inputHandles () const override |
| Return this algorithm's input handles. More...
|
|
virtual std::vector< Gaudi::DataHandle * > | outputHandles () const override |
| Return this algorithm's output handles. More...
|
|
Gaudi::Details::PropertyBase & | declareProperty (Gaudi::Property< T > &t) |
|
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, SG::VarHandleKey &hndl, const std::string &doc, const SG::VarHandleKeyType &) |
| Declare a new Gaudi property. More...
|
|
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, SG::VarHandleBase &hndl, const std::string &doc, const SG::VarHandleType &) |
| Declare a new Gaudi property. More...
|
|
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, SG::VarHandleKeyArray &hndArr, const std::string &doc, const SG::VarHandleKeyArrayType &) |
|
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, T &property, const std::string &doc, const SG::NotHandleType &) |
| Declare a new Gaudi property. More...
|
|
Gaudi::Details::PropertyBase * | declareProperty (const std::string &name, T &property, const std::string &doc="none") |
| Declare a new Gaudi property. More...
|
|
void | updateVHKA (Gaudi::Details::PropertyBase &) |
|
MsgStream & | msg () const |
|
MsgStream & | msg (const MSG::Level lvl) const |
|
bool | msgLvl (const MSG::Level lvl) const |
|
|
StatusCode | processHvData (const EventContext &ctx) const |
|
StatusCode | loadHvData (const EventContext &ctx, const readKey_t &readKey, const DcsTechType tech, writeHandleDcs_t &writeHandle, NswDcsDbData *writeCdo) const |
|
StatusCode | loadTDaqData (const EventContext &ctx, const readKey_t &readKey, const DcsTechType tech, writeHandleDcs_t &writeHandle, NswDcsDbData *writeCdo) const |
|
StatusCode | loadELTXData (const EventContext &ctx, const readKey_t &readKey, const DcsTechType tech, writeHandleDcs_t &writeHandle, NswDcsDbData *writeCdo) const |
|
bool | buildChannelIdForHv (Identifier &channelId, const DcsTechType tech0, const std::string &chanName, bool &isOK) const |
|
bool | buildChannelIdForTDaq (Identifier &channelId, uint &elink, const DcsTechType tech0, const std::string &chanName, bool &isOK) const |
|
bool | buildChannelIdForEltx (Identifier &channelId, const DcsTechType tech0, const std::string &chanName, bool &isOK) const |
|
Gaudi::Details::PropertyBase & | declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleKeyType &) |
| specialization for handling Gaudi::Property<SG::VarHandleKey> More...
|
|
Gaudi::Details::PropertyBase & | declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleKeyArrayType &) |
| specialization for handling Gaudi::Property<SG::VarHandleKeyArray> More...
|
|
Gaudi::Details::PropertyBase & | declareGaudiProperty (Gaudi::Property< T > &hndl, const SG::VarHandleType &) |
| specialization for handling Gaudi::Property<SG::VarHandleBase> More...
|
|
Gaudi::Details::PropertyBase & | declareGaudiProperty (Gaudi::Property< T > &t, const SG::NotHandleType &) |
| specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray> More...
|
|
|
ServiceHandle< ICondSvc > | m_condSvc {this, "CondSvc", "CondSvc"} |
|
ServiceHandle< Muon::IMuonIdHelperSvc > | m_idHelperSvc {this, "MuonIdHelperSvc", "Muon::MuonIdHelperSvc/MuonIdHelperSvc"} |
|
writeKey_t | m_writeKey {this, "WriteKey", "NswDcsDbData", "Key of output data object" } |
|
readKey_t | m_readKey_mmg_hv {this, "ReadKey_MMG_HV", "/MMG/DCS/HV", "Key of input MMG condition data for HV"} |
|
readKey_t | m_readKey_stg_hv {this, "ReadKey_STG_HV", "/STG/DCS/HV", "Key of input STG condition data for HV"} |
|
readKey_t | m_readKey_mmg_tdaq {this, "ReadKey_MMG_TDAQ", "", "Key of input MMG condition data for TDAQ"} |
|
readKey_t | m_readKey_stg_tdaq {this, "ReadKey_STG_TDAQ", "", "Key of input STG condition data for TDAQ"} |
|
readKey_t | m_readKey_mmg_eltx {this, "ReadKey_MMG_ELTX", "", "Key of input MMG condition data for SCA status"} |
|
readKey_t | m_readKey_stg_eltx {this, "ReadKey_STG_ELTX", "", "Key of input STG condition data for SCA status"} |
|
Gaudi::Property< bool > | m_loadTdaq {this, "LoadTdaq",false,"enable the processing of Elinks in the NswDcsDbAlg"} |
|
Gaudi::Property< bool > | m_loadEltx {this, "LoadEltx",false,"enable the processing of SCAs in the NswDcsDbAlg"} |
|
const MuonGM::MuonDetectorManager * | m_muDetMgrFromDetStore |
|
DataObjIDColl | m_extendedExtraObjects |
| Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks. More...
|
|
StoreGateSvc_t | m_evtStore |
| Pointer to StoreGate (event store by default) More...
|
|
StoreGateSvc_t | m_detStore |
| Pointer to StoreGate (detector store by default) More...
|
|
std::vector< SG::VarHandleKeyArray * > | m_vhka |
|
bool | m_varHandleArraysDeclared |
|
Definition at line 31 of file NswDcsDbAlg.h.
◆ DcsDataType
◆ DcsTechType
◆ readKey_t
◆ StoreGateSvc_t
◆ writeHandleDcs_t
◆ writeKey_t
◆ ~NswDcsDbAlg()
virtual NswDcsDbAlg::~NswDcsDbAlg |
( |
| ) |
|
|
virtualdefault |
◆ AthReentrantAlgorithm()
AthReentrantAlgorithm::AthReentrantAlgorithm |
Constructor with parameters:
Definition at line 90 of file AthReentrantAlgorithm.cxx.
30 std::make_unique<AthenaBaseComps::AthAlgorithmDHUpdate>
32 std::move (m_updateDataHandles));
◆ buildChannelIdForEltx()
Definition at line 461 of file NswDcsDbAlg.cxx.
464 std::regex re(
"^(A|C)_([0-9]{2})_L([0-9])_B([0-9]{2})");
468 if(!std::regex_match(chanName,
re)) {
477 std::regex_match(chanName,
m,
re);
480 std::vector<std::string>
res;
481 for(
unsigned int i=0;
i<
m.size(); ++
i)
res.push_back(
m[
i].str());
484 int wheel =
res[1]==
"A"? 1 : -1;
485 int sector = std::stoi(
res[2])+1;
486 int board = std::stoi(
res[4]);
497 board -= (
layer%2==1 ? 1 : 2);
501 }
else if (board%4==3) {
511 ATH_MSG_WARNING(
"Could not extract valid channelId for MMG channel "<<chanName);
527 else if((
layer&1)==1){
529 channelType=sTgcIdHelper::sTgcChannelTypes::Strip;
531 channelType=sTgcIdHelper::sTgcChannelTypes::Pad;
533 }
else if(
layer%1==0){
535 channelType=sTgcIdHelper::sTgcChannelTypes::Pad;
537 channelType=sTgcIdHelper::sTgcChannelTypes::Strip;
542 ATH_MSG_WARNING(
"Could not extract valid channelId for STG channel "<<chanName);
◆ buildChannelIdForHv()
Definition at line 242 of file NswDcsDbAlg.cxx.
245 std::regex reMMG(
"^([A-Za-z]{1})([0-9]{2})_ML([0-9])P([0-9])_(IP|HO)R([0-9])__HV");
246 std::regex reMMD(
"^([A-Za-z]{1})([0-9]{2})_DRIFT_(IP|HO)R([0-9])__HV");
247 std::regex reSTG(
"^([A-Za-z]{1})([0-9]{2})_ML([0-9])_(IP|HO)R([0-9])__HV");
252 if(std::regex_match(chanName, reMMG)) {
256 else if(std::regex_match(chanName, reMMD)) {
260 else if(std::regex_match(chanName, reSTG)) {
265 ATH_MSG_ERROR(
"Could not identify channel with name "<<chanName);
279 std::regex_match(chanName,
m,
re);
282 std::vector<std::string>
res;
283 for(
unsigned int i=0;
i<
m.size(); ++
i)
res.push_back(
m[
i].str());
287 int wheel =
res[1]==
"A"? 1 : -1;
288 int sector = std::stoi(
res[2]);
289 const std::string
stationName = sector%2==0 ?
"MMS" :
"MML";
294 int pcb = std::stoi(
res[4]);
297 ATH_MSG_DEBUG(
"Could not extract valid channelId for MMG channel "<<chanName);
307 int wheel =
res[1]==
"A"? 1 : -1;
308 int sector = std::stoi(
res[2]);
309 const std::string
stationName = sector%2==0 ?
"MMS" :
"MML";
315 ATH_MSG_DEBUG(
"Could not extract valid elementId for MMGD channel "<<chanName);
322 ATH_MSG_DEBUG(
"Could not extract valid multilayerId for MMG channel "<<chanName);
332 int wheel =
res[1]==
"A"? 1 : -1;
333 int sector = std::stoi(
res[2]);
334 const std::string
stationName = sector%2==0 ?
"STS" :
"STL";
342 ATH_MSG_DEBUG(
"Could not extract valid channelId for STG channel "<<chanName);
◆ buildChannelIdForTDaq()
Definition at line 356 of file NswDcsDbAlg.cxx.
359 std::regex reMMG(
"^ELink-MM-(A|C)/V([0-9]{1})/L1A/Strip/S([0-9]{1,2})/L([0-9]{1})/R([0-9]{1,2})/E([0-9]{1})");
360 std::regex reSTG(
"^ELink-sTGC-(A|C)/V([0-9]{1})/L1A/(Strip|Pad)/S([0-9]{1,2})/L([0-9]{1})/R([0-9]{1})/E([0-9]{1})");
361 std::regex reSTGTrigProc(
"^ELink-sTGC-A/V0/L1A/TrigProc/");
362 std::regex reSTGPadTrig(
"^ELink-sTGC-A/V0/L1A/PadTrig/");
368 if(std::regex_match(chanName, reMMG)) {
372 else if(std::regex_match(chanName, reSTG)) {
375 }
else if(std::regex_match(chanName, reSTGPadTrig) || std::regex_match(chanName, reSTGTrigProc)){
380 ATH_MSG_DEBUG(
"Could not identify channel with name "<<chanName);
394 std::regex_match(chanName,
m,
re);
397 std::vector<std::string>
res;
398 for(
unsigned int i=0;
i<
m.size(); ++
i)
res.push_back(
m[
i].str());
402 int wheel =
res[1]==
"A"? 1 : -1;
403 int sector = std::stoi(
res[3])+1;
416 elink = std::stoi(
res[6]);
418 ATH_MSG_DEBUG(
"Could not extract valid channelId for MMG channel "<<chanName);
428 int wheel =
res[1]==
"A"? 1 : -1;
429 int sector = std::stoi(
res[4]) + 1;
430 std::string
stationName = sector%2==0 ?
"STS" :
"STL";
444 uint channelType = (
res[3] ==
"Pad" ? sTgcIdHelper::sTgcChannelTypes::Pad : sTgcIdHelper::sTgcChannelTypes::Strip);
447 ATH_MSG_DEBUG(
"Could not extract valid channelId for STG channel "<<chanName);
453 elink = std::stoi(
res[7]);
◆ cardinality()
unsigned int AthReentrantAlgorithm::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.
Override this to return 0 for reentrant algorithms.
Definition at line 55 of file AthReentrantAlgorithm.cxx.
◆ declareGaudiProperty() [1/4]
specialization for handling Gaudi::Property<SG::VarHandleKeyArray>
Definition at line 170 of file AthCommonDataStore.h.
175 hndl.documentation());
◆ declareGaudiProperty() [2/4]
specialization for handling Gaudi::Property<SG::VarHandleKey>
Definition at line 156 of file AthCommonDataStore.h.
161 hndl.documentation());
◆ declareGaudiProperty() [3/4]
specialization for handling Gaudi::Property<SG::VarHandleBase>
Definition at line 184 of file AthCommonDataStore.h.
189 hndl.documentation());
◆ declareGaudiProperty() [4/4]
◆ declareProperty() [1/6]
Declare a new Gaudi property.
- Parameters
-
name | Name of the property. |
hndl | Object holding the property value. |
doc | Documentation string for the property. |
This is the version for types that derive from SG::VarHandleBase
. The property value object is put on the input and output lists as appropriate; then we forward to the base class.
Definition at line 245 of file AthCommonDataStore.h.
250 this->declare(hndl.
vhKey());
251 hndl.
vhKey().setOwner(
this);
◆ declareProperty() [2/6]
Declare a new Gaudi property.
- Parameters
-
name | Name of the property. |
hndl | Object holding the property value. |
doc | Documentation string for the property. |
This is the version for types that derive from SG::VarHandleKey
. The property value object is put on the input and output lists as appropriate; then we forward to the base class.
Definition at line 221 of file AthCommonDataStore.h.
◆ declareProperty() [3/6]
◆ declareProperty() [4/6]
Declare a new Gaudi property.
- Parameters
-
name | Name of the property. |
property | Object holding the property value. |
doc | Documentation string for the property. |
This is the generic version, for types that do not derive from SG::VarHandleKey
. It just forwards to the base class version of declareProperty
.
Definition at line 333 of file AthCommonDataStore.h.
◆ declareProperty() [5/6]
Declare a new Gaudi property.
- Parameters
-
name | Name of the property. |
property | Object holding the property value. |
doc | Documentation string for the property. |
This dispatches to either the generic declareProperty
or the one for VarHandle/Key/KeyArray.
Definition at line 352 of file AthCommonDataStore.h.
◆ declareProperty() [6/6]
◆ detStore()
◆ evtStore() [1/2]
◆ evtStore() [2/2]
◆ execute()
StatusCode NswDcsDbAlg::execute |
( |
const EventContext & |
ctx | ) |
const |
|
overridevirtual |
Definition at line 43 of file NswDcsDbAlg.cxx.
49 if (wrHdl.isValid()) {
50 ATH_MSG_DEBUG(
"CondHandle " << wrHdl.fullKey() <<
" is already valid."
51 <<
" In theory this should not be called, but may happen"
52 <<
" if multiple concurrent events are being processed out of order.");
53 return StatusCode::SUCCESS;
56 ATH_MSG_DEBUG(
"Range of time/charge output is " << wrHdl.getRange());
75 if (wrHdl.record(std::move(wrCdo)).isFailure()) {
77 <<
" with EventRange " << wrHdl.getRange()
78 <<
" into Conditions Store");
79 return StatusCode::FAILURE;
81 ATH_MSG_DEBUG(
"Recorded new " << wrHdl.key() <<
" with range " << wrHdl.getRange() <<
" into Conditions Store");
83 return StatusCode::SUCCESS;
◆ extraDeps_update_handler()
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 & AthReentrantAlgorithm::extraOutputDeps |
( |
| ) |
const |
|
overridevirtualinherited |
Return the list of extra output dependencies.
This list is extended to include symlinks implied by inheritance relations.
Definition at line 79 of file AthReentrantAlgorithm.cxx.
86 return Algorithm::extraOutputDeps();
◆ filterPassed()
virtual bool AthReentrantAlgorithm::filterPassed |
( |
const EventContext & |
ctx | ) |
const |
|
inlinevirtualinherited |
◆ initialize()
StatusCode NswDcsDbAlg::initialize |
( |
| ) |
|
|
overridevirtual |
◆ inputHandles()
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()
bool AthReentrantAlgorithm::isClonable |
( |
| ) |
const |
|
overridevirtualinherited |
Specify if the algorithm is clonable.
Reentrant algorithms are clonable.
Reimplemented in Simulation::BeamEffectsAlg, InDet::SiTrackerSpacePointFinder, InDet::SCT_Clusterization, InDet::SiSPSeededTrackFinder, SCTRawDataProvider, InDet::GNNSeedingTrackMaker, SCT_PrepDataToxAOD, RoIBResultToxAOD, SCT_CablingCondAlgFromCoraCool, SCT_ReadCalibDataTestAlg, SCT_CablingCondAlgFromText, InDet::SiSPGNNTrackMaker, SCT_ReadCalibChipDataTestAlg, SCT_TestCablingAlg, SCT_ConfigurationConditionsTestAlg, ITkPixelCablingAlg, SCTEventFlagWriter, SCT_ConditionsSummaryTestAlg, SCT_ModuleVetoTestAlg, SCT_MonitorConditionsTestAlg, SCT_LinkMaskingTestAlg, SCT_MajorityConditionsTestAlg, SCT_RODVetoTestAlg, SCT_SensorsTestAlg, SCT_TdaqEnabledTestAlg, SCT_SiliconConditionsTestAlg, SCTSiLorentzAngleTestAlg, SCT_ByteStreamErrorsTestAlg, SCT_ConditionsParameterTestAlg, SCT_FlaggedConditionTestAlg, SCT_StripVetoTestAlg, SCT_RawDataToxAOD, and SCTSiPropertiesTestAlg.
Definition at line 44 of file AthReentrantAlgorithm.cxx.
◆ isReEntrant()
virtual bool NswDcsDbAlg::isReEntrant |
( |
| ) |
const |
|
inlineoverridevirtual |
◆ loadELTXData()
Definition at line 195 of file NswDcsDbAlg.cxx.
202 return StatusCode::FAILURE;
204 writeHandle.addDependency(readHandle);
205 ATH_MSG_DEBUG(
"Size of CondAttrListCollection " << readHandle.fullKey() <<
" readCdo->size()= " << readCdo->size());
206 ATH_MSG_DEBUG(
"Range of input is " << readHandle.getRange() <<
", range of output is " << writeHandle.getRange());
214 for(itr = readCdo->begin(); itr != readCdo->end(); ++itr) {
217 const unsigned int chanNum = itr->first;
218 const std::string& chanName = readCdo->chanName(
chanNum);
219 if(chanName.empty()){
224 bool online = *(
static_cast<const bool*
>((atr[
"online"]).addressOfData()));
225 ATH_MSG_DEBUG(
"found SCA " << chanName <<
" with status " << atr[
"online"] <<
" " <<
online);
235 return StatusCode::SUCCESS;
◆ loadHvData()
Definition at line 89 of file NswDcsDbAlg.cxx.
96 return StatusCode::FAILURE;
98 writeHandle.addDependency(readHandle);
99 ATH_MSG_DEBUG(
"Size of CondAttrListCollection " << readHandle.fullKey() <<
" readCdo->size()= " << readCdo->size());
100 ATH_MSG_DEBUG(
"Range of input is " << readHandle.getRange() <<
", range of output is " << writeHandle.getRange());
104 unsigned int nChns = 0;
105 for(itr = readCdo->begin(); itr != readCdo->end(); ++itr) {
108 const unsigned int chanNum = itr->first;
109 const std::string& chanName = readCdo->chanName(
chanNum);
110 if(chanName.empty()){
119 ATH_MSG_ERROR(
"Could not identify valid channelId for channel "<<
chanNum<<
" with name "<< chanName<<
"!");
120 throw std::runtime_error(
"NswDcsDbAlg: Could not identify valid channelId for HV channel");
129 dcs_data.
standbyVolt = *(
static_cast<const float*
>((atr[
"v0Set"]).addressOfData()));
130 dcs_data.readyVolt = *(
static_cast<const float*
>((atr[
"v1Set"]).addressOfData()));
131 dcs_data.fsmState =
MuonCond::getFsmStateEnum(*(
static_cast<const std::string*
>((atr[
"fsmCurrentState"]).addressOfData())));
132 ATH_MSG_DEBUG(
"channel " << chanName <<
" has fsm state " << *(
static_cast<const std::string*
>((atr[
"fsmCurrentState"]).addressOfData()))<<
" has v0 state " << *(
static_cast<const float*
>( (atr[
"v0Set"]).addressOfData()))<<
" has v1 " << *(
static_cast<const float*
>((atr[
"v1Set"]).addressOfData())));
139 return StatusCode::SUCCESS;
◆ loadTDaqData()
Definition at line 145 of file NswDcsDbAlg.cxx.
151 return StatusCode::FAILURE;
153 writeHandle.addDependency(readHandle);
154 ATH_MSG_DEBUG(
"Size of CondAttrListCollection " << readHandle.fullKey() <<
" readCdo->size()= " << readCdo->size());
155 ATH_MSG_DEBUG(
"Range of input is " << readHandle.getRange() <<
", range of output is " << writeHandle.getRange());
159 for(itr = readCdo->begin(); itr != readCdo->end(); ++itr) {
163 std::string
data = *(
static_cast<const std::string *
>((atr[
"data_array"]).addressOfData()));
167 unsigned int nLB = 0;
170 for (
auto &
yy : jx[
"holes"].
items()) {
180 ATH_MSG_DEBUG(
"Could not identify valid channelId for channel "<<jt[
"channelId"]<<
" with name "<< jt[
"channelName"]<<
"! Skipping...");
184 int channelDead = jt[
"channelDead"];
185 writeCdo->
setDataTDaq(tech,
channelId, jt[
"hole_iovSince"], jt[
"hole_iovUntil"], elink, channelDead );
189 ATH_MSG_VERBOSE(
"Retrieved data for "<<
nLB<<
" entries (combinations of lumi block and channel).");
192 return StatusCode::SUCCESS;
◆ msg() [1/2]
◆ msg() [2/2]
◆ msgLvl()
◆ outputHandles()
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.
◆ processHvData()
StatusCode NswDcsDbAlg::processHvData |
( |
const EventContext & |
ctx | ) |
const |
|
private |
◆ renounce()
◆ renounceArray()
◆ setFilterPassed()
virtual void AthReentrantAlgorithm::setFilterPassed |
( |
bool |
state, |
|
|
const EventContext & |
ctx |
|
) |
| const |
|
inlinevirtualinherited |
◆ sysExecute()
StatusCode AthReentrantAlgorithm::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 67 of file AthReentrantAlgorithm.cxx.
69 return Gaudi::Algorithm::sysExecute (ctx);
◆ sysInitialize()
StatusCode AthReentrantAlgorithm::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 InputMakerBase, and HypoBase.
Definition at line 96 of file AthReentrantAlgorithm.cxx.
107 if ( cs.retrieve().isFailure() ) {
109 return StatusCode::SUCCESS;
111 if (cs->regHandle(
this,*
h).isFailure()) {
112 sc = StatusCode::FAILURE;
113 ATH_MSG_ERROR(
"unable to register WriteCondHandle " <<
h->fullKey()
◆ sysStart()
Handle START transition.
We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.
◆ updateVHKA()
◆ m_condSvc
◆ m_detStore
◆ m_evtStore
◆ m_extendedExtraObjects
DataObjIDColl AthReentrantAlgorithm::m_extendedExtraObjects |
|
privateinherited |
Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.
Empty if no symlinks were found.
Definition at line 153 of file AthReentrantAlgorithm.h.
◆ m_idHelperSvc
◆ m_loadEltx
Gaudi::Property<bool> NswDcsDbAlg::m_loadEltx {this, "LoadEltx",false,"enable the processing of SCAs in the NswDcsDbAlg"} |
|
private |
◆ m_loadTdaq
Gaudi::Property<bool> NswDcsDbAlg::m_loadTdaq {this, "LoadTdaq",false,"enable the processing of Elinks in the NswDcsDbAlg"} |
|
private |
◆ m_muDetMgrFromDetStore
◆ m_readKey_mmg_eltx
readKey_t NswDcsDbAlg::m_readKey_mmg_eltx {this, "ReadKey_MMG_ELTX", "", "Key of input MMG condition data for SCA status"} |
|
private |
◆ m_readKey_mmg_hv
readKey_t NswDcsDbAlg::m_readKey_mmg_hv {this, "ReadKey_MMG_HV", "/MMG/DCS/HV", "Key of input MMG condition data for HV"} |
|
private |
◆ m_readKey_mmg_tdaq
readKey_t NswDcsDbAlg::m_readKey_mmg_tdaq {this, "ReadKey_MMG_TDAQ", "", "Key of input MMG condition data for TDAQ"} |
|
private |
◆ m_readKey_stg_eltx
readKey_t NswDcsDbAlg::m_readKey_stg_eltx {this, "ReadKey_STG_ELTX", "", "Key of input STG condition data for SCA status"} |
|
private |
◆ m_readKey_stg_hv
readKey_t NswDcsDbAlg::m_readKey_stg_hv {this, "ReadKey_STG_HV", "/STG/DCS/HV", "Key of input STG condition data for HV"} |
|
private |
◆ m_readKey_stg_tdaq
readKey_t NswDcsDbAlg::m_readKey_stg_tdaq {this, "ReadKey_STG_TDAQ", "", "Key of input STG condition data for TDAQ"} |
|
private |
◆ m_varHandleArraysDeclared
◆ m_vhka
◆ m_writeKey
The documentation for this class was generated from the following files:
def retrieve(aClass, aKey=None)
bool buildChannelIdForEltx(Identifier &channelId, const DcsTechType tech0, const std::string &chanName, bool &isOK) const
char data[hepevt_bytes_allocation_ATLAS]
constexpr uint8_t stationPhi
station Phi 1 to 8
void setDataEltx(const DcsTechType tech, const Identifier &chnlId)
Gaudi::Details::PropertyBase & declareProperty(Gaudi::Property< T > &t)
ServiceHandle< Muon::IMuonIdHelperSvc > m_idHelperSvc
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)
static EventIDRange infiniteMixed()
Produces an mixed EventIDRange that is infinite in Time and RunLumi.
StoreGateSvc_t m_evtStore
Pointer to StoreGate (event store by default)
std::vector< SG::VarHandleKeyArray * > m_vhka
const MuonGM::MuonDetectorManager * m_muDetMgrFromDetStore
NswDcsDbData::DcsTechType DcsTechType
#define ATH_MSG_VERBOSE(x)
bool buildChannelIdForTDaq(Identifier &channelId, uint &elink, const DcsTechType tech0, const std::string &chanName, bool &isOK) const
bool empty() const
Test if the key is blank.
This class is a collection of AttributeLists where each one is associated with a channel number....
readKey_t m_readKey_stg_tdaq
const ServiceHandle< StoreGateSvc > & detStore() const
The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.
virtual void setOwner(IDataHandleHolder *o)=0
bool buildChannelIdForHv(Identifier &channelId, const DcsTechType tech0, const std::string &chanName, bool &isOK) const
virtual std::vector< Gaudi::DataHandle * > outputHandles() const override
Return this algorithm's output handles.
::StatusCode StatusCode
StatusCode definition for legacy code.
std::pair< std::vector< unsigned int >, bool > res
Helper struct to cache all dcs constants in a common place of the memory.
StatusCode loadELTXData(const EventContext &ctx, const readKey_t &readKey, const DcsTechType tech, writeHandleDcs_t &writeHandle, NswDcsDbData *writeCdo) const
StoreGateSvc_t m_detStore
Pointer to StoreGate (detector store by default)
StatusCode loadHvData(const EventContext &ctx, const readKey_t &readKey, const DcsTechType tech, writeHandleDcs_t &writeHandle, NswDcsDbData *writeCdo) const
DataObjIDColl m_extendedExtraObjects
Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.
virtual void renounce()=0
std::conditional< std::is_base_of< SG::VarHandleKeyArray, T >::value, VarHandleKeyArrayType, type2 >::type type
Gaudi::Property< bool > m_loadEltx
void setDataHv(const DcsTechType tech, const Identifier &chnlId, DcsConstants constants)
virtual StatusCode sysInitialize() override
Override sysInitialize.
readKey_t m_readKey_mmg_tdaq
StatusCode initialize(bool used=true)
readKey_t m_readKey_mmg_eltx
readKey_t m_readKey_stg_eltx
#define ATH_MSG_WARNING(x)
ChanAttrListMap::const_iterator const_iterator
const boost::regex re(r_e)
Gaudi::Property< bool > m_loadTdaq
readKey_t m_readKey_mmg_hv
DcsFsmState getFsmStateEnum(const std::string &fsmState)
StatusCode loadTDaqData(const EventContext &ctx, const readKey_t &readKey, const DcsTechType tech, writeHandleDcs_t &writeHandle, NswDcsDbData *writeCdo) const
SG::VarHandleKey & vhKey()
Return a non-const reference to the HandleKey.
void setDataTDaq(const DcsTechType tech, const Identifier &chnlId, uint64_t timeSince, uint64_t timeUntil, unsigned int elink, bool permanentlyDisabled)
ServiceHandle< ICondSvc > m_condSvc
constexpr uint8_t stationEta
1 to 3
Gaudi::Details::PropertyBase & declareGaudiProperty(Gaudi::Property< T > &hndl, const SG::VarHandleKeyType &)
specialization for handling Gaudi::Property<SG::VarHandleKey>
readKey_t m_readKey_stg_hv