IOVDbTestAlg Class Reference

Algorithm to test writing conditions data and reading them back. More...

#include <IOVDbTestAlg.h>

Inheritance diagram for IOVDbTestAlg:

Collaboration diagram for IOVDbTestAlg:

Public Member Functions
	IOVDbTestAlg (const std::string &name, ISvcLocator *pSvcLocator)
virtual	~IOVDbTestAlg ()
virtual StatusCode initialize	ATLAS_NOT_THREAD_SAFE () override
virtual StatusCode	execute (const EventContext &ctx) const override
virtual StatusCode	finalize () 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
typedef ServiceHandle< StoreGateSvc >	StoreGateSvc_t

Private Member Functions
StatusCode	createCondObjects (const EventContext &ctx) const
StatusCode	printCondObjects () const
StatusCode	streamOutCondObjects ()
StatusCode	registerCondObjects ()
StatusCode	readWithBeginRun ()
void	waitForSecond () const
StatusCode	testCallBack (IOVSVC_CALLBACK_ARGS)
StatusCode	registerIOV (const CLID &clid)
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
BooleanProperty	m_writeCondObjs {this, "WriteCondObjs", false}
BooleanProperty	m_regIOV {this, "RegisterIOV", false}
BooleanProperty	m_readWriteCool {this, "ReadWriteCool", false}
BooleanProperty	m_twoStepWriteReg {this, "TwoStepWriteReg", false}
BooleanProperty	m_createExtraChans {this, "CreateExtraChanns", false}
BooleanProperty	m_nameChans {this, "NameChanns", false}
BooleanProperty	m_readInInit {this, "ReadInInit", false}
BooleanProperty	m_writeOnlyCool {this, "WriteOnlyCool", false}
BooleanProperty	m_fancylist {this, "FancyList", false}
BooleanProperty	m_printLB {this, "PrintLB", false}
BooleanProperty	m_writeNewTag {this, "WriteNewTag", false}
BooleanProperty	m_readNewTag {this, "ReadNewTag", false}
BooleanProperty	m_noStream {this, "NoStream", false}
IntegerProperty	m_regTime {this, "RegTime", 0, "Register time in sec"}
StringProperty	m_streamName {this, "StreamName", "CondStream1"}
IntegerProperty	m_run {this, "run", 0}
BooleanProperty	m_online {this, "online", false}
StringProperty	m_tagID {this, "TagID", ""}
ServiceHandle< IIOVRegistrationSvc >	m_regSvc
ToolHandle< IAthenaOutputStreamTool >	m_streamer
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

Algorithm to test writing conditions data and reading them back.

Definition at line 35 of file IOVDbTestAlg.h.

Member Typedef Documentation

StoreGateSvc_t

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

privateinherited

Definition at line 388 of file AthCommonDataStore.h.

Constructor & Destructor Documentation

IOVDbTestAlg()

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

Definition at line 36 of file IOVDbTestAlg.cxx.

                                                                          :
        AthReentrantAlgorithm(name, pSvcLocator),
        m_regSvc("IOVRegistrationSvc", name),
        m_streamer ("CondStream1")
{
}

~IOVDbTestAlg()

IOVDbTestAlg::~IOVDbTestAlg ( )

virtual

Definition at line 45 of file IOVDbTestAlg.cxx.

{ }

Member Function Documentation

ATLAS_NOT_THREAD_SAFE()

virtual StatusCode initialize IOVDbTestAlg::ATLAS_NOT_THREAD_SAFE ( )

overridevirtual

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.

Override this to return 0 for reentrant algorithms.

Definition at line 75 of file AthCommonReentrantAlgorithm.cxx.

{
  return 0;
}

createCondObjects()

StatusCode IOVDbTestAlg::createCondObjects ( const EventContext &  ctx ) const

private

Definition at line 142 of file IOVDbTestAlg.cxx.

{
    ATH_MSG_INFO ("in createCondObjects()");
 
    // Create IOVDbTestMDTEleMap
    IOVDbTestMDTEleMap* elemMap = new IOVDbTestMDTEleMap;
    unsigned long long timestamp = ctx.eventID().time_stamp();
    if (timestamp) 
        elemMap->set(ctx.eventID().time_stamp(),"mdt element map");
    else 
        elemMap->set(ctx.eventID().run_number(), ctx.eventID().event_number(), "mdt element map");
    
  
    // Must provide a key which is used as the name to create the folder
    ATH_CHECK( detStore()->record(elemMap, "/IOVDbTest/IOVDbTestMDTEleMap") );
 
    // Create IOVDbTestMDTEleMapColl
    IOVDbTestMDTEleMapColl* elemMapColl = new IOVDbTestMDTEleMapColl;
 
    // Add in 10 maps, set indices
    unsigned int offset = 0;
    if (m_createExtraChans) offset = 100;
    for (unsigned int i = 0; i < 10; ++i) {
        IOVDbTestMDTEleMap* elemMap = new IOVDbTestMDTEleMap;
 
        unsigned long long timestamp = ctx.eventID().time_stamp();
        if (timestamp) 
            elemMap->set(ctx.eventID().time_stamp() + 10*i, "mdt element map");
        else 
            elemMap->set(ctx.eventID().run_number() + i, ctx.eventID().event_number(), "mdt element map");
    
        elemMapColl->push_back(elemMap);
        elemMapColl->add(2*i+1+i + offset);
    }
    
    // Must provide a key which is used as the name to create the folder
    ATH_CHECK( detStore()->record(elemMapColl, "/IOVDbTest/IOVDbTestMDTEleMapColl") );
    
    // Create IOVDbTestAmdbCorrection
    IOVDbTestAmdbCorrection* amdbCorr =   new IOVDbTestAmdbCorrection;
    HepGeom::Point3D<double> x(1.0, 2.0, 3.0);
    HepGeom::Point3D<double> y(4.0, 5.0, 6.0);
    if (m_writeNewTag) {
        // writing with new tag, set to different values
        x = HepGeom::Point3D<double>(11.0, 22.0, 33.0);
        y = HepGeom::Point3D<double>(44.0, 55.0, 66.0);
    }
    amdbCorr->set(x, y, "amdb correction");
  
    ATH_CHECK( detStore()->record(amdbCorr, "/IOVDbTest/IOVDbTestAMDBCorrection") );
 
    // Create an attribute list
 
    // Create spec
    coral::AttributeListSpecification* attrSpec = new coral::AttributeListSpecification();
    attrSpec->extend("xPosition", "float");
    attrSpec->extend("id", "int");
    attrSpec->extend("name", "string");
 
    if (!attrSpec->size()) {
        ATH_MSG_ERROR (" Attribute list specification is empty");
        return(StatusCode::FAILURE);
    } 
 
    // FIX this 
    //std::ostringstream attrStr;
    //attrSpec->print( attrStr );
    //log << MSG::DEBUG << "Attribute spec " << attrStr.str() << endmsg;
 
    AthenaAttributeList* attrList = new AthenaAttributeList(*attrSpec);
    (*attrList)["xPosition"].setValue((float)m_run);
    (*attrList)["id"].setValue((int)7);
    (*attrList)["name"].setValue(std::string("TestAttrList"));
    if (m_writeNewTag) {
        // writing with new tag, set to different values
        (*attrList)["xPosition"].setValue((float)125.0);
        (*attrList)["id"].setValue((int)27);
        (*attrList)["name"].setValue(std::string("TestAttrListNEWTAG"));
    }
    std::ostringstream attrStr1;
    // FIXME
    attrList->toOutputStream( attrStr1 );
    // attrList->print(std::cout);
    ATH_MSG_DEBUG( "Attribute list " << attrStr1.str() );
 
    ATH_CHECK( detStore()->record(attrList, "/IOVDbTest/IOVDbTestAttrList") );
 
    // optionally create a second 'fancy' attributelist testing more datatypes
    // including bool, CLOB and BLOB types
    if (m_fancylist) {
        coral::AttributeListSpecification* fanSpec = new coral::AttributeListSpecification();
        fanSpec->extend("FanBool","bool");
        fanSpec->extend("FanInt","int");
        fanSpec->extend("FanUInt","unsigned int");
        fanSpec->extend("FanI64","long long");
        fanSpec->extend("FanU64","unsigned long long");
        fanSpec->extend("FanFloat","float");
        fanSpec->extend("FanDouble","double");
        fanSpec->extend("FanSmallString","string");
        fanSpec->extend("FanBigString","string");
        fanSpec->extend("FanBlob","blob");
        AthenaAttributeList* fanList=new AthenaAttributeList(*fanSpec);
        // set values, note new style access methods
        (*fanList)["FanBool"].data<bool>()=true;
        (*fanList)["FanInt"].data<int>()=-12345;
        (*fanList)["FanUInt"].data<unsigned int>()=12345;
        (*fanList)["FanI64"].data<long long>()=-98765432100LL;
        (*fanList)["FanU64"].data<unsigned long long>()=98765432100LL;
        (*fanList)["FanFloat"].data<float>()=1.2345;
        (*fanList)["FanDouble"].data<double>()=1.23456789;
        (*fanList)["FanSmallString"].data<std::string>()="small string";
        (*fanList)["FanBigString"].data<std::string>()="potentially long string";
        // special construction to set blob type
        coral::Blob& blob=(*fanList)["FanBlob"].data<coral::Blob>();
        unsigned int blobsize=2000;
        blob.resize(blobsize);
        unsigned char* p=static_cast<unsigned char*>(blob.startingAddress());
        for (unsigned int i=0;i<blobsize;++i,++p) *p=(i % 256);
        // print out attributelist
        std::ostringstream fanstr;
        fanList->toOutputStream(fanstr);
        ATH_MSG_DEBUG( "Fancy Attribute list " << fanstr.str() );
        ATH_CHECK( detStore()->record(fanList, "/IOVDbTest/IOVDbTestFancyList") );
    }
 
    // Create an attribute list collection
  
    // Use existing spec
    CondAttrListCollection* attrListColl = new CondAttrListCollection(true);
 
    // Add three attr lists
    coral::AttributeList attrList0(*attrSpec);
    attrList0["xPosition"].setValue((float)35.0);
    attrList0["id"].setValue((int)17);
    attrList0["name"].setValue(std::string("TestAttrList"));
    CondAttrListCollection::ChanNum chanNum = 16;
    
    std::ostringstream attrStr2;
    attrList0.toOutputStream( attrStr2 );
    ATH_MSG_DEBUG( "ChanNum " << chanNum << " Attribute list " << attrStr2.str() );
    attrListColl->add(chanNum, attrList0);
 
    coral::AttributeList attrList1(*attrSpec);
    attrList1["xPosition"].setValue((float)45.0);
    attrList1["id"].setValue((int)27);
    attrList1["name"].setValue(std::string("TestAttrList"));
    chanNum = 26;
    
    std::ostringstream attrStr3;
    attrList1.toOutputStream( attrStr3 );
    ATH_MSG_DEBUG( "ChanNum " << chanNum << " Attribute list " << attrStr3.str() );
    attrListColl->add(chanNum, attrList1);
 
    coral::AttributeList attrList2(*attrSpec);
    attrList2["xPosition"].setValue((float)55.0);
    attrList2["id"].setValue((int)37);
    attrList2["name"].setValue(std::string("TestAttrList"));
    chanNum = 36;
    
    std::ostringstream attrStr4;
    attrList2.toOutputStream( attrStr4 );
    ATH_MSG_DEBUG( "ChanNum " << chanNum << " Attribute list " << attrStr4.str() );
    attrListColl->add(chanNum, attrList2);
 
    if(m_createExtraChans) {
        // Two more channels
        coral::AttributeList attrList3(*attrSpec);
        attrList3["xPosition"].setValue((float)65.0);
        attrList3["id"].setValue((int)47);
        attrList3["name"].setValue(std::string("TestAttrList"));
        chanNum = 46;
    
        std::ostringstream attrStr5;
        attrList3.toOutputStream( attrStr5 );
        ATH_MSG_DEBUG( "ChanNum " << chanNum << " Attribute list " << attrStr5.str() );
        attrListColl->add(chanNum, attrList3);
 
        // Add in new IOV with min run == 4
        IOVRange range(IOVTime(4, IOVTime::MINEVENT), IOVTime(IOVTime::MAXRUN, IOVTime::MAXEVENT));
        attrListColl->add(chanNum, range);
        ATH_MSG_DEBUG( "Add min : since " << range.start().run() << " " << range.start().event()
                       << " till " << range.stop().run() << " " << range.stop().event() );
 
        coral::AttributeList attrList4(*attrSpec);
        attrList4["xPosition"].setValue((float)75.0);
        attrList4["id"].setValue((int)57);
        attrList4["name"].setValue(std::string("TestAttrList"));
        chanNum = 56;
    
        std::ostringstream attrStr6;
        attrList4.toOutputStream( attrStr6 );
        ATH_MSG_DEBUG( "ChanNum " << chanNum << " Attribute list " << attrStr6.str() );
        attrListColl->add(chanNum, attrList4);
 
        // Add in new IOV with min run == 5
        IOVRange range1(IOVTime(5, IOVTime::MINEVENT), IOVTime(IOVTime::MAXRUN, IOVTime::MAXEVENT));
        attrListColl->add(chanNum, range1);
        ATH_MSG_DEBUG( "Add min : since " << range1.start().run() << " " << range1.start().event() << " till " << range1.stop().run() << " " << range1.stop().event() );
    }
    // add names to the channels if needed
    if (m_nameChans) {
      ATH_MSG_DEBUG( "Name channels in CondAttrListCollection" );
      for (CondAttrListCollection::const_iterator citr=attrListColl->begin();
       citr!=attrListColl->end();++citr) {
    CondAttrListCollection::ChanNum chan=citr->first;
    std::ostringstream name;
    name << "Name_" << chan;
    attrListColl->add(chan,name.str());
      }
    }
 
    ATH_CHECK( detStore()->record(attrListColl, "/IOVDbTest/IOVDbTestAttrListColl") );
 
    return StatusCode::SUCCESS;
}

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.

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

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

{ return m_evtStore; }

execute()

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

overridevirtual

Definition at line 553 of file IOVDbTestAlg.cxx.

                                                               {
 
    // There are different scenario for conditions data:
    // 
    //  A) Calculating and writing conditions
    //
    //    1) Loop over events and accumulate "averages" 
    //
    //    2) At the desired moment, e.g. after N events or at the end
    //       of the job, calculate the conditions data to be written
    //       out by creating the corresponding objects and store in the
    //       DetectorStore
    //
    //    3) Write out objects with the IAthenaOutputStreamTool - done
    //       in finalize.
    //
    //    4) Finally, one must "register" the objects written out in
    //       the IOV DB. This writes and IOV and a ref to each object,
    //       and is done in the finalize method.
    //
    //  B) Reading back in conditions data to analyse it
    //
    //    1) Aside from specifying the correct jobOptions, this is
    //       simply done by doing a standard StoreGate retrieve from
    //       the DetectorStore.
 
    if (msgLvl (MSG::DEBUG)) {
      msg() << MSG::DEBUG << "Event (run,ev,lb:time): [" << ctx.eventID().run_number() << "," << ctx.eventID().event_number();
      if (m_printLB) msg() << "," << ctx.eventID().lumi_block();
      msg()  << ":" << ctx.eventID().time_stamp() << "]" << endmsg;
    }
 
    if (m_writeCondObjs||m_noStream) {
 
        // We create the conditions objects only at run == 2, event == 5
        if (2 != ctx.eventID().run_number() || 5 != ctx.eventID().event_number()) {
            ATH_MSG_DEBUG( "Event NOT selected for creating conditions objects " );
            return StatusCode::SUCCESS;
        }
        
        ATH_MSG_DEBUG( "Creating condtions objects " );
        ATH_CHECK( createCondObjects(ctx) );
 
        //  Read objects from DetectorStore
        if(!m_noStream){
          ATH_CHECK( printCondObjects() );
    }
    }
    else {
    
        ATH_MSG_DEBUG( "Calling printCondObjects" <<m_online<< "\t"<<ctx.eventID().run_number()<<"\t"<<ctx.eventID().event_number() );
 
        //  Read objects from DetectorStore
        if (m_online && 2 == ctx.eventID().run_number() && 9 == ctx.eventID().event_number())
            waitForSecond();
        ATH_CHECK( printCondObjects() );
    }
    
    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();
  }

finalize()

StatusCode IOVDbTestAlg::finalize ( )

overridevirtual

Definition at line 616 of file IOVDbTestAlg.cxx.

                                 {
    ATH_MSG_INFO( "in finalize()" );
 
    if (m_writeCondObjs) {
        // Stream out and register objects here
        ATH_MSG_DEBUG( "Stream out objects directly " );
        ATH_CHECK( streamOutCondObjects() );
        ATH_MSG_DEBUG( "Streamed out OK " );
    }
    if(m_regIOV) {
        ATH_CHECK( registerCondObjects() );
        ATH_MSG_DEBUG( "Register OK " );
    }
  
    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;
}

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.

printCondObjects()

StatusCode IOVDbTestAlg::printCondObjects ( ) const

private

Definition at line 360 of file IOVDbTestAlg.cxx.

                                                {
    ATH_MSG_INFO( "in printCondObjects()" );
 
    // IOVDbTestMDTEleMap
    const IOVDbTestMDTEleMap* elemMap = nullptr;
    ATH_CHECK( detStore()->retrieve(elemMap, "/IOVDbTest/IOVDbTestMDTEleMap") );
    ATH_MSG_INFO( "Retrieved IOVDbTestMDTEleMap " );
    
    ATH_MSG_INFO( "Found " <<  elemMap->name() 
                  << " run "   <<  elemMap->runNumber() 
                  << " event " <<  elemMap->eventNumber()
                  << " time  " <<  elemMap->timeStamp() );
 
 
 
    // IOVDbTestAmdbCorrection
    const IOVDbTestAmdbCorrection* amdbCorr = nullptr;
    ATH_CHECK( detStore()->retrieve(amdbCorr, "/IOVDbTest/IOVDbTestAMDBCorrection") );
    ATH_MSG_INFO ("Retrieved /IOVDbTest/IOVDbTestAMDBCorrection" );
 
    HepGeom::Point3D<double> trans = amdbCorr->getTranslation();
    HepGeom::Point3D<double> rot   = amdbCorr->getRotation();
  
    ATH_MSG_INFO( "Found " <<  amdbCorr->name() 
                  << " trans " << trans.x() << " " << trans.y() << " " << trans.z()
                  << " rot " <<  rot.x() << " " << rot.y() << " " << rot.z() );
 
    
    if (m_readNewTag) {
        // IOVDbTestAmdbCorrection
        const IOVDbTestAmdbCorrection* amdbCorr = nullptr;
        ATH_CHECK( detStore()->retrieve(amdbCorr, "/IOVDbTest/IOVDbTestAMDBCorrection-NEWTAG") );
        ATH_MSG_INFO( "Retrieved /IOVDbTest/IOVDbTestAMDBCorrection-NEWTAG" );
 
        HepGeom::Point3D<double> trans = amdbCorr->getTranslation();
        HepGeom::Point3D<double> rot   = amdbCorr->getRotation();
  
        ATH_MSG_INFO( "Found " <<  amdbCorr->name() 
                      << " trans " << trans.x() << " " << trans.y() << " " << trans.z()
                      << " rot " <<  rot.x() << " " << rot.y() << " " << rot.z() );
    }
    
 
    const AthenaAttributeList*    attrList     = nullptr;
    const CondAttrListCollection* attrListColl = nullptr;
 
    if (!m_twoStepWriteReg && m_readWriteCool) {
    // AttrList
        ATH_CHECK( detStore()->retrieve(attrList, "/IOVDbTest/IOVDbTestAttrList") );
        ATH_MSG_DEBUG( "Retrieved IOVDbTestAttrList" );
  
    std::ostringstream attrStr1;
    attrList->print( attrStr1 );
    ATH_MSG_DEBUG( "Attribute list " << attrStr1.str() );
 
        if (m_readNewTag) {
            // AttrList
            ATH_CHECK( detStore()->retrieve(attrList, "/IOVDbTest/IOVDbTestAttrList-NEWTAG") );
            ATH_MSG_DEBUG( "Retrieved IOVDbTestAttrList-NEWTAG" );
  
            std::ostringstream attrStr1;
            attrList->print( attrStr1 );
            ATH_MSG_DEBUG( "Attribute list NEWTAG: " << attrStr1.str() );
        }
 
    // fancy attributelist
    if (m_fancylist) {
            ATH_MSG_DEBUG( detStore()->retrieve(attrList, "/IOVDbTest/IOVDbTestFancyList") );
            ATH_MSG_DEBUG( "Retrieved IOVDbTestFancyList" );
            std::ostringstream fanstr;
            attrList->print( fanstr );
            ATH_MSG_DEBUG( "Fancy Attribute list " << fanstr.str() );
            // for the blob type, check the actual data is correct
            const coral::Blob& blob=(*attrList)["FanBlob"].data<coral::Blob>();
            const unsigned char* p=static_cast<const unsigned char*>
                (blob.startingAddress());
            int nerr=0;
            for (int i=0;i<blob.size();++i,++p) if (*p!=(i % 256)) ++nerr;
            if (nerr>0) ATH_MSG_ERROR(  "Blob has " << nerr << 
                                        " data mismatches!" );
    }
 
    // AttrListColl
    ATH_CHECK( detStore()->retrieve(attrListColl, "/IOVDbTest/IOVDbTestAttrListColl") );
        ATH_MSG_DEBUG( "Retrieved IOVDbTestAttrListColl" );
  
 
    std::ostringstream attrStr2;
    
    // Loop over collection
    CondAttrListCollection::const_iterator first = attrListColl->begin();
    CondAttrListCollection::const_iterator last  = attrListColl->end();
    for (; first != last; ++first) {
 
            if (msgLvl (MSG::DEBUG)) {
              std::ostringstream attrStr1;
              (*first).second.toOutputStream( attrStr1 );
              msg() << MSG::DEBUG << "ChanNum " << (*first).first;
              // print out the name if present
              if (attrListColl->name_size()>0) {
                CondAttrListCollection::name_const_iterator 
                  nitr=attrListColl->chanNamePair((*first).first);
                if (nitr!=attrListColl->name_end())
                  msg() << MSG::DEBUG << " name " << nitr->second;
              }
              msg() << MSG::DEBUG << 
                " Attribute list " << attrStr1.str() << endmsg;
            }
 
            // Print out range if it exits
            CondAttrListCollection::ChanNum chanNum = (*first).first;
            CondAttrListCollection::iov_const_iterator iovIt = attrListColl->chanIOVPair(chanNum);
            if (iovIt != attrListColl->iov_end()) {
              const IOVRange& range = (*iovIt).second;
              if(range.start().isTimestamp()) {
                ATH_MSG_DEBUG( "Range timestamp : since " << range.start().timestamp()
                               << " till " << range.stop().timestamp() );
              }
              else {
                ATH_MSG_DEBUG( "Range R/E : since " << range.start().run() << " " 
                               << range.start().event()
                               << " till " << range.stop().run() << " " 
                               << range.stop().event() );
              }
        }
        else {
              ATH_MSG_DEBUG( "No range found " );
            }
    }
 
        // Simulation and digitization parameters:
 
    if ( detStore()->retrieve(attrList, "/Simulation/Parameters").isFailure() ) {
        // May not have been added - just a warning
            ATH_MSG_WARNING( "Could not retrieve Simulation parameters" );
    }
        else {
          ATH_MSG_DEBUG( "Retrieved Simulation parameters" );
          std::ostringstream attrStr;
          attrList->print( attrStr );
          ATH_MSG_DEBUG( "Attribute list " << attrStr.str() );
    }
  
    if (detStore()->retrieve(attrList, "/Digitization/Parameters").isFailure()) {
            // May not have been added - just a warning
            ATH_MSG_WARNING( "Could not retrieve Digitization parameters" );
        }
        else {
            ATH_MSG_DEBUG( "Retrieved Digitization parameters" );
            std::ostringstream attrStr;
            attrList->print( attrStr );
            ATH_MSG_DEBUG( "Attribute list " << attrStr.str() );
    }
    }
    
 
    // IOVDbTestMDTEleMapColl
 
//    if (m_readWriteCool) {
    
    const IOVDbTestMDTEleMapColl* elemMapColl = nullptr;
    ATH_CHECK( detStore()->retrieve(elemMapColl, "/IOVDbTest/IOVDbTestMDTEleMapColl") );
    ATH_MSG_INFO( "Retrieved IOVDbTestMDTEleMapColl " );
  
    // Make sure the channel vector is filled
    if (elemMapColl->size() != elemMapColl->chan_size()) {
        ATH_MSG_ERROR( "Must fill in channel numbers! Number of objects: " << elemMapColl->size()
                       << "  Number of channels: " << elemMapColl->chan_size() );
        return(StatusCode::FAILURE);       
    }
    // Print out IOVs if they are there
    bool hasIOVs = (elemMapColl->iov_size() == elemMapColl->size());
    IOVDbTestMDTEleMapColl::chan_const_iterator itChan = elemMapColl->chan_begin();
    IOVDbTestMDTEleMapColl::iov_const_iterator  itIOV  = elemMapColl->iov_begin();
    for (unsigned int i = 0; i < elemMapColl->size(); ++i, ++itChan) {
        const IOVDbTestMDTEleMap* elemMap = (*elemMapColl)[i];
        msg() << MSG::INFO << "Found " <<  elemMap->name() 
            << " run "   <<  elemMap->runNumber() 
            << " event " <<  elemMap->eventNumber()
            << " time  " <<  elemMap->timeStamp()
            << " channel " << (*itChan);
        if(hasIOVs) {
            msg() << MSG::INFO << " iov " <<  (*itIOV);
            ++itIOV;
        }
        msg() << MSG::INFO << endmsg;
    }
//    }
    return StatusCode::SUCCESS;
}

readWithBeginRun()

StatusCode IOVDbTestAlg::readWithBeginRun ( )

private

Definition at line 124 of file IOVDbTestAlg.cxx.

                                         {
    ATH_MSG_INFO( "in readWithBeginRun()" );
 
    // As a result of the restructuring the EventIncident class (dropping the reference to EventInfo)
    // the old mechanism of overriding run&event&time is no longer working.
    // If we need this functionality, then we need to find a new way of implementing it.
    // For the time being this function simply fires a BeginRun incident using the EventContext, without overriding anything
 
    ServiceHandle<IIncidentSvc> incSvc("IncidentSvc", name() );
    ATH_CHECK( incSvc.retrieve() );
 
    incSvc->fireIncident( Incident(name(), IncidentType::BeginRun, Gaudi::Hive::currentContext()) );
 
    return StatusCode::SUCCESS;
}

registerCondObjects()

StatusCode IOVDbTestAlg::registerCondObjects ( )

private

Definition at line 665 of file IOVDbTestAlg.cxx.

                                 {
    ATH_MSG_DEBUG( "entering registerCondObject " );
 
    // Register the IOV DB with the conditions data written out
    std::string tag = "no tag";
    if (m_tagID!="") {
        tag = "tag MDTEleMap_" + m_tagID;
        ATH_CHECK( m_regSvc->registerIOV("IOVDbTestMDTEleMap", "MDTEleMap_"+m_tagID,m_run,IOVTime::MAXRUN,IOVTime::MINEVENT,IOVTime::MAXEVENT) );
    } else {
        ATH_CHECK( m_regSvc->registerIOV("IOVDbTestMDTEleMap", "") );
    }
    ATH_MSG_DEBUG( "registered IOVDbTestMDTEleMap with " << tag );
 
    // For IOVDbTestAmdbCorrection use time (in sec)
    uint64_t start=static_cast<long long>(m_regTime)*1000000000LL;
    uint64_t stop = IOVTime::MAXTIMESTAMP;
    tag = "no tag";
    if (m_tagID!="") {
        tag = "tag AmdbCorrection_" + m_tagID;
        ATH_CHECK( m_regSvc->registerIOV("IOVDbTestAmdbCorrection", "AmdbCorrection_"+m_tagID, start, stop) );
    } else {
        ATH_CHECK( m_regSvc->registerIOV("IOVDbTestAmdbCorrection", "", start, stop) );
    }
    ATH_MSG_DEBUG( "registered IOVDbTestAmdbCorrection with " << tag );
    if (m_readWriteCool) {
 
    // Can only write out AttrList's if this is NOT write and reg in two steps
    if (!m_twoStepWriteReg) { 
        
        // Using COOL, write out attrlist and collection of attrlists
            tag = "no tag";
            if (m_tagID!="") {
            tag = "tag AttrList_" + m_tagID;
                ATH_CHECK( m_regSvc->registerIOV("AthenaAttributeList","/IOVDbTest/IOVDbTestAttrList","AttrList_"+m_tagID,m_run,IOVTime::MAXRUN,IOVTime::MINEVENT,IOVTime::MAXEVENT) );
        } else {
                ATH_CHECK( m_regSvc->registerIOV("AthenaAttributeList","/IOVDbTest/IOVDbTestAttrList","") );
        }
            ATH_MSG_DEBUG( "registered AthenaAttributeList with " << tag );
        if (m_fancylist) {
                // register Fancy AttributeList
                tag = "no tag";
                if (m_tagID!="") {
                    tag = "tag FancyList_" + m_tagID;
                    ATH_CHECK( m_regSvc->registerIOV("AthenaAttributeList","/IOVDbTest/IOVDbTestFancyList","FancyList_"+m_tagID,m_run,IOVTime::MAXRUN,IOVTime::MINEVENT,IOVTime::MAXEVENT) );
                } else {
                    ATH_CHECK( m_regSvc->registerIOV("AthenaAttributeList", "/IOVDbTest/IOVDbTestFancyList","") );
                }
                ATH_MSG_DEBUG ( "registered Fancy AthenaAttributeList with " << tag );
        }
        // attrlist collection 
            tag = "no tag";
            if (m_tagID!="") {
                tag = "tag AttrListColl_" + m_tagID;
                ATH_CHECK( m_regSvc->registerIOV("CondAttrListCollection","AttrListColl_"+m_tagID,m_run,IOVTime::MAXRUN,IOVTime::MINEVENT,IOVTime::MAXEVENT) );
        } else {
                ATH_CHECK( m_regSvc->registerIOV("CondAttrListCollection", "") );
        }
            ATH_MSG_DEBUG( "registered CondAttrListCollection with " << tag );
    }
        
    // mdtMapColl
        tag = "no tag";
        if (m_tagID!="") {
            tag = "tag MDTEleMapColl_" + m_tagID;
            ATH_CHECK( m_regSvc->registerIOV("IOVDbTestMDTEleMapColl","MDTEleMapColl_"+m_tagID,m_run,IOVTime::MAXRUN,IOVTime::MINEVENT,IOVTime::MAXEVENT) );
    } else {
            ATH_CHECK( m_regSvc->registerIOV("IOVDbTestMDTEleMapColl","") );
    }
        ATH_MSG_DEBUG( "registered IOVDbTestMDTEleMapColl with " << tag );
    }
 
    return StatusCode::SUCCESS;
 
}

registerIOV()

StatusCode IOVDbTestAlg::registerIOV ( const CLID &  clid )

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 );
  }

streamOutCondObjects()

StatusCode IOVDbTestAlg::streamOutCondObjects ( )

private

Definition at line 638 of file IOVDbTestAlg.cxx.

                                  {
    ATH_MSG_DEBUG( "entering streamOutCondObjects " );
    ATH_CHECK( m_streamer->connectOutput() );
 
    IAthenaOutputStreamTool::TypeKeyPairs  typeKeys;
    if (!m_writeOnlyCool) {
        typeKeys.emplace_back("IOVDbTestMDTEleMap", "");
        typeKeys.emplace_back("IOVDbTestAmdbCorrection", "");
        typeKeys.emplace_back("IOVDbTestMDTEleMapColl", "");
    }
    typeKeys.resize(3);
 
    ATH_MSG_DEBUG( "Stream out for pairs:" );
    for (unsigned int i = 0; i < typeKeys.size(); ++i) {
      ATH_MSG_DEBUG( typeKeys[i].first << " " << typeKeys[i].second << " " );
    }
    
    ATH_CHECK( m_streamer->streamObjects(typeKeys) );
    ATH_CHECK( m_streamer->commitOutput() );
 
    return StatusCode::SUCCESS;
}

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.

testCallBack()

StatusCode IOVDbTestAlg::testCallBack ( IOVSVC_CALLBACK_ARGS  )

private

Definition at line 78 of file IOVDbTestAlg.cxx.

                                                                        { 
  // print out the keys we were given (for info)
  msg() << MSG::INFO << "IOVDbTestAlg::testCallBack callback invoked for keys: i = " << i << " ";
  for (std::list<std::string>::const_iterator itr=keys.begin(); itr!=keys.end(); ++itr) {
    msg() << *itr << " ";
  }
  msg() << endmsg;
  return  StatusCode::SUCCESS;
}

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);
      }
    }
  }

waitForSecond()

void IOVDbTestAlg::waitForSecond ( ) const

private

Definition at line 49 of file IOVDbTestAlg.cxx.

                                       {
    struct mymsgbuf {
        long mtype;
        char mtext[80];
    };
 
    key_t key;
    int   msgqueue_id;
    struct mymsgbuf qbuf;
    
    /* Create unique key via call to ftok() */
    key = ftok(".", 'm');
    
    /* Open the queue */
    while((msgqueue_id = msgget(key, 0660)) == -1) {
        printf("waiting for message here.\n");
        sleep(3);
    }
    printf("Recieving a message ...\n");
    
    qbuf.mtype = 123;
    msgrcv(msgqueue_id, reinterpret_cast< msgbuf *>(&qbuf), 80, 123, 0);
    
    printf("Type: %ld Text: %s\n", qbuf.mtype, qbuf.mtext);
    
    msgctl(msgqueue_id, IPC_RMID, 0); // clearing the message
    
}

Member Data Documentation

m_createExtraChans

BooleanProperty IOVDbTestAlg::m_createExtraChans {this, "CreateExtraChanns", false}

private

Definition at line 60 of file IOVDbTestAlg.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_fancylist

BooleanProperty IOVDbTestAlg::m_fancylist {this, "FancyList", false}

private

Definition at line 64 of file IOVDbTestAlg.h.

m_nameChans

BooleanProperty IOVDbTestAlg::m_nameChans {this, "NameChanns", false}

private

Definition at line 61 of file IOVDbTestAlg.h.

m_noStream

BooleanProperty IOVDbTestAlg::m_noStream {this, "NoStream", false}

private

Definition at line 68 of file IOVDbTestAlg.h.

m_online

BooleanProperty IOVDbTestAlg::m_online {this, "online", false}

private

Definition at line 72 of file IOVDbTestAlg.h.

m_printLB

BooleanProperty IOVDbTestAlg::m_printLB {this, "PrintLB", false}

private

Definition at line 65 of file IOVDbTestAlg.h.

m_readInInit

BooleanProperty IOVDbTestAlg::m_readInInit {this, "ReadInInit", false}

private

Definition at line 62 of file IOVDbTestAlg.h.

m_readNewTag

BooleanProperty IOVDbTestAlg::m_readNewTag {this, "ReadNewTag", false}

private

Definition at line 67 of file IOVDbTestAlg.h.

m_readWriteCool

BooleanProperty IOVDbTestAlg::m_readWriteCool {this, "ReadWriteCool", false}

private

Definition at line 58 of file IOVDbTestAlg.h.

m_regIOV

BooleanProperty IOVDbTestAlg::m_regIOV {this, "RegisterIOV", false}

private

Definition at line 57 of file IOVDbTestAlg.h.

m_regSvc

ServiceHandle<IIOVRegistrationSvc> IOVDbTestAlg::m_regSvc

private

Definition at line 75 of file IOVDbTestAlg.h.

m_regTime

IntegerProperty IOVDbTestAlg::m_regTime {this, "RegTime", 0, "Register time in sec"}

private

Definition at line 69 of file IOVDbTestAlg.h.

m_run

IntegerProperty IOVDbTestAlg::m_run {this, "run", 0}

private

Definition at line 71 of file IOVDbTestAlg.h.

m_streamer

ToolHandle<IAthenaOutputStreamTool> IOVDbTestAlg::m_streamer

private

Definition at line 76 of file IOVDbTestAlg.h.

m_streamName

StringProperty IOVDbTestAlg::m_streamName {this, "StreamName", "CondStream1"}

private

Definition at line 70 of file IOVDbTestAlg.h.

m_tagID

StringProperty IOVDbTestAlg::m_tagID {this, "TagID", ""}

private

Definition at line 73 of file IOVDbTestAlg.h.

m_twoStepWriteReg

BooleanProperty IOVDbTestAlg::m_twoStepWriteReg {this, "TwoStepWriteReg", false}

private

Definition at line 59 of file IOVDbTestAlg.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_writeCondObjs

BooleanProperty IOVDbTestAlg::m_writeCondObjs {this, "WriteCondObjs", false}

private

Definition at line 56 of file IOVDbTestAlg.h.

m_writeNewTag

BooleanProperty IOVDbTestAlg::m_writeNewTag {this, "WriteNewTag", false}

private

Definition at line 66 of file IOVDbTestAlg.h.

m_writeOnlyCool

BooleanProperty IOVDbTestAlg::m_writeOnlyCool {this, "WriteOnlyCool", false}

private

Definition at line 63 of file IOVDbTestAlg.h.

---

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

• IOVDbTestAlg.h
• IOVDbTestAlg.cxx