#include <NswDcsDbAlg.h>

Inheritance diagram for NswDcsDbAlg:

Collaboration diagram for NswDcsDbAlg:

Public Member Functions
virtual	~NswDcsDbAlg ()=default

virtual StatusCode	initialize () override

virtual StatusCode	execute (const EventContext &) const override

virtual bool	isReEntrant () const override

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, V, H > &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

Protected Member Functions
void	renounceArray (SG::VarHandleKeyArray &handlesArray)
	remove all handles from I/O resolution More...

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

Private Types
using	writeKey_t = SG::WriteCondHandleKey< NswDcsDbData >

using	readKey_t = SG::ReadCondHandleKey< CondAttrListCollection >

using	writeHandleDcs_t = SG::WriteCondHandle< NswDcsDbData >

using	DcsTechType = NswDcsDbData::DcsTechType

using	DcsDataType = NswDcsDbData::DcsDataType

typedef ServiceHandle< StoreGateSvc >	StoreGateSvc_t

Private Member Functions
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, V, H > &hndl, const SG::VarHandleKeyType &)
	specialization for handling Gaudi::Property<SG::VarHandleKey> More...

Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyArrayType &)
	specialization for handling Gaudi::Property<SG::VarHandleKeyArray> More...

Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleType &)
	specialization for handling Gaudi::Property<SG::VarHandleBase> More...

Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T, V, H > &t, const SG::NotHandleType &)
	specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray> More...

Private Attributes
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"}

SG::ReadCondHandleKey< MuonGM::MuonDetectorManager >	m_muonManagerKey

const MuonGM::MuonDetectorManager *	m_detManager {nullptr}

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

Detailed Description

Definition at line 31 of file NswDcsDbAlg.h.

Member Typedef Documentation

◆ DcsDataType

using NswDcsDbAlg::DcsDataType = NswDcsDbData::DcsDataType

private

Definition at line 52 of file NswDcsDbAlg.h.

◆ DcsTechType

using NswDcsDbAlg::DcsTechType = NswDcsDbData::DcsTechType

private

Definition at line 51 of file NswDcsDbAlg.h.

◆ readKey_t

using NswDcsDbAlg::readKey_t = SG::ReadCondHandleKey<CondAttrListCollection>

private

Definition at line 45 of file NswDcsDbAlg.h.

◆ StoreGateSvc_t

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

privateinherited

Definition at line 388 of file AthCommonDataStore.h.

◆ writeHandleDcs_t

using NswDcsDbAlg::writeHandleDcs_t = SG::WriteCondHandle<NswDcsDbData>

private

Definition at line 47 of file NswDcsDbAlg.h.

◆ writeKey_t

using NswDcsDbAlg::writeKey_t = SG::WriteCondHandleKey<NswDcsDbData>

private

Definition at line 44 of file NswDcsDbAlg.h.

Constructor & Destructor Documentation

◆ ~NswDcsDbAlg()

virtual NswDcsDbAlg::~NswDcsDbAlg ( )

virtualdefault

Member Function Documentation

◆ buildChannelIdForEltx()

bool NswDcsDbAlg::buildChannelIdForEltx	(	Identifier &	channelId,
		const DcsTechType	tech0,
		const std::string &	chanName,
		bool &	isOK
	)		const

private

Definition at line 483 of file NswDcsDbAlg.cxx.

                                                                                                                              {
  
     // prepare regex
     std::regex re("^(A|C)_([0-9]{2})_L([0-9])_B([0-9]{2})");
     
  
     // match regex
     if(!std::regex_match(chanName, re)) {
       ATH_MSG_WARNING("Could not identify channel with name "<<chanName);
       isOK = false;
       return false;
     }
  
     // build channel Id
     bool isValid{false};
     std::smatch m;
     std::regex_match(chanName, m, re);
  
     // copy to vec of strings
     std::vector<std::string> res;
     for(unsigned int i=0; i<m.size(); ++i) res.push_back(m[i].str());
  
     //extract field common to MM and stgc
     int wheel         = res[1]=="A"? 1 : -1;
     int sector        = std::stoi(res[2])+1;
     int board         = std::stoi(res[4]);
     int layer         = std::stoi(res[3]);
     int stationPhi    = (sector-1)/2+1;
     int multiLayer    = layer< 5 ? 1 : 2; // layers 1-4 are on multilayer 1 and layers 5-8 are on multilayer 2
     int gasGap        = ((layer-1)%4) + 1; // identifies layer within multilayer
  
  
     // MMG Channel
     if(tech==DcsTechType::MMG){
         int stationName   = sector%2==0 ? 56 : 55;
     
         board -= (layer%2==1 ? 1 : 2); // for odd layers (counting 1-8 here) the first board is on position 1 for even ones on position 2. https://mattermost.web.cern.ch/files/i84ghkjsfbrzje7c3kr5h7ccdy/public?h=xs3cQQ38yZJDrct75eY73G9d1deOaEtJCHmk2Qcni4s
         int radius{0};
         if(board%4==0){
             radius = 2*(board/4);
         } else if (board%4==3) {
             radius = 2*(board/4) + 1;
         } else { // not a readout board
             isOK = true;
             return false;
         }
  
         int stationEta    = wheel*(radius<10? 1 : 2); // boards 0-9 are on the first quad, boards 10-15 on the second one
         Identifier chnlId = m_idHelperSvc->mmIdHelper().febID(stationName, stationEta, stationPhi, multiLayer, gasGap, radius, isValid);
         if(!isValid){
             ATH_MSG_WARNING("Could not extract valid channelId for MMG channel "<<chanName);
             ATH_MSG_WARNING("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer<<" " << gasGap<<" " << radius<<" " << board);
             isOK = false;
             return false;
         }
         channelId = chnlId;
     } else if(tech==DcsTechType::STG){
         int stationName   = sector%2==0 ? 58 : 57;
         board -= 1; // count from 0 while input counts from one
         uint radius = board/2;
         int stationEta = wheel*(radius+1);
         uint channelType{0};
         if(board>=6){ // not a STG readout board
             isOK = true;
             return false;
         }    
         else if((layer&1)==1){// for odd layers (counting 1-8 here) the boards on even positions are reading the strips. https://mattermost.web.cern.ch/files/bdh8wwjzf7yiiggtad3u8bttrr/public?h=2fFnVki1EUefrMEa3tb8AZkTiC-tF3L11qdq43dBbJc 
             if(board%2==0){
                 channelType=sTgcIdHelper::sTgcChannelTypes::Strip;
             } else {
                 channelType=sTgcIdHelper::sTgcChannelTypes::Pad;
             }
         } else if(layer%1==0){// for even layers (counting 1-8 here) the boards on even positions are reading the pads and wires. https://mattermost.web.cern.ch/files/taro34muwpb18pqgiufhwf5a5c/public?h=3YlA-w0NfEuCV2JIGUjiWwpnpDlxvIaEkzrTXWfo71M 
             if(board%2==0){
                 channelType=sTgcIdHelper::sTgcChannelTypes::Pad;
             } else {
                 channelType=sTgcIdHelper::sTgcChannelTypes::Strip;
             }
         }
         Identifier chnlId = m_idHelperSvc->stgcIdHelper().febID(stationName, stationEta, stationPhi, multiLayer, gasGap, channelType ,isValid);
         if(!isValid){
             ATH_MSG_WARNING("Could not extract valid channelId for STG channel "<<chanName);
             ATH_MSG_WARNING("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer<<" " << gasGap<<" " << radius<<" " << board << " " << channelType);
             isOK = false;
             return false;
         }
         channelId = chnlId;
     }
     return true;
 }

◆ buildChannelIdForHv()

bool NswDcsDbAlg::buildChannelIdForHv	(	Identifier &	channelId,
		const DcsTechType	tech0,
		const std::string &	chanName,
		bool &	isOK
	)		const

private

Definition at line 264 of file NswDcsDbAlg.cxx.

                                                                                                                             {
  
     // prepare regex
     std::regex reMMG("^([A-Za-z]{1})([0-9]{2})_ML([0-9])P([0-9])_(IP|HO)R([0-9])__HV");
     std::regex reMMD("^([A-Za-z]{1})([0-9]{2})_DRIFT_(IP|HO)R([0-9])__HV");
     std::regex reSTG("^([A-Za-z]{1})([0-9]{2})_ML([0-9])_(IP|HO)R([0-9])__HV");
     std::regex re;
     DcsTechType tech = DcsTechType::MMG; 
  
     // match regex
     if(std::regex_match(chanName, reMMG)) {
         re   = reMMG;
         tech = DcsTechType::MMG;
     }
     else if(std::regex_match(chanName, reMMD)) {
         re   = reMMD;
         tech = DcsTechType::MMD;
     }
     else if(std::regex_match(chanName, reSTG)) {
         re   = reSTG;
         tech = DcsTechType::STG;
     }
     else {
         ATH_MSG_ERROR("Could not identify channel with name "<<chanName);
         isOK = false;
         return false;
     }
  
     // sanity check
     if(tech0!=tech) {
         isOK = true; // need to distinguish error in parsing and simple difference between required technologies
         return false;
     }
  
     // build channel Id
     bool isValid{false};
     std::smatch m;
     std::regex_match(chanName, m, re);
  
     // copy to vec of strings
     std::vector<std::string> res;
     for(unsigned int i=0; i<m.size(); ++i) res.push_back(m[i].str());
  
     // MMG Channel
     if(tech==DcsTechType::MMG){
         int wheel         = res[1]=="A"? 1 : -1;
         int sector        = std::stoi(res[2]);
         const std::string stationName   = sector%2==0 ? "MMS" : "MML";
         int stationEta    = wheel*std::stoi(res[6]);
         int stationPhi    = (sector-1)/2+1;
         int multiLayer    = res[5]=="IP" ? 1 : 2;
         int gasGap        = std::stoi(res[3]);
         int pcb           = std::stoi(res[4]);
         Identifier chnlId = m_idHelperSvc->mmIdHelper().pcbID(stationName, stationEta, stationPhi, multiLayer, gasGap, pcb, isValid);
         if(!isValid){
             ATH_MSG_DEBUG("Could not extract valid channelId for MMG channel "<<chanName);
             ATH_MSG_DEBUG("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer);
             isOK = false;
             return false;
         }
         channelId = chnlId;
     }
  
     // MMG Drift Channel
     else if(tech==DcsTechType::MMD){
         int wheel         = res[1]=="A"? 1 : -1;
         int sector        = std::stoi(res[2]);
         const std::string stationName   = sector%2==0 ? "MMS" : "MML";
         int stationEta    = wheel*std::stoi(res[4]);
         int stationPhi    = (sector-1)/2+1;
         int multiLayer    = res[3]=="IP" ? 1 : 2;
         Identifier modId  = m_idHelperSvc->mmIdHelper().elementID(stationName, stationEta, stationPhi, isValid);
         if(!isValid){
             ATH_MSG_DEBUG("Could not extract valid elementId for MMGD channel "<<chanName);
             ATH_MSG_DEBUG("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer);
             isOK = false;
             return false;
         }
         Identifier chnlId = m_idHelperSvc->mmIdHelper().multilayerID(modId, multiLayer, isValid);
         if(!isValid){
             ATH_MSG_DEBUG("Could not extract valid multilayerId for MMG channel "<<chanName);
             ATH_MSG_DEBUG("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer);
             isOK = false;
             //return false;
         }
         channelId = chnlId;
     }
  
     // STG
     else if(tech==DcsTechType::STG){
         int wheel         = res[1]=="A"? 1 : -1;
         int sector        = std::stoi(res[2]);
         const std::string stationName   = sector%2==0 ? "STS" : "STL";
         int radius        = std::stoi(res[5]);
         int stationEta    = wheel*(radius<=2 ? 1 : radius-1);
         int stationPhi    = (sector-1)/2+1;
         int multiLayer    = res[4]=="IP" ? 1 : 2;
         int gasGap        = std::stoi(res[3]);
         Identifier chnlId = m_idHelperSvc->stgcIdHelper().hvID(stationName, stationEta, stationPhi, multiLayer, gasGap, radius == 1 /*radius 1 is the inner hv section*/ , isValid);
         if(!isValid){
             ATH_MSG_DEBUG("Could not extract valid channelId for STG channel "<<chanName);
             ATH_MSG_DEBUG("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer);
             isOK = false;
             return false;
         }
         channelId = chnlId;
     }
  
     return true;
 }

◆ buildChannelIdForTDaq()

bool NswDcsDbAlg::buildChannelIdForTDaq	(	Identifier &	channelId,
		uint &	elink,
		const DcsTechType	tech0,
		const std::string &	chanName,
		bool &	isOK
	)		const

private

Definition at line 378 of file NswDcsDbAlg.cxx.

                                                                                                                                            {
  
     // prepare regex
     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})");
     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})");
     std::regex reSTGTrigProc("^ELink-sTGC-A/V0/L1A/TrigProc/");
     std::regex reSTGPadTrig("^ELink-sTGC-A/V0/L1A/PadTrig/");
     
     std::regex re;
     DcsTechType tech = DcsTechType::MMG; 
  
     // match regex
     if(std::regex_match(chanName, reMMG)) {
         re   = reMMG;
         tech = DcsTechType::MMG;
     }
     else if(std::regex_match(chanName, reSTG)) {
         re   = reSTG;
         tech = DcsTechType::STG;
     } else if(std::regex_match(chanName, reSTGPadTrig) || std::regex_match(chanName, reSTGTrigProc)){ // those are trigger elinks that are not needed in athena
         isOK = true;
         return false;
     }
     else {
         ATH_MSG_DEBUG("Could not identify channel with name "<<chanName);
         isOK = false;
         return false;
     }
  
     // sanity check
     if(tech0!=tech) {
         isOK = true; // need to distinguish error in parsing and simple difference between required technologies
         return false;
     }
  
     // build channel Id
     bool isValid{false};
     std::smatch m;
     std::regex_match(chanName, m, re);
  
     // copy to vec of strings
     std::vector<std::string> res;
     for(unsigned int i=0; i<m.size(); ++i) res.push_back(m[i].str());
  
     // MMG Channel
     if(tech==DcsTechType::MMG){
         int wheel         = res[1]=="A"? 1 : -1;
         int sector        = std::stoi(res[3])+1; // elx counts from 0 athena from 1 -->need a +1
         int stationName   = sector%2==0 ? 55 : 56;
         /*
         res[4] -> L
         res[5] -> R
         res[6] -> E
         */
         int stationEta    = wheel*(std::stoi(res[5])<10? 1 : 2); // boards 0-9 are und the first quad, boards 10-15 und the second one
         int stationPhi    = (sector-1)/2+1;
         int multiLayer    = std::stoi(res[4])< 4 ? 1 : 2; // layers 0-3 are on multilayer 1 and layers 4-7 are on multilayer 2
         int gasGap        = (std::stoi(res[4])%4) + 1; // identifies layer within multilayer --> counts from  0-3; +1 because athena counts from 1-4 
         int radius = std::stoi(res[5]);
         Identifier chnlId = m_idHelperSvc->mmIdHelper().febID(stationName, stationEta, stationPhi, multiLayer, gasGap, radius, isValid);
         elink = std::stoi(res[6]);
         if(!isValid){
             ATH_MSG_DEBUG("Could not extract valid channelId for MMG channel "<<chanName);
             ATH_MSG_DEBUG("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer<<" " << gasGap<<" " << radius<<" " << elink);
             isOK = false;
             return false;
         }
         channelId = chnlId;
     }
  
     // STG
     else if(tech==DcsTechType::STG){
         int wheel         = res[1]=="A"? 1 : -1;
         int sector        = std::stoi(res[4]) + 1;
         std::string stationName   = sector%2==0 ? "STS" : "STL";
         
         /*
         res[3] -> Strip/Pad
         res[5] -> L
         res[6] -> R
         res[7] -> E
         */
         
         int    radius        = std::stoi(res[6]);
         int stationEta    = wheel*(radius+1);
         int stationPhi    = (sector-1)/2+1;
         int multiLayer    = (std::stoi(res[5]) < 4 ?  1 : 2);
         int gasGap        = ((std::stoi(res[5]))%4)+1;
         uint channelType  = (res[3] == "Pad" ? sTgcIdHelper::sTgcChannelTypes::Pad : sTgcIdHelper::sTgcChannelTypes::Strip);
         Identifier chnlId = m_idHelperSvc->stgcIdHelper().febID(stationName, stationEta, stationPhi, multiLayer, gasGap, channelType, isValid);
         if(!isValid){
             ATH_MSG_DEBUG("Could not extract valid channelId for STG channel "<<chanName);
             ATH_MSG_DEBUG("Fields: "<< wheel << " "<<sector<<" " << stationName<< " " << stationEta<<" "<<stationPhi<<" "<<multiLayer<<" " << gasGap<<" " << radius<<" " << elink);
             isOK = false;
             return false;
         }
         channelId = chnlId;
         elink = std::stoi(res[7]);    
     }
  
     return true;
 }

◆ cardinality()

unsigned int AthCommonReentrantAlgorithm< Gaudi::Algorithm >::cardinality

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.

 {
   return 0;
 }

◆ declareGaudiProperty() [1/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty	(	Gaudi::Property< T, V, H > &	hndl,
		const SG::VarHandleKeyArrayType &
	)

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKeyArray>

Definition at line 170 of file AthCommonDataStore.h.

   {
     return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                        hndl.value(), 
                                                        hndl.documentation());
  
   }

◆ declareGaudiProperty() [2/4]

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.

   {
     return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                        hndl.value(), 
                                                        hndl.documentation());
  
   }

◆ declareGaudiProperty() [3/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty	(	Gaudi::Property< T, V, H > &	hndl,
		const SG::VarHandleType &
	)

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleBase>

Definition at line 184 of file AthCommonDataStore.h.

   {
     return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                        hndl.value(), 
                                                        hndl.documentation());
   }

◆ declareGaudiProperty() [4/4]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareGaudiProperty	(	Gaudi::Property< T, V, H > &	t,
		const SG::NotHandleType &
	)

inlineprivateinherited

specialization for handling everything that's not a Gaudi::Property<SG::VarHandleKey> or a <SG::VarHandleKeyArray>

Definition at line 199 of file AthCommonDataStore.h.

   {
     return PBASE::declareProperty(t);
   }

◆ declareProperty() [1/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty	(	const std::string &	name,
		SG::VarHandleBase &	hndl,
		const std::string &	doc,
		const SG::VarHandleType &
	)

inlineinherited

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.

   {
     this->declare(hndl.vhKey());
     hndl.vhKey().setOwner(this);
  
     return PBASE::declareProperty(name,hndl,doc);
   }

◆ declareProperty() [2/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty	(	const std::string &	name,
		SG::VarHandleKey &	hndl,
		const std::string &	doc,
		const SG::VarHandleKeyType &
	)

inlineinherited

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.

   {
     this->declare(hndl);
     hndl.setOwner(this);
  
     return PBASE::declareProperty(name,hndl,doc);
   }

◆ declareProperty() [3/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty	(	const std::string &	name,
		SG::VarHandleKeyArray &	hndArr,
		const std::string &	doc,
		const SG::VarHandleKeyArrayType &
	)

inlineinherited

Definition at line 259 of file AthCommonDataStore.h.

   {
  
     // std::ostringstream ost;
     // ost << Algorithm::name() << " VHKA declareProp: " << name 
     //     << " size: " << hndArr.keys().size() 
     //     << " mode: " << hndArr.mode() 
     //     << "  vhka size: " << m_vhka.size()
     //     << "\n";
     // debug() << ost.str() << endmsg;
  
     hndArr.setOwner(this);
     m_vhka.push_back(&hndArr);
  
     Gaudi::Details::PropertyBase* p =  PBASE::declareProperty(name, hndArr, doc);
     if (p != 0) {
       p->declareUpdateHandler(&AthCommonDataStore<PBASE>::updateVHKA, this);
     } else {
       ATH_MSG_ERROR("unable to call declareProperty on VarHandleKeyArray " 
                     << name);
     }
  
     return p;
  
   }

◆ declareProperty() [4/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty	(	const std::string &	name,
		T &	property,
		const std::string &	doc,
		const SG::NotHandleType &
	)

inlineinherited

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.

   {
     return PBASE::declareProperty(name, property, doc);
   }

◆ declareProperty() [5/6]

Gaudi::Details::PropertyBase* AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty	(	const std::string &	name,
		T &	property,
		const std::string &	doc = `"none"`
	)

inlineinherited

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.

   {
     typedef typename SG::HandleClassifier<T>::type htype;
     return declareProperty (name, property, doc, htype());
   }

◆ declareProperty() [6/6]

Gaudi::Details::PropertyBase& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::declareProperty ( Gaudi::Property< T, V, H > & t )

inlineinherited

Definition at line 145 of file AthCommonDataStore.h.

                                                                      {
     typedef typename SG::HandleClassifier<T>::type htype;
     return AthCommonDataStore<PBASE>::declareGaudiProperty(t, htype());
   }

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

95 { return m_detStore; }

◆ evtStore() [1/2]

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.

85 { return m_evtStore; }

◆ evtStore() [2/2]

const ServiceHandle<StoreGateSvc>& AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::evtStore ( ) const

inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 90 of file AthCommonDataStore.h.

90 { return m_evtStore; }

◆ execute()

StatusCode NswDcsDbAlg::execute ( const EventContext & ctx ) const

overridevirtual

Definition at line 44 of file NswDcsDbAlg.cxx.

                                                   {
  
     ATH_MSG_DEBUG( "execute " << name() );   
  
     // set up write handles
     SG::WriteCondHandle<NswDcsDbData> wrHdl{m_writeKey, ctx};
     if (wrHdl.isValid()) {
         ATH_MSG_DEBUG("CondHandle " << wrHdl.fullKey() << " is already valid."
             << " In theory this should not be called, but may happen"
             << " if multiple concurrent events are being processed out of order.");
         return StatusCode::SUCCESS;
     }
     wrHdl.addDependency(EventIDRange(IOVInfiniteRange::infiniteMixed()));
     ATH_MSG_DEBUG("Range of time/charge output is " << wrHdl.getRange());
  
     SG::ReadCondHandle<MuonGM::MuonDetectorManager> detMgr{m_muonManagerKey, ctx};
     if (!detMgr.isValid()) {
         ATH_MSG_FATAL(
             "Failed to retrieve the detector manager from the conditions store "
             << m_muonManagerKey.fullKey());
         return StatusCode::FAILURE;
     }
     wrHdl.addDependency(detMgr);
     std::unique_ptr<NswDcsDbData> wrCdo{std::make_unique<NswDcsDbData>(m_idHelperSvc.get(), detMgr.cptr())};
  
     // load HV data
     if(!m_readKey_mmg_hv.empty()){
         ATH_CHECK(loadHvData(ctx, m_readKey_mmg_hv, DcsTechType::MMG, wrHdl, wrCdo.get()));
         ATH_CHECK(loadHvData(ctx, m_readKey_mmg_hv, DcsTechType::MMD, wrHdl, wrCdo.get()));
     }
     if(!m_readKey_stg_hv.empty()){
         ATH_CHECK(loadHvData(ctx, m_readKey_stg_hv, DcsTechType::STG, wrHdl, wrCdo.get()));
     }
  
     // load TDAQ data
     if(m_loadTdaq){
         if(!m_readKey_mmg_tdaq.empty()) {
             ATH_CHECK(loadTDaqData(ctx, m_readKey_mmg_tdaq, DcsTechType::MMG, wrHdl, wrCdo.get()));
         }
         if(!m_readKey_stg_tdaq.empty()) {
             ATH_CHECK(loadTDaqData(ctx, m_readKey_stg_tdaq, DcsTechType::STG, wrHdl, wrCdo.get()));
         }
     }
     if(m_loadEltx){
         if(!m_readKey_mmg_eltx.empty()) {
             ATH_CHECK(loadELTXData(ctx, m_readKey_mmg_eltx, DcsTechType::MMG, wrHdl, wrCdo.get()));
         }
         if(!m_readKey_stg_eltx.empty()) {
             ATH_CHECK(loadELTXData(ctx, m_readKey_stg_eltx, DcsTechType::STG, wrHdl, wrCdo.get()));
         }
     }
   
     // insert/write data
     if (wrHdl.record(std::move(wrCdo)).isFailure()) {
         ATH_MSG_FATAL("Could not record " << wrHdl.key() 
                << " with EventRange " << wrHdl.getRange()
                << " into Conditions Store");
         return StatusCode::FAILURE;
     }      
     ATH_MSG_DEBUG("Recorded new " << wrHdl.key() << " with range " << wrHdl.getRange() << " into Conditions Store");
     
     return StatusCode::SUCCESS;
  
 }

◆ 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

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.

 {
   // If we didn't find any symlinks to add, just return the collection
   // from the base class.  Otherwise, return the extended collection.
   if (!m_extendedExtraObjects.empty()) {
     return m_extendedExtraObjects;
   }
   return BaseAlg::extraOutputDeps();
 }

◆ filterPassed()

virtual bool AthCommonReentrantAlgorithm< Gaudi::Algorithm >::filterPassed ( const EventContext & ctx ) const

inlinevirtualinherited

Definition at line 96 of file AthCommonReentrantAlgorithm.h.

                                                            {
     return execState( ctx ).filterPassed();
   }

◆ initialize()

StatusCode NswDcsDbAlg::initialize ( )

overridevirtual

Definition at line 17 of file NswDcsDbAlg.cxx.

                        {
  
     // retrievals
     ATH_MSG_DEBUG( "initializing " << name() );                
     ATH_CHECK(m_condSvc     .retrieve());
     ATH_CHECK(m_idHelperSvc.retrieve());
     
     // initialize read keys
     ATH_CHECK(m_readKey_mmg_hv.initialize(!m_readKey_mmg_hv.empty() && m_idHelperSvc->hasMM() ));
     ATH_CHECK(m_readKey_stg_hv.initialize(!m_readKey_stg_hv.empty() && m_idHelperSvc->hasSTGC() ));
     ATH_CHECK(m_readKey_mmg_tdaq.initialize(!m_readKey_mmg_tdaq.empty() && m_loadTdaq && m_idHelperSvc->hasMM() ));
     ATH_CHECK(m_readKey_stg_tdaq.initialize(!m_readKey_stg_tdaq.empty() && m_loadTdaq && m_idHelperSvc->hasSTGC() ));
     ATH_CHECK(m_readKey_mmg_eltx.initialize(!m_readKey_mmg_eltx.empty() && m_loadEltx && m_idHelperSvc->hasMM() ));
     ATH_CHECK(m_readKey_stg_eltx.initialize(!m_readKey_stg_eltx.empty() && m_loadEltx && m_idHelperSvc->hasSTGC() ));
     
     // write key for time/charge data
     ATH_CHECK(m_writeKey.initialize());
  
     CHECK(m_muonManagerKey.initialize());
  
     ATH_MSG_INFO("NswDcsAlg is using tdaq "<< m_loadTdaq << " and eltx " << m_loadEltx);
     
     return StatusCode::SUCCESS;
 }

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

bool AthCommonReentrantAlgorithm< Gaudi::Algorithm >::isClonable

overridevirtualinherited

Specify if the algorithm is clonable.

Reentrant algorithms are clonable.

Definition at line 68 of file AthCommonReentrantAlgorithm.cxx.

 {
   // Reentrant algorithms are clonable.
   return true;
 }

◆ isReEntrant()

virtual bool NswDcsDbAlg::isReEntrant ( ) const

inlineoverridevirtual

Definition at line 39 of file NswDcsDbAlg.h.

39 { return false; }

◆ loadELTXData()

StatusCode NswDcsDbAlg::loadELTXData	(	const EventContext &	ctx,
		const readKey_t &	readKey,
		const DcsTechType	tech,
		writeHandleDcs_t &	writeHandle,
		NswDcsDbData *	writeCdo
	)		const

private

Definition at line 217 of file NswDcsDbAlg.cxx.

                                                                                                                                                                            {
  
     // set up read handle
     SG::ReadCondHandle<CondAttrListCollection> readHandle{readKey, ctx};
     const CondAttrListCollection* readCdo{*readHandle}; 
     if(!readCdo){
         ATH_MSG_ERROR("Null pointer to the read conditions object");
         return StatusCode::FAILURE; 
     } 
     writeHandle.addDependency(readHandle);
     ATH_MSG_DEBUG("Size of CondAttrListCollection " << readHandle.fullKey() << " readCdo->size()= " << readCdo->size());
     ATH_MSG_DEBUG("Range of input is " << readHandle.getRange() << ", range of output is " << writeHandle.getRange());
  
     // This code is under development so lets mute unused variable warnings for now
     (void) writeCdo;
     (void) tech;
  
     // iterate through data
     CondAttrListCollection::const_iterator itr;
     for(itr = readCdo->begin(); itr != readCdo->end(); ++itr) {
  
         // channel ID and name
         const unsigned int chanNum  = itr->first;
         const std::string& chanName = readCdo->chanName(chanNum);
         if(chanName.empty()){
             ATH_MSG_DEBUG("Channel number "<< chanNum <<"has empty name");
             continue;
         }
         const coral::AttributeList& atr = itr->second;
         bool online = *(static_cast<const bool*>((atr["online"]).addressOfData()));
         ATH_MSG_DEBUG("found SCA " << chanName << " with status " << atr["online"] << " " << online);
         if(online) continue; // we only want to record things that are dead
         Identifier channelId{};
         bool isOk{false};
         if(!buildChannelIdForEltx(channelId, tech, chanName, isOk)){
           continue;
         }
         ATH_MSG_DEBUG(__FILE__<<":"<<__LINE__<<" "<<m_idHelperSvc->toString(channelId));
         writeCdo->setDataEltx(tech, channelId);
     }
     return StatusCode::SUCCESS;
  
 }

◆ loadHvData()

StatusCode NswDcsDbAlg::loadHvData	(	const EventContext &	ctx,
		const readKey_t &	readKey,
		const DcsTechType	tech,
		writeHandleDcs_t &	writeHandle,
		NswDcsDbData *	writeCdo
	)		const

private

Definition at line 111 of file NswDcsDbAlg.cxx.

                                                                                                                                                               {
  
     // set up read handle
     SG::ReadCondHandle<CondAttrListCollection> readHandle{readKey, ctx};
     const CondAttrListCollection* readCdo{*readHandle}; 
     if(!readCdo){
         ATH_MSG_ERROR("Null pointer to the read conditions object");
         return StatusCode::FAILURE; 
     } 
     writeHandle.addDependency(readHandle);
     ATH_MSG_DEBUG("Size of CondAttrListCollection " << readHandle.fullKey() << " readCdo->size()= " << readCdo->size());
     ATH_MSG_DEBUG("Range of input is " << readHandle.getRange() << ", range of output is " << writeHandle.getRange());
  
     // iterate through data
     CondAttrListCollection::const_iterator itr;
     unsigned int nChns = 0;
     for(itr = readCdo->begin(); itr != readCdo->end(); ++itr) {
  
         // channel ID and name
         const unsigned int chanNum  = itr->first;
         const std::string& chanName = readCdo->chanName(chanNum);
         if(chanName.empty()){
             ATH_MSG_DEBUG("Channel number "<< chanNum <<"has empty name");
             continue;
         }
         Identifier channelId{0};
         bool isOK = false;
         bool found = buildChannelIdForHv(channelId, tech, chanName, isOK);
         if(!found){
             if(!isOK){
                 ATH_MSG_ERROR("Could not identify valid channelId for channel "<<chanNum<<" with name "<< chanName<<"!");
                 THROW_EXCEPTION("NswDcsDbAlg: Could not identify valid channelId for HV channel");
             }
         continue;
         }
  
         // payload
         const coral::AttributeList& atr = itr->second;
  
         NswDcsDbData::DcsConstants dcs_data{};
         dcs_data.standbyVolt     = *(static_cast<const float*>((atr["v0Set"]).addressOfData()));
         dcs_data.readyVolt     = *(static_cast<const float*>((atr["v1Set"]).addressOfData()));
         dcs_data.fsmState  = MuonCond::getFsmStateEnum(*(static_cast<const std::string*>((atr["fsmCurrentState"]).addressOfData())));
         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())));
         
         writeCdo->setDataHv(tech, channelId, dcs_data);
         ++nChns;
     }
     ATH_MSG_VERBOSE("Retrieved data for "<<nChns<<" channels.");
  
     return StatusCode::SUCCESS;
 }

◆ loadTDaqData()

StatusCode NswDcsDbAlg::loadTDaqData	(	const EventContext &	ctx,
		const readKey_t &	readKey,
		const DcsTechType	tech,
		writeHandleDcs_t &	writeHandle,
		NswDcsDbData *	writeCdo
	)		const

private

Definition at line 167 of file NswDcsDbAlg.cxx.

                                                                                                                                                                 {
     // set up read handle
     SG::ReadCondHandle<CondAttrListCollection> readHandle{readKey, ctx};
     const CondAttrListCollection* readCdo{*readHandle}; 
     if(!readCdo){
         ATH_MSG_ERROR("Null pointer to the read conditions object");
         return StatusCode::FAILURE; 
     } 
     writeHandle.addDependency(readHandle);
     ATH_MSG_DEBUG("Size of CondAttrListCollection " << readHandle.fullKey() << " readCdo->size()= " << readCdo->size());
     ATH_MSG_DEBUG("Range of input is " << readHandle.getRange() << ", range of output is " << writeHandle.getRange());
  
     // iterate through data
     CondAttrListCollection::const_iterator itr;
     for(itr = readCdo->begin(); itr != readCdo->end(); ++itr) {
  
         // retrieve data
         const coral::AttributeList& atr = itr->second;
         std::string data = *(static_cast<const std::string *>((atr["data_array"]).addressOfData()));
  
         // unwrap the json and process the data
         nlohmann::json jx = nlohmann::json::parse(data);
         unsigned int nLB = 0; 
  
         // loop over lumi blocks and channels
         for (auto &yy : jx["holes"].items()) {
             nlohmann::json jt = yy.value();
  
             // channel ID and name
             Identifier channelId{0};
             bool isOK = false;
             uint elink{0};
             bool found = buildChannelIdForTDaq(channelId, elink, tech, jt["channelName"], isOK);
             if(!found){
                 if(!isOK)
                     ATH_MSG_DEBUG("Could not identify valid channelId for channel "<<jt["channelId"]<<" with name "<< jt["channelName"]<<"! Skipping...");
                 continue;
             }
             // write data
             int channelDead = jt["channelDead"];
             writeCdo->setDataTDaq(tech, channelId, jt["hole_iovSince"], jt["hole_iovUntil"], elink, channelDead );
             ATH_MSG_VERBOSE(m_idHelperSvc->toString(channelId)<<" " << jt["channelName"] << " " << jt["hole_iovSince"]<<" " <<jt["hole_iovUntil"]<<" " <<  elink<<" "<<channelDead );
             ++nLB;
         }
         ATH_MSG_VERBOSE("Retrieved data for "<<nLB<<" entries (combinations of lumi block and channel).");
     }
  
     return StatusCode::SUCCESS;
 }

◆ msg() [1/2]

MsgStream& AthCommonMsg< Gaudi::Algorithm >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                 {
     return this->msgStream();
   }

◆ msg() [2/2]

MsgStream& AthCommonMsg< Gaudi::Algorithm >::msg ( const MSG::Level lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                   {
     return this->msgStream(lvl);
   }

◆ msgLvl()

bool AthCommonMsg< Gaudi::Algorithm >::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                                {
     return this->msgLevel(lvl);
   }

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

◆ processHvData()

StatusCode NswDcsDbAlg::processHvData ( const EventContext & ctx ) const

private

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

   {
     h.renounce();
     PBASE::renounce (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.

                                                           {
     handlesArray.renounce();
   }

◆ setFilterPassed()

virtual void AthCommonReentrantAlgorithm< Gaudi::Algorithm >::setFilterPassed	(	bool	state,
		const EventContext &	ctx
	)		const

inlinevirtualinherited

Definition at line 100 of file AthCommonReentrantAlgorithm.h.

                                                                             {
     execState( ctx ).setFilterPassed( state );
   }

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

 {
   return BaseAlg::sysExecute (ctx);
 }

◆ 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 InputMakerBase, and HypoBase.

Definition at line 61 of file AthCommonReentrantAlgorithm.cxx.

                                                                {
   StatusCode sc=AthCommonDataStore<AthCommonMsg<BaseAlg>>::sysInitialize();
  
   if (sc.isFailure()) {
     return sc;
   }
   
   ServiceHandle<ICondSvc> cs("CondSvc",name());
   for (auto h : outputHandles()) {
     if (h->isCondition() && h->mode() == Gaudi::DataHandle::Writer) {
       // do this inside the loop so we don't create the CondSvc until needed
       if ( cs.retrieve().isFailure() ) {
         ATH_MSG_WARNING("no CondSvc found: won't autoreg WriteCondHandles");
         return StatusCode::SUCCESS;
       }      
       if (cs->regHandle(this,*h).isFailure()) {
         sc = StatusCode::FAILURE;
         ATH_MSG_ERROR("unable to register WriteCondHandle " << h->fullKey()
                       << " with CondSvc");
       }
     }
   }
   return sc;  
 }

◆ sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::sysStart ( )

overridevirtualinherited

Handle START transition.

We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.

◆ updateVHKA()

void AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::updateVHKA ( Gaudi::Details::PropertyBase & )

inlineinherited

Definition at line 308 of file AthCommonDataStore.h.

                                                {
     // debug() << "updateVHKA for property " << p.name() << " " << p.toString() 
     //         << "  size: " << m_vhka.size() << endmsg;
     for (auto &a : m_vhka) {
       std::vector<SG::VarHandleKey*> keys = a->keys();
       for (auto k : keys) {
         k->setOwner(this);
       }
     }
   }

Member Data Documentation

◆ m_condSvc

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

private

Definition at line 64 of file NswDcsDbAlg.h.

◆ m_detManager

const MuonGM::MuonDetectorManager* NswDcsDbAlg::m_detManager {nullptr}

private

Definition at line 84 of file NswDcsDbAlg.h.

◆ m_detStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_detStore

privateinherited

Pointer to StoreGate (detector store by default)

Definition at line 393 of file AthCommonDataStore.h.

◆ m_evtStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< Gaudi::Algorithm > >::m_evtStore

privateinherited

Pointer to StoreGate (event store by default)

Definition at line 390 of file AthCommonDataStore.h.

◆ m_extendedExtraObjects

DataObjIDColl AthCommonReentrantAlgorithm< Gaudi::Algorithm >::m_extendedExtraObjects

privateinherited

Extra output dependency collection, extended by AthAlgorithmDHUpdate to add symlinks.

Empty if no symlinks were found.

Definition at line 114 of file AthCommonReentrantAlgorithm.h.

◆ m_idHelperSvc

ServiceHandle<Muon::IMuonIdHelperSvc> NswDcsDbAlg::m_idHelperSvc {this, "MuonIdHelperSvc", "Muon::MuonIdHelperSvc/MuonIdHelperSvc"}

private

Definition at line 65 of file NswDcsDbAlg.h.

◆ m_loadEltx

Gaudi::Property<bool> NswDcsDbAlg::m_loadEltx {this, "LoadEltx",false,"enable the processing of SCAs in the NswDcsDbAlg"}

private

Definition at line 79 of file NswDcsDbAlg.h.

◆ m_loadTdaq

Gaudi::Property<bool> NswDcsDbAlg::m_loadTdaq {this, "LoadTdaq",false,"enable the processing of Elinks in the NswDcsDbAlg"}

private

Definition at line 78 of file NswDcsDbAlg.h.

◆ m_muonManagerKey

SG::ReadCondHandleKey<MuonGM::MuonDetectorManager> NswDcsDbAlg::m_muonManagerKey

private

Initial value:

{
        this, "DetectorManagerKey", "MuonDetectorManager",
        "Key of input MuonDetectorManager condition data"}

Definition at line 81 of file NswDcsDbAlg.h.

◆ 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

Definition at line 75 of file NswDcsDbAlg.h.

◆ 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

Definition at line 69 of file NswDcsDbAlg.h.

◆ m_readKey_mmg_tdaq

readKey_t NswDcsDbAlg::m_readKey_mmg_tdaq {this, "ReadKey_MMG_TDAQ", "", "Key of input MMG condition data for TDAQ"}

private

Definition at line 72 of file NswDcsDbAlg.h.

◆ 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

Definition at line 76 of file NswDcsDbAlg.h.

◆ 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

Definition at line 70 of file NswDcsDbAlg.h.

◆ m_readKey_stg_tdaq

readKey_t NswDcsDbAlg::m_readKey_stg_tdaq {this, "ReadKey_STG_TDAQ", "", "Key of input STG condition data for TDAQ"}

private

Definition at line 73 of file NswDcsDbAlg.h.

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

writeKey_t NswDcsDbAlg::m_writeKey {this, "WriteKey", "NswDcsDbData", "Key of output data object" }

private

Definition at line 67 of file NswDcsDbAlg.h.

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

Public Member Functions

Protected Member Functions

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ DcsDataType

◆ DcsTechType

◆ readKey_t

◆ StoreGateSvc_t

◆ writeHandleDcs_t

◆ writeKey_t

Constructor & Destructor Documentation

◆ ~NswDcsDbAlg()

Member Function Documentation

◆ buildChannelIdForEltx()

◆ buildChannelIdForHv()

◆ buildChannelIdForTDaq()

◆ cardinality()

◆ declareGaudiProperty() [1/4]

◆ declareGaudiProperty() [2/4]

◆ declareGaudiProperty() [3/4]

◆ declareGaudiProperty() [4/4]

◆ declareProperty() [1/6]

◆ declareProperty() [2/6]

◆ declareProperty() [3/6]

◆ declareProperty() [4/6]

◆ declareProperty() [5/6]

◆ declareProperty() [6/6]

◆ detStore()

◆ evtStore() [1/2]

◆ evtStore() [2/2]

◆ execute()

◆ extraDeps_update_handler()

◆ extraOutputDeps()

◆ filterPassed()

◆ initialize()

◆ inputHandles()

◆ isClonable()

◆ isReEntrant()

◆ loadELTXData()

◆ loadHvData()

◆ loadTDaqData()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ outputHandles()

◆ processHvData()

◆ renounce()

◆ renounceArray()

◆ setFilterPassed()

◆ sysExecute()

◆ sysInitialize()

◆ sysStart()

◆ updateVHKA()

Member Data Documentation

◆ m_condSvc

◆ m_detManager

◆ m_detStore

◆ m_evtStore

◆ m_extendedExtraObjects

◆ m_idHelperSvc

◆ m_loadEltx

◆ m_loadTdaq

◆ m_muonManagerKey

◆ m_readKey_mmg_eltx

◆ m_readKey_mmg_hv

◆ m_readKey_mmg_tdaq

◆ m_readKey_stg_eltx

◆ m_readKey_stg_hv

◆ m_readKey_stg_tdaq

◆ m_varHandleArraysDeclared

◆ m_vhka

◆ m_writeKey